IM 即时通讯
Android
产品介绍
简介
产品优势
主要功能
功能介绍
帐号集成与登录
群组功能
聊天室功能
聊天室标签功能
圈组功能
多端登录与互踢策略
质量数据监控台
海外数据中心
IM平滑迁移方案
接口及业务限制
更新日志
IM UIKit 更新日志
NIM SDK 开发版更新日志
NIM SDK 稳定版更新日志
体验 Demo
下载 SDK 与 Demo 源码
快速开始
跑通 IM Demo 源码
实现单聊消息收发(不含 UI)
跑通圈组 Demo 源码
实现圈组消息收发(不含 UI)
含 UI 集成
什么是 IM UIKit
IM UIKit 功能概览
快速集成 IM UIKit
组件导入
初始化
界面跳转
自定义用户信息
全局配置
会话列表相关
集成会话列表界面
会话列表事件监听
自定义会话列表界面 UI
会话列表 API 概览
会话消息相关
集成会话界面
会话界面事件监听
实现音视频通话
实现地理位置消息功能(含 UI)
实现自定义消息发送(含 UI)
自定义会话界面 UI
会话消息 API 概览
通讯录相关
集成通讯录界面
自定义通讯录界面 UI
通讯录界面事件监听
通讯录 API 概览
IM UIKit 常见问题排查
IM UIKit API 概览
不含 UI 集成
集成 SDK
初始化
登录相关
登录 IM
多端登录与互踢
登出 IM
消息相关
消息概述
消息收发
自定义消息收发
消息配置选项
NOS 存储场景
广播消息收发
消息已读回执
消息撤回
消息重发与转发
消息更新
消息过滤
语音消息处理
插入本地消息
历史消息
最近会话
服务端会话服务
用户资料
用户关系
在线状态订阅
系统通知
系统通知概述
内置系统通知管理
内置系统通知未读数
自定义系统通知收发
Android 离线推送
实现离线推送
配置消息的推送属性
设置群消息强制推送
设置推送全局免打扰
设置多端推送策略
集成小米推送
集成华为推送
集成荣耀推送
集成 OPPO 推送
集成 vivo 推送
集成魅族推送
集成谷歌推送(FCM)
消息提醒
实现消息提醒
配置消息提醒功能
设置群消息强制提醒
设置消息提醒文案
定制通知栏显示信息
群组功能
群组概述
群组管理
群成员管理
群消息管理
超大群功能
聊天室
圈组功能
圈组概述
登录管理
服务器相关
服务器概述
服务器管理
服务器成员管理
游客功能
服务器未读数管理
频道相关
频道概述
频道管理
频道黑白名单
实时互动频道
频道分组
频道分组黑白名单
频道未读数管理
搜索服务器和频道
身份组相关
身份组概述
身份组应用场景
服务器身份组
频道身份组
用户定制权限
频道分组身份组
自定义权限项
成员权限查询与判定
身份组相关查询
圈组订阅机制
圈组消息相关
图解圈组消息流转
圈组消息收发
圈组消息撤回
圈组消息更新
圈组消息删除
消息正在输入
会话消息回复(Thread)
圈组快捷评论
获取频道最后一条消息
查询历史消息
查询@我的消息
圈组消息缓存
圈组消息搜索
圈组系统通知相关
圈组系统通知概述
圈组系统通知收发
圈组系统通知更新
圈组离线推送
圈组内容审核
圈组相关抄送
圈组第三方回调
圈组各端接口命名差异
反垃圾
聊天扩展
其他
最佳实践
IM 登录最佳实践
IM 应用隐私合规
聊天室重要消息投递
API 参考
Android SDK API
Android SDK 状态码
IM 控制台指南
创建应用
注册 IM 账号
升级服务
开通聊天室功能
配置应用客户端标识
常见问题
FAQ
错题集
Android 端推送问题排查
第三方推送厂商的限制说明
服务协议

圈组消息收发

