如何短时间内手动关闭websocket连接

[JerryChaox]

有时候虽然绑定了Activity的生命周期，但是有时候希望在Activity生命周期内的某一段时间暂时关闭websocket链接

[dhhAndroid]

你用的RxJava1，还是RxJava2版本？

[wolfking0608]

com.dhh:websocket2:2.1.4'如何实现手动取消连接,别自动连接 这种: 有些需求要手动关闭它 Config config = new Config.Builder().setClient(new OkHttpClient().newBuilder() .pingInterval(2, TimeUnit.SECONDS).build() ).setShowLog(true, "test_websocket").build(); RxWebSocket.setConfig(config); //处理有时候,加载过慢,url为空闪退问题 webSocketInfoObservable = RxWebSocket.get("wss://chattest.xxxxx.com"); webSocketInfoObservable.as(RxLifecycleUtils.bindLifecycle(getLifecycleOwner())) .subscribe(new WebSocketSubscriber() {

                @Override
                protected void onMessage(String messageInfo) {
                    Log.e("messageInfo", "messageInfo==" + messageInfo);
                    onMessageResponse(messageInfo);
                }

                @Override
                protected void onMessage(ByteString byteString) {
                    super.onMessage(byteString);
                    Log.e("messageInfo", "byteString==" + byteString.toString());
                }

                @Override
                public void onError(Throwable e) {
                    super.onError(e);
                    Log.e("messageInfo", "onError==" + e.getMessage());
                }

                @Override
                protected void onOpen(WebSocket webSocket) {
                    mWebSocket = webSocket;
                    super.onOpen(webSocket);

                    JSONObject jsonObject = new JSONObject();
                    jsonObject.put("type", "ping");
                    WebSocketSetting.setConnectUrl("wss://chattest.xxx.com");
                    RxWebSocket.send(WebSocketSetting.getConnectUrl(), jsonObject.toJSONString());
                    MLog.e("-------------------------------", "ping-------------------------");
                    initDownTimer();
                }

                @Override
                protected void onReconnect() {
                    super.onReconnect();
                    Log.e("messageInfo", "onReconnect");
                }

                @Override
                protected void onClose() {
                    super.onClose();
                    Log.e("messageInfo", "onClose");
                }
            });

[dhhAndroid]

请查看 issues #50