详解 C# 中基于发布-订阅模式的 Messenger 消息传递机制：Messenger.Default.Send/Register

news2025/7/18 11:26:20

在这里插入图片描述

🧑 博主简介：CSDN博客专家、CSDN平台优质创作者，高级开发工程师，数学专业，10年以上C/C++, C#, Java等多种编程语言开发经验，拥有高级工程师证书；擅长C/C++、C#等开发语言，熟悉Java常用开发技术，能熟练应用常用数据库SQL server,Oracle,mysql,postgresql等进行开发应用，熟悉DICOM医学影像及DICOM协议,业余时间自学JavaScript,Vue,qt,python等，具备多种混合语言开发能力。撰写博客分享知识，致力于帮助编程爱好者共同进步。欢迎关注、交流及合作，提供技术支持与解决方案。
技术合作请加本人wx（注明来自csdn）：xt20160813

在这里插入图片描述

详解 C# 中基于发布-订阅模式的 Messenger 消息传递机制：Messenger.Default.Send/Register

在 C# 开发中，特别是在 MVVM（Model-View-ViewModel）架构的客户端应用程序中，跨组件通信是实现模块化设计和松耦合的关键。Messenger 是一种基于发布-订阅模式（Publish-Subscribe Pattern）的消息传递机制，广泛应用于 WPF、WinForms 和其他 C# 框架中。本文以 Messenger.Default.Send 和 Messenger.Default.Register 为核心，结合历史对话中提到的代码示例（如 Messenger.Default.Send<string>("Recovery", "fanxuan")），详细解析其实现原理、应用场景、技术细节，并提供完整代码示例和开发注意事项。文章特别融入国产化环境（如银河麒麟系统）的开发视角，确保内容准确、实用。

一、引言

发布-订阅模式是一种设计模式，允许消息发布者（Publisher）将消息发送给订阅者（Subscriber），而无需直接耦合。Messenger 是 MVVM 框架（如 MVVM Light、Prism 或自定义实现）中常见的消息传递工具，通过 Messenger.Default.Send 和 Messenger.Default.Register 实现异步、定向的模块间通信。

在历史对话中，代码片段展示了通过 Messenger.Default.Send<string>("Recovery", "fanxuan") 发送消息，并在接收端通过 Messenger.Default.Register<string> 捕获消息并触发 button1_Click 方法。这种机制广泛用于 UI 状态管理（如恢复按钮状态）、跨 ViewModel 通信或后台服务协调。本文将从原理、实现、代码示例到国产化开发适配，全面解析这一机制。

二、发布-订阅模式与 Messenger 概述

1. 发布-订阅模式

发布-订阅模式的核心思想是：

  • 发布者：发送消息但不关心谁接收。
  • 订阅者：注册对特定消息的兴趣，接收并处理消息。
  • 消息中介：管理消息的分发，通常通过令牌（Token）或消息类型过滤。

优点：

  • 松耦合：发布者和订阅者无需直接引用，降低模块间依赖。
  • 灵活性：支持一对多通信，动态注册/注销订阅者。
  • 线程安全：常结合 Dispatcher 机制，确保 UI 操作在主线程执行。
2. Messenger 的功能

Messenger 是 MVVM 框架中的消息传递工具（如 MVVM Light 的 GalaSoft.MvvmLight.Messaging.Messenger），提供以下功能：

  • 发送消息：通过 Messenger.Default.Send<T>(message, token) 发送特定类型的消息。
  • 注册订阅：通过 Messenger.Default.Register<T>(recipient, token, action) 注册消息处理逻辑。
  • 令牌机制：使用 token（如字符串 "fanxuan"）实现定向消息传递，减少无关模块的处理开销。
  • 线程调度：结合 Dispatcher 或异步机制，确保线程安全。

在历史对话中，Messenger.Default.Send<string>("Recovery", "fanxuan") 表示发送字符串消息 "Recovery"，目标是注册了 "fanxuan" 令牌的订阅者。

三、Messenger 的核心方法

1. Messenger.Default.Send

签名：

void Send<T>(T message, object token = null);
  • 参数：
    • T message：消息内容，支持任意类型（如 string、自定义类）。
    • token：可选的令牌，用于过滤接收者，通常为字符串或对象。
  • 作用：将消息广播给所有匹配 token 和消息类型 T 的订阅者。
  • 示例：
    // 发送字符串消息 "Recovery"，令牌为 "fanxuan"
Messenger.Default.Send<string>("Recovery", "fanxuan");
2. Messenger.Default.Register

签名：

