Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊

这篇具有很好参考价值的文章主要介绍了Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。


🎈 简介

在之前的文章中已经介绍了如何接入环信IM Unity SDK,及基于该SDK实现用户的登录注册功能,该篇文章介绍的是如何通过它来实现用户管理、好友系统(联系人管理)及聊天消息管理功能。

Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊
Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊

🎈 用户管理

SDK为我们提供的用户属性管理包括用户昵称头像邮箱电话性别签名生日等,除此之外,我们可以使用扩展字段Ext来管理业务层所需的其它用户属性。例如在我们的Metaverse项目中,就将用户的Avatar人物信息存储在了Ext扩展字段中,在拿到Ext字段的值后通过反序列化即可得到用户的Avatar人数信息,反之,在用户的Avatar信息发生变更时,只需序列化再存储到Ext扩展字段中并更新用户属性即可。

用户属性管理相关的接口调用封装:

/// <summary>
/// 获取用户信息
/// </summary>
/// <param name="userId">UserID</param>
/// <param name="onSuccess">获取成功回调事件</param>
/// <param name="onError">获取失败回调事件</param>
public void GetUserInfo(string userId, Action<AgoraChat.UserInfo> onSuccess, Action<int, string> onError = null)
{
    SDKClient.Instance.UserInfoManager.FetchUserInfoByUserId(new List<string>(1) { userId },
        new ValueCallBack<Dictionary<string, AgoraChat.UserInfo>>(
        onSuccess: dic =>
        {
            AgoraChat.UserInfo userInfo = dic[userId];
            Main.Log.Info("【环信IM SDK】获取用户{0}信息:{1}", userId, userInfo);
            onSuccess.Invoke(userInfo);
        },
        onError: (code, desc) =>
        {
            Main.Log.Info("【环信IM SDK】获取用户{0}信息失败:Code -{1}  Desc -{2}", userId, code, desc);
            onError?.Invoke(code, desc);
        }));
}
/// <summary>
/// 更新自身用户信息
/// </summary>
/// <param name="userInfo">用户信息</param>
/// <param name="onSuccess">更新成功回调事件</param>
/// <param name="onError">更新失败回调事件</param>
public void UpdateOwnUserInfo(AgoraChat.UserInfo userInfo, Action onSuccess, Action<int, string> onError = null)
{
    SDKClient.Instance.UserInfoManager.UpdateOwnInfo(userInfo, new CallBack(
    onSuccess: () =>
    {
        LocalUserInfo.Update(userInfo);
        Main.Log.Info("【环信IM SDK】更新自身用户信息成功:{0}", LocalUserInfo);
        onSuccess?.Invoke();
    },
    onError: (code, desc) =>
    {
        Main.Log.Info("【环信IM SDK】更新自身用户信息失败:Code -{0}  Desc -{1}", code, desc);
        onError?.Invoke(code, desc);
    }));
}

🎈 好友管理

Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊

好友功能是通过环信IM SDK提供的Contact Manager联系人管理来实现的,例如发起添加联系人请求:

/// <summary>
/// 发送添加好友请求
/// </summary>
/// <param name="userId">用户ID</param>
/// <param name="reason">原因/验证信息</param>
/// <param name="onSuccess">请求成功回调事件</param>
/// <param name="onError">请求失败回调事件</param>
public void AddContact(string userId, string reason, Action onSuccess = null, Action<int, string> onError = null)
{
    SDKClient.Instance.ContactManager.AddContact(userId, reason, new CallBack(
        onSuccess: () =>
        {
            Main.Log.Info("【Contact Manager】添加好友请求成功:UserId -{0}  Reason -{1}", userId, reason);
            onSuccess?.Invoke();
        },
        onError: (code, desc) =>
        {
            Main.Log.Info("【Contact Manager】添加好友请求失败:UserId -{0}  Reason -{1}  Code -{2}  Desc -{3}", userId, reason, code, desc);
            onError?.Invoke(code, desc);
        }));
}

请求人发起请求后,被请求人如果监听了与联系人管理相关的回调,会执行On Contact Invited回调事件,在回到事件中我们可以通过弹窗形式来让用户决定是否同意添加联系人。如何监听与联系人管理相关的回调?继承IContactManagerDelegate接口并实现,通过Add Contact Manager DelegateRemove Contact Manager Delegate来开启监听和停止监听。