更新时间: 2023/03/08 20:03:52

NIM SDK 的QChatMessageService接口提供圈组消息收发的方法,支持支持文本、图片、语音、视频、文件、地理位置和自定义等消息类型。定义圈组消息的结构体为QchatMessage

功能介绍

消息类型
API关键字
说明
文本消息 text 消息内容为普通文本
图片消息 image 消息内容为图片 URL 地址、尺寸、图片大小等信息
语音消息 audio 消息内容为语音文件的 URL 地址、时长、大小、格式等信息
视频消息 video 消息内容为视频文件的 URL 地址、时长、大小、格式等信息
文件消息 file 消息内容为文件的 URL 地址、大小、格式等信息
位置消息 location 消息内容为地理位置标题、经度、纬度信息
提示消息 tip 又叫做 Tip 消息,没有推送和通知栏提醒,主要用于会话内的通知提醒,例如进入会话时出现的欢迎消息,或是会话过程中命中敏感词后的提示消息等场景
通知消息 notification 主要用于圈组的事件通知
自定义消息 custom 开发者自定义的消息类型,例如红包消息、石头剪子布等形式的消息

技术原理

下图展示了集成并初始化 NIM SDK 后,实现圈组消息收发的基本工作流。图中的 QChat 即为 NIM SDK 的圈组组件,云信服务端包含 IM 服务端和圈组服务端。

圈组消息收发原理.png

  • 上图仅以静态 Token 登录为例展示消息收发流程。网易云信 IM 还支持动态 Token 登录鉴权和第三方回调登录鉴权,相关详情请参见登录鉴权
  • 圈组服务端圈组服务器是两个不同概念,前者指云信服务器内提供圈组功能的服务端,后者为圈组的特殊概念,对应 Discord 的 Server, 为社群本身。

上图中的流程可归纳为如下 5 步:

  1. 账号集成与登录。
    1. 开发者将应用的用户账号传入云信 IM 服务端,注册云信 IM 账号。
    2. 云信 IM 服务端返回 Token 给应用服务端。
    3. 应用客户端登录应用服务端。
    4. 应用服务端将 Token 返回给应用客户端。
    5. 用户A 和用户B 带 Token 登录云信 IM 服务端。
    6. 用户A 和用户B 登录云信圈组服务端,此时无需再传入 Token 等参数。
  2. 用户A 创建圈组服务器,并在服务器内创建频道。
  3. 用户B 加入圈组服务器。
  4. 用户A 在频道发送一条消息到云信圈组服务端。
  5. 云信圈组服务端投递消息至频道,用户B 接收消息。

前提条件

  • 已开通圈组功能。如未开通,可通过云信官网首页提供的在线聊天、电话等方式联系商务经理开通。
  • 已完成圈组初始化。

如果频道所属的服务器的成员人数超过 2000 人阈值,接收方还必须先订阅该频道,才能收到该频道的消息。如果未超过 2000 人阈值,无需订阅也能收到消息。订阅相关说明,请参见圈组订阅机制

实现消息收发

API 调用时序

以下时序图可能因网络问题而显示异常。如显示异常,一般刷新当前页面即可正常显示。

uml diagram

具体流程

