Тайм-аут сокета всегда с библиотеками Android
Сокет в Android не будет подключаться, даже если на сервере (Java Server) с ранее вызванным ServerSocket.Accpet() соединение от клиента (устройство Android) получено и принято, но клиент никогда не узнает об этом и не истекает время ожидания.
Вот код сервера, который работает на iOS с библиотекой CocoaAsync и работает на открытом порте, и "сокет, принятый от..." печатается, когда клиент пытается подключиться, поэтому его подключенный и обработчик запросов - это просто класс для обработки чтений из каждого клиент, после принятия одного, он снова зациклится и будет ждать на serverSocket.Accpet() другого клиента:
ServerSocket serverSocket = null;
Socket socket = null;
serverSocket = new ServerSocket(PORT);
logger.info("started socket server on 127.0.0.1:" + PORT);
while (true) {
try {
logger.info("waiting to receive connection ...");
socket = serverSocket.accept();
logger.info("socket accepted from " + socket.getInetAddress().getHostAddress());
} catch (IOException e) {
System.out.println("I/O error: " + e);
}
// new thread for a client
RequestHandler t = new RequestHandler(socket);
t.start();
}
Сторона Android:
в манифесте <uses-permission android:name="android.permission.INTERNET" />
Использование Socket-io сохраняет время ожидания печати, ошибку соединения, переподключение,...
IO.Options options = new IO.Options();
options.forceNew = true;
options.transports = new String[]{WebSocket.NAME};
try {
socket = IO.socket(IP,options); //ip with port
socket.connect();
socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_CONNECT", API.class);
}
}).on(Socket.EVENT_DISCONNECT, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_DISCONNECT", API.class);
}
}).on(Socket.EVENT_CONNECT_ERROR, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_CONNECT_ERROR", API.class);
}
}).on(Socket.EVENT_CONNECT_TIMEOUT, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_CONNECT_TIMEOUT", API.class);
}
}).on(Socket.EVENT_RECONNECT_ERROR, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_RECONNECT_ERROR", API.class);
}
})
.on(Socket.EVENT_RECONNECT_FAILED, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_RECONNECT_FAILED", API.class);
}
}).on(Socket.EVENT_RECONNECTING, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_RECONNECTING", API.class);
}
}).on(Socket.EVENT_CONNECT_TIMEOUT, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_CONNECT_TIMEOUT", API.class);
}
}).on(Socket.EVENT_MESSAGE, new Emitter.Listener() {
@Override
public void call(Object... args) {
Utils.Log("Socket EVENT_MESSAGE", API.class);
}
});
} catch (URISyntaxException e) {
e.printStackTrace();
}
Используя AsyncAndroid тоже получаю тайм-аут,
AsyncHttpClient.getDefaultInstance().websocket(IP, "my-protocol", new AsyncHttpClient.WebSocketConnectCallback() {
@Override
public void onCompleted(Exception ex, WebSocket webSocket) {
if (ex != null) {
ex.printStackTrace();
return;
}
webSocket.setEndCallback(new CompletedCallback() {
@Override
public void onCompleted(Exception ex) {
Utils.Log("Socket EndCallback", API.class);
}
});
webSocket.setClosedCallback(new CompletedCallback() {
@Override
public void onCompleted(Exception ex) {
Utils.Log("Socket ClosedCallback", API.class);
}
});
webSocket.setStringCallback(new WebSocket.StringCallback() {
public void onStringAvailable(String s) {
Utils.Log("Socket setStringCallback", API.class);
}
});
webSocket.setDataCallback(new DataCallback() {
public void onDataAvailable(DataEmitter emitter, ByteBufferList byteBufferList) {
Utils.Log("Socket DataCallback", API.class);
byteBufferList.recycle();
}
});
}
});
, пробовал rxWebSocket, OkSocket,nv-websocket-client и некоторые другие библиотеки с тем же результатом, имейте в виду, что я могу подключиться к серверу с помощью простого сокета Java.net и его работы с iOS тоже.
Тестирование на устройстве Android 8.1 и эмуляторе Заранее спасибо.
ОБНОВЛЕНИЕ: я придумал 2 решения с 2 библиотеками и опубликую их позже
1 ответ
Это код, который я придумал, используя AsyncAndroid, где server, currentSocket, isConnected, isConnecting, sessionReloaded (вам это может не понадобиться) являются статическими переменными для отправки запроса. Я просто вызываю connectSocket(..), если сокет подключен " переменная currentSocket "возвращается, чтобы ее можно было записать и обработать процесс чтения в DataCallBack, или он добавит запрос или все, что вы хотите записать в сокет, в pendingList и попытается соединиться, а затем записать все отложенные записи. (в моем случае первое, что нужно написать после подключения, это сеанс, так что вы можете игнорировать этот шаблон, и у вас может быть своя собственная политика в отношении того, что запрос застрял (ожидает рассмотрения) за соединительным сокетом, чтобы сделать то, что вы хотите, и это просто шаблон, который я используется но кроме этого это обычное дело)
public static void connectSocket(onSocketConnectionListener listener) {
if (server == null) {
server = new AsyncServer();
}
if (server.isRunning()) {
if (listener != null)
listener.connected(currentSocket);
return;
}
ConnectCallback socketCallBack = new ConnectCallback() {
@Override
public void onConnectCompleted(Exception ex, AsyncSocket socket) {
isConnecting = false;
if (ex != null) {
server.stop();
sessionReloaded = false;
Utils.Log("Exception = " + ex.getCause() + " , Server Running State = " + server.isRunning(), API.class);
A.runOnUiThread(new Runnable() {
@Override
public void run() {
new android.os.Handler().postDelayed(new Runnable() {
@Override
public void run() {
connectSocket(null);
}
}, 3000);
}
});
return;
}
Utils.Log("Server Running State = " + server.isRunning(), API.class);
isConnected = true;
currentSocket = socket;
triggerConnections();
socket.setDataCallback(new DataCallback() {
@Override
public void onDataAvailable(DataEmitter emitter, ByteBufferList bb) {
byte[] bytes = bb.getAllByteArray();
String[] content = Utils.splitJson(new String(bytes));
for (int i = 0; i < content.length; i++) {
Utils.Log("SocketDataReceived = " + content[i], API.class);
handleData(content[i]);
}
bb.recycle();
}
});
socket.setClosedCallback(new CompletedCallback() {
@Override
public void onCompleted(Exception ex) {
if (ex != null) {
Utils.Log("Closed CallBack With Exception = " + ex.getCause(), API.class);
} else {
Utils.Log("Closed CallBack", API.class);
}
sessionReloaded = false;
isConnected = false;
server.stop();
triggerDisconnections();
A.runOnUiThread(new Runnable() {
@Override
public void run() {
new android.os.Handler().postDelayed(new Runnable() {
@Override
public void run() {
connectSocket(new onSocketConnectionListener() {
@Override
public void connected(AsyncSocket socket) {
}
});
Utils.Log("Closed CallBack", API.class);
}
}, 3000);
}
});
}
});
socket.setEndCallback(new CompletedCallback() {
@Override
public void onCompleted(Exception ex) {
if (ex != null) {
Utils.Log("End CallBack With Exception = " + ex.getCause(), API.class);
} else {
Utils.Log("End CallBack", API.class);
}
sessionReloaded = false;
isConnected = false;
server.stop();
}
});
socket.setWriteableCallback(new WritableCallback() {
@Override
public void onWriteable() {
Utils.Log("Write CallBack", API.class);
}
});
User user = MDatabase.getUser();
String session = MDatabase.getSession();
if (sessionNeedsReload()) {
reloadSession(user.mobile, session);
} else {
doPendingRequests();
}
}
};
synchronized (isConnecting) {
if (!isConnecting) {
isConnecting = true;
Utils.Log("Socket Connecting ...", API.class);
server.connectSocket(IP, PORT, socketCallBack);
}
}
}