从服务器错误收到的 Signalr 关闭消息

Question

我处理这个错误已经很久了。我只想让信号器听我的 2 方法。当我评论 (this) 方法时，它工作得很好。但它不起作用。有人能帮我吗？有时我可以获得该值，但它会给我带来如下图所示的错误。我研究了一些页面，但实际上找不到任何答案。

Vuejs

 const hubConnection = new signalR.HubConnectionBuilder()
        .configureLogging(signalR.LogLevel.Debug)
        .withUrl("http://localhost:7002/ChatHub", {
          skipNegotiation: true,
          transport: signalR.HttpTransportType.WebSockets,
        })
        .build();
      hubConnection.start();
      this.connectionId = hubConnection.connectionId;
      this.connection = hubConnection; 
      hubConnection.on("UserConnected",(users) => console.log(users));(this)
      hubConnection.on(categoryId, (all) => {
        all = JSON.parse(all);
         this.userMessage = {
           id: all.Id,
           text: all.Text,
           userId:all.UserId,
           userName:all.UserName,
           categoryName: all.CategoryName,
           createdOn: all.CreatedOn,
          };          
        this.messages.push(this.userMessage);
        console.log(this.userMessages);
      });
    },

using Microsoft.AspNetCore.SignalR;
using System.Text;
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.AspNetCore.Http;
using System;
using System.Web;
using System.Net.Http.Headers;
using System.Linq;
using System.IdentityModel.Tokens.Jwt;
using System.IdentityModel.Tokens;
using System.Collections.Generic;
using System.Threading.Tasks;
using Message.Dal.Concrete;
using Message.Dal.Abstract;
using Message.Dal.Model;
using Microsoft.Extensions.Configuration;
namespace Message.Dal.SignalRHub
{
    public class ChatHub : Hub
    {
        private readonly IHubContext<ChatHub> _chatHub;    
        private readonly IHttpContextAccessor _httpContextAccessor; 
        private readonly IElasticRepository<OnlineUserModel> _elasticRepository;  
        private readonly string _indexName;
        public ChatHub(IHubContext<ChatHub> chatHub,IElasticRepository<OnlineUserModel> elasticRepository,IConfiguration configuration)
        {
            _chatHub = chatHub; 
            _httpContextAccessor = new HttpContextAccessor();
            _elasticRepository = elasticRepository;
            _indexName = configuration["elasticsearchserver:User"].ToString();
        }
        public async Task SendMessage(Guid categoryId,string message)
        {          
            await _chatHub.Clients.All.SendAsync(categoryId.ToString(),message);           
        }        
        
        public override Task OnConnectedAsync()
        {      
            
           var token = string.Empty;           
           var httpContext = _httpContextAccessor.HttpContext.Request.Cookies;
           var onlineUserModel = new OnlineUserModel();
           onlineUserModel.Id = Context.ConnectionId;           
           if(!httpContext.Any())
           {
               return Task.CompletedTask;
           }
           token = httpContext.Where(x=> x.Key == "CodeChatBackend").FirstOrDefault().Value;
           if(AuthenticationHeaderValue.TryParse(token,out var headerVal))
            {                
                var handler = new JwtSecurityTokenHandler();
                var val = handler.ReadJwtToken(headerVal.ToString());  
                onlineUserModel.UserName = val.Claims.FirstOrDefault(x => x.Type == "Name").Value;           
            } 
            var checkOnlineUser = _elasticRepository.GetUserAsync(onlineUserModel.UserName,_indexName); 
            if(checkOnlineUser.Result == null)
            {
                _elasticRepository.CreateUserAsync(onlineUserModel.Id,onlineUserModel,_indexName);
            }       
            var getOnlineUser = _elasticRepository.GetAllAsync(_indexName);
            _chatHub.Clients.All.SendAsync("UserConnected",getOnlineUser);(this) 
           base.OnConnectedAsync();         
           return Task.CompletedTask;
        }     

         public override Task OnDisconnectedAsync(Exception exception)
        {
            var httpContext = _httpContextAccessor.HttpContext.Request.Cookies;
            var token = string.Empty;          
            var result = _elasticRepository.DeleteUserAsync(Context.ConnectionId,_indexName); 
            var getOnlineUser = _elasticRepository.GetAllAsync(_indexName);
            _chatHub.Clients.All.SendAsync("UserConnected",getOnlineUser);(this)      
            base.OnDisconnectedAsync(exception);  
           return Task.CompletedTask;
        }
        
    }
}

当我删除 onconnectedasync 客户端方法时。它工作得很好。我错过了什么吗？

Answer 1

我修好了！完全是我的错误。我试图建立一个集线器来连接不同的方法。要解决此问题：创建第二个集线器 class 并配置您的启动，然后使用新连接调用集线器方法。

从服务器错误收到的 Signalr 关闭消息

Signalr Close Message Recieved From Server Error

javascript

c#

signalr

vue.js

asp.net-core