void Register<T>(object recipient, object token, Action<T> action);
  • 参数：
    • recipient：订阅者对象（通常为 this，表示当前类实例）。
    • token：与发送端匹配的令牌。
    • action：收到消息后执行的回调函数，接收消息内容 T。
  • 作用：注册一个消息处理逻辑，仅处理匹配 token 和类型 T 的消息。
  • 示例：
    // 注册处理 "fanxuan" 令牌的字符串消息
Messenger.Default.Register<string>(
    this,
    "fanxuan",
    message => { Console.WriteLine($"Received: {message}"); }
);
3. 消息传递流程

以下是 Messenger 的工作流程（结合历史对话中的代码）：

graph LR
    A[Send: Messenger.Default.Send<string>("Recovery", "fanxuan")] --> B[Messenger 中介]
    B --> C[查找匹配 "fanxuan" 和 string 的订阅者]
    C --> D[Register: Messenger.Default.Register<string>(this, "fanxuan", ...)]
    D --> E[执行回调: DicomOperateDispatcher.Invoke(button1_Click)]

四、Messenger 的实现原理

Messenger 通常基于单例模式（Messenger.Default），内部维护一个订阅者列表。核心实现逻辑如下：

  1. 消息注册：

    • Register 方法将订阅者的 {recipient, token, action} 组合存储在一个字典或列表中。
    • 键为消息类型 T 和 token，值为回调函数 Action<T>。

  2. 消息发送：

    • Send 方法遍历订阅者列表，查找匹配 T 和 token 的注册项。
    • 对每个匹配的订阅者，调用其 action 回调，传递消息内容。

  3. 线程安全：

    • Messenger 通常不直接处理线程切换，需结合 Dispatcher（如 WPF 的 Dispatcher.Invoke）确保 UI 操作在主线程执行。

  4. 令牌机制：

    • 令牌（token）通过哈希比较（如字符串的 Equals 方法）实现高效匹配。
    • 如果 token 为 null，消息广播给所有订阅了类型 T 的接收者。

五、Messenger 在历史对话中的应用

在历史对话中，代码展示了 Messenger 在医学影像系统（DICOM 相关）中的应用，用于触发恢复按钮状态：

发送端：
case ItCallBackMSG.Recovery: // 复原按钮状态通过 ESC 键触发
{
    // 发送恢复命令
    Messenger.Default.Send<string>("Recovery", "fanxuan");
    break;
}
  • 场景：当用户按下 ESC 键，系统触发 ItCCallBackMSG.Recovery 状态，发送 "Recovery" 消息，目标为 "fanxuan" 通道。
  • 目的：通知订阅了 "fanxuan" 的模块执行状态恢复（如恢复 UI 按钮或 DICOM 数据状态）。
接收端：
Messenger.Default.Register<string>(
    this,
    "fanxuan",
    message => DicomOperateDispatcher.Invoke(new Onclick(button1_Click), null, null)
);
  • 场景：某个类（可能是 View 或 ViewModel）注册了 "fanxuan" 通道的字符串消息处理。
  • 处理逻辑：收到消息后，通过 DicomOperateDispatcher.Invoke 调用 button1_Click 方法，可能是恢复 UI 按钮状态或重置 DICOM 数据。
  • 线程安全：DicomOperateDispatcher.Invoke 确保 button1_Click 在 UI 线程执行，避免跨线程访问冲突。
分析：
  • 消息内容："Recovery" 表示恢复命令，可能触发 UI 重置、数据恢复或其他状态复原。
  • 令牌："fanxuan"（可能意为“反选”或特定模块标识）确保消息只发送给特定订阅者。
  • 问题：当前代码未对 message 内容进行判断，可能响应所有 "fanxuan" 通道的消息，建议添加条件判断（如 if (message == "Recovery")）。

六、完整代码示例

以下是一个完整的 C# 示例，展示 Messenger 的发送和接收过程，结合 WPF 和 MVVM 架构，模拟恢复按钮状态的场景。

1. 安装 MVVM Light

在项目中添加 MVVM Light NuGet 包：

Install-Package MvvmLight
2. 发送端（MainViewModel.cs）
using GalaSoft.MvvmLight;
using GalaSoft.MvvmLight.Messaging;

public class MainViewModel : ViewModelBase
{
    public MainViewModel()
    {
        // 模拟 ESC 键触发恢复
        SendRecoveryCommand();
    }

    private void SendRecoveryCommand()
    {
        // 发送恢复消息，目标为 "fanxuan" 通道
        Messenger.Default.Send<string>("Recovery", "fanxuan");
    }
}
3. 接收端（ButtonViewModel.cs）
using GalaSoft.MvvmLight;
using GalaSoft.MvvmLight.Messaging;
using System.Windows;

