管理消息话题

大约 6 分钟

管理消息话题

消息话题是群组成员的子集，是支持多人沟通的即时通讯系统。使用消息话题功能前，你需要联系商务开通。

本文介绍如何使用环信即时通讯 IM SDK 在实时互动 app 中创建和管理消息话题，并实现消息话题相关功能。

技术原理

环信即时通讯 IM Windows SDK 提供 IChatThreadManager、ChatThread、ChatThreadEvent 和 IChatThreadManagerDelegate 类，用于管理消息话题，支持你通过调用 API 在项目中实现如下功能：

创建、解散消息话题
加入、退出消息话题
消息话题踢人
修改消息话题名称
获取消息话题详情
获取消息话题成员列表
获取消息话题列表
批量获取消息话题中的最新消息
监听消息话题事件

前提条件

开始前，请确保满足以下条件：

完成 1.0.5 或以上版本 SDK 初始化，详见快速开始。
了解环信即时通讯 IM API 的使用限制。
了解消息话题和消息话题成员数量限制，详见使用限制。
已联系商务开通消息话题功能。

实现方法

本节介绍如何使用环信即时通讯 IM Windows SDK 提供的 API 实现上述功能。

创建消息话题

所有群成员均可以调用 CreateThread 方法，基于一条群组消息新建消息话题。

单设备登录时，消息话题所属群组的所有成员均会收到 IChatThreadManagerDelegate#OnCreateThread 回调；多设备登录时，其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_CREATE。

示例代码如下：

SDKClient.Instance.ThreadManager.CreateThread(threadName, msgId, groupid, new ValueCallBack<ChatThread>(
    onSuccess: (thread) =>
    {
        DebugLog($"CreateThread success");
        if (null != thread)
        {
            //处理返回的消息话题对象
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"CreateThread failed, code:{code}, desc:{desc}");
    }
));

解散消息话题

仅消息话题所在群组的群主和群管理员可以调用 DestroyThread 方法解散消息话题。

单设备登录时，消息话题所属群组的所有成员均会收到 IChatThreadManagerDelegate#onThreadNotifyChange 回调；多设备登录时，其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_DESTROY。

提示

解散消息话题或解散消息话题所在的群组后，将删除本地数据库及内存中关于该消息话题的全部数据，需谨慎操作。

示例代码如下：

SDKClient.Instance.ThreadManager.DestroyThread(tid, new CallBack(
    onSuccess: () =>
    {
        Debug.Log($"DestroyThread success");
    },
    onError: (code, desc) =>
    {
        Debug.Log($"DestroyThread failed, code:{code}, desc:{desc}");
    }
));

加入消息话题

消息话题所在群组的所有成员均可以调用 JoinThread 方法加入群组。

加入消息话题的具体步骤如下：

收到 IChatThreadManagerDelegate#OnCreateThread 回调或 IChatThreadManagerDelegate#onThreadNotifyChange 回调，或调用 FetchThreadListOfGroup 方法从服务器获取指定群组的消息话题列表，从中获取到想要加入的消息话题 ID。
调用 JoinThread 传入消息话题 ID 加入对应消息话题。

多设备登录时，其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_JOIN。

示例代码如下：

SDKClient.Instance.ThreadManager.JoinThread(tid, new ValueCallBack<ChatThread>(
    onSuccess: (thread) =>
    {
        Debug.Log($"JoinThread success");
        if (null != thread)
        {
           //处理返回 thread 对象
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"JoinThread failed, code:{code}, desc:{desc}");
    }
));

退出消息话题

消息话题成员均可以主动调用 LeaveThread 方法退出消息话题，退出消息话题后，该成员将不会再收到消息话题中的消息。

多设备登录时，其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_LEAVE。

示例代码如下：

SDKClient.Instance.ThreadManager.LeaveThread(tid, new CallBack(
    onSuccess: () =>
    {
        Debug.Log($"LeaveThread success");
    },
    onError: (code, desc) =>
    {
        Debug.Log($"LeaveThread failed, code:{code}, desc:{desc}");
    }
));

从消息话题移出成员

仅群主和群管理员可以调用 RemoveThreadMember 方法将指定成员 (群管理员或普通成员) 踢出消息话题，被踢出消息话题的成员将不再接收到消息话题中的消息。

被踢出消息话题的成员会收到 IChatThreadManagerDelegate#OnUserKickOutOfChatThread 回调。多设备登录时，执行踢人操作的成员的其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_KICK。

示例代码如下：

SDKClient.Instance.ThreadManager.RemoveThreadMember(tid, uname, new CallBack(
    onSuccess: () =>
    {
        Debug.Log($"RemoveThreadMember success");
    },
    onError: (code, desc) =>
    {
        Debug.Log($"RemoveThreadMember failed, code:{code}, desc:{desc}");
    }
));

修改消息话题名称

仅群主和群管理员以及消息话题的创建者可以调用 ChangeThreadSubject 方法修改消息话题名称。

单设备登录时，消息话题所属群组的所有成员会收到 IChatThreadManagerDelegate#OnChatThreadUpdate 回调；多设备登录时，其他设备会同时收到 IMultiDeviceDelegate#onThreadMultiDevicesEvent 回调，回调事件为 THREAD_UPDATE。

