ASP.NET Web API Signalr не использует метод OnConnected - PullRequest
Новая
       15

ASP.NET Web API Signalr не использует метод OnConnected

0 голосов
/ 10 сентября 2018

У меня есть концентратор внутри моего проекта ASP.NET Stateful, размещенного в локальном кластере Service Fabric, и я переопределил метод OnConnected . При установке точки останова на метод OnConnected он не вводится, но в то же время сообщения должным образом передаются через концентратор.

Класс концентратора: 

public class NotificationHub : BaseHub
{
    private IFragStateManager _stateManager;
    private static IHubContext _context;

    public NotificationHub(IFragStateManager stateManager) : this(stateManager, _context)
    {
        _stateManager = stateManager;
        _context = GlobalHost.ConnectionManager.GetHubContext<NotificationHub>();
    }

    private NotificationHub(IFragStateManager stateManager, IHubContext context) : base(stateManager, context)
    { }

    /// <summary>
    /// Broadcasts payload to all clients
    /// </summary>
    /// <param name="payload"></param>
    public void Broadcast(object payload)
    {
        try
        {
            _context.Clients.All.broadcast(payload);
        }
        catch (Exception e)
        {
            Log.Error(e.ToString());
        }            
    }

    //Investigate more why it's not hitting breakpoint while it actually connects and broadcasts messages
    public override Task OnConnected()
    {
        return base.OnConnected();
    }

    public override Task OnDisconnected(bool stopCalled)
    {
        return base.OnDisconnected(stopCalled);
    }
}

_context.Clients.All.broadcast (полезная нагрузка); работает хорошо. Он доставляет полезную нагрузку успешно

Базовый класс хаба: 

    public abstract class BaseHub : Hub
    {
        protected IPrincipal User {
            get { return base.Context.User ?? _user; }
        }

        private ClaimsPrincipal _user;
        private Guid _userId;

        private IFragStateManager _stateManager;
        private IHubContext _context;

        public BaseHub(IFragStateManager stateManager, IHubContext context)
        {
            _stateManager = stateManager;
            _context = context;
        }        

        public override async Task OnConnected()
        {
            GetUserId();

            var map = await _stateManager.GetOrAddAsync<FragDictionary<Guid, string>>("UserConnectionMap");

            using (var tx = _stateManager.CreateTransaction())
            {
                var exisingValue = await map.TryGetValueAsync(tx, _userId);
                await map.SetAsync(tx, _userId, Context.ConnectionId);
                await tx.CommitAsync();
            }

            await base.OnConnected();
        }        

        public override async Task OnDisconnected(bool stopCalled)
        {
            var map = await _stateManager.GetOrAddAsync<FragDictionary<Guid, string>>("UserConnectionMap");

            using (var tx = _stateManager.CreateTransaction())
            {
                await map.TryRemoveAsync(tx, _userId); 
                await tx.CommitAsync();
            }

            await base.OnDisconnected(stopCalled);
        }

        private void GetUserId()
        {

            if (Context.User == null)
                _user = (ClaimsPrincipal)(IPrincipal)Context.Request.Environment["server.User"];
            else
                _userId = new Guid(_user.FindFirst("AccountId").Value);
        }
    }

Хаб-клиент: 

    $.connection.hub.logging = true;
    $.connection.hub.url = 'http://localhost:8298/api/realtime/70c604f8-7996-4107-9ec3-28d08c869899/131810464642593740/4b98412e-8f09-4460-9c90-1d155cb8efca/signalr';

    var hub = $.connection.notificationHub;

    $.extend(hub.client, {
        broadcast: function (msg) {console.log(msg)}
    });

    $.connection.hub.start().done(function() {
        console.log('Connected');
    });

Клиентские скрипты: 

<script src="Scripts/jquery-1.6.4.js"></script>
<script src="Scripts/jquery.signalR-2.1.0.js"></script>
<script src="http://localhost:8298/api/realtime/70c604f8-7996-4107-9ec3-28d08c869899/131810464642593740/4b98412e-8f09-4460-9c90-1d155cb8efca/signalr/hubs"></script>

Что уже проверено:

  1. Пониженный СигналR. Ездил с 2,3 до 2,1. Нет результатов.
  2. js клиент уже подписан, поэтому, вероятно, здесь нет проблем.
  3. Когда Hub высовывается из кода бэкенда, он транслирует сообщения должным образом.
...