即时通信 IM Android（AI 聊天机器人）

一、功能描述

核心功能包括：

1. 接收 AI 机器人的首次流式消息响应。

3. 用户中断正在生成中的流式消息。

4. 接收 AI 机器人的错误信息反馈。

所有相关消息均通过自定义消息（Custom Message） 类型传输，消息内容为特定结构的 JSON 字符串。

注意：说明：

二、1. 首次响应

用户发起问题后，AI 机器人开始生成回复。当生成出第一段有效内容时，会立即通过一条新的自定义消息发送给用户，触发 onRecvNewMessage。

三、2. 流式更新

AI 机器人持续生成内容。每当有新内容片段产生，它不会发送新消息，而是修改之前发送的那条自定义消息，会触发 onRecvMessageModified。接收方看到的是同一消息的内容在不断追加更新。

四、3. 完成标志

当 AI 机器人完成整个回复的生成，会在最后一次更新（或唯一一次消息，如果流很短）时，将消息中的 isFinished 标志置为 1。

五、4. 用户中断

用户在消息生成过程中可以主动中断。需发送一条特定格式的自定义消息到该 AI 机器人。

六、5. 错误反馈

如果 AI 机器人在处理请求或生成流式消息过程中发生错误，会通过 onRecvNewMessage ，发送给用户一条特定格式的错误消息 。

七、步骤1：创建机器人

集成 AI 聊天机器人组件之前，请先在控制台 创建机器人。

八、步骤2：添加机器人好友

使用 RestAPI 添加上一步创建的机器人为好友。

注意：为避免你的 AI 资源被恶意消耗，现只支持使用 REST API 添加机器人好友，用户无法主动添加 AI 机器人为好友。

九、步骤3：向机器人发送文本消息

注意：说明：

注意：RBT_ID 为上一步添加的机器人好友的 ID；Text 为向机器人发送的文本内容。

String msgID = V2TIMManager.getInstance().sendC2CTextMessage("Text", "RBT_ID", new V2TIMValueCallback<V2TIMMessage>() { @Override public void onSuccess(V2TIMMessage message) { } @Override public void onError(int code, String desc) { }});

十、监听回调

向 IMSDK 注册 onRecvNewMessage 和 onRecvMessageModified 回调监听器。

V2TIMManager.getMessageManager().addAdvancedMsgListener(new V2TIMAdvancedMsgListener() { @Override public void onRecvNewMessage(V2TIMMessage msg) { String jsonString = new String(v2TIMMessage.getCustomElem().getData()); } @Override public void onRecvMessageModified(V2TIMMessage msg) { String jsonString = new String(v2TIMMessage.getCustomElem().getData()); }});

十一、处理消息

当你收到 onRecvNewMessage（首次）或 onRecvMessageModified（后续更新）回调，且消息来自 AI 机器人时，其自定义消息体结构（jsonString）如下：

{ "chatbotPlugin": 2, "src": 2, "chunks": [ "Hello", ], "isFinished": 0}

十二、步骤5：发送给 AI 的中断消息

当用户想要中断一个正在生成中的 AI 流式回复时，用户客户端需要向该 AI 机器人主动发送一条自定义消息，自定义消息中携带想要中断的 AI 流式消息的 msgKey。

生成 msgKey

public static String generateMsgKey(V2TIMMessage message) { return message.getSeq() + "_" + message.getRandom() + "_" + message.getTimestamp();}

V2TIMMessage message = V2TIMManager.getMessageManager().createCustomMessage(jsonString.getBytes(StandardCharsets.UTF_8));message.setExcludedFromLastMessage(true);message.setExcludedFromUnreadCount(true);V2TIMManager.getMessageManager().sendMessage(message, userID, groupID, V2TIMMessage.V2TIM_PRIORITY_DEFAULT, true, null, new V2TIMSendCallback<V2TIMMessage>() { @Override public void onProgress(int progress) {} @Override public void onSuccess(V2TIMMessage v2TIMMessage) { } @Override public void onError(int code, String desc) { } });

自定义消息体（jsonString）结构如下：

{ "chatbotPlugin": 2, "src": 22, "msgKey": "xxx"}

十三、步骤6：接收到 AI 报错消息

当AI机器人在处理请求或生成流式消息过程中遇到错误时，会发送一条错误消息，此时你会收到 onRecvNewMessage 回调。

V2TIMManager.getMessageManager().addAdvancedMsgListener(new V2TIMAdvancedMsgListener() { @Override public void onRecvNewMessage(V2TIMMessage msg) { String jsonString = new String(v2TIMMessage.getCustomElem().getData()); }});

自定义消息体（jsonString）结构如下：

{ "chatbotPlugin": 2, "src": 23, "errorInfo": "xxxxxxxxxxx"}