compile 'com.neovisionaries:nv-websocket-client:2.2'
WebSocket ws = new WebSocketFactory()
.createSocket(DEF_URL, CONNECT_TIMEOUT)
.setFrameQueueSize(FRAME_QUEUE_SIZE)//设置帧队列最大值为5
.setMissingCloseFrameAllowed(false)//设置不允许服务端关闭连接却未发送关闭帧
.addListener(...)//添加回调监听
.connectAsynchronously();//异步连接
class WsListener extends WebSocketAdapter {
@Override
public void onTextMessage(WebSocket websocket, String text) throws Exception {
super.onTextMessage(websocket, text);
//接收到服务器数据
Log.e("TAG",text);
}
@Override
public void onConnected(WebSocket websocket, Map<String, List<String>> headers)
throws Exception {
super.onConnected(websocket, headers);
Log.e("TAG","连接成功");
}
@Override
public void onConnectError(WebSocket websocket, WebSocketException exception)
throws Exception {
super.onConnectError(websocket, exception);
Log.e("TAG","连接错误");
}
@Override
public void onDisconnected(WebSocket websocket, WebSocketFrame serverCloseFrame, WebSocketFrame clientCloseFrame, boolean closedByServer)
throws Exception {
super.onDisconnected(websocket, serverCloseFrame, clientCloseFrame, closedByServer);
}
}
WebSocket安卓客户端实现详解(一)--连接建立与重连
WebSocket安卓客户端实现详解(二)--客户端发送请求
WebSocket安卓客户端实现详解(三)--服务端主动通知
网友评论