3 回答

• 109

  一些笔记 .

  • koush/AndroidAsync 不执行RFC 6455所需的closing handshake . 有关详细信息，请参阅this .

  • Project Tyrus 适用于Android，但要确保其许可证（CDDL 1.1 and GPL 2 with CPE）及其大小（Reducing WebSocket client jar size with ProGuard）符合您的要求 . 另请注意，当文本大小很大时，Tyrus可能会抛出异常（这可能是一个错误） . 有关详细信息，请参阅this .

  • Jetty ：2年前email thread在jetty-users邮件列表中说"We currently have no Android compatible Jetty 9 WebSocket client. There are plans to attempt to backport the Jetty WebSocket Client from JDK 7 to JDK 5/6 for android use, but its a lower priority than finishing our implementation of JSR-356 Java WebSocket API (javax.websocket)." Jetty当前关于其WebSocket Client API的document没有提及有关Android的任何内容 .

  • codebutler/android-websocket 不执行RFC 6455所需的closing handshake，并且可能会在关闭时抛出异常 . 见this .

  • Atmosphere/wasync 使用 AsyncHttpClient/async-http-client 作为其WebSocket实现 . 因此，应该提到AsyncHttpClient / async-http-client .

  • firebase/TubeSock 无法验证 Sec-WebSocket-Accept . 这违反了RFC 6455 . 此外，TubeSock在构建短信时存在错误 . 如果您对文本消息使用多字节UTF-8字符，您迟早会遇到该错误 . 有关TubeSock问题的详细列表，请参阅delight-im/Android-DDP中的Issue 3 .

  考虑点

  选择用Java编写的WebSocket客户端实现时的注意事项：

  • Compliance . 不少实现不实现RFC 6455所需的closing handshake . （如果未执行结束握手会怎样？请参阅this . ）

  • Required Java version . Java SE 5,6,7,8或Java EE？甚至可以在Android上运行？

  • Size . 一些实现具有许多依赖性 .

  • wss 支持 .

  • HTTP proxy 支持 .

  • wss over HTTP proxy 支持 . 请参阅How HTML5 Web Sockets Interact With Proxy Servers中的图2，了解WebSocket客户端库必须采取哪些措施来支持HTTP代理上的wss .

  • Flexibility on SSL configuration . SSLSocketFactory 和 SSLContext 应该能够在没有不必要限制的情况下使用 .

  • Custom HTTP headers in the opening handshake ，包括基本身份验证 .

  • Custom HTTP headers in HTTP proxy negotiation ，包括代理服务器上的身份验证 .

  • Capable of sending all the frame types （继续，二进制，文本，关闭，ping和pong）与否 . 大多数实现都没有为开发人员提供手动发送fragmented frames和未经请求的pong frames的方法 .

  • Listener interface 接收各种WebSocket事件 . 糟糕的界面让开发人员感到沮丧 . 丰富的界面可帮助开发人员编写健壮的应

  • Able to inquire WebSocket state 与否 . RFC 6455定义了CONNECTING，OPEN，CLOSING和CLOSED状态，但很少有实现以定义的方式维护其内部状态转换 .

  • Able to set a timeout value for socket connection . （相当于 Socket.connect(SocketAddress endpoint, int timeout) 方法的第二个参数）

  • Able to access the underlying raw socket .

  • Intuitive easy-to-use API 与否 .
    是否

  • Well-documented .

  • RFC 7692 (Compression Extensions for WebSocket) 支持（aka permessage-deflate） .

  • Redirection （3xx）支持 .

  • Digest Authentication 支持 .

  nv-websocket-client 涵盖了除最后两个之外的所有内容 . 此外，它的一个小而方便的功能是定期发送ping / pong帧 . 只需调用 setPingInterval / setPongInterval 方法即可实现（参见JavaDoc） .

  免责声明：Takahiko Kawasaki是nv-websocket-client的作者 .

  回复于 2024-04-26T13:20:14+08:00
• 3

  其他一些考虑：

  Tyrus适用于Android . 但是，它在Android 5.0中使用的SSL库是错误的fail SSL handshakes . 这应该在较新版本的Android中修复，但由于Android未在许多设备上更新的方式，这可能是一个问题 .

  根据SSL对其他websocket实现的实现方式，这可能也是一个问题 .

  AndroidAsync没有此SSL问题 . 它确实有其他问题，如not being able to set timeouts .

  回复于 2024-04-26T13:20:14+08:00
• 2

  a）在gradle文件中添加此文件

  compile 'com.github.nkzawa:socket.io-client:0.3.0'

  b）在Application Activity中添加以下行：

  public class MyApplication extends Application {
       private Socket mSocket;
          {
              try {
                 mSocket = IO.socket(Config.getBaseURL());
  
              } catch (URISyntaxException e) {
                  throw new RuntimeException(e);
              }
          }
  
          public Socket getSocket() {
              return mSocket;
          }
  }
  

  c）将此函数添加到您调用WebSocket的活动中：

  private void websocketConnection() {
              //Get websocket from application
              MyApplication app = (MyApplication ) getApplication();
              mSocket = app.getSocket();
              mSocket.on(Socket.EVENT_CONNECT, onConnect);
              mSocket.on(Socket.EVENT_DISCONNECT, onDisconnect);
              mSocket.on(Socket.EVENT_CONNECT_ERROR, onConnectError);
              mSocket.on(Socket.EVENT_CONNECT_TIMEOUT, onConnectError);
              mSocket.on("messageFromServer", onNewLocation);
              mSocket.connect();
          } 
  
  
      private Emitter.Listener onConnect = new Emitter.Listener() {
          @Override
          public void call(Object... args) {
              runOnUiThread(() -> {
                  if (!isConnected) {
  
                      RequestSocket mRequestSocket = new RequestSocket();
  
                      mRequestSocket.setToken("anil_singhania");
                     /* your parameter */
                      mSocket.emit("messageFromClient", new Gson().toJson(mRequestSocket));
                      Log.i("Socket Data", new Gson().toJson(mRequestSocket));
                      isConnected = true;
                  }
              });
          }
      };
  
      private Emitter.Listener onDisconnect = args -> runOnUiThread(() -> {
          isConnected = false;
         /* Toast.makeText(getApplicationContext(),
                  R.string.disconnect, Toast.LENGTH_LONG).show();*/
      });
  
      private Emitter.Listener onConnectError = args -> runOnUiThread(() -> {
           /*   Toast.makeText(getApplicationContext(),
              R.string.error_connect, Toast.LENGTH_LONG).show()*/
      });
  
      private Emitter.Listener onNewLocation = new Emitter.Listener() {
          @Override
          public void call(final Object... args) {
              runOnUiThread(() -> {
  
  
              });
          }
      };
  

  回复于 2024-04-26T13:20:14+08:00