Unity EventCenter 消息中心的设计与实现

news2025/5/25 0:57:47

在开发过程中，想要传递信号和数据，就得在不同模块之间实现通信。直接通过单例调用虽然简单，但会导致代码高度耦合，难以维护。消息中心提供了一种松耦合的通信方式：发布者不需要知道谁接收事件，接收者不需要知道事件来自哪里，由此减少模块间的直接依赖，便于扩展和维护。

架构

%% EventCenter 架构图
graph TD
    subgraph 事件中心核心
        A[EventCenter] --> B[ConcurrentDictionary eventKey:callback]
    end

    subgraph 调用接口
        A --> E[添加监听 AddListener]
        A --> F[移除监听 RemoveListener]
        A --> G[同步触发 SyncBroadcast]
        A --> H[异步触发 Broadcast]
    end

    subgraph 线程管理
        G -->|立即执行| J[当前线程]
        H -->|主线程队列延迟| K[主线程]
    end

    subgraph 异常处理
        G --> L[Try-Catch块]
        H --> L
        L --> M[打印错误日志]
        M --> N[继续触发剩余回调]
    end

数据结构

我们需要一个数据结构来存储eventKey与callback的映射关系，可以使用字典。

如果使用Dictionary，当多个线程同时注册或触发事件，可能导致数据异常，因此我们可以使用ConcurrentDictionary，它是门为高并发场景设计的线程安全集合，内置原子操作，无需手动加锁。

ConcurrentDictionary 提供以下方法：

bool TryAdd(TKey key, TValue value);
bool TryRemove(TKey key, out TValue value);
bool TryGetValue(TKey key, out TValue value);
bool ContainsKey(TKey key);

思考一下，可以使用 ConcurrentDictionary<string,delegate>存储eventKey与callback的映射，但很快便发现，这样一个key只能对应一个回调，不能满足多个模块监听一个事件的应用场景。

于是我们尝试 ConcurrentDictionary<string,List<delegate>>，但是ConcurrentDictionary只能保证获取到 List<T> 的过程是安全的，修改 List<T> 仍然会存在线程不安全的问题。

假设有两个线程同时执行这段代码：

if (!eventDic.ContainsKey("Attack")) 
{ 
    eventDic["Attack"] = new List<Delegate>(); 
    eventDic["Attack"].Add(callback); 
}
时间线程1线程2
t1执行步骤1（判断"Attack"不存在）-
t2-执行步骤1（同样判断"Attack"不存在）
t3执行步骤2（创建新List）-
t4-执行步骤2（再次创建新List，覆盖线程1创建的List）
t5执行步骤3（向被覆盖的List添加handler1）-
t6-执行步骤3（向新List添加handler2）

可以看到线程2覆盖了线程1创建的List，这可能会导致数据错误。

我们可以尝试使用ConcurrentDictionary<string,ConcurrentDictionary<Delegate,bool>>，嵌套的内层字典可以存储多个Delegate，并且修改操作都是线程安全的，对于内存字典的值，我们是用不上的，可以使用字节数最小的bool类型来占位。

广播

在广播时，我们遍历存储当前key所有委托的内层字典，并依次执行其回调函数。

因为我们不需要回调函数的返回值，所以我们把这些方法委托都从基类Delegate转换成无返回值类型的Action委托。

回调函数无参数：

public static void SyncBroadcast(string eventKey)
{
    if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
    {
        foreach (var callback in callbackList.Keys)
        {
            (callback as Action)?.Invoke();
        }
    }
}

回调函数带参数，使用泛型实现：

一般来说，三个参数就可以覆盖绝大多数的使用场景，所以我们只实现0~3个参数的方法。

public static void SyncBroadcast<T>(string eventKey, T data)
{
    if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
    {
        foreach (var callback in callbackList.Keys)
        {
            (callback as Action<T>)?.Invoke(data);
        }
    }
}

错误处理

如果某个回调抛出异常，会中断后续回调的执行，还需要增加 try-catch 包裹回调执行部分。

