SignalR java 无法连接到服务器。

Question

我在将我的Java应用程序连接到SignalR服务器时遇到了问题。
这个服务器非常简单，可以在这里找到：
https://code.msdn.microsoft.com/windowsdesktop/Using-SignalR-in-WinForms-f1ec847b

我可以连接Web客户端（JavaScript）和Windows客户端（C#），但是我在使用我的Java客户端时遇到了问题。(https://github.com/SignalR/java-client)

以下是我的代码：

package javaapplication2;

import java.io.IOException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import microsoft.aspnet.signalr.client.SignalRFuture;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;

public class JavaApplication2 {
       public static void main(String[] args) throws IOException, InterruptedException, ExecutionException, TimeoutException 
       {
            String ServerURI = "http://localhost:8080/signalr";
            HubConnection Connection = new HubConnection(ServerURI);
            HubProxy HubProxy = Connection.createHubProxy("MyHub");
            HubProxy.on("AddMessage", () -> { System.out.println("Some message");        });

            Connection.error(new ErrorCallback() {
                @Override
                public void onError(Throwable error) {
                    error.printStackTrace(); //<==SocketException
                }
            });

            SignalRFuture<Void> con  =Connection.start();
            con.get(); 
       }
}

更新

当我运行它时，出现“ExecutionException: java.net.SocketException: Connection reset”错误。

Exception in thread "main" java.util.concurrent.ExecutionException: java.net.SocketException: Connection reset
at microsoft.aspnet.signalr.client.SignalRFuture.get(SignalRFuture.java:112)
at microsoft.aspnet.signalr.client.SignalRFuture.get(SignalRFuture.java:102)
at javaapplication2.JavaApplication2.main(JavaApplication2.java:27)
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:209)
at java.net.SocketInputStream.read(SocketInputStream.java:141)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read1(BufferedInputStream.java:286)
at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:704)
at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:647)
at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:675)
at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1535)
at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1440)
at java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480)
at microsoft.aspnet.signalr.client.http.java.NetworkRunnable.run(NetworkRunnable.java:72)
at java.lang.Thread.run(Thread.java:745)

-如果我把“localhost”改成不存在的东西（例如locahostX），我会得到一个java.net.UnknownHostException异常。

-如果我把“localhost”改成我的IP，甚至不会有异常……

-所有其他应用程序都可以使用localhost或IP正常工作。

起初我以为这是防火墙问题，但事实并非如此……

显然我漏掉了什么...... 有什么想法吗？

谢谢

- George Vovos

---

你能否提供你所使用的依赖版本？ - Vimukthi Sineth

@VimukthiSineth 那是5年前的事了，我不记得了。 - George Vovos

Answer 1

原来我需要使用start的一个重载方法，该方法需要传入一个ClientTransport对象作为参数。

public SignalRFuture<Void> start(ClientTransport transport)

如果有人能解释为什么无参的启动方法会失败，请在回答中发表并我会将其标记为解决方案。

这里是一个完整的例子，可以正常工作：

package javaapplication2;

import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import microsoft.aspnet.signalr.client.SignalRFuture;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;
import microsoft.aspnet.signalr.client.transport.ServerSentEventsTransport;
import microsoft.aspnet.signalr.client.hubs.SubscriptionHandler2;

public class JavaApplication2 {
   public static void main(String[] args) throws IOException, InterruptedException, ExecutionException, TimeoutException 
   {
        String ServerURI = "http://localhost:8080/signalr";
        HubConnection Connection = new HubConnection(ServerURI);
        HubProxy HubProxy = Connection.createHubProxy("MyHub");

        HubProxy.on("AddMessage", new SubscriptionHandler2<String, String>() {
          @Override
          public void run(String e1, String e2) {
             System.out.println(e1.toString()+  " -> " +e2.toString());   
          }
        }, String.class, String.class);

        SignalRFuture<Void> con  =Connection.start(new ServerSentEventsTransport(Connection.getLogger())); //Or LongPollingTransport

        con.get(); 

        Scanner inputReader = new Scanner(System.in);
        String line = inputReader.nextLine();
        while (!"exit".equals(line)) {
              HubProxy.invoke("send", "Console", line);
              line = inputReader.next();
         }

        inputReader.close();

        Connection.stop();
   }
}

- George Vovos

---

不确定问题所在，但您是否尝试使用带有ILogger实例的HubConnection构造函数重载？似乎自动传输选择（协商）无法正常工作，内部SignalR日志可能会有所帮助。请尝试并发布日志... - Michal Levý

Answer 2

如果我将“localhost”更改为不存在的内容（例如locahostX），我会收到java.net.UnknownHostException错误。

你确定吗？

以下是解决方法：

1. 在服务器命令提示符中运行“ipconfig”以获取服务器的IP地址。 2. 从客户端命令提示符中键入“ping”+服务器的IP地址。 3. 如果ping发送数据包，则尝试将IP放入字符串“ServerURI”中，使其类似于“http://”+ ServerIP +“：8080 / signalr”。

- Hristo Georgiev

---

谢谢Hristo，但我已经尝试过IP了。起初我以为是防火墙问题，但也不是那个问题... - George Vovos