Android 应用未从 SignalR 集线器接收数据

Question

我已经阅读了这些主题：

我用 Android 编写了一个与 SignalR 配合使用的简单聊天系统。
假设客户端发送消息（通过在服务器上调用 SendMessage 方法），服务器应该在客户端上调用 NewMessage 方法。

这是我用 C# 编写的 ChatHub class（简体）。

public class ChatHub : Hub
{
    // Store the clients connections Id
    static readonly List<string> _connectedClients;

    public override Task OnConnected()
    {
        // Keep connections id
        // This section works fine and when the android device connects to the server,
        // Its connection id will stored.
        _connectedClients.Add(Context.ConnectionId)

        //... other codes
    }

    public void SendMessage(string message)
    {
        foreach (var connectionId in _connectedClients)
        {
            // according to the logs 
            // android device connection id exists here
            // and it works fine.
            Clients.Client(connectionId).NewMessage(message);
        }
    }
}

当android 客户端连接到服务器时，在OnConnected 方法中，连接ID 将存储在_connectedClients 中并且工作正常。

在ChatHubclass的SendMessage方法中，我们有android设备连接id，我确定android设备在列表中

这是我的 Andoird 代码：

public class ChatActivity extends AppCompatActivity
{
    // private fields
    HubConnection connection;
    HubProxy hub;
    ClientTransport transport;

    protected void onCreate(Bundle savedInstanceState) {

        Logger logger = new Logger() {
            @Override
            public void log(String message, LogLevel logLevel) {
                Log.e("SignalR", message);
            }
        };

        Platform.loadPlatformComponent(new AndroidPlatformComponent());
        connection = new HubConnection("192.168.1.100");
        hub = connection.createHubProxy("chatHub"); // case insensitivity

        transport = new LongPollingTransport(connection.getLogger());

        // no difference when using this:
        //transport = new ServerSentEventsTransport(connection.getLogger());

        // this event never fired!
        hub.subscribe(new Object() {
            public void NewMessage(String message)
            {
                Log.d("<Debug", "new message received in subscribe"); // won't work!
            }
        }

        // this event never fired!
        hub.on("NewMessage", new SubscriptionHandler() {
            @Override
            public void run() {
                Log.d("<Debug", "new message received in `on`"); // won't work!
            }
        });

        // connect to the server that works fine.
        SignalRFuture<Void> awaitConnection = connection.start(transport);
        try {
            awaitConnection.get(); // seems useless when using this or not!
        }
        catch (Exception ex) {
        }

        // this method works fine.
        hub.invoke("sendMessage", "this is a test message to the server")
        .done(new Action<Void>() {
                @Override
                public void run(Void aVoid) throws Exception {
                    Log.d("<Debug", "message sent."); // Works fine
                }
        });

    }
}

在上面的 java 代码中，调用服务器上的 sendMessage 工作正常并且服务器收到消息。
但唯一的问题是服务器永远不会调用 hub.on(...) 或 hub.subscribe(...) 事件。
简单说明一下，我的app可以发消息，但是收不到别人的消息。
任何建议将不胜感激。

Answer 1

您没有在您的客户端提供参数，该参数应该与您的副站点相同。代码应如下：

      hub.on("NewMessage", new SubscriptionHandler1<String>() {
        @Override
        public void run(String message) {
            Log.d("<Debug", "new message received in `on`"); 
        }
    },String.class);  //do not forget say the String class in the end

Answer 2

对于futures这就是我最终得到答案的方式（请先阅读问题android代码）：

public class ChatActivity extends AppCompatActivity
{
    // private fields
    HubConnection connection;
    HubProxy hub;
    ClientTransport transport;

    protected void onCreate(Bundle savedInstanceState) {

        Logger logger = new Logger() {
            @Override
            public void log(String message, LogLevel logLevel) {
                Log.e("SignalR", message);
            }
        };

        Platform.loadPlatformComponent(new AndroidPlatformComponent());
        connection = new HubConnection("192.168.1.100");
        hub = connection.createHubProxy("chatHub"); // case insensitivity

        /* ****new codes here**** */
        hub.subscribe(this);

        transport = new LongPollingTransport(connection.getLogger());

        /* ****new codes here**** */
        connection.start(transport);

        /* ****new codes here**** */
        /* ****seems useless but should be here!**** */
        hub.subscribe(new Object() {
            @SuppressWarnings("unused")
            public void newMessage(final String message, final String messageId, final String chatId,
                                   final String senderUserId, final String fileUrl, final String replyToMessageId) {


            }
        });


        /* ********************** */
        /* ****new codes here**** */
        /* **** the main method that I fetch data from server**** */
        connection.received(new MessageReceivedHandler() {
            @Override
            public void onMessageReceived(final JsonElement json) {
                runOnUiThread(new Runnable() {
                    public void run() {
                        JsonObject jsonObject = json.getAsJsonObject();
                        Log.e("<Debug>", "response = " + jsonObject.toString());

                    }
                });
            }
        });
        /* ********************** */

    }
}

!重要提示：
代码的优先级很重要。这就是我解决本主题问题的方法。

Android 应用未从 SignalR 集线器接收数据

Android app did not receive data from SignalR hub

c#

java

android

chat

signalr