Broadcast与SyncBroadcast

对于SyncBroadcast，Invoke会在调用SyncBroadcast的线程执行。

但很多时候，我们需要在Unity主线程执行回调函数，可以使LoomManager.QueueOnMainThread方法把回调函数传给主线程执行。于是我们可以这样包装一下：

public static void Broadcast(string eventKey)
{
    LoomManager.QueueOnMainThread(() => SyncBroadcast(eventKey));
}

代码

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using UnityEngine;

public static class EventCenter
{
    private static string TAG = "[EventCenter]";

    private static readonly ConcurrentDictionary<string, ConcurrentDictionary<Delegate, bool>>
        eventDic = new ConcurrentDictionary<string, ConcurrentDictionary<Delegate, bool>>();

    // 添加事件监听
    public static void AddListener(string eventKey, Action callback)
    {
        if (!eventDic.ContainsKey(eventKey))
        {
            eventDic[eventKey] = new ConcurrentDictionary<Delegate, bool>();
        }
        eventDic[eventKey].TryAdd(callback, false);
    }

    #region 有参
    public static void AddListener<T>(string eventKey, Action<T> callback)
    {
        if (!eventDic.ContainsKey(eventKey))
        {
            eventDic[eventKey] = new ConcurrentDictionary<Delegate, bool>();
        }
        eventDic[eventKey].TryAdd(callback, false);
    }

    public static void AddListener<T,U>(string eventKey, Action<T,U> callback)
    {
        if (!eventDic.ContainsKey(eventKey))
        {
            eventDic[eventKey] = new ConcurrentDictionary<Delegate, bool>();
        }
        eventDic[eventKey].TryAdd(callback, false);
    }

    public static void AddListener<T, U, V>(string eventKey, Action<T, U, V> callback)
    {
        if (!eventDic.ContainsKey(eventKey))
        {
            eventDic[eventKey] = new ConcurrentDictionary<Delegate, bool>();
        }
        eventDic[eventKey].TryAdd(callback, false);
    }
    #endregion

    // 移除事件监听
    public static void RemoveListener(string eventKey, Action callback)
    {
        if(eventDic.TryGetValue(eventKey,out ConcurrentDictionary<Delegate,bool> callbackList))
        {
            if (callbackList.ContainsKey(callback))
                callbackList.TryRemove(callback, out bool result);
        }
    }

    // 移除全部事件监听
    public static void Clear() => eventDic.Clear();

