jquery signaler客户端可以工作，但在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);
    }
}

有人能帮我把工作中的jQuerySignalR客户端代码翻译成可用的java客户端代码吗？我没有关于hub的任何信息，所以我不知道代理或函数名，我想查看所有内容（比如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

由于您不知道hub名称，因此必须直接使用handle处理连接对象上的事件（就像在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

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