如何检查信号器hubconnection是否在线或不在android？

Question

我正在使用signalr进行聊天api，signalr服务正在启动并获取一段时间的聊天消息，但经过一段时间后，信号中心连接没有响应，我无法与signalR服务器联系。如何检查signalr hubconnection是否在线或不在android。

Answer 1

试试这个方法

public static boolean isInternetOn(Context context) { 
    ConnectivityManager connec = (ConnectivityManager) context 
      .getSystemService(Context.CONNECTIVITY_SERVICE); 
    NetworkInfo mWifi = connec.getNetworkInfo(ConnectivityManager.TYPE_WIFI); 
    if (connec.getNetworkInfo(0).getState() == NetworkInfo.State.CONNECTED || 
      connec.getNetworkInfo(0).getState() == NetworkInfo.State.CONNECTING || 
      connec.getNetworkInfo(1).getState() == NetworkInfo.State.CONNECTING || 
      connec.getNetworkInfo(1).getState() == NetworkInfo.State.CONNECTED 
      || mWifi.isConnectedOrConnecting()) { 
     return true; 
    } else if (connec.getNetworkInfo(0).getState() == NetworkInfo.State.DISCONNECTED || 
      connec.getNetworkInfo(1).getState() == NetworkInfo.State.DISCONNECTED || 
      mWifi.getState() == NetworkInfo.State.DISCONNECTED) { 
     return false; 
    } 
    return false; 
} 

Answer 2

，当你调用此方法比这种情况下，你可以得到hubconnection的当前状态。

private void startSignalR() { 
     Platform.loadPlatformComponent(new AndroidPlatformComponent()); 
     mInstance.setmHubConnection(getApplicationContext()); 
     mInstance.setHubProxy(); 
     ClientTransport clientTransport = new ServerSentEventsTransport(mInstance.mHubConnection.getLogger()); 
     signalRFuture = mInstance.mHubConnection.start(clientTransport); 
     try { 
      signalRFuture.get(); 
     } catch (InterruptedException | ExecutionException e) { 
      SharedPrefUtil.clearAllSharedPreferences(getApplicationContext()); 
      Toast.makeText(getApplicationContext(), getString(R.string.wrong_server), Toast.LENGTH_LONG).show(); 
      Log.e("SimpleSignalR", e.toString()); 
      return; 
     } 

     mInstance.mHubConnection.error(new ErrorCallback() { 

      @Override 
      public void onError(Throwable error) { 
       error.printStackTrace(); 
      } 
     }); 

     // Subscribe to the connected event 
     mInstance.mHubConnection.connected(new Runnable() { 

      @Override 
      public void run() { 
       System.out.println("CONNECTED"); 
      } 
     }); 

     mInstance.mHubConnection.reconnected(new Runnable() { 

      @Override 
      public void run() { 

       System.out.println("RECONNECTED"); 
      } 
     }); 
     // Subscribe to the closed event 
     mInstance.mHubConnection.closed(new Runnable() { 

      @Override 
      public void run() { 

       System.out.println("DISCONNECTED"); 
      } 
     }); 

     mInstance.mHubProxy.on(SignalRConstant.CLIENT_METHOD_BROADAST_MESSAGE, 
       new SubscriptionHandler2<String, Object>() { 
        @Override 
        public void run(final String msg, final Object data) { 
         if (msg != null && data != null && !data.equals("")) { 
          Intent intent = new Intent(); 
          intent.setAction(MY_ACTION); 
          intent.putExtra("CAPTION", msg); 
          if(msg.equals(SignalRConstant.CAPTION_LOGINPASS)) 
          { 
           Gson gson = new GsonBuilder().setDateFormat(AppConstant.DATE_FORMAT).create(); 
           intent.putExtra("DATA", gson.toJson(data)); 
          }else{ 
           intent.putExtra("DATA", data.toString()); 
          } 
          sendBroadcast(intent); 
         } 
        } 
       } 
       , String.class, Object.class); 
    }