    #region 有参
    public static void RemoveListener<T>(string eventKey, Action<T> callback)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            if (callbackList.ContainsKey(callback))
                callbackList.TryRemove(callback, out bool result);
        }
    }

    public static void RemoveListener<T, U>(string eventKey, Action<T, U> callback)
    {
        if(eventDic.TryGetValue(eventKey,out ConcurrentDictionary<Delegate,bool> callbackList))
        {
            if (callbackList.ContainsKey(callback))
                callbackList.TryRemove(callback, out bool result);
        }
    }

    public static void RemoveListener<T, U, V>(string eventKey, Action<T, U, V> callback)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            if (callbackList.ContainsKey(callback))
                callbackList.TryRemove(callback, out bool result);
        }
    }
    #endregion

    // 立即触发事件
    public static void SyncBroadcast(string eventKey)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            foreach (var callback in callbackList.Keys)
            {
                try
                {
                    (callback as Action)?.Invoke();
                }
                catch(Exception ex)
                {
                    Debug.LogError(TAG + $"Event:{eventKey} Callback:{callback.Method.Name} Failed: {ex.Message}");
                }
            }
        }
    }

    #region 有参
    public static void SyncBroadcast<T>(string eventKey, T data)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            foreach (var callback in callbackList.Keys)
            {
                try
                {
                    (callback as Action<T>)?.Invoke(data);
                }
                catch (Exception ex)
                {
                    Debug.LogError(TAG + $"Event:{eventKey} Callback:{callback.Method.Name} Failed: {ex.Message}");
                }
            }
        }
    }

    public static void SyncBroadcast<T, U>(string eventKey, T dataT, U dataU)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            foreach (var callback in callbackList.Keys)
            {
                try
                {
                    (callback as Action<T, U>)?.Invoke(dataT, dataU);
                }
                catch (Exception ex)
                {
                    Debug.LogError(TAG + $"Event:{eventKey} Callback:{callback.Method.Name} Failed: {ex.Message}");
                }
            }
        }
    }

    public static void SyncBroadcast<T, U, V>(string eventKey, T dataT, U dataU, V dataV)
    {
        if (eventDic.TryGetValue(eventKey, out ConcurrentDictionary<Delegate, bool> callbackList))
        {
            foreach (var callback in callbackList.Keys)
            {
                try
                {
                    (callback as Action<T, U, V>)?.Invoke(dataT, dataU, dataV);
                }
                catch (Exception ex)
                {
                    Debug.LogError(TAG + $"Event:{eventKey} Callback:{callback.Method.Name} Failed: {ex.Message}");
                }
            }
        }
    }
    #endregion

    // 在主线程触发事件
    public static void Broadcast(string eventKey)
    {
        LoomManager.QueueOnMainThread(() => SyncBroadcast(eventKey));
    }

    #region 有参
    public static void Broadcast<T>(string eventKey, T data)
    {
        LoomManager.QueueOnMainThread(() => SyncBroadcast(eventKey, data));
    }

    public static void Broadcast<T, U>(string eventKey, T dataT, U dataU)
    {
        LoomManager.QueueOnMainThread(() => SyncBroadcast(eventKey, dataT, dataU));
    }

    public static void Broadcast<T, U, V>(string eventKey, T dataT, U dataU, V dataV)
    {
        LoomManager.QueueOnMainThread(() => SyncBroadcast(eventKey, dataT, dataU, dataV));
    }
    #endregion
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2384992.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

MySQL远程连接10060错误：防火墙端口设置指南

MySQL远程连接10060错误：防火墙端口设置指南

问题描述&#xff1a; 如果你通过本机服务器远程连接MySQL&#xff0c;出现10060错误&#xff0c;那可能是你的防火墙的问题 解决&#xff1a; 第一步&#xff1a;查看防火墙规则 通过以下命令查询&#xff0c;看ports是否开放了3306端口&#xff0c;目前只开放了22端口 f…
阅读更多...
使用 OpenCV 实现 ArUco 码识别与坐标轴绘制

使用 OpenCV 实现 ArUco 码识别与坐标轴绘制

&#x1f3af; 使用 OpenCV 实现 ArUco 码识别与坐标轴绘制&#xff08;含Python源码&#xff09; Aruco 是一种广泛用于机器人、增强现实&#xff08;AR&#xff09;和相机标定的方形标记系统。本文将带你一步一步使用 Python OpenCV 实现图像中多个 ArUco 码的检测与坐标轴…
阅读更多...
canal实现mysql数据同步

canal实现mysql数据同步

目录 1、canal下载 2、mysql同步用户创建和授权 3、canal admin安装和启动 4、canal server安装和启动 5、java 端集成监听canal 同步的mysql数据 6、java tcp同步只是其中一种方式&#xff0c;还可以通过kafka、rabbitmq等方式进行数据同步 1、canal下载 canal实现mysq…
阅读更多...
易境通专线散拼系统：全方位支持多种专线物流业务！

易境通专线散拼系统：全方位支持多种专线物流业务！

在全球化电商快速发展的今天&#xff0c;跨境电商物流已成为电商运营中极为重要的环节。为了确保物流效率、降低运输成本&#xff0c;越来越多的电商卖家选择专线物流服务。专线物流作为五大主要跨境电商物流模式之一&#xff0c;通过固定的运输路线和流程&#xff0c;极大提高…
阅读更多...
06 如何定义方法，掌握有参无参，有无返回值，调用数组作为参数的方法，方法的重载

