Android Nkzawa SocketIO 断开连接并建立新连接

Question

我正在使用 android，socketio (nkzawa)。当我第一次连接时工作正常。但是如果我断开连接并尝试建立“另一个连接”，则永远不会调用 EVENT_CONNECT。

这里我放了一些 fragment

连接时

在 BeforeActivity 中

@Override
public void onResume() {
    super.onResume();   
    socketManager = (socketManager) socketManager.Instance(this, UrlHelper.URL.replaceAll("\\{userId\\}", userId.toString());
}

然后我有一个从 GenericSocket 扩展的类 SocketManager，其中我有一个用于单例的变量 (SocketManager) 实例

public static SocketManager Instance(SocketListener listener, String url) {

  if (instance == null) {
    instance = new socketManager(url);
    instance.init();
  }

  socketManager.listener = (listener)listener;

  return instance;
}

套接字的初始化是在类 GenericSocket 中完成的，我有一个类型为 (com.github.nkzawa.socketio.client.Socket) 的变量，称为套接字

protected void init() {
    try {
        socket = IO.socket(url);
        socket
        .on(com.github.nkzawa.socketio.client.Socket.EVENT_CONNECT, new Emitter.Listener() {

            @Override
            public void call(Object... args) {
                onConnect();
                JSONObject connectionMessage = getConnectionMessage();
                socket.emit(MESSAGE_JOIN, connectionMessage);
            }

        }).on(MESSAGE, new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Object data = args[0];
                if (data instanceof JSONObject) {
                    JSONObject json = (JSONObject) data;
                    try {
                        onMessage(json.get("content").toString());
                    } catch (Exception ex) {
                        Log.e(TAG, ex.getMessage());
                    }
                } else {
                    onMessage(data.toString());
                }

            }
        }).on(Constant.CONNECTION, new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                Object data = args[0];
                if (data instanceof JSONObject) {
                    JSONObject json = (JSONObject) data;
                    try {
                        onMessage(json.get("content").toString());
                    }
                    catch(Exception ex) {
                        Log.e(TAG, ex.getMessage());
                    }
                } else {
                    onMessage(data.toString());
                }

            }
        }).on(com.github.nkzawa.socketio.client.Socket.EVENT_DISCONNECT, new Emitter.Listener() {

            @Override
            public void call(Object... args) {
                onDisconnect();
            }
        });
        socket.connect();
    }catch (Exception e){
        Log.i("Socket connection error: ", e.getMessage());
    }
    //end socket connection
}

当我断开连接时

在SocketManager类中断开连接是这样的我有这个方法

public void disconnect() {
  this.socket.disconnect();
  this.socket=null;
  SocketManager.instance = null;
}

谢谢

Answer 1

您的代码看起来不错。尝试将 this.socket.off() 放在 socket.disconnect() 之前。我遇到了一个问题，即使在 disconnect()、socket.off() 对我有效之后，服务器仍然保持我的连接。