我知道当调用来自服务器时,SignalR 不能从客户端返回。在 SignalR 的 github 存储库中,我要求提供一种解决方法(https://github.com/aspnet/SignalR/issues/1329),他们建议我通过将结果从客户端发送到服务器到集线器中的另一个方法来获得结果所以使用 TaskCompletionSource 和一些连接元数据来捕捉结果,但我坚持如何做到这一点
控制器服务器:
[HttpPut("send/{message}")]
public async Task<IActionResult> SendMessage(string message)
{
if (!ModelState.IsValid) return BadRequest(ModelState.Values);
string connectionId = Request.Headers["connectionId"];
await _chatHubContext.Clients.Client(connectionId).InvokeAsync("send");
// Catch the call of MessageReceived and get the chat status
return new OkObjectResult(new EmptyJsonResult() { Result = "OK" });
}
集线器服务器
public class ChatHub : Hub
{
public Task MessageReceive(bool chatStatus)
{
// Tell controller that message is received
}
}
Angular 4 客户端
import { Component, Inject } from '@angular/core';
import { HubConnection } from '@aspnet/signalr-client';
@Component({
selector: 'chat',
templateUrl: './chat.component.html',
styleUrls: ['./chat.component.css']
})
/** chat component*/
export class ChatComponent {
hubConnection: HubConnection;
chatStatus = false;
/** chat ctor */
constructor( @Inject('BASE_URL') private originUrl: string) {
this.hubConnection = new HubConnection(`${this.originUrl}chat`);
setInterval(() => {
this.chatStatus = !this.chatStatus;
},
5000);
this.hubConnection
.start()
.then(() => {
this.hubConnection.on('send', (message: string) => {
if (this.chatStatus) {
//send message
}
this.hubConnection
.invoke('messageReceived', this.chatStatus);
});
});
}
}
正如您在这段代码中看到的那样,我不知道在控制器方法和 Hub 方法中要做什么才能知道方法 MessageReceive 被调用并获取他的返回以将其发送回控制器请求。