06 如何定义方法，掌握有参无参，有无返回值，调用数组作为参数的方法，方法的重载

1.调用方法 2.掌握有参函数 3.调用数组作为参数 一个例题&#xff1a;数组参数&#xff0c;返回值 方法的重载 两个例题&#xff1a;冒泡排序和九九乘法表的格式学习
阅读更多...
使用vscode MSVC CMake进行C++开发和Debug

使用vscode MSVC CMake进行C++开发和Debug

使用vscode MSVC CMake进行C开发和Debug 前言软件安装安装插件构建debuug方案一debug方案二其他 前言 一般情况下我都是使用visual studio来进行c开发的&#xff0c;但是由于python用的是vscode&#xff0c;所以二者如果统一的话能稍微提高一点效率。 软件安装 需要安装的软…
阅读更多...
提升开发运维效率：原力棱镜游戏公司的 Amazon Q Developer CLI 实践

提升开发运维效率：原力棱镜游戏公司的 Amazon Q Developer CLI 实践

引言 在当今快速发展的云计算环境中&#xff0c;游戏开发者面临着新的挑战和机遇。为了提升开发效率&#xff0c;需要更智能的工具来辅助工作流程。Amazon Q Developer CLI 作为亚马逊云科技推出的生成式 AI 助手&#xff0c;为开发者提供了一种新的方式来与云服务交互。 Ama…
阅读更多...
@Column 注解属性详解

@Column 注解属性详解

提示&#xff1a;文章旨在说明 Column 注解属性如何在日常开发中使用&#xff0c;数据库类型为 MySql&#xff0c;其他类型数据库可能存在偏差&#xff0c;需要注意。 文章目录 一、name 方法二、unique 方法三、nullable 方法四、insertable 方法五、updatable 方法六、column…
阅读更多...
基于 ESP32 与 AWS 全托管服务的 IoT 架构：MQTT + WebSocket 实现设备-云-APP 高效互联

基于 ESP32 与 AWS 全托管服务的 IoT 架构：MQTT + WebSocket 实现设备-云-APP 高效互联

目录 一、总体架构图 二、设备端（ESP32）低功耗设计（适配 AWS IoT） 1.MQTT 设置（ESP32 连接 AWS IoT Core） 2.低功耗策略总结（ESP32） 三、云端架构（基于 AWS Serverless + IoT Core） 1.AWS IoT Core 接入 2.云端 → APP：WebSocket 推送方案 流程： 3.数据存…
阅读更多...
unity在urp管线中插入事件

unity在urp管线中插入事件

由于在urp下&#xff0c;打包后传统的相机事件有些无法正确执行&#xff0c;这时候我们需要在urp管线中的特定时机进行处理一些事件&#xff0c;需要创建继承ScriptableRenderPass和ScriptableRendererFeature的脚本&#xff0c;示例如下&#xff1a; PluginEventPass&#xf…
阅读更多...
docker安装es连接kibana并安装分词器

docker安装es连接kibana并安装分词器

使用Docker部署Elasticsearch、Kibana并安装分词器有以下主要优点&#xff1a; 1. 快速部署与一致性 一键式部署&#xff1a;通过Docker Compose可以快速搭建完整的ELK栈环境 环境一致性&#xff1a;确保开发、测试和生产环境完全一致&#xff0c;避免"在我机器上能运行…
阅读更多...
线性回归中涉及的数学基础

线性回归中涉及的数学基础

线性回归中涉及的数学基础 本文详细地说明了线性回归中涉及到的主要的数学基础。 如果数学基础很扎实可以直接空降博文: 线性回归&#xff08;一&#xff09;-CSDN博客 一、概率、似然与概率密度函数 1. 概率&#xff08;Probability&#xff09; 定义&#xff1a;概率是描述…
阅读更多...
如何计算VLLM本地部署Qwen3-4B的GPU最小配置应该是多少？多人并发访问本地大模型的GPU配置应该怎么分配？