本节仅对上图中标为橙色的流程进行说明,其他流程请参考相关文档。例如:


  1. 发送方在登录圈组前,注册observeMessageStatusChange消息状态变化观察者,监听圈组消息状态(MsgStatusEnum)和消息附件传输状态(AttachStatusEnum)的变化。

    如果发送的是多媒体消息(包括图片、语音、视频和文件消息),还需注册observeAttachmentProgress消息附件上传/下载进度观察者。


    示例代码如下:

    注册消息状态变化观察者
    NIMClient.getService(QChatServiceObserver.class).observeMessageStatusChange(new Observer<QChatMessage>() {
        @Override
        public void onEvent(QChatMessage qChatMessage) {
            //收到状态变化的消息qChatMessage
            
        }
    }, true);
    
    注册消息附件上传/下载进度观察者
    NIMClient.getService(QChatServiceObserver.class).observeAttachmentProgress(new Observer<AttachmentProgress>() {
        @Override
        public void onEvent(AttachmentProgress attachmentProgress) {
            //消息uuid
            String uuid = attachmentProgress.getUuid();
            //已传输字节数
            long transferred = attachmentProgress.getTransferred();
            //文件总大小
            long total = attachmentProgress.getTotal();
    
        }
    },true);
    
  2. 接收方在登录圈组前,注册observeReceiveMessage消息接收观察者,监听圈组消息接收。

    示例代码如下:

    NIMClient.getService(QChatServiceObserver.class).observeReceiveMessage(new Observer<List<QChatMessage>>() {
        @Override
        public void onEvent(List<QChatMessage> qChatMessages) {
            //收到消息qChatMessages
            for (QChatMessage qChatMessage : qChatMessages) {
                //处理消息
            }
        }
    }, true);
    
  3. 发送方调用sendMessage方法发送消息,调用时通过getTypeMsgTypeEnum枚举设置消息的类型。

    消息发送方需要拥有发送消息的权限(SEND_MSG)。


    QChatSendMessageParam为该方法的入参结构,必须传入ServerIdChannelId和消息类型。

    QChatSendMessageParam的部分重要方法说明如下:

    返回值
    方法 说明
    void setAntiSpamOption 配置安全通(易盾反垃圾)相关的各项参数。如果您配置了这些参数,在发送消息时,会对发送的文本和附件进行内容审核(反垃圾检测)。根据您在控制台预设的拦截/过滤规则,如果检测到违规内容,消息可能发送失败或者敏感信息被过滤。 圈组的安全通功能属于增值功能,需要在开通圈组功能后再额外开通。如尚未开通,请通过云信官网首页提供的联系方式咨询商务经理开通。更多相关说明请参见圈组内容审核
    void setMentionedAccidList(List<String> mentionedAccidList) @部分人,如果将该消息设置为@所有人或者@身份组,则本参数无效)用户需要拥有@某个人权限(REMIND_OTHER)才能@部分人。
    void setMentionedAll(boolean mentionedAll) 设置是否@所有人 用户需要拥有@所有人权限(REMIND_EVERYONE)才能@所有人
    void setMentionRoleidList(List<String> mentionRoleidList) @身份组,最多@ 10 个身份组。如果将该消息设置为@所有人,则本参数无效 用户需要拥有@身份组权限(MENTIONED_ROLE)才能@身份组。
    void setHistoryEnable(boolean historyEnable) 设置是否消息是否存储云端历史
    void setNeedBadge(boolean needBadge) 设置是否需要消息计数
    QChatMessage toQChatMessage QChatSendMessageParam转换成QChatMessage。如果需要在发送消息前提前构造一个QChatMessage,可以通过该方法构造。

    发送各类型消息的示例代码如下:

    文本
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L, MsgTypeEnum.text);
    param.setBody("测试消息");
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    param.setPushPayload(getPushPayload());
    param.setPushContent("测试推送消息");
    param.setMentionedAccidList(mentionedAccidList);
    param.setPushEnable(true);
    param.setNeedBadge(true);
    param.setNeedPushNick(true);
    //通过QChatSendMessageParam构造一个QChatMessage
    QChatMessage currentMessage = param.toQChatMessage();
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    图片
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.image);
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    param.setPushPayload(getPushPayload());
    param.setPushContent("测试图片消息");
    param.setMentionedAccidList(mentionedAccidList);
    param.setPushEnable(true);
    param.setNeedBadge(true);
    param.setNeedPushNick(true);
    //创建图片附件
    File file = getImageFile();
    final ImageAttachment attachment = new ImageAttachment();
    attachment.setPath(file.getPath());
    attachment.setSize(file.length());
    int[] dimension = BitmapDecoder.decodeBound(file);
    attachment.setWidth(dimension[0]);
    attachment.setHeight(dimension[1]);
    attachment.setDisplayName(file.getName());
    attachment.setExtension(StringUtil.getExtension(file.getName()));
    //设置图片附件
    param.setAttachment(attachment);
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    语音
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.audio);
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    param.setPushPayload(getPushPayload());
    param.setPushContent("测试语音消息");
    param.setMentionedAccidList(mentionedAccidList);
    param.setPushEnable(true);
    param.setNeedBadge(true);
    param.setNeedPushNick(true);
    //创建音频附件
    File file = getAudioFile();
    long duration = getAudioDuration();
    final AudioAttachment attachment = new AudioAttachment();
    attachment.setPath(file.getPath());
    attachment.setSize(file.length());
    if (duration > 0 && duration < 1000) {// 最低显示1秒
        duration = 1000;
    }
    attachment.setDuration(duration);// ms
    attachment.setExtension(StringUtil.getExtension(file.getName()));
    //设置附件
    param.setAttachment(attachment);
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    视频
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.video);
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    param.setPushPayload(getPushPayload());
    param.setPushContent("测试视频消息");
    param.setMentionedAccidList(mentionedAccidList);
    param.setPushEnable(true);
    param.setNeedBadge(true);
    param.setNeedPushNick(true);
    //创建视频附件
    File file = getVideoFile();
    MediaPlayer mediaPlayer = null;
    try {
        mediaPlayer = MediaPlayer.create(context, Uri.fromFile(file));
    } catch (Exception e) {
        e.printStackTrace();
    }
    long duration = mediaPlayer == null ? 0 : mediaPlayer.getDuration();
    int height = mediaPlayer == null ? 0 : mediaPlayer.getVideoHeight();
    int width = mediaPlayer == null ? 0 : mediaPlayer.getVideoWidth();
    final VideoAttachment attachment = new VideoAttachment();
    attachment.setPath(file.getPath());
    attachment.setSize(file.length());
    attachment.setDuration(duration);
    attachment.setWidth(width);
    attachment.setHeight(height);
    attachment.setDisplayName(file.getName());
    attachment.setExtension(StringUtil.getExtension(file.getName()));
    //设置附件
    param.setAttachment(attachment);
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    文件
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.file);
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    param.setPushPayload(getPushPayload());
    param.setPushContent("测试语音消息");
    param.setMentionedAccidList(mentionedAccidList);
    param.setPushEnable(true);
    param.setNeedBadge(true);
    param.setNeedPushNick(true);
    //创建文件附件
    File file = getFile();
    final FileAttachment attachment = new FileAttachment();
    attachment.setPath(file.getPath());
    attachment.setSize(file.length());
    attachment.setDisplayName(file.getName());
    attachment.setExtension(StringUtil.getExtension(file.getName()));
    //设置附件
    param.setAttachment(attachment);
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    提示
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.tip);
    param.setBody("测试提示消息");
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
    自定义
    QChatSendMessageParam param = new QChatSendMessageParam(943445L,885305L,MsgTypeEnum.custom);
    param.setBody("测试自定义消息");
    param.setMentionedAll(false);
    param.setHistoryEnable(true);
    param.setExtension(getExtension());
    //自定义消息附件,非必须
    MsgAttachment customAttachment = getCustomAttachment();
    param.setAttachment(customAttachment);
    
    NIMClient.getService(QChatMessageService.class).sendMessage(param).setCallback(new RequestCallback<QChatSendMessageResult>() {
        @Override
        public void onSuccess(QChatSendMessageResult result) {
            //发送消息成功,返回发送成功的消息具体信息
            QChatMessage message = result.getSentMessage();
        }
    
        @Override
        public void onFailed(int code) {
            //发送消息失败,返回错误code
        }
    
        @Override
        public void onException(Throwable exception) {
            //发送消息异常
        }
    });
    
  4. 消息接收观察者的回调函数触发,接收方通过回调收到消息。

  5. 接收方调用markMessageRead方法将接收到的消息标记为已读。

    • 将消息标记为已读后,该消息之前接收到的消息全部变为已读状态。
    • 如果传入的时间戳参数为 0,则频道内所有消息将被标记为未读。
    • 该方法调用存在频控,300ms 内最多可调用一次。

    示例代码如下:

    NIMClient.getService(QChatMessageService.class).markMessageRead(new QChatMarkMessageReadParam(943445L,885305L,currentMessage.getTime())).setCallback(
            new RequestCallback<Void>() {
                @Override
                public void onSuccess(Void param) {
                    //标记已读成功
                }
    
                @Override
                public void onFailed(int code) {
                    //标记已读失败,返回错误code
                }
    
                @Override
                public void onException(Throwable exception) {
                    //标记已读异常
                }
            });
    
  6. 如果接收方接收到的是多媒体消息,可调用downloadAttachment方法下载附件。

    下载附件会触发QChatServiceObserverobserveAttachmentProgress通知下载进度,同时触发observeMessageStatusChange通知下载状态。

    默认情况下(即 SDK 初始化时将SDKOPtions#preloadAttach设置为true,开启预加载多媒体消息附件),当 SDK 收到多媒体消息后,如果附件是图片或视频,会自动下载图片或视频的缩略图;如果附件是音频,SDK 会自动下载音频文件。如果需要下载原图或者原视频等,可调用该方法下载附件。


    示例代码如下:

    QChatMessage message = getMessage();
    //是否下载缩略图
    boolean thumb = false;
    QChatDownloadAttachmentParam param = new QChatDownloadAttachmentParam(message,thumb);
    NIMClient.getService(QChatMessageService.class).downloadAttachment(param).setCallback(new RequestCallback<Void>() {
        @Override
        public void onSuccess(Void result) {
            //下载成功
        }
    
        @Override
        public void onFailed(int code) {
            //下载失败
        }
    
        @Override
        public void onException(Throwable exception) {
            //下载异常
        }
    });
    

实现消息重发

如果因为网络等原因消息发送失败,可以调用resendMessage方法重发消息。该方法的入参QChatResendMessageParam需传入待重发的消息体(QChatMessage)。

示例代码如下:

NIMClient.getService(QChatMessageService.class).resendMessage(new QChatResendMessageParam(currentMessage)).setCallback(new RequestCallback<QChatSendMessageResult>() {
    @Override
    public void onSuccess(QChatSendMessageResult result) {
        //重发消息成功,返回发送成功的消息具体信息
        QChatMessage message = result.getSentMessage();
    }

    @Override
    public void onFailed(int code) {
        //重发消息失败,返回错误code
    }

    @Override
    public void onException(Throwable exception) {
        //重发消息异常
    }
});

相关参考

相关控制台配置

  • 每个频道上的 消息未读数 (包括@消息的未读数)默认最多显示为 99+ 。

    最大未读数可在云信控制台配置在云信控制台选择应用,进入IM 免费版/专业版 > 功能权限开通 > 拓展配置 > 圈组 > 所有未读消息(包括@)的消息计数即可配置。
  • @消息的未读数的有效期,默认为 7 天。

    可在云信控制台配置该有效期在云信控制台选择应用,进入IM 免费版/专业版 > 功能权限开通 > 拓展配置 > 圈组 > 未读的@消息数-周期即可配置。

API 参考

API
说明
observeReceiveMessage 注册/注销消息接收观察者
observeMessageStatusChange 注册/注销消息状态变化观察者
sendMessage 发送圈组消息
markMessageRead 将消息标记为已读
downloadAttachment 下载多媒体消息的附件
此文档是否对你有帮助?
有帮助
我要吐槽
  • 功能介绍
  • 技术原理
  • 前提条件
  • 实现消息收发
  • API 调用时序
  • 具体流程
  • 实现消息重发
  • 相关参考
  • 相关控制台配置
  • API 参考