namespace Metaverse
{
    public class ContactManagerDelegate : IContactManagerDelegate
    {
        /// <summary>
        /// 好友新增事件
        /// 用户B向用户A发送好友请求,用户A同意该请求,用户A收到该事件。
        /// </summary>
        /// <param name="userId">B用户ID</param>
        public void OnContactAdded(string userId)
        {
            Main.Log.Info("【环信IM SDK】新增好友{0}", userId);
        }
        /// <summary>
        /// 被删除好友事件
        /// 用户B将用户A从联系人列表上删除,用户A收到该事件。
        /// </summary>
        /// <param name="userId">B用户ID</param>
        public void OnContactDeleted(string userId)
        {
            Main.Log.Info("【环信IM SDK】被用户{0}删除好友", userId);
        }
        /// <summary>
        /// 被请求添加好友事件
        /// 用户B向用户A发送好友请求,用户A收到该事件。
        /// </summary>
        /// <param name="userId">B用户ID</param>
        /// <param name="reason">原因/验证信息</param>
        public void OnContactInvited(string userId, string reason)
        {
            Main.Log.Info("【环信IM SDK】收到用户{0}添加好友的请求:{1}", userId, reason);

            /*************************************************************
             * 收到添加好友的请求,弹出弹窗,让用户点击同意或拒绝
             * 同意就调用Main.Custom.ContactManager.AcceptAddContact
             * 拒绝就调用Main.Custom.ContactManager.DeclineAddContact
             *************************************************************/

            Main.UI.ShowOrLoadView<PopupView>(ViewLevel.POP, new PopupData("添加好友请求", string.Format("用户{0}请求添加您为好友,是否同意?", userId))
            {
                confirm = "同意",
                cancle = "拒绝",
                onConfirm = () => Main.Custom.ContactManager.AcceptAddContact(userId),
                onCancle = () => Main.Custom.ContactManager.DeclineAddContact(userId),
            });
        }
        /// <summary>
        /// 请求添加好友被对方同意事件
        /// 用户A向用户B发送好友请求,用户B收到好友请求后,同意加好友,则用户A收到该事件。
        /// </summary>
        /// <param name="userId">B用户ID</param>
        public void OnFriendRequestAccepted(string userId)
        {
            Main.Log.Info("【环信IM SDK】添加用户{0}为好友的请求被对方同意", userId);
        }
        /// <summary>
        /// 请求添加好友被对方拒绝事件
        /// 用户A向用户B发送好友请求,用户B收到好友请求后,拒绝加好友,则用户A收到该事件。
        /// </summary>
        /// <param name="userId">B用户ID</param>
        public void OnFriendRequestDeclined(string userId)
        {
            Main.Log.Info("【环信IM SDK】添加用户{0}为好友的请求被对方拒绝", userId);
        }
    }
}
  • 用户A向用户B发送好友请求,用户B同意则调用AcceptAddContact,拒绝则调用DeclineAddContact
  • 用户A向用户B发送好友请求,用户B收到好友请求后,同意加好友,则用户A收到OnFriendRequestAccepted事件;
  • 用户A向用户B发送好友请求,用户B收到好友请求后,拒绝加好友,则用户A收到OnFriendRequestDeclined事件。

🎈 聊天管理

Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊

Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊

聊天是通过环信IM SDK提供的Chat Manager实现的,会话(Conversation)分为三种,单聊群聊聊天室会话

  • 单聊是指两个用户建立的会话,双方可以在会话中收发消息。私聊基于此实现。
  • 群聊会话是由群成员发送消息所组成的,群成员可以在群会话中收发消息。我们的房间IM就是通过群里会话实现的。
  • 聊天室会话并未应用于项目中。

🔸 发送与接收消息

SDK将消息划分为多种类型,包括文本消息语音消息图片消息视频消息文件消息透传消息等,以基本的文本消息为例,消息发送的接口封装如下:

/// <summary>
/// 发送文本消息
/// </summary>
/// <param name="messageType">消息类型 Chat:单聊  Group:群聊  Room:聊天室消息</param>
/// <param name="userOrGroupId">用户或者群聊的ID</param>
/// <param name="content">文本内容</param>
/// <param name="onSuccess">发送成功回调事件</param>
/// <param name="onError">发送失败回调事件</param>
public void SendTextMessage(MessageType messageType, string userOrGroupId,
    string content, Action<Message> onSuccess = null, Action<int, string> onError = null)
{
    Message msg = Message.CreateTextSendMessage(userOrGroupId, content);
    msg.MessageType = messageType;
    SDKClient.Instance.ChatManager.SendMessage(ref msg, new CallBack(
        onSuccess: () =>
        {
            Main.Log.Info("【Chat Manager】发送文本消息成功:MessageType -{0}  UserOrGroupId -{1}  Content -{2}",
                messageType, userOrGroupId, content);
            onSuccess?.Invoke(msg);
        },
        onError: (code, desc) =>
        {
            Main.Log.Info("【Chat Manager】发送文本消息失败:MessageType -{0}  UserOrGroupId -{1}  Content -{2}  Code -{3}  Desc -{4}",
                messageType, userOrGroupId, content, code, desc);
            onError?.Invoke(code, desc);
        }));
}