如何计算VLLM本地部署Qwen3-4B的GPU最小配置应该是多少？多人并发访问本地大模型的GPU配置应该怎么分配？

本文一定要阅读我上篇文章&#xff01;&#xff01;&#xff01; 超详细VLLM框架部署qwen3-4B加混合推理探索&#xff01;&#xff01;&#xff01;-CSDN博客 本文是基于上篇文章遗留下的问题进行说明的。 一、本文解决的问题 问题1&#xff1a;我明明只部署了qwen3-4B的模型…
阅读更多...
Attu下载 Mac版与Win版

Attu下载 Mac版与Win版

通过Git地址下载 Mac 版选择对于的架构进行安装 其中遇到了安装不成功&#xff0c;文件损坏等问题 一般是两种情况导致 1.安装版本不对 2.系统权限限制 https://www.cnblogs.com/similar/p/11280162.html打开terminal执行以下命令 sudo spctl --master-disable安装包Git下载地…
阅读更多...
V2X协议｜如何做到“车联万物”？【无线通信小百科】

V2X协议｜如何做到“车联万物”？【无线通信小百科】

1、什么是V2X V2X&#xff08;Vehicle-to-Everything&#xff09;即“车联万物”&#xff0c;是一项使车辆能够与周围环境实现实时通信的前沿技术。它允许车辆与其他交通参与者和基础设施进行信息交互。通过V2X&#xff0c;车辆不仅具备“远程感知”能力&#xff0c;还能在更大…
阅读更多...
[测试_3] 生命周期 | Bug级别 | 测试流程 | 思考

[测试_3] 生命周期 | Bug级别 | 测试流程 | 思考

目录 一、软件测试的生命周期&#xff08;重点&#xff09; 1、软件测试 & 软件开发生命周期 &#xff08;1&#xff09;需求分析 &#xff08;2&#xff09;测试计划 &#xff08;3&#xff09;测试设计与开发 &#xff08;4&#xff09;测试执行 &#xff08;5&am…
阅读更多...
RabbitMQ ⑤-顺序性保障 || 消息积压 || 幂等性

RabbitMQ ⑤-顺序性保障 || 消息积压 || 幂等性

幂等性保障 幂等性&#xff08;Idempotency&#xff09; 是计算机科学和网络通信中的一个重要概念&#xff0c;指的是某个操作无论被执行多少次&#xff0c;所产生的效果与执行一次的效果相同。 应用程序的幂等性&#xff1a; 在应用程序中&#xff0c;幂等性就是指对一个系统…
阅读更多...
java基础知识回顾1（可用于Java基础速通）考前，面试前均可用！

java基础知识回顾1（可用于Java基础速通）考前，面试前均可用！

目录 一、初识java 二、基础语法 1.字面量 2.变量 3.关键字 4.标识符 声明&#xff1a;本文章根据黑马程序员b站教学视频做的笔记&#xff0c;可对应课程听&#xff0c;课程链接如下: 02、Java入门&#xff1a;初识Java_哔哩哔哩_bilibili 一、初识java Java是美国 sun 公…
阅读更多...
云原生CICD-Tekton入门到精通

云原生CICD-Tekton入门到精通

文章目录 一、Tekton介绍二、Tekton组件介绍三、执行流程四、安装Tekton管道五、安装Tekton Dashboard六、安装Tekton Cli七、运行单Task八、运行流水线九、在流水线中使用secret十、taskSpec、taskRef、pipelineRef、pipelineSpec使用pipelineRef与taskRef结合使用(推荐)pipel…
阅读更多...
opencv 图像的平移和旋转

opencv 图像的平移和旋转

warpAffine函数讲解,图片可自行下载&#xff0c;也可用自己的图片 原图im 平移im_shifted 旋转im_rotated # 图像仿射变换 # 步骤&#xff1a; 读取图像 -> 创建仿射变换矩阵 -> 仿射变换计算 # 平移变换矩阵&#xff1a;一种写法&#xff0c;直接写死 # 旋转变…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023