//WebSocket 依赖包

implementation 'com.neovisionaries:nv-websocket-client:2.2'

  try {

          WebSocket ws = new WebSocketFactory().createSocket(url, CONNECT_TIMEOUT) //ws地址，和设置超时时间

                    .setFrameQueueSize(FRAME_QUEUE_SIZE)//设置帧队列最大值为5

                    .setMissingCloseFrameAllowed(false)//设置不允许服务端关闭连接却未发送关闭帧

                    .addListener(wsListener = new WsListener())//添加回调监听

                    .connectAsynchronously();//异步连接

        } catch (IOException e) {

            e.printStackTrace();

        }

/**

     * 继承默认的监听空实现WebSocketAdapter,重写我们需要的方法

     * onTextMessage 收到文字信息

     * onConnected 连接成功

     * onConnectError 连接失败

     * onDisconnected 连接关闭

     */

    class WsListener extends WebSocketAdapter {

        @Override

        public void onTextMessage(WebSocket websocket, String text) throws Exception {

            super.onTextMessage(websocket, text);

            logger.info(text);

            String[] msgs = text.split("\\|");

            if (msgs.length >= 2) {

                NotificationShow(msgs[0], msgs[1]);

                sendReceiveMessageBroadcast(msgs[0], msgs[1]);

            }

        }

        @Override

        public void onConnected(WebSocket websocket, Map<String, List<String>> headers)

                throws Exception {

            super.onConnected(websocket, headers);

            logger.info("连接成功");

        }

        @Override

        public void onConnectError(WebSocket websocket, WebSocketException exception)

                throws Exception {

            super.onConnectError(websocket, exception);

            logger.warning("连接错误：" + exception.getMessage());

        }

        @Override

        public void onDisconnected(WebSocket websocket, WebSocketFrame serverCloseFrame, WebSocketFrame clientCloseFrame, boolean closedByServer)

                throws Exception {

            super.onDisconnected(websocket, serverCloseFrame, clientCloseFrame, closedByServer);

            logger.warning("断开连接");

        }

    }