接收消息
监听在线、离线与仅在线消息事件,并按 clientMsgID 合并到会话。
消息页通常同时处理实时推送的新消息、应用进入后台后到达的消息、只在线投递的消息,以及首次进入会话时主动读取的历史消息。消息到达通过 CbEvents 进入应用状态;历史列表通过 getAdvancedHistoryMessageList() 按 conversationID 分页读取。
在同一个 SDK 实例上注册事件处理器,并在组件卸载、退出登录或切换账号前用同一个函数引用调用 off(),避免同一批消息被重复合并。
消息类型
CbEvents.OnRecvNewMessages 返回的是 MessageItem[]。每条消息可根据内容元素或消息类型选择对应的渲染方式,例如文本、自定义消息、@ 文本、图片、音频、视频和文件。
function renderMessage(message: MessageItem) {
if (message.textElem) {
return renderTextMessage(message);
}
if (message.atTextElem) {
return renderMentionMessage(message);
}
if (message.customElem) {
return renderCustomMessage(message);
}
if (message.pictureElem || message.soundElem || message.videoElem || message.fileElem) {
return renderFileLikeMessage(message);
}
return renderUnsupportedMessage(message);
}消息事件可能包含当前用户没有打开的会话。MessageItem 不直接提供 conversationID;应根据 sessionType、sendID、recvID 和 groupID 计算或查出目标会话,再按 clientMsgID 去重。
function messagesForCurrentConversation(messages: MessageItem[]) {
return messages.filter(
(message) => getConversationIDForMessage(message) === conversationID
);
}图片、音频、视频和文件消息
WASM SDK 使用不同的消息元素表示图片、音频、视频和普通文件。接收端无需重新上传文件,只需读取消息中已有的文件地址、大小、名称、时长或快照图等字段,并按界面规则展示。
如果产品需要一次发送多个文件,常见实现是连续发送多条文件消息,或发送一条自定义消息承载文件组数据。接收端仍应以每条 MessageItem 的 clientMsgID 作为渲染和状态更新的稳定标识。
事件处理器
CbEvents.OnRecvNewMessages 是聊天页面最常用的新消息事件。处理器中把当前会话的消息合并到列表,并根据用户滚动位置决定是否自动滚到底部。
function handleNewMessages({ data }: { data: MessageItem[] }) {
const messages = messagesForCurrentConversation(data);
if (messages.length === 0) {
return;
}
mergeMessagesByClientMsgID(messages);
scrollToLatestMessageIfNeeded();
}
openimsdk.on(CbEvents.OnRecvNewMessages, handleNewMessages);应用通过 setAppBackgroundStatus(true) 进入后台后,新到达的消息一般会走 CbEvents.OnRecvOfflineNewMessages,而不是前台常用的 OnRecvNewMessages。回到前台时应再调用 setAppBackgroundStatus(false)。处理方式与实时新消息相同:筛选当前会话、按 clientMsgID 去重,并保持时间顺序。前后台状态调用见认证与管理登录会话。
function handleOfflineMessages({ data }: { data: MessageItem[] }) {
mergeMessagesByClientMsgID(messagesForCurrentConversation(data));
}
openimsdk.on(CbEvents.OnRecvOfflineNewMessages, handleOfflineMessages);发送方在 sendMessage() 或 sendMessageNotOss() 中把 isOnlineOnly 设为 true 时,接收端通过 CbEvents.OnRecvOnlineOnlyMessages 收到这类只在线投递的消息。它们不会写入 SDK 本地消息存储,也不能通过历史消息接口回放,通常只适合临时提示或业务通知;是否展示在当前界面由产品规则决定。发送参数见发送消息。
function handleOnlineOnlyMessages({ data }: { data: MessageItem[] }) {
handleTransientMessages(messagesForCurrentConversation(data));
}
openimsdk.on(CbEvents.OnRecvOnlineOnlyMessages, handleOnlineOnlyMessages);
function removeMessageListeners() {
openimsdk.off(CbEvents.OnRecvNewMessages, handleNewMessages);
openimsdk.off(CbEvents.OnRecvOfflineNewMessages, handleOfflineMessages);
openimsdk.off(CbEvents.OnRecvOnlineOnlyMessages, handleOnlineOnlyMessages);
}SDK 同时导出单条事件 OnRecvNewMessage、OnRecvOfflineNewMessage 和 OnRecvOnlineOnlyMessage。新代码优先使用返回 MessageItem[] 的复数事件,便于统一批量合并。维护旧项目时,如果当前部署只触发单条事件,应把 data 包装成数组,再复用相同的去重流程;不要同时监听单数和复数事件名称,以免重复插入消息。
本页是这六个消息接收事件的归属页。上方示例使用三个复数事件;它们的 data 均为 MessageItem[],先根据消息路由字段确定目标会话,再使用“目标会话 + clientMsgID”幂等合并。组件卸载、退出登录或切换账号时调用 removeMessageListeners()。
当会话成员撤回消息时,接收端通过 CbEvents.OnNewRecvMessageRevoked 得到更新。建议把对应气泡更新为撤回态,而不是直接从列表中删除;事件处理器和清理方式见撤回消息。
首次进入会话时读取历史
事件只负责推送新到达的消息。首次进入会话、向上翻页或需要补齐断线期间的列表时,应另外读取历史快照。分页参数、调用示例和 AdvancedGetMessageResult 结构见加载历史消息。
历史查询不会触发新消息事件;事件和分页结果可能包含同一条消息,因此两条路径都必须使用相同的 clientMsgID 去重规则。
将群聊会话标记为已读
用户进入群聊并看到最新消息后,可以清理该会话的未读数。这个操作处理的是会话未读数,不等同于群消息成员级已读回执;调用方式和状态同步见标记会话已读。
会话列表和总未读角标分别通过获取会话列表和维护总未读数中的事件处理器做最终同步。
如果事件注册在全局消息状态层,不要在每次进入同一个群聊页面时重复注册全局处理器。需要显示当前会话的历史快照时,再读取边界历史;重新登录后的消息变化由事件同步,不要把事件到达视为某次历史查询或已读调用的完成回调。
验证接收流程
- 在另一个已登录账号中向目标
groupID发送消息,确认当前浏览器通过CbEvents.OnRecvNewMessages收到消息。 - 确认回调使用当前群聊的
conversationID过滤消息,并且列表按clientMsgID去重后只渲染一次。 - 调用
setAppBackgroundStatus(true)后,再由另一端发送消息,确认当前端通过CbEvents.OnRecvOfflineNewMessages收到;回到前台后调用setAppBackgroundStatus(false)。 - 发送方将
isOnlineOnly设为true后,确认接收端通过CbEvents.OnRecvOnlineOnlyMessages收到,且该消息不会进入本地消息存储或历史列表。 - 撤回一条群消息,确认接收端通过
CbEvents.OnNewRecvMessageRevoked把对应clientMsgID更新为撤回态。 - 进入群聊后调用
markConversationMessageAsRead(conversationID),确认会话未读数和总未读角标随事件更新。
相关页面
这个页面有帮助吗?