public class ButtonViewModel : ViewModelBase
{
    public ButtonViewModel()
    {
        // 注册 "fanxuan" 通道的字符串消息
        Messenger.Default.Register<string>(
            this,
            "fanxuan",
            message =>
            {
                // 仅处理 "Recovery" 消息
                if (message == "Recovery")
                {
                    // 在 UI 线程执行按钮状态恢复
                    Application.Current.Dispatcher.Invoke(() =>
                    {
                        ButtonClickHandler();
                    });
                }
            });
    }

    private void ButtonClickHandler()
    {
        // 模拟恢复按钮状态
        MessageBox.Show("Button state recovered!");
        // 实际逻辑：重置 UI 按钮、DICOM 数据状态等
    }
}
4. 主程序（App.xaml.cs）
using GalaSoft.MvvmLight.Messaging;

public partial class App : Application
{
    protected override void OnStartup(StartupEventArgs e)
    {
        base.OnStartup(e);
        // 初始化 ViewModel
        var mainViewModel = new MainViewModel();
        var buttonViewModel = new ButtonViewModel();
    }
}
运行结果：
  • 当 MainViewModel 发送 "Recovery" 消息时，ButtonViewModel 捕获消息并执行 ButtonClickHandler，显示提示框。
  • Dispatcher.Invoke 确保 UI 操作在主线程执行。

七、国产化环境中的应用

结合历史对话中关于银河麒麟系统的离线部署经验，以下是 Messenger 在国产化环境中的开发注意事项：

  1. 离线安装 MVVM Light：

    • 在银河麒麟上离线安装 NuGet 包：
      sudo rpm -ivh mvvmlightlibs-5.4.1.rpm --nodeps --force
    • 确保项目引用 GalaSoft.MvvmLight.dll。

  2. DICOM 集成：

    • Messenger 可用于 DICOM 系统中模块间通信（如 UI 与 PACS 数据同步）。
    • 示例：解析 DICOM 文件并发送状态更新：
      using pydicom; // 需通过 Python 脚本解析后传递
var ds = pydicom.dcmread("mri.dcm");
Messenger.Default.Send<string>("DICOMLoaded", "fanxuan");

  3. 防火墙配置：

    • 如果 Messenger 用于跨进程通信（如与 Orthanc PACS 服务交互），需放行端口：
      sudo firewall-cmd --zone=public --add-port=4242/tcp --permanent
sudo firewall-cmd --reload

  4. Fitten Code 集成：

    • 使用 Fitten Code 生成消息处理代码：
      // @Fitten 生成 Messenger 注册代码
Messenger.Default.Register<string>(
    this,
    "fanxuan",
    message => { if (message == "Recovery") { /* 恢复逻辑 */ } }
);

八、常见问题与解决方案

问题解决方案
消息未被接收检查 Register 和 Send 的 token 和消息类型是否匹配。
UI 线程冲突使用 Dispatcher.Invoke 确保回调在主线程执行。
国产系统依赖缺失离线安装 MVVM Light：sudo rpm -ivh mvvmlightlibs.rpm --nodeps。
消息广播过广添加 token（如 "fanxuan"）或条件判断（如 if (message == "Recovery")）。

九、总结

Messenger.Default.Send 和 Messenger.Default.Register 是 C# 中基于发布-订阅模式的强大消息传递机制，适用于 MVVM 架构中的模块间通信。核心特点：

  1. 松耦合：通过 token 实现定向消息传递。
  2. 线程安全：结合 Dispatcher 确保 UI 操作安全。
  3. 灵活性：支持任意消息类型和动态注册/注销。

结合历史对话中的 DICOM 系统场景，Messenger 在恢复按钮状态、跨模块通信中发挥了关键作用。在国产化环境（如银河麒麟）中，需注意离线依赖管理和防火墙配置。提供的代码示例可直接运行，适合开发者快速上手。

建议：

  • 在接收端添加消息内容判断，提升代码健壮性。
  • 使用 MVVM Light 或 Prism 的 Messenger 实现标准化开发。
  • 在国产化环境中测试消息传递的性能和稳定性。

参考资料

  • MVVM Light 文档：http://www.mvvmlight.net/
  • DICOM 标准：http://dicom.nema.org/
  • C# 委托与事件：https://docs.microsoft.com/en-us/dotnet/csharp/programming-guide/events/

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

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

相关文章

多场景游戏AI新突破！Divide-Fuse-Conquer如何激发大模型“顿悟时刻“？

多场景游戏AI新突破！Divide-Fuse-Conquer如何激发大模型“顿悟时刻“？

