2015-05-15 97 views
9

我无法将我的java应用程序连接到我的SignalR服务器。
服务器非常简单,可以在这里找到:
https://code.msdn.microsoft.com/windowsdesktop/Using-SignalR-in-WinForms-f1ec847bSignalR java无法连接到服务器

我可以连接,但我有我的Java客户端的麻烦Web客户端(JavaScript)的Windows客户端(C#)( 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异常:连接复位”

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,我不事件得到一个异常...

- 所有的其他应用程序与两个(或本地主机IP)

工作起初我以为这是一个防火墙的问题,但它不是...

显然我失去了一些东西... 任何想法?

感谢

回答

3

事实证明,我不得不使用开始过载,一个是作为一个参数一个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(); 
    } 
} 
+0

不知道关于这个问题,但你曾尝试使用带有ILogger实例的HubConnection构造函数重载吗?似乎自动传输选择(协商)不起作用,并且内部SignalR日志可能对此有所帮助。尝试一下并发布日志... –

0

如果我把 “localhost” 的东西,不存在(例如 locahostX)我得到的java.net.UnknownHostException

你肯定吗?

  1. 在服务器命令提示符上运行“ipconfig”以获取服务器的IP地址。
  2. 从客户端命令提示符处输入“ping”+服务器的IP地址。
  3. 如果ping发送包,则尝试将字符串“ServerURI”中的IP设置为“http://”+ ServerIP +“:8080/signalr”。
+0

谢谢斯托伊奇但我已经试过IP.At开始我还以为这是一个防火墙的问题,但它不是,要么...... –