5

我正在使用 React 前端的 ASP.NET Core 2.2 应用程序中实现 Azure SignalR 服务。当我发送消息时，我没有收到任何错误，但我的消息没有到达 Azure SignalR 服务。

具体来说，这是一个私人聊天应用程序，因此当消息到达中心时，我只需要将其发送给该特定聊天的参与者，而不是发送给所有连接。

当我发送消息时，它会到达我的集线器，但我看不到消息正在发送到 Azure 服务的任何迹象。

为了安全起见，我使用 Auth0JWT Token身份验证。在我的中心，我正确地看到了授权用户的声明，所以我认为安全性没有任何问题。正如我所提到的，我能够访问集线器这一事实告诉我，前端和安全性工作正常。

然而，在 Azure 门户中，我看不到任何消息的迹象，但如果我正确读取数据，我确实看到 2 个客户端连接在我的测试中是正确的，即我用于测试的两个打开的浏览器。这是一个屏幕截图：

在此处输入图像描述

这是我的Startup.cs代码：

public void ConfigureServices(IServiceCollection services)
{
   // Omitted for brevity
   services.AddAuthentication(options => {
                options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
                options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
   })
   .AddJwtBearer(jwtOptions => {
       jwtOptions.Authority = authority;
       jwtOptions.Audience = audience;

       jwtOptions.Events = new JwtBearerEvents
       {
            OnMessageReceived = context =>
            {
                var accessToken = context.Request.Query["access_token"];

                // Check to see if the message is coming into chat
                var path = context.HttpContext.Request.Path;
                if (!string.IsNullOrEmpty(accessToken) &&
                    (path.StartsWithSegments("/im")))
                {
                   context.Token = accessToken;
                }
                return System.Threading.Tasks.Task.CompletedTask;
             }
        };
    });


    // Add SignalR
    services.AddSignalR(hubOptions => {
       hubOptions.KeepAliveInterval = TimeSpan.FromSeconds(10);
    }).AddAzureSignalR(Configuration["AzureSignalR:ConnectionString"]);
}

这是Configure()方法：

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
   // Omitted for brevity
   app.UseSignalRQueryStringAuth();

   app.UseAzureSignalR(routes =>
   {
      routes.MapHub<Hubs.IngridMessaging>("/im");
   });
}

这是我用来将用户映射connectionId到的方法userName：

public override async Task OnConnectedAsync()
{
    // Get connectionId
    var connectionId = Context.ConnectionId;

    // Get current userId
    var userId = Utils.GetUserId(Context.User);

    // Add connection
    var connections = await _myServices.AddHubConnection(userId, connectionId);

    await Groups.AddToGroupAsync(connectionId, "Online Users");
    await base.OnConnectedAsync();
}

这是我的中心方法之一。请注意，我知道一个用户可能同时有多个连接。我只是简化了这里的代码以使其更容易消化。我的实际代码说明了具有多个连接的用户：

[Authorize]
public async Task CreateConversation(Conversation conversation)
{
   // Get sender
   var user = Context.User;
   var connectionId = Context.ConnectionId;

   // Send message to all participants of this chat
   foreach(var person in conversation.Participants)
   {
       var userConnectionId = Utils.GetUserConnectionId(user.Id);
       await Clients.User(userConnectionId.ToString()).SendAsync("new_conversation", conversation.Message);
   }
}

知道我做错了什么导致消息无法到达 Azure SignalR 服务吗？

4

1 回答 1

1

这可能是由拼写错误的方法、错误的方法签名、错误的集线器名称、客户端上的重复方法名称或客户端上缺少 JSON 解析器引起的，因为它可能会在服务器上静默失败。

取自客户端和服务器之间的调用方法静默失败 ：

拼写错误的方法、不正确的方法签名或不正确的集线器名称

如果被调用方法的名称或签名与客户端上的适当方法不完全匹配，则调用将失败。验证服务器调用的方法名称是否与客户端上的方法名称匹配。此外，SignalR 使用驼峰式方法创建集线器代理，这在 JavaScript 中是合适的，因此SendMessage在服务器上调用的方法将sendMessage在客户端代理中调用。如果您HubName在服务器端代码中使用该属性，请验证使用的名称是否与用于在客户端上创建集线器的名称相匹配。如果您不使用该HubName属性，请验证 JavaScript 客户端中集线器的名称是否为驼峰式，例如 chatHub 而不是 ChatHub。

客户端上的方法名称重复

验证您在客户端上没有仅因大小写而异的重复方法。如果您的客户端应用程序有一个名为 的方法sendMessage，请验证是否也有一个方法被调用SendMessage。

客户端缺少 JSON 解析器

SignalR 需要一个 JSON 解析器来序列化服务器和客户端之间的调用。如果您的客户端没有内置的 JSON 解析器（例如 Internet Explorer 7），您需要在应用程序中包含一个。

更新

作为对您的评论的回应，我建议您尝试其中一个Azure SignalR示例，例如 SignalR 入门：聊天室示例，看看您是否得到相同的行为。

希望能帮助到你！

于 2018-12-05T07:07:54.360 回答