多场景游戏AI新突破&#xff01;Divide-Fuse-Conquer如何激发大模型"顿悟时刻"&#xff1f; 大语言模型在强化学习中偶现的"顿悟时刻"引人关注&#xff0c;但多场景游戏中训练不稳定、泛化能力差等问题亟待解决。Divide-Fuse-Conquer方法&#xff0c;通过…
阅读更多...
Java 函数式接口（Functional Interface）

Java 函数式接口（Functional Interface）

一、理论说明 1. 函数式接口的定义 Java 函数式接口是一种特殊的接口&#xff0c;它只包含一个抽象方法&#xff08;Single Abstract Method, SAM&#xff09;&#xff0c;但可以包含多个默认方法或静态方法。函数式接口是 Java 8 引入 Lambda 表达式的基础&#xff0c;通过函…
阅读更多...
分布式锁总结

分布式锁总结

文章目录 分布式锁什么是分布式锁&#xff1f;分布式锁的实现方式基于数据库(mysql)实现基于缓存(redis)多实例并发访问问题演示项目代码(使用redis)配置nginx.confjmeter压测复现问题并发是1&#xff0c;即不产生并发问题并发30测试,产生并发问题(虽然单实例是synchronized&am…
阅读更多...
使用MybatisPlus实现sql日志打印优化

使用MybatisPlus实现sql日志打印优化

背景&#xff1a; 在排查无忧行后台服务日志时&#xff0c;一个请求可能会包含多个执行的sql&#xff0c;经常会遇到SQL语句与对应参数不连续显示&#xff0c;或者参数较多需要逐个匹配的情况。这种情况下&#xff0c;如果需要还原完整SQL语句就会比较耗时。因此&#xff0c;我…
阅读更多...
client.chat.completions.create方法参数详解

client.chat.completions.create方法参数详解