当用户监听了与聊天管理相关的回调后,收到消息时会执行On Messages Received回调事件,在事件中处理我们的业务逻辑。如何监听与聊天管理相关的回调?继承IChatManagerDelegate接口并实现,通过Add Chat Manager DelegateRemove Chat Manager Delegate来开启监听和停止监听。

/// <summary>
/// 新消息接收事件
/// </summary>
/// <param name="messages">新消息列表</param>
public void OnMessagesReceived(List<Message> messages)
{
    for (int i = 0; i < messages.Count; i++)
    {
        Message msg = messages[i];
        //抛出事件
        Main.Events.Publish(MessageReceivedEventArgs.Allocate(msg));
    }
}

🔸 消息处理

接收到消息后,通过开发框架中Event事件系统将其抛出,好友视图中会订阅该事件来接收来自好友的消息,房间视图中会订阅该事件来接收来自房间内其他用户发送的消息。例如:

namespace Metaverse
{
    public class RoomPlaceView : UIView
    {
        #region >> NonPublic Variables
        [Tooltip("聊天输入框"), SerializeField] private InputField chatInputField;
        [Tooltip("聊天项预制件"), SerializeField] private Text chatItemPrefab;
        [Tooltip("聊天项列表"), SerializeField] private RectTransform chatContent;
        #endregion

        #region >> View
        protected override void OnInit(IViewData data)
        {
            base.OnInit(data);
            //订阅消息接收事件
            Main.Events.Subscribe(MessageReceivedEventArgs.EventID, OnMessageReceivedEvent);
        }
        protected override void OnUnload()
        {
            base.OnUnload();
            //取消订阅消息接收事件
            Main.Events.Unsubscribe(MessageReceivedEventArgs.EventID, OnMessageReceivedEvent);
        }
        #endregion

        #region >> UI Event
        /// <summary>
        /// 聊天发送按钮点击事件
        /// </summary>
        public void OnSendButtonClick()
        {
            //未输入任何内容 返回
            if (string.IsNullOrEmpty(chatInputField.text)) return;
            //将当前聊天框中输入的文字内容发送
            Main.Custom.ChatManager.SendTextMessage(MessageType.Group, (Main.FSM.GetMachine<GamePlace>().CurrentState as PlaceRoom).PlaceID,
                chatInputField.text, message =>
                {
                    //添加聊天项
                    AddChatItem(message);
                    //消息发送成功,将聊天框输入的内容清空
                    chatInputField.text = string.Empty;
                });
        }
        #endregion

        #region >> Subscribed Event
        //消息接收事件
        private void OnMessageReceivedEvent(EventArgs e)
        {
            if (e is MessageReceivedEventArgs mre)
            {
                //新增聊天项
                AddChatItem(mre.message, false);
            }
        }
        #endregion

        #region >> NonPublic Methods
        /**********************************************************************************
         * 添加聊天项:
         *  isFromSelf - 消息发送方是否是自己
         *  如果不是自己发送的消息 需要根据用户ID获取用户信息
         **********************************************************************************/
        private void AddChatItem(Message message, bool isFromSelf = true)
        {
            if (isFromSelf)
                Add(Main.Custom.UserManager.LocalUserInfo.NickName, (message.Body as TextBody).Text);
            else
                Main.Custom.UserManager.GetOrQuery(message.From, userInfo => Add(userInfo.NickName, (message.Body as TextBody).Text));

            void Add(string userName, string content)
            {
                /********************************************************************************
                 * 此处判断如果PlaceID不一致,不执行代码块中逻辑
                 * 因为此处逻辑的执行是在异步回调中 假如在异步期间已经退出之前的房间 
                 * 则此处会实例化会造成异常
                 ********************************************************************************/
                if ((Main.FSM.GetMachine<GamePlace>().CurrentState as PlaceRoom).PlaceID == message.To)
                {
                    //实例化
                    var instance = Instantiate(chatItemPrefab);
                    //设置父级
                    instance.transform.SetParent(chatContent.transform, false);
                    //消息内容
                    instance.text = string.Format("<color=cyan>{0}:</color>{1}", userName, content);
                    //预制件是隐藏的 实例化后显示
                    instance.gameObject.SetActive(true);
                    //一帧之后更新LayoutGroup自动布局
                    Main.Actions.Sequence(this)
                        .Frame(1)
                        .Event(() => LayoutRebuilder.ForceRebuildLayoutImmediate(chatContent))
                        .Begin();
                }
            }
        }
        #endregion
    }
}

