Unity | 工具类:消息管理器-延迟分发

ops/2025/3/15 0:51:46/

目录

一、消息管理器

二、获得新装备

三、UI面板创建


        消息管理器除了简单的订阅(Subscribe)、取消订阅(Unsubscribe)操作以外,还需处理延迟分发(Dispatch)的情况。

        (即时处理可参考:Unity | 工具类-利用事件系统进行业务串通-CSDN博客)

        假设玩家在游戏中获得新装备后,系统则会发送消息通知UI面板去显示第二个页签上的红点提示,但此时UI面板尚未创建,当玩家打开UI面板时消息早就发送过了。而延迟消息可以先把消息推送到缓存中,由需要拉取延迟消息的类(UI面板)自行调用拉取函数即可。这样的设计可以应对大部分游戏对于消息管理方面的需求,包括刷怪、关卡的消息提示等。

一、消息管理器


public class MessageManager
{static MessageManager mInstance;public static MessageManager Instance{get{return mInstance ?? (mInstance = new MessageManager());}}Dictionary<string, Action<object[]>> mMessageDict = new Dictionary<string, Action<object[]>>(32);// 将缓存字典设置为存储队列,防止多次分发时覆盖,key为消息名,value为参数队列Dictionary<string, Queue<object[]>> mDispatchCacheDict = new Dictionary<string, Queue<object[]>>(16);private MessageManager() { }//订阅消息public void Subscribe(string message, Action<object[]> action){Action<object[]> value = null;//已有消息则追加绑定if (mMessageDict.TryGetValue(message, out value)){value += action;mMessageDict[message] = value;}else                                                       //没有消息则添加到字典里{mMessageDict.Add(message, action);}}//取消消息订阅public void Unsubscribe(string message){mMessageDict.Remove(message);}//允许按委托实例取消订阅public void Unsubscribe(string message, Action<object[]> action){if (mMessageDict.TryGetValue(message, out var existingAction)){existingAction -= action; // 移除特定委托if (existingAction == null){mMessageDict.Remove(message); // 无订阅者则移除消息}else{mMessageDict[message] = existingAction;}}}public void Dispatch(string message, object[] args = null, bool addToCache = false){if (addToCache){// 如果不存在则创建新队列if (!mDispatchCacheDict.TryGetValue(message, out var queue)){queue = new Queue<object[]>();mDispatchCacheDict[message] = queue;}queue.Enqueue(args); // 参数入队}else{// 触发所有订阅者if (mMessageDict.TryGetValue(message, out var action)){action.Invoke(args);}}}public void ProcessDispatchCache(string message){if (mDispatchCacheDict.TryGetValue(message, out var queue)){// 处理队列中的所有消息while (queue.Count > 0){var args = queue.Dequeue();Dispatch(message, args); // 分发时不再缓存}mDispatchCacheDict.Remove(message);}}/// <summary>/// 重置消息管理器,必须用Static方法修饰/// </summary>public static void Reset(){mInstance = null; // 下次访问时会重新初始化}
}

二、获得新装备

        获得新食物时,UI面板未初始化。

    //处理获得新食物的消息void OnGetNewFood1(){MessageManager.Instance.Dispatch("GetNewFood", new object[] { 3 }, true);}void OnGetNewFood2(){MessageManager.Instance.Dispatch("GetNewFood", new object[] { 2 }, true);}

三、UI面板创建

void OnEnable(){MessageManager.Instance.Subscribe("GetNewFood", OnGetNewFood);//处理延迟消息MessageManager.Instance.ProcessDispatchCache("GetNewFood");//避免场景切换后残留旧数据,可重置单例实例。SceneManager.sceneLoaded += (scene, mode) => MessageManager.Reset();}/// <summary>/// 移除所有订阅/// </summary>// void OnDisable()// {//     MessageManager.Instance.Unsubscribe("GetNewFood");// }/// <summary>/// 移除当前实例的订阅/// </summary>void OnDisable(){// 仅移除当前实例的委托MessageManager.Instance.Unsubscribe("GetNewFood", OnGetNewFood);}private void OnGetNewFood(object[] obj){if (obj != null && obj.Length > 0 && obj[0] is int count){Debug.Log($"获得 {count} 个新食物");}else{Debug.LogError("无效的食物数量参数!");}}


http://www.ppmy.cn/ops/165805.html

相关文章

基于Spring Cloud Alibaba的电商系统微服务化实战:从拆分到高可用部署

一、系统架构设计与技术选型 1.1 电商系统拆分方案 将单体电商系统拆分为以下核心服务模块: 用户服务:负责用户注册、登录、权限管理 商品服务:管理商品信息、库存、分类 订单服务:处理订单创建、支付、状态流转 支付服务:对接第三方支付平台 网关服务:统一入口,路由与…

PHPCMS V9 登录加密改造

要改造 phpcms 的后台登录&#xff0c;使其前端使用加密方式提交&#xff0c;后端解密&#xff0c;你可以采用 RSA 非对称加密 或 AES 对称加密 方式来增强安全性。 方案设计 前端加密 生成公私钥对&#xff08;推荐使用 RSA&#xff09;。前端使用公钥加密密码&#xff0c;然…

Pytorch中矩阵乘法使用及案例

六种矩阵乘法 torch中包含许多矩阵乘法&#xff0c;大致可以分为以下几种&#xff1a; *&#xff1a;即a * b 按位相乘&#xff0c;要求a和b的形状必须一致&#xff0c;支持广播操作 torch.matmul()&#xff1a;最广泛的矩阵乘法 &#xff1a;与torch.matmul()效果一样&…

如何用终端运行一个SpringBoot项目

在项目开发阶段&#xff0c;为了能够快速测试一个SpringBoot项目的执行结果&#xff0c;就可以采用终端&#xff08;黑窗&#xff09;运行查看&#xff0c;因为我们不能要求每一个客户都安装idea并且适配我们的项目版本。 下面将展示打包运行这两个方面的过程&#xff1a; 创建…

重新安排行程 (leetcode 332

看了一上午题解&#xff0c;还是没明白 targets[result[result.size() - 1]] 是什么意思/(ㄒoㄒ)/~~ 然后搜到了&#xff1a; 对于targets[result[result.size() - 1]]的解释 突然就清楚多了&#xff01;&#xff01;

Ktor库使用HTTP编写了一个下载程序

使用 Ktor 库编写一个下载程序也是非常简单的&#xff0c;Ktor 是一个强大的 Kotlin 网络框架&#xff0c;支持 HTTP 请求和响应&#xff0c;适用于构建客户端和服务器应用。 下面是使用 Ktor 库编写的一个简单下载程序&#xff0c;功能是从指定的 URL 下载文件并保存到本地。…

RoboVQA:机器人多模态长范围推理

23 年 11 月来自 Google Deepmind 的论文“RoboVQA: Multimodal Long-Horizon Reasoning for Robotics”。 本文提出一种可扩展、自下而上且本质多样化的数据收集方案&#xff0c;该方案可用于长期和中期的高级推理&#xff0c;与传统的狭窄自上而下的逐步收集相比&#xff0c…

Python学习第十三天

正则表达式 什么是正则表达式&#xff1a;简单来说就是通过特殊符号匹配想要的字符串&#xff0c;正则表达式本身就是基于字符串的一套搜索规则&#xff0c;掌握了正则表达式对于字符串有了更深的把握和理解。 概念 官网概念&#xff1a;正则表达式&#xff08;Regular Expres…