发送和接收消息

//发送自定义消息的示例代码
public void sendHello() {
    try {
        // 自定义消息命令字, 这里需要根据业务定制一套规则，这里以0x1代表发送文字广播消息为例
        int cmdID = 0x1;
        String hello = "Hello";
        byte[] data = hello.getBytes("UTF-8");
        // reliable 和 ordered 目前需要一致，这里以需要保证消息按发送顺序到达为例
        trtcCloud.sendCustomCmdMsg(cmdID, data, true, true);

    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }
}

// 发送自定义消息的示例代码
void sendHello()
{
    // 自定义消息命令字, 这里需要根据业务定制一套规则，这里以0x1代表发送文字广播消息为例

    uint32_t cmdID = 0x1;
    uint8_t* data = { '1', '2', '3' };
    uint32_t dataSize = 3;  // data的长度

    // reliable 和 ordered 目前需要一致，这里以需要保证消息按发送顺序到达为例
    trtcCloud->sendCustomCmdMsg(cmdID, data, dataSize, true, true);
}

// 发送自定义消息的示例代码
private void sendHello()
{
    // 自定义消息命令字, 这里需要根据业务定制一套规则，这里以0x1代表发送文字广播消息为例

    uint cmdID = 0x1;
    byte[] data = { '1', '2', '3' };
    uint dataSize = 3;  // data的长度

    // reliable 和 ordered 目前需要一致，这里以需要保证消息按发送顺序到达为例
    mTRTCCloud.sendCustomCmdMsg(cmdID, data, dataSize, true, true);
}

// send custom message
trtc.sendCustomMessage({
  cmdId: 1,
  data: new TextEncoder().encode('hello').buffer
});

//发送自定义消息的示例代码
sendHello() {
  try {
    // 自定义消息命令字, 这里需要根据业务定制一套规则，这里以0x1代表发送文字广播消息为例
    int cmdID = 0x1;
    String hello = "Hello";
    // reliable 和 ordered 目前需要一致，这里以需要保证消息按发送顺序到达为例
    trtcCloud.sendCustomCmdMsg(cmdID, hello, true, true);
  } catch (e) {
    print(e);
  }
}

//继承 TRTCCloudListener，实现 onRecvCustomCmdMsg 方法接收和处理房间内其他人发送的消息
public void onRecvCustomCmdMsg(String userId, int cmdId, int seq, byte[] message) {
    // 接收到 userId 发送的消息
    switch (cmdId)  // 发送方和接收方协商好的cmdId
    {
    case 0:
        // 处理cmdId = 0消息
        break;
    case 1:
        // 处理cmdId = 1消息
        break;
    case 2:
        // 处理cmdId = 2消息
        break;
    default:
        break;

}

// 接收和处理房间内其他人发送的消息
void TRTCCloudCallbackImpl::onRecvCustomCmdMsg(
                            const char* userId, int32_t cmdId, uint32_t seq, const uint8_t* msg, uint32_t msgSize)
{
    // 接收到 userId 发送的消息
    switch (cmdId)  // 发送方和接收方协商好的cmdId
    {
    case 0:
        // 处理cmdId = 0消息
        break;
    case 1:
        // 处理cmdId = 1消息
        break;
    case 2:
        // 处理cmdId = 2消息
        break;
    default:
        break;
    }
}

// 接收和处理房间内其他人发送的消息
public void onRecvCustomCmdMsg(string userId, int cmdId, uint seq, byte[] msg, uint msgSize)
{
    // 接收到 userId 发送的消息
    switch (cmdId)  // 发送方和接收方协商好的cmdId
    {
    case 0:
        // 处理cmdId = 0消息
        break;
    case 1:
        // 处理cmdId = 1消息
        break;
    case 2:
        // 处理cmdId = 2消息
        break;
    default:
        break;
    }
}

// receive custom message
trtc.on(TRTC.EVENT.CUSTOM_MESSAGE, event => {
   // event.userId: 远端发消息的 userId
   // event.cmdId: 您自定义的消息 Id
   // event.seq: 消息的序号
   // event.data: 消息内容，ArrayBuffer 类型
   console.log(`received custom msg from ${event.userId}, message: ${new TextDecoder().decode(event.data)}`)
})

// 注册trtc回调
trtcCloud.registerListener(_onRtcListener);

// 实现 onRecvCustomCmdMsg 方法接收和处理房间内其他人发送的消息
_onRtcListener(type, param) async {
  if (type == TRTCCloudListener.onRecvCustomCmdMsg) {
    // 接收到 userId 发送的消息
    String userId = param['userId'];
    // 发送方和接收方协商好的cmdId
    switch (param['cmdID']) {
      case 0:
      // 处理 cmdID = 0 消息
        break;
      case 1:
      // 处理 cmdID = 1 消息
        break;
      case 2:
      // 处理 cmdID = 2 消息
        break;
      default:
        break;
    }
  }
}