IM 信令方案

// 调用 addSimpleMsgListener 设置事件监听器
V2TIMManager.getInstance().addSimpleMsgListener(sdkListener);

/**
 * 接收单聊自定义消息
 * @param msgID 消息 ID
 * @param sender 发送方信息
 * @param customData 发送内容
 */
public void onRecvC2CCustomMessage(String msgID, V2TIMUserInfo sender, byte[] customData) {
    Log.i("onRecvC2CCustomMessage", "msgID:" + msgID + ", from:" + sender.getNickName() + ", content:" + new String(customData));
    try {
        String jsonString = new String(customData, "UTF-8");
        JSONObject jsonObject = new JSONObject(jsonString);
        System.out.println("onRecvGroupCustomMessage: " + jsonObject);
        handleMessage(jsonObject);
     } catch (UnsupportedEncodingException e) {
        System.out.println("The data is not a dictionary.");
     } catch (JSONException e) {
        System.out.println("Error parsing JSON: " + e);
     }
}

const onMessageReceived = (event) => {
  const messageList = event.data;
  messageList?.forEach((msg) => {
    if (msg.type === TencentCloudChat.TYPES.MSG_CUSTOM) {
      console.log('收到自定义消息', event);
      const { data } = msg.payload;
      try {
        const jsonData = JSON.parse(data);
        console.log(`receive custom msg from ${msg.from} data: ${data}`);
        if (jsonData.type === 10000) {
          console.log('字幕消息', jsonData);
          return;
        }
        if (jsonData.type === 10001) {
          console.log('机器人的状态', jsonData);
          return;
        }
      } catch (error) {
        console.error('receive custom msg', data, error);
      }
    }
  });
}

// 监听消息
chat.on(TencentCloudChat.EVENT.MESSAGE_RECEIVED, onMessageReceived);

public void interruptAi() {
    long timestamp = System.currentTimeMillis();
    Map<String, Object> payload = new HashMap<>();
    payload.put("id", userId + "_" + roomId + "_" + timestamp); // 消息id，可以使用uuid，排查问题使用
    payload.put("timestamp", timestamp); // 时间戳，排查问题使用
    payload.put("taskid", aiTaskId);

    Map<String, Object> content = new HashMap<>();
    content.put("type", 20001);
    content.put("sender", userId);
    content.put("receiver", Collections.singletonList(botId));
    content.put("payload", payload);

    String contentString = new JSONObject(content).toString();

    Map<String, Object> dataDict = new HashMap<>();
    dataDict.put("service_command", "trtc_ai_service.SendCustomCmdMsg");
    dataDict.put("request_content", contentString);

    try {
        byte[] jsonData = new JSONObject(dataDict).toString().getBytes("UTF-8");
        V2TIMManager.getInstance().callExperimentalAPI("sendTRTCCustomData", jsonData, new V2TIMValueCallback() {
            @Override
            public void onSuccess(Object o) {
                System.out.println("sendTRTCCustomData success");
            }
            @Override
            public void onError(int code, String desc) {
                System.out.println("sendTRTCCustomData error, " + code + ", " + (desc != null ? desc : "null"));
            }
        });
    } catch (UnsupportedEncodingException e) {
        System.out.println("Error serializing dictionary to JSON: " + e);
    }
}

// 发送打断信令
chat.callExperimentalAPI('sendTRTCCustomData', {
serviceCommand: 'trtc_ai_service.SendCustomCmdMsg',
data: {
  type: 20001,
  sender: "user_a", // 发送者userid， 服务端会check该userid是否有效
  receiver: ["user_bot"], // 接受者userid列表，只需要填写机器人userid
  payload: {
    id: "uuid", // 消息id，可以使用uuid，排查问题使用
    timestamp: 123, // 时间戳，排查问题使用
    taskid: "任务的taskid",
  }
}
});