如何短时间内手动关闭websocket连接 about rxwebsocket HOT 3 CLOSED

                @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");
                }
            });