const cloud = tt.createCloud({
         envID: 'env-0WIYiY4PNP'
      });

const webSocket = cloud.connectContainer({
  path: "/path"
});

webSocket.onMessage((message) => {
      // 每次 WebSocket 发送的信息
      console.log("socket message:", message);
});

tt.createCloud(options)

Cloud.connectContainer(options);

CloudSocketTask.send(options);

CloudSocketTask.close(options);

CloudSocketTask.onOpen(callback);

CloudSocketTask.onClose(callback);

CloudSocketTask.onMessage(callback);

CloudSocketTask.onError(callback);

CloudSocketTask.getCloudExtensionManager()

CloudExtensionManager.joinGroup(options)

CloudExtensionManager.exitGroup(options)

<!-- index.ttml -->
  <view>
    <button size="default" bindtap="socketConnect">创建 WebSocket </button>
    <button size="default" bindtap="closeSocket"> 关闭 WebSocket </button>
    <input value="{{inputValue}}" bindinput="inputChange"></input>
    <button size="default" bindtap="sendSocket"> 发送 WebSocket 数据 </button>
    <button size="default" bindtap="joinGroup"> 加入组播数据组 </button>
    <button size="default" bindtap="exitGroup"> 离开组播数据组 </button>
  <view>

// index.js
let cloudSocketTask;
let cloud;
Page({
  data: {
    inputValue: "",
    isOpen:false,
  },
  onLoad(){
      cloud = tt.createCloud({envID:'envID',serviceID:'serviceID'})
  },
  socketConnect() {
    // 如果已经创建，就不再创建了
    if (cloudSocketTask) {
      return;
    }
    cloudSocketTask = cloud.connectContainer({
      path: "path", //开发者提供的url
      success: (res) => {
        // 创建成功的回调
        console.log("创建成功", res);
      },
      fail: (res) => {
        // 创建失败的回调
        console.log("创建失败", res);
      },
      complete: (res) => {
        // 创建完毕的回调
        console.log("创建完毕", res);
      },
    });

    cloudSocketTask.onOpen(() => {
      // 此时表示 websocket 已经处于 open 状态
      console.log("WebSocket 已连接");
      this.setData({
          isOpen:true    
      })
    });

    cloudSocketTask.onClose(() => {
      // 此时表示 websocket 已经处于 closed 状态
      console.log("WebSocket 已断开");
      this.setData({
          isOpen:false   
      })
    });

    cloudSocketTask.onError((error) => {
      // 此处表示 websocket 有错误发生
      console.error("WebSocket 发生错误:", error);
    });

    cloudSocketTask.onMessage((message) => {
      // 每次 WebSocket 发送的信息
      console.log("socket message:", message);
    });
  },
  closeSocket() {
    // 主动关闭 websocket 连接
    console.log("---- close");
    if (cloudSocketTask) {
      cloudSocketTask.close({
        success: (res) => {
          // 关闭成功的回调
          console.log("close success", res);
        },
        fail: (res) => {
          // 关闭失败的回调
          console.log("close fail", res);
        },
      });
    }
  },
  sendSocket() {
    // 向 websocket 发送信息
    console.log("---- send", this.data.inputValue);
    if (this.data.isOpen) {
      cloudSocketTask.send({
        data: this.data.inputValue,
        success: (res) => {
          // 发送成功的回调
          console.log("send success", res);
        },
        fail: (res) => {
          // 发送失败的回调
          console.log("send fail", res);
        },
      });
    }
  },
  joinGroup(){
    // 切换组播数据组
    console.log("---- joinGroup");
    if (cloudSocketTask) {
      const extensionManager = cloudSocketTask.getCloudExtensionManager()
      extensionManger.joinGroup({
        groupInfoArray:[{
          groupName:"group1",
          groupValue:"tag1"
        }],
        success: (res) => {
          // 加入组播组成功的回调
          console.log("join group success", res);
        },
        fail: (res) => {
          // 加入组播组失败的回调
          console.log("join group fail", res);
        },
      });
    }
  },
  exitGroup(){
    // 切换组播数据组
    console.log("---- exitGroup");
    if (cloudSocketTask) {
      const extensionManager = cloudSocketTask.getCloudExtensionManager()
      extensionManger.exitGroup({
        groupInfoArray:[{
          groupName:"group1",
          groupValue:"tag1"
        }],
        success: (res) => {
          // 离开组播组成功的回调
          console.log("exit group success", res);
        },
        fail: (res) => {
          // 离开组播组失败的回调
          console.log("exit group fail", res);
        },
      });
    }
  },
  inputChange(e) {
    this.setData({
      inputValue: e.detail.value,
    });
  },
});