示例代码如下：

SDKClient.Instance.ThreadManager.ChangeThreadSubject(tid, subject, new CallBack(
    onSuccess: () =>
    {
        Debug.Log($"ChangeThreadSubject success");
    },
    onError: (code, desc) =>
    {
        Debug.Log($"ChangeThreadSubject failed, code:{code}, desc:{desc}");
    }
));

获取消息话题详情

消息话题所属群组的所有成员均可以调用 GetThreadDetail 方法从服务器获取消息话题详情。

示例代码如下：

SDKClient.Instance.ThreadManager.GetThreadDetail(tid, new ValueCallBack<ChatThread>(
    onSuccess: (thread) =>
    {
        Debug.Log($"GetThreadDetail success");
        if (null != thread)
        {
            //添加消息话题处理
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"GetThreadDetail failed, code:{code}, desc:{desc}");
    }
));

获取消息话题成员列表

消息话题所属群组的所有成员均可以调用 FetchThreadMembers 方法从服务器分页获取消息话题成员列表。

SDKClient.Instance.ThreadManager.FetchThreadMembers(tid, cursor, page_size, new ValueCallBack<CursorResult<string>>(
    onSuccess: (cursor_result) =>
    {
        Debug.Log($"FetchThreadMembers success");
        if(null != cursor_result)
        {
            //处理返回的结果
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"FetchThreadMembers failed, code:{code}, desc:{desc}");
    }
));

获取消息话题列表

用户可以调用 FetchMineJoinedThreadList 方法从服务器分页获取自己加入和创建的消息话题列表：

 SDKClient.Instance.ThreadManager.FetchMineJoinedThreadList(cursor, page_size, new ValueCallBack<CursorResult<ChatThread>>(
    onSuccess: (cursor_result) =>
    {
        Debug.Log($"FetchMineJoinedThreadList success");
        if (null != cursor_result)
        {
            //处理返回的消息话题列表cursor_result.Data
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"FetchMineJoinedThreadList failed, code:{code}, desc:{desc}");
    }
));

用户还可以调用 FetchThreadListOfGroup 方法从服务器分页获取指定群组的消息话题列表：

SDKClient.Instance.ThreadManager.FetchThreadListOfGroup(tid, joined, cursor, page_size, new ValueCallBack<CursorResult<ChatThread>>(
    onSuccess: (cursor_result) =>
    {
        Debug.Log($"FetchThreadListOfGroup success");
        if (null != cursor_result)
        {
            //处理返回的消息话题列表 cursor_result.Data
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"FetchThreadListOfGroup failed, code:{code}, desc:{desc}");
    }
));

批量获取消息话题中的最新一条消息

用户可以调用 GetLastMessageAccordingThreads 方法从服务器批量获取消息话题中的最新一条消息。

示例代码如下：

SDKClient.Instance.ThreadManager.GetLastMessageAccordingThreads(threadIds, new ValueCallBack<Dictionary<string, Message>>(
    onSuccess: (dict) =>
    {
        Debug.Log($"GetLastMessageAccordingThreads success");
        foreach (var it in dict)
        {
            //遍历字典，依次处理里面的每一个最新消息
        }
    },
    onError: (code, desc) =>
    {
        Debug.Log($"GetLastMessageAccordingThreads failed, code:{code}, desc:{desc}");
    }
));

监听消息话题事件

IChatThreadManagerDelegate 类中提供消息话题事件的监听接口。开发者可以通过设置此监听，获取消息话题中的事件，并做出相应处理。如果不再使用该监听，需要移除，防止出现内存泄漏。

示例代码如下：

class ThreadManagerDelegate : IChatThreadManagerDelegate
{

    public void OnChatThreadCreate(ChatThreadEvent threadEvent)
    {
    }

    public void OnChatThreadUpdate(ChatThreadEvent threadEvent)
    {
    }

    public void OnChatThreadDestroy(ChatThreadEvent threadEvent)
    {
    }

    public void OnUserKickOutOfChatThread(ChatThreadEvent threadEvent)
    {
    }
}
// 注册监听
IChatThreadManagerDelegate threadManagerDelegate = new ThreadManagerDelegate();
SDKClient.Instance.ThreadManager.AddThreadManagerDelegate(threadManagerDelegate);

// 移除监听
SDKClient.Instance.ThreadManager.RemoveThreadManagerDelegate(threadManagerDelegate);

管理消息话题

# 管理消息话题

# 技术原理

# 前提条件

# 实现方法

# 创建消息话题

# 解散消息话题

# 加入消息话题

# 退出消息话题

# 从消息话题移出成员

# 修改消息话题名称

# 获取消息话题详情

# 获取消息话题成员列表

# 获取消息话题列表

# 批量获取消息话题中的最新一条消息

# 监听消息话题事件

管理消息话题

技术原理

前提条件

实现方法

创建消息话题

解散消息话题

加入消息话题

退出消息话题

从消息话题移出成员

修改消息话题名称

获取消息话题详情

获取消息话题成员列表

获取消息话题列表

批量获取消息话题中的最新一条消息

监听消息话题事件