我有一个 MXChip,它将数据发送到 Azure IoT Hub,从那里我使用带有 Azure SignalR 绑定的 Azure Function 将设备数据发布到 Azure Signal R。我有一个 Angular 客户端,它将通过调用获取连接信息我使用包创建的 Azure 协商函数@aspnet/signalr
。
但问题是我的 Angular 客户端每隔几秒钟就会抛出一个错误,当我检查时,我可以理解hubConnection.onclose
事件每隔几秒钟就会触发一次。
下面是我的 Angular 服务代码。
export class SignalRService {
mxChipData: Subject < string > = new Subject();
private hubConnection: SignalR.HubConnection;
constructor(private http: HttpClient) {}
private getSignalRConnection(): Observable < SignalRConnection > {
return this.http.get < SignalRConnection > (`${environment.baseUrl}negotiate`);
}
init() {
this.getSignalRConnection().subscribe(con => {
const options = {
accessTokenFactory: () => con.accessToken
};
this.hubConnection = new SignalR.HubConnectionBuilder()
.withUrl(con.url, options)
.configureLogging(SignalR.LogLevel.Information)
.build();
this.hubConnection.on('notify', data => {
this.mxChipData.next(data);
});
this.hubConnection.start()
.catch(error => console.error(error));
this.hubConnection.onclose((error) => {
console.error(`Something went wrong: ${error}`);
});
});
}
}
有什么办法可以摆脱这种行为?