jquery signalr 客户端工作 - 但在 java 中它不能工作

Question

我们有一个 SignalR 集线器。以下 jQuery 代码在 cordova 上成功连接并正确处理 SignalR 客户端“调用”事件。

        var connectionURL = "https://SOMEURL.azurewebsites.net/message";
        connection = $.connection(connectionURL);

        connection.start().done(function () {
            console.log("Connected to hub again");
        });

        connection.disconnected(function () {
            setTimeout(function () {
                connection.start().done(function () {
                    console.log("Disconnected and Connected to hub again");
                });
            }, 5000);
        });

        connection.stateChanged(function (change) {
            if (change.newState == $.signalR.connectionState.reconnecting) {
            }
            else if (change.newState == $.signalR.connectionState.connected) {
            }
            else if (change.newState == $.signalR.connectionState.disconnected) {
            }// else if 
        });

        connection.received(function (data) {
            connectId = connection.id + "";
            console.log("onDeviceReady run");

            // call the function to parse the data
            if (data.PayloadType == "Dispatch") {
                dataDispatch(data);
            }
            if (data.PayloadType == "ConnectionAcknowledge") {
                sendConnectionAcknowledge(data);
            }
        });

但是，当我尝试使用SignalR Java Client 在 java android 中模拟此代码时，我得到了很多日志输出（吨），并且没有连接完成。它一直到awaitConnection.get(); 行的调试，并且从不打印调试的第二行，而是打印无休止的（数千行）半乱码行（它不是管道，就像某种“SSL 握手”但它是除了重复记录同一件事之外什么都不做，非常奇怪）无论如何它永远不会运行“我的”调试的第二行

package com.some.thing;

import android.util.Log;

import java.util.concurrent.ExecutionException;

import microsoft.aspnet.signalr.client.Platform;
import microsoft.aspnet.signalr.client.SignalRFuture;
import microsoft.aspnet.signalr.client.http.android.AndroidPlatformComponent;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;
import microsoft.aspnet.signalr.client.hubs.SubscriptionHandler1;

public class SignalRClient {

    public static void startConnection() {

        Platform.loadPlatformComponent(new AndroidPlatformComponent());
        String host = "https://SOMEURL.azurewebsites.net/message";
        HubConnection connection = new HubConnection(host);
        HubProxy hub = connection.createHubProxy( "IDoNoHaveThisNorKnowIt" );

        SignalRFuture<Void> awaitConnection = connection.start();
        try {
            Log.v("CONANSignalR :=", "CONNECTING");
            awaitConnection.get();
            Log.v("CONANSignalR :=", "CONNECTED");
        } catch (InterruptedException e) {
            // Handle ...
        } catch (ExecutionException e) {
            // Handle ...
        }

        hub.on("IDoNotKnowThisEither", new SubscriptionHandler1<String>(){
            @Override
            public void run( String status ){
                Log.v("CONANDispatch :=", status);
            }
        }, String.class);
    }
}

谁能帮我将工作的 jQuery SignalR 客户端代码翻译成可用的 Java 客户端代码？我没有关于集线器的任何信息，所以我不知道代理或函数名称，我想查看所有内容（如 jQuery）。

编辑

为了测试，我改变了原来的 jquery 代码，它用来说

console.log("onDeviceReady run");

现在它说

console.log("SignalR Raw Data:" + JSON.stringify(data));

当我这样做时，这就是 jquery 返回的内容

SignalR Raw Data:{"ConnectionId":"9c4b4ba5-cb6e-4dcb-8df9-069cbf749873","OrderId":null,"SenderId":null,"PayloadType":"ConnectionAck","Message":"Welcome, you are connected to the Hub!","Payload":null,"Initiator":"HUB","Version":null}

但是这些都没有出现在 java 等效项中

connection.received(new MessageReceivedHandler() {
    @Override
    public void onMessageReceived(JsonElement json) {
        System.out.println("RAW received message: " + json.toString());

        // ADD HANDLING OF RECEIVED IN HERE
    }
});

即根本没有出现“RAW received message:”文本

Answer 1

由于您不知道集线器名称，因此您必须直接在连接对象上使用处理事件（就像您在 js 客户端中所做的那样）。

这是可以帮助您入门的示例代码（注意，这未经测试，只是从我的脑海中编写的）：

public static void startConnection() {

    Platform.loadPlatformComponent(new AndroidPlatformComponent());
    String host = "https://SOMEURL.azurewebsites.net/message";
    HubConnection connection = new HubConnection(host);

    // subscribe to received - equal to `connection.received(function (data)` from javascript 
    connection.received(new MessageReceivedHandler() {

        @Override
        public void onMessageReceived(JsonElement json) {
            System.out.println("RAW received message: " + json.toString());

            // ADD HANDLING OF RECEIVED IN HERE
        }
    });

    // equal to `connection.disconnected(function ()` from javascript
    connection.closed(new Runnable() {

        @Override
        public void run() {
            // ADD CODE TO HANDLE DISCONNECTED EVENT
        }
    });

    // equal to `connection.stateChanged(function (change)`
    connection.stateChanged(new StateChangedCallback() {

        @Override
        public void stateChanged(ConnectionState oldState, ConnectionState newState) {
            // ADD CODE TO HANDLE STATE CHANGES
        }
    });

    // start the connection
    connection.start()
        .done(new Action<Void>() {

            @Override
            public void run(Void obj) throws Exception {
                System.out.println("Connected");
            }
        });
}

另外，我建议您查看 java 聊天客户端示例，可在此处找到：https://github.com/SignalR/java-samples/blob/master/signalr-sample-chat/src/microsoft/aspnet/signalr/samples/chat/Program.java

我发布的大部分代码都是基于那个。