response client.chat.completions.create(model"gpt-3.5-turbo", # 必需参数messages[], # 必需参数temperature1.0, # 可选参数max_tokensNone, # 可选参数top_p1.0, # 可选参数frequency_penalty0.0, # 可选参数presenc…
阅读更多...
深入浅出人工智能：机器学习、深度学习、强化学习原理详解与对比！

深入浅出人工智能：机器学习、深度学习、强化学习原理详解与对比！

各位朋友&#xff0c;大家好&#xff01;今天咱们聊聊人工智能领域里最火的“三剑客”&#xff1a;机器学习 (Machine Learning)、深度学习 (Deep Learning) 和 强化学习 (Reinforcement Learning)。 听起来是不是有点高大上&#xff1f; 别怕&#xff0c;我保证把它们讲得明明…
阅读更多...
基于 ColBERT 框架的后交互 (late interaction) 模型速递：Reason-ModernColBERT

基于 ColBERT 框架的后交互 (late interaction) 模型速递：Reason-ModernColBERT

一、Reason-ModernColBERT 模型概述 Reason-ModernColBERT 是一种基于 ColBERT 框架的后交互 (late interaction) 模型&#xff0c;专为信息检索任务中的推理密集型场景设计。该模型在 reasonir-hq 数据集上进行训练&#xff0c;于 BRIGHT 基准测试中取得了极具竞争力的性能表…
阅读更多...
vector中reserve导致的析构函数问题

vector中reserve导致的析构函数问题

接上一节vector实现&#xff0c;解决杨辉三角问题时&#xff0c;我在最后调试的时候&#xff0c;发现return vv时&#xff0c;调用析构函数&#xff0c;到第四步时才析构含有14641的vector。我设置了一个全局变量i来记录。 初始为35&#xff1a; 当为39时&#xff0c;也就是第…
阅读更多...
微软开源多智能体自定义自动化工作流系统：构建企业级AI驱动的智能引擎

微软开源多智能体自定义自动化工作流系统：构建企业级AI驱动的智能引擎

微软近期推出了一款开源解决方案加速器——Multi-Agent Custom Automation Engine Solution Accelerator，这是一个基于AI多智能体协作的自动化工作流系统。该系统通过指挥多个智能体（Agent）协同完成复杂任务，显著提升企业在数据处理、业务流程管理等场景中的效率与准确性。…
阅读更多...
安卓无障碍脚本开发全教程

安卓无障碍脚本开发全教程

文章目录 第一部分&#xff1a;无障碍服务基础1.1 无障碍服务概述核心功能&#xff1a; 1.2 基本原理与架构1.3 开发环境配置所需工具&#xff1a;关键依赖&#xff1a; 第二部分&#xff1a;创建基础无障碍服务2.1 服务声明配置2.2 服务配置文件关键属性说明&#xff1a; 2.3 …
阅读更多...
SOC-ESP32S3部分：10-GPIO中断按键中断实现

SOC-ESP32S3部分：10-GPIO中断按键中断实现

飞书文档https://x509p6c8to.feishu.cn/wiki/W4Wlw45P2izk5PkfXEaceMAunKg 学习了GPIO输入和输出功能后&#xff0c;参考示例工程&#xff0c;我们再来看看GPIO中断&#xff0c;IO中断的配置分为三步 配置中断触发类型安装中断服务注册中断回调函数 ESP32-S3的所有通用GPIO…
阅读更多...
战略-2.1 -战略分析（PEST/五力模型/成功关键因素）

战略-2.1 -战略分析（PEST/五力模型/成功关键因素）

战略分析路径&#xff0c;先宏观&#xff08;PEST&#xff09;、再产业&#xff08;产品生命周期、五力模型、成功关键因素&#xff09;、再竞争对手分析、最后企业内部分析。 本文介绍&#xff1a;PEST、产品生命周期、五力模型、成功关键因素、产业内的战略群组 一、宏观环境…
阅读更多...
python第三方库安装错位

python第三方库安装错位

问题所在 今天在安装我的django库时&#xff0c;我的库安装到了python3.13版本。我本意是想安装到python3.11版本的。我的pycharm右下角也设置了python3.11 但是太可恶了&#xff0c;我在pycharm的项目终端执行安装命令的时候还是给我安装到了python3.13的位置。 解决方法 我…
阅读更多...
如何把vue项目部署在nginx上

如何把vue项目部署在nginx上

1&#xff1a;在vscode中把vue项目打包会出现dist文件夹 按照图示内容即可把vue项目部署在nginx上
阅读更多...
Vue3集成Element Plus完整指南：从安装到主题定制下-实现后台管理系统框架搭建

Vue3集成Element Plus完整指南：从安装到主题定制下-实现后台管理系统框架搭建

本文将详细介绍如何使用 Vue 3 构建一个综合管理系统&#xff0c;包括路由配置、页面布局以及常用组件集成。 一、路由配置 首先&#xff0c;我们来看系统的路由配置&#xff0c;这是整个应用的基础架构&#xff1a; import {createRouter, createWebHistory} from vue-rout…
阅读更多...
SpringBoot项目配置文件、yml配置文件

SpringBoot项目配置文件、yml配置文件

一. 配置文件格式 1. SpringBoot项目提供了多种属性配置方式(properties、yaml、yml)。 二. yml配置文件 1. 格式&#xff1a; (1) 数值前边必须有空格&#xff0c;作为分隔符。 (2) 使用缩进表示层级关系&#xff0c;缩进时&#xff0c;不允许使用Tab键&#xff0c;只能使用空…
阅读更多...
windows11 安装 jupyter lab

windows11 安装 jupyter lab

1、安装python环境 略 2、安装jupyterlab pip install jupyterlab 3、将jupyterlab的目录配置到path pip show jupyterlab 看到location的值&#xff0c;那么 jupyterlab就安装在与之同级的Scripts下&#xff0c;将Scripts目录设置在Path即可。
阅读更多...
【算法】：动态规划--背包问题

【算法】：动态规划--背包问题

背包问题 引言 什么是背包问题&#xff1f; 背包问题就是一个有限的背包&#xff0c;给出一定的物品&#xff0c;如何合理的装入物品使得背包中的物品的价值最大&#xff1f; 01背包 01背包&#xff0c;顾名思义就是每一种给定的物品要么选择&#xff0c;要么不选&#xff…
阅读更多...
Nginx核心功能

Nginx核心功能

目录 前言一. 正向代理1.配置正向代理&#xff08;1&#xff09;添加正向代理&#xff08;2&#xff09;验证正向代理 二. 反向代理1.配置nginx七层代理&#xff08;1&#xff09;环境安装&#xff08;2&#xff09;配置nginx七层代理转发&#xff08;3&#xff09;测试 2. 配置…
阅读更多...
upload-labs通关笔记-第15关 文件上传之图片马getimagesize绕过

upload-labs通关笔记-第15关 文件上传之图片马getimagesize绕过

系列目录 upload-labs通关笔记-第1关 文件上传之前端绕过&#xff08;3种渗透方法&#xff09; upload-labs通关笔记-第2关 文件上传之MIME绕过-CSDN博客 upload-labs通关笔记-第3关 文件上传之黑名单绕过-CSDN博客 upload-labs通关笔记-第4关 文件上传之.htacess绕过-CSDN…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023