websocket#

1importPackage(Packages["okhttp3"]); //导入包
2var client = new OkHttpClient.Builder().retryOnConnectionFailure(true).build();
3var request = new Request.Builder().url("ws://192.168.31.164:9317").build(); //vscode  插件的ip地址，
4client.dispatcher().cancelAll(); //清理一次
5myListener = {
6    onOpen: function (webSocket, response) {
7        print("onOpen");
8        //打开链接后，想服务器端发送一条消息
9        var json = {};
10        json.type = "hello";
11        json.data = { device_name: "模拟设备", client_version: 123, app_version: 123, app_version_code: "233" };
12        var hello = JSON.stringify(json);
13        webSocket.send(hello);
14    },
15    onMessage: function (webSocket, msg) {
16        //msg可能是字符串，也可能是byte数组，取决于服务器送的内容
17        print("msg");
18        print(msg);
19    },
20    onClosing: function (webSocket, code, response) {
21        print("正在关闭");
22    },
23    onClosed: function (webSocket, code, response) {
24        print("已关闭");
25    },
26    onFailure: function (webSocket, t, response) {
27        print("错误");
28        print(t);
29    },
30};
31
32var webSocket = client.newWebSocket(request, new WebSocketListener(myListener)); //创建链接
33
34setInterval(() => {
35    // 防止主线程退出
36}, 1000);