websocket

websocket

websocket

4.2.8 新增

稳定性: 稳定

websocket模块，采用okhttp3 实现，本模块中包含了okhttp3 核心所有的类，下面讲解其基本的使用方法，更多的使用规则,可参考：(https://square.github.io/okhttp/)，这里涉及一些线程安全问题，请学习多线程，生命周期等内容。%EF%BC%8C%E8%BF%99%E9%87%8C%E6%B6%89%E5%8F%8A%E4%B8%80%E4%BA%9B%E7%BA%BF%E7%A8%8B%E5%AE%89%E5%85%A8%E9%97%AE%E9%A2%98%EF%BC%8C%E8%AF%B7%E5%AD%A6%E4%B9%A0%E5%A4%9A%E7%BA%BF%E7%A8%8B%EF%BC%8C%E7%94%9F%E5%91%BD%E5%91%A8%E6%9C%9F%E7%AD%89%E5%86%85%E5%AE%B9%E3%80%82)

创建websocket客户端

• 创建一个http client，可以设定client是否重连，心跳等功能

• 创建一个request 请求对象，采用什么协议ws 或wss 、服务器、端口都能内容

• 设置监听，当websocket 生命周期内的一些事情。

• 设置上面的操作以后，打开链接，创建webSocket 客户端。

• 用webSocket 客户端 发送消息 webSocket.send("你好服务器");

  importPackage(Packages[“okhttp3”]); //导入包
  var client = new OkHttpClient.Builder().retryOnConnectionFailure(true).build();
  var request = new Request.Builder().url(“ws://192.168.31.164:9317”).build(); //vscode 插件的ip地址，
  client.dispatcher().cancelAll();//清理一次
  myListener = {
  onOpen: function (webSocket, response) {
  print(“onOpen”);
  //打开链接后，想服务器端发送一条消息
  var json = {};
  json.type=”hello”;
  json.data= {device_name:”模拟设备”,client_version:123,app_version:123,app_version_code:”233”};
  var hello=JSON.stringify(json);
  webSocket.send(hello);
  },
  onMessage: function (webSocket, msg) { //msg可能是字符串，也可能是byte数组，取决于服务器送的内容
  print(“msg”);
  print(msg);
  },
  onClosing: function (webSocket, code, response) {
  print(“正在关闭”);
  },
  onClosed: function (webSocket, code, response) {
  print(“已关闭”);
  },
  onFailure: function (webSocket, t, response) {
  print(“错误”);
  print( t);
  }
  }

  var webSocket= client.newWebSocket(request, new WebSocketListener(myListener)); //创建链接

  setInterval(() => { // 防止主线程退出

  }, 1000);

创建 websocket 服务器端，一样支持，可以参考 okhttp 官网。