我正在使用Android、socketio (nkzawa)进行工作。第一次连接时完美运行。但是,如果我断开连接并尝试进行“另一个连接”,则EVENT_CONNECT永远不会被调用。
这里我放了一些片段
当我连接时
在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)的变量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;
}
谢谢你