Вызов метода SignalR Hub из клиента блокирует приложение Xamarin для Android - PullRequest
0 голосов
/ 04 апреля 2019

Я наконец-то получил концентратор SignalR для работы с использованием Microsoft.AspNet.SignalR и Microsoft.AspNetCore.SignalR. Мне не удалось получить Microsoft.AspNetCore.SignalR, не знаю почему.Но я заставил другого работать.Я могу подключиться, связать клиентов с идентификаторами соединений с помощью OnConnect и удалить их с помощью OnDisconnect.Мой код хаба:

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Web;
using Microsoft.AspNet.SignalR;
using SignalrHub;

namespace SignalRChat
{
    public class ChatHub : Hub
    {

        private static readonly List<User> Users = new List<User>();

        public override Task OnConnected()
        {

            // string userName = Context.User.Identity.Name;
            string userName = Context.QueryString["username"];
            string org= Context.QueryString["organization"];
            string dept = Context.QueryString["dept"];
            string team = Context.QueryString["team"];
            string firstname = Context.QueryString["firstname"];
            string lastname = Context.QueryString["lastname"];
            string connectionId = this.Context.ConnectionId;

            // for now I just capture username and connection Id
            var user = new User(); 
            user.Name = userName;
            user.ConnectionIds = connectionId;


            try
            {
                Users.Add(user);
            }
            catch (Exception ex)
            {
                var msg = ex.Message;
            }

            // TODO: Broadcast the connected user

            // send list of connected users to client
            Send("Welcome " + userName, "Connected users are:");

            foreach (var display in Users)
            {
                Send("",display.Name.ToString());

            }


            return base.OnConnected();
        }

        public override Task OnDisconnected(bool stopped)
        {

            string userName = Context.User.Identity.Name;
            string connectionId = Context.ConnectionId;

            var item = Users.Find(x => x.ConnectionIds == connectionId);
            Users.Remove(item);

            return base.OnDisconnected(true);
        }


        public void Send(string name, string message)
        {
            // Call the broadcastMessage method to update clients.
            Clients.All.broadcastMessage(name, message);
        }

        public List<String> GetConnectedUsers()
        {
            List<string> UserNames = new List<string>();

            foreach (var ConnectedUser in Users)
            {
                UserNames.Add(ConnectedUser.Name);
            }

            return UserNames;
        }
    }
}

Все отлично работает, кроме случаев, когда я звоню GetConnectedUsers(), когда я звоню с клиента с этим кодом ConnecteduserList = client.ConnectedUsers(); приложение блокируется, например;концентратор никогда не возвращается из этого метода.Я явно что-то упускаю.Может кто-нибудь сказать мне, что?

Код клиента в приложении:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using Android.App;
using Android.Content;
using Android.OS;
using Android.Runtime;
using Android.Views;
using Android.Widget;

using System.Threading.Tasks;
using Microsoft.AspNet.SignalR.Client;

namespace ChatClient.Shared
{
    class Client
    {
        //public string username;
        private readonly string _platform;
        private readonly HubConnection _connection;
        private readonly IHubProxy _proxy;

        public event EventHandler<string> OnMessageReceived;

        public Client(string platform, string username)
        {
            string _username = "username=" + username;
            _platform = platform;
            _connection = new HubConnection("https://MyApp.com/SignalRhub", _username);
            _proxy = _connection.CreateHubProxy("chathub");
        }

        public async Task Connect()
        {

            await _connection.Start();                 _proxy.On("broadcastMessage", (string platform, string message) =>
            {
                if (OnMessageReceived != null)
                    OnMessageReceived(this, string.Format("{0}: {1}", platform, message));
            });

            Send("Connected");
        }

        public List<string> ConnectedUsers()
        {
            List<string> Users = new List<string>();

            // Locks up when this line is esecuted.  The server log has nothing in it.
            Users =  _proxy.Invoke<List<string>>("GetConnectedUsers").Result;

            return Users;
        }

        public Task Send(string message)
        {
            return _proxy.Invoke("Send", _platform, message);
        }
    }
}

1 Ответ

0 голосов
/ 08 апреля 2019

Спасибо Дэвиду Фаулеру из GitHub, который предоставил ссылку на этот документ (https://github.com/davidfowl/AspNetCoreDiagnosticScenarios/blob/master/AsyncGuidance.md#avoid-using-taskresult-and-taskwait),. Мне удалось заставить это работать, изменив мой код следующим образом:

На клиенте: с:

public List<string> ConnectedUsers()
{
    // Hangs on this line
    List<string> Users = _proxy.Invoke<List<string>>("getConnectedUsers").Result;

    return Users;
}

Кому:

public async Task <List<string>> ConnectedUsers()
{
    List<string> Users = await _proxy.Invoke<List<string>>("getConnectedUsers");
    return Users;
}

Также был изменен вызов функции ConnectedUsers в Client.cs: С:

List<string> userList = client.ConnectedUsers();

Кому:

List<string> userList = await client.ConnectedUsers();

Никаких изменений в коде концентратора не требовалось.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...