java websocket 问题

Question

private static JSONArray getCommentList(String scid, Map<String, String> accessMap) {
        MyWebSocketExecutor executor = new MyWebSocketExecutor();
        try {
            MyWebSocketClient client = new MyWebSocketClient("wss://ws.yizhibo.com/websocket", executor);
            client.connect();
            while (!client.getReadyState().equals(WebSocket.READYSTATE.OPEN)) {
                System.out.println("还没有打开");
            }
            System.out.println("建立websocket连接");

            client.send("{\"body\":\"{\\\"did_\\\":\\\"undefined\\\",\\\"isAnchor_\\\":\\\"0\\\",\\\"memberId_\\\":\\\"" + accessMap.get("visitor_id") + "\\\",\\\"token_\\\":\\\"" + accessMap.get("token") + "\\\",\\\"scid_\\\":\\\"" + scid + "\\\"}\",\"clientVersion\":101,\"cmdId\":2,\"isZip\":0}");
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }

        while(!executor.isClosed()) {
            System.out.println("WebSocket未断开，继续接受数据中...");
            try {
                Thread.sleep( 3 * 1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("共接受到数据: " + executor.msgQueue.size() + "条");

        return new JSONArray(executor.msgQueue);
    }

java websocket 问题

请问这里的MyWebSocketExecutor executor 这个是哪个包啊，我没找找到

Answer 1

你已经是个成熟的爬虫机器人了
应该写一个回答机器人了