关于会话ID:
Conversation Id,即会话ID,在单聊中它其实就是对方用户的User Id(用户ID),在群聊中它其实就是群组的Group Id(群组ID)。

消息项的对象池管理

每一条消息处理时都需要实例化一个消息项,尤其是在与不同的好友聊天时,消息项会被大量使用,因此在项目中考虑使用对象池来管理:文章来源地址https://www.toymoban.com/news/detail-478513.html

protected override void OnInit(IViewData data)
{
    base.OnInit(data);

    //订阅消息接收事件
    Main.Events.Subscribe(MessageReceivedEventArgs.EventID, OnMessageReceivedEvent);

    /********************************************
     * 初始化对象池
     * 设置创建方法
     * 设置最大缓存数量
     ********************************************/
    Main.ObjectPool.Mono.CreateBy(() =>
    {
        //实例化
        var instance = Instantiate(chatItemPrefabLocal);
        //设置父级
        instance.transform.SetParent(chatItemPrefabLocal.transform.parent, false);
        //获取组件并返回
        return instance.GetComponent<ChatItemLocal>();
    });
    Main.ObjectPool.Mono.SetMaxCacheCount<ChatItemLocal>(99);

    Main.ObjectPool.Mono.CreateBy(() =>
    {
        //实例化
        var instance = Instantiate(chatItemPrefabRemote);
        //设置父级
        instance.transform.SetParent(chatItemPrefabRemote.transform.parent, false);
        //获取组件并返回
        return instance.GetComponent<ChatItemRemote>();
    });
    Main.ObjectPool.Mono.SetMaxCacheCount<ChatItemRemote>(99);
}
  • 从对象池中获取实例
/**********************************************************************************
 * 添加聊天项:
 *  userId - 发送者用户ID 传null表示发送方是自己
 *      如果发送者是自己 会新增一项ChatItemLocal
 *      如果发送者是对方 会新增一项ChatItemRemote
 **********************************************************************************/
private void AddChatItem(Message message, string userId = null)
{
    bool flag = !string.IsNullOrEmpty(userId);
    //从对象池中获取实例
    ChatItemBase instance;
    if (flag) instance = Main.ObjectPool.Mono.Allocate<ChatItemRemote>();
    else instance = Main.ObjectPool.Mono.Allocate<ChatItemLocal>();
    //预制件是隐藏的 实例化后调用显示接口
    instance.gameObject.SetActive(true);
    //设置数据
    instance.Set((message.Body as AgoraChat.MessageBody.TextBody).Text,
        DateTime2MessageTimeString(new DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc).AddMilliseconds(
            message.ServerTime != 0 ? message.ServerTime : message.LocalTime).ToLocalTime()));
    //开始适配大小
    instance.GetComponentInChildren<ChatItemTextBgAdaptor>().Adapt();
    //缓存到字典
    chatItemDic.Add(message, instance);
}
  • 回收实例到对象池中
string CurrentChatUserID
{
    get
    {
        return currentChatUserID;
    }
    set
    {
        /*****************************************************************************
         * 判断当前聊天对象是否发生变更
         *  发生变更后不仅更新值 还要执行聊天对象发生变更事件
         *  即回收当前实例化出的聊天项 并清空字典缓存
         *****************************************************************************/
        if (currentChatUserID != value)
        {
            currentChatUserID = value;
            foreach (var kv in chatItemDic)
            {
                switch (kv.Value.Type)
                {
                    case ChatItemType.LOCAL: Main.ObjectPool.Mono.Recycle(kv.Value as ChatItemLocal); break;
                    case ChatItemType.REMOTE: Main.ObjectPool.Mono.Recycle(kv.Value as ChatItemRemote); break;
                }
            }
            chatItemDic.Clear();
        }
    }
}

到了这里,关于Unity Metaverse(七)、基于环信IM SDK实现的好友系统、私聊、群聊的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 环信IM Demo登录方式如何修改为自己项目的?

    在环信即时通讯云IM 官网下载Demo,本地运行只有 手机+验证码 的方式登录?怎么更改为自己项目的Appkey和用户去进行登录呢? 👇👇👇本文以Web端为例,教大家如何更改代码来实现 1、 VUE2 Demo vue2 demo源码下载 vue2 demo线上体验 第一步:更改appkey webim-vue-demo===src===utils===WebIM

    2024年01月23日
    浏览(38)
  • IM即时通讯源码/im源码基于uniapp框架从0开始设计搭建在线聊天系统

    随着人社交产品的不断发展,即时通讯聊天这门技术也越来越重要,很多人都开启了学习通讯技术,本文就介绍了即时通讯的基础内容。 在开始设计和搭建聊天系统之前,需要确定所需技术栈。常用的技术栈包括前端、后端和数据库。例如,前端可以选择uni-app,后端可以选

    2024年02月04日
    浏览(57)
  • 如何实现IM即时通信系统(一)

    在企业数字化建设过程中,如何与客户保持线上链接是重要的组成部分。而IM通信系统就属于数字化建设的基础设施。那么,如何实现一个符合企业需求的IM系统呢?采购当然是其中需要考虑的方式之一。但就我个人的经验来看,市面上好的IM厂商很稀少,因为IM厂商需要做标

    2024年02月10日
    浏览(69)
  • 集成 Firebase 后,Flutter IM SDK 在 Android 端不触发回调

    描述 客户已集成 Firebase Messaging,Android 平台 Flutter IM SDK 的不触发任何回调。 分析(根因分析、需求分析) 可能原因是客户构建了一个 FlutterEngine instance,导致 SDK 的 FlutterEngine instance 失效了。 解决方案 找到以下 java 文件 packages/firebase_messaging/firebase_messaging/android/src/main/jav

    2024年02月01日
    浏览(41)
  • 基于Unity和Vive眼动SDK的VR眼动追踪研究场景开发

    前言:因为毕业论文的需要,我得在一年内尽快熟悉实验室的Vive pro eye并基于这套设备完成眼动追踪教育学注意力行为研究。感谢@Farewell弈和b站“邓布利多军”的先前工作,目前我的东西就是基于这两位大佬的东西摸着石头过河的。 跟随本篇文章,你将学到如何在Unity开发环

    2024年02月04日
    浏览(85)
  • 基于 Web SDK 实现视频通话场景 | 声网 SDK 教程

    声网视频 SDK 被广泛应用于多种实时互动场景中,例如视频会议、视频通话、音视频社交、在线教育等。为了让刚刚接触声网 SDK 的开发者,可以更顺畅地实现基础的视频通话功能,我们基于声网 Web SDK 4.x 版本梳理了本篇教程。 在本文末,会提供相应 Demo 、文档地址供大家参

    2023年04月09日
    浏览(45)
  • Unity iOS平台接入微信SDK,实现微信登录等功能

    文章目录 一、前言 二、流程 1、申请开发者账号 2、创建应用 3、下载SDK 4、导入到Unity中 5、编写Objective-C代码 5.1、CustomAppController.mm 5.2、WXApiManager.h 5.3、WXApiManager.mm 5.4、注册回调对象 5.5、封装初始化接口 5.6、封装登录接口 5.7、其他接口封装 6、XCodeAPI 7、关于Universal Link 8、

    2024年02月13日
    浏览(111)
  • Unity 好友列表、聊天记录使用本地数据库储存 --SimpleSQL SQLite

            Unity官方提供提供了插件 SimpleSQL,使用的是SQLite本地数据库的功能,插件这里就不做过多介绍了,移步Unity AssetStore 自行查看吧 SimpleSQL | 整合 | Unity Asset Store         这里主要讲一下插件的用法和我们在实际开发功能中需要用到的东西         聊天系统,一台设备

    2024年04月11日
    浏览(128)
  • IM 系统通信系统是什么

    IM(Instant Messaging)系统是一种实时通信系统,允许用户通过互联网或内部网络即时发送文本消息、文件、音频、视频和其他类型的数据给其他用户或群组。这类系统通常支持在线状态显示、消息确认、消息历史记录和多端同步等功能,以提高用户沟通的效率和体验。 IM 系统

    2024年02月06日
    浏览(29)
  • 基于海康威视的SDK实现二次开发

    因为网上关于海康威视SDK这块的开发资源比较少,自己也是一步一步摸索过来,知道那种痛苦, 所以把自己的一些过来人的经验写出来供大家学习参考 进入海康威视官网 下载你所需要的SDK开发包(这里我就用windows来作为案列) 下载完SDK解压 里面有开发文档和SDK的动态库文

    2024年04月10日
    浏览(45)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包