当前位置：首页 > news >正文

使用 NServiceBus 在 .NET 中构建分布式系统

news 来源：原创 2025/6/8 4:06:22

在 .NET 中，NServiceBus 依然是构建可靠、可扩展、异步消息驱动架构的强大工具。本文将为你讲解如何在 .NET 环境下集成 NServiceBus，帮助你理解其核心概念及配置方法，并快速上手构建基于消息的系统。

一、NServiceBus 简介

NServiceBus 是一个用于构建分布式系统、微服务架构和事件驱动架构的消息中间件框架。它允许服务之间通过异步消息传递进行通信，从而降低了服务间的耦合度，提高了系统的可扩展性和可靠性。

NServiceBus 支持以下核心功能：

异步消息传递：通过消息队列异步传递信息，避免服务间的同步调用和阻塞。
消息驱动架构：支持基于事件的发布/订阅模型，能够快速构建解耦的分布式系统。
事务管理和可靠性：NServiceBus 提供了可靠的消息传递机制，支持消息重试、事务和死信队列等特性。

二、.NET 中的 NServiceBus 集成

在 .NET 环境下，集成 NServiceBus 的步骤与以前的版本相似，但它受益于 .NET 新的性能优化和架构改进。以下是详细的集成步骤。

1. 安装必要的 NuGet 包

首先，确保你的 .NET 8 项目中已经安装了 NServiceBus 及相关的传输和持久化包。

使用以下命令安装 NServiceBus 主包：

dotnet add package NServiceBus

如果你选择使用某种特定的消息传输技术（如 SQL Server、RabbitMQ 等），你还需要安装相应的包。比如，使用 SQL Server 作为消息持久化存储时，安装以下包：

dotnet add package NServiceBus.SqlServer

或者，如果你选择使用 RabbitMQ，安装 NServiceBus.RabbitMQ 包：

dotnet add package NServiceBus.RabbitMQ

2. 配置 NServiceBus 端点

在 .NET 中，你通常会在 Program.cs 文件中配置 NServiceBus。这是因为 .NET 中不再有 Startup.cs，而是使用了基于 Program.cs 的简化启动方式。以下是一个 NServiceBus 配置的示例：

using Microsoft.Extensions.Hosting;
using NServiceBus;
using NServiceBus.Persistence.Sql;
using Microsoft.Extensions.DependencyInjection;var builder = Host.CreateApplicationBuilder(args);// 配置 NServiceBus 端点
builder.Services.AddSingleton<IEndpointInstance>(provider =>
{var endpointConfiguration = new EndpointConfiguration("MyEndpoint");// 配置消息持久化方式（使用 SQL Server）var persistence = endpointConfiguration.UsePersistence<SqlPersistence>();persistence.SqlDialect<SqlDialect.MsSqlServer>();// 配置消息传输方式（使用 LearningTransport，适用于开发环境）var transport = endpointConfiguration.UseTransport<LearningTransport>();// 启动端点并返回var endpointInstance = Endpoint.Start(endpointConfiguration).GetAwaiter().GetResult();return endpointInstance;
});var app = builder.Build();app.Run();

在这个配置中，我们创建了一个名为 MyEndpoint 的 NServiceBus 端点，并选择了 SQL Server 作为消息持久化存储。我们还使用 LearningTransport 作为消息传输方式，这适合于开发和学习环境。如果你在生产环境中使用 NServiceBus，建议使用更高效的传输方式，如 RabbitMQ 或 Azure Service Bus。

3. 定义消息类和处理程序

在 NServiceBus 中，消息是与应用程序组件之间进行交互的基本单位。我们通常会为每个消息定义一个 C# 类，并通过消息处理程序（Handler）来处理这些消息。

定义消息类：

public class MyMessage : ICommand
{public string Content { get; set; }
}

在这个例子中，MyMessage 是一个命令类（ICommand），它携带一个简单的 Content 属性。

创建消息处理程序：

using NServiceBus;
using System.Threading.Tasks;public class MyMessageHandler : IHandleMessages<MyMessage>
{public async Task Handle(MyMessage message, IMessageHandlerContext context){// 处理消息的逻辑Console.WriteLine($"Received message: {message.Content}");await Task.CompletedTask;}
}

MyMessageHandler 是一个处理程序类，它实现了 IHandleMessages<MyMessage> 接口，处理 MyMessage 类型的消息。每当收到 MyMessage 消息时，Handle 方法会被调用，打印出消息的内容。

4. 发送消息

通过端点实例，你可以将消息发送到目标端点。以下是一个示例服务类，它通过 IEndpointInstance 发送消息：

using NServiceBus;public class MyService
{private readonly IEndpointInstance _endpointInstance;public MyService(IEndpointInstance endpointInstance){_endpointInstance = endpointInstance;}public async Task SendMessage(){var message = new MyMessage { Content = "Hello, NServiceBus in .NET 8!" };await _endpointInstance.Send(message);}
}

在这个例子中，MyService 类通过 IEndpointInstance 向其他端点发送 MyMessage 消息。你可以根据业务需求发送不同类型的消息。

5. 配置传输和持久化

NServiceBus 支持多种消息传输和持久化技术，包括 SQL Server、RabbitMQ、Azure Service Bus 等。你可以根据项目的实际需求选择合适的技术。

例如，如果你使用 RabbitMQ 作为消息传输方式，可以如下配置：

endpointConfiguration.UseTransport<RabbitMQTransport>();

如果你选择使用 SQL Server 进行消息存储，可以进行如下配置：

endpointConfiguration.UsePersistence<SqlPersistence>();

三、NServiceBus 的可靠性特性

NServiceBus 提供了许多可靠性特性，使得它适合用于构建高可用性、可靠的分布式系统。

事务支持：NServiceBus 可以确保消息的处理是事务性的，保证数据的一致性。
自动重试机制：如果消息处理失败，NServiceBus 会自动重试处理，直到成功或达到最大重试次数。
死信队列（Dead-letter Queue）：无法成功处理的消息会被转移到死信队列中，方便后续调查和处理。
可靠的消息传递：NServiceBus 确保消息不会丢失，并支持消息顺序保证。

四、总结

在 .NET 8中使用 NServiceBus，你可以轻松构建高可靠、可扩展的分布式系统。NServiceBus 提供了强大的消息传递功能，支持事务管理、重试机制和事件驱动架构，使得服务间的通信更加灵活和可靠。

使用 NServiceBus 在 .NET 中构建分布式系统

在 .NET 中，NServiceBus 依然是构建可靠、可扩展、异步消息驱动架构的强大工具。本文将为你讲解如何在 .NET 环境下集成 NServiceBus，帮助你理解其核心概念及配置方法，并快速上手构建基于消息的系统。一、NServiceBus 简介 NServiceBus …...

编程日记 2025/4/28 13:18:18

【Linux网络与网络编程】13.五种 IO 模型

前言在前面的学习中，有一个问题一直没有展开来说，即 IO 问题。 IO 到底有多少种方式呢？什么是高效的 IO 呢？ IO 本质上就是 INPUT 和 OUTPUT 。在网络中 INPUT 就是从网卡中获取数据，而 OUTPUT 就是向网卡中发送数据…...

编程日记 2025/4/28 13:18:18

Java后端开发day37--源码解析：TreeMap可变参数--集合工具类：Collections

（以下内容全部来自上述课程） 1. TreeMap 1.1 须知 1.1.1 Entry 节点初始为黑色：提高代码阅读性 1.1.2 TreeMap中的成员变量 comparator：比较规则root：红黑树根节点的地址值size：集合的长度和红黑树…...

编程日记 2025/4/28 13:18:17

海关瑞数后缀分析 rs

声明本文章中所有内容仅供学习交流使用，不用于其他任何目的，抓包内容、敏感网址、数据接口等均已做脱敏处理，严禁用于商业用途和非法用途，否则由此产生的一切后果均与作者无关！ 逆向过程部分python代码 cp execj…...

编程日记 2025/4/28 13:17:13

【合新通信】---Mini单路光模块（Mini SFF/USOT)

产品特性 l 高可靠、全金属外壳、抗振动设计 l 紧凑的结构设计, 超小模块尺寸 l 可插拔标准LC单模光纤连接器接口，方便动态和灵活的配置数据连接 l 每通道工作速率可达1.25Gbps，速率可向下兼容 l 单路发射光纤通道，内置1310nm波长光发射…...

编程日记 2025/4/28 13:17:11

Java详解LeetCode 热题 100(02):LeetCode 49. 字母异位词分组（Group Anagrams）详解

文章目录 1. 题目描述2. 理解题目3. 解法一：排序法3.1 思路3.2 Java代码实现3.3 代码详解3.4 复杂度分析3.5 适用场景4. 解法二：计数法4.1 思路4.2 Java代码实现4.3 代码详解4.4 复杂度分析4.5 适用场景5. 解法三：字符串哈希法5.1 思路5.2 Java代码实现5.3 代码详解5.4 复杂…...

编程日记 2025/4/28 13:16:08

【每日随笔】文化属性 ① ( 天机 | 强势文化与弱势文化 | 文化属性的形成与改变 | 强势文化具备的特点 )

文章目录一、文化属性1、天机2、文化属性的强势文化与弱势文化强势文化弱势文化二、文化属性的形成与改变1、文化属性形成2、文化属性改变3、文化知识的阶层三、强势文化具备的特点一、文化属性 1、天机如果想要了解这个世界的底层架构 , 就需要掌握洞察事物本质的能…...

编程日记 2025/5/13 3:00:09

Java + Seleium4.X + TestNG自动化技术

系列文章目录文章目录系列文章目录前言一、 Java版Selenium自动化测试框架介绍和原理1.1 什么是Seleium1.2 特点1.3 注意点二、安装SeleiumChrome环境创建Maven项目2.1 安装Seleium Chrome环境2.2 Maven环境三、Selenium4.X UI元素定位实战3.1 ID选择器3.2 Name选择器3.…...

编程日记 2025/4/28 13:15:00

Spark SQL核心概念与编程实战：从DataFrame到DataSet的结构化数据处理

一、Spark-SQL是什么 Spark SQL 是 Spark 用于结构化数据(structured data)处理的 Spark 模块。二、Hive and SparkSQL SparkSQL 的前身是 Shark，Shark是给熟悉 RDBMS 但又不理解 MapReduce 的技术人员提供的快速上手的工具。 Hive 是早期唯一运行在 Hadoop 上的 S…...

编程日记 2025/4/28 13:15:00

electron-vite 应用打包自定义图标不显示问题

// 修改electron-builder.yml ... win:executableName: xxx //可执行文件名称icon: build/icon.ico //你的图标路径 ...打包后，自定义图标不显示原因: 1 cannot execute causeexit status 2，安装包无法生成用管理员身份运行，win11右击开始…...

编程日记 2025/4/28 13:14:59

AI中Token的理解与使用总结

AI中Token的理解与使用总结什么是Token 在AI领域，特别是自然语言处理(NLP)中，Token是指将文本分割成的最小处理单元。Tokenization(分词)是将原始文本分解为Token的过程。 Token的几种形式单词级Token：以单词为基本单位示例：“Hello world” → [“Hello”, “world”…...

编程日记 2025/4/28 13:13:54

C++/SDL 进阶游戏开发 —— 双人塔防（代号：村庄保卫战 14）

🎁个人主页：工藤新一 🔍系列专栏：C面向对象（类和对象篇） 🌟心中的天空之城，终会照亮我前方的路 🎉欢迎大家点赞👍评论📝收藏⭐文章文章目录二…...

编程日记 2025/4/28 13:13:53

全栈量子跃迁：当Shor算法破解RSA时，我们如何用晶格密码重构数字世界的信任基岩？

一、量子威胁的降维打击 1. Shor算法的毁灭性力量 # Shor算法量子电路简化示例（Qiskit实现） from qiskit import QuantumCircuit from qiskit.circuit.library import QFTdef shor_circuit(n: int, a: int) -> QuantumCircuit:qc QuantumCircuit(2…...

编程日记 2025/4/28 13:10:34

python实战项目65：drissionpage采集boss直聘数据

python实战项目65：drissionpage采集boss直聘数据一、需求简介二、流程分析三、完整代码一、需求简介 boss直聘网站近期改版，改版之后代码需要做相应的升级维护。drissionpage采集网页数据是一种不错的方式，笔者认为比Selenium好用，使用方法大家可以自行查阅资料。boss直聘…...

编程日记 2025/4/28 13:08:24

常用的性能提升手段--提纲

上一篇文章里，介绍了提升性能的一种优化手段：池化。这篇文章来归纳整理一下其他的常见的提升性能的手段 1. 缓存 (Caching) 缓存可以说是计算机领域的万金油了，它无处不在。举个最简单的例子，CPU -> L1,L2,L3 Cache -> 内存。 CPU的处理速度要比内存快几个数量…...

编程日记 2025/4/28 13:07:20

天梯——现代战争

第一次做的时候，直接暴力，显然最后超时。暴力代码如下： #include<bits/stdc.h> using namespace std; const int N10005; bool mark1[N]{0},mark2[N]{0}; int p[N][N]; int main(){int n,m,k,a,b;cin>>n>>m>>k;fo…...

编程日记 2025/4/28 13:06:14

Codeforces Round 1021 (Div. 2) D. Baggage Claim（建图）

每周五篇博客：（4/5） https://codeforces.com/contest/2098/problem/D 题意每个机场都有一个行李索赔区，巴尔贝索沃机场也不例外。在某个时候，Sheremetyevo的一位管理员提出了一个不寻常的想法：将行李索…...

编程日记 2025/4/28 13:06:13

常用第三方库：shared_preferences数据持久化

常用第三方库：shared_preferences数据持久化前言 shared_preferences是Flutter中最常用的轻量级数据持久化解决方案，它提供了一个简单的key-value存储机制，适合存储用户配置、应用设置等小型数据。本文将从实战角度深入讲解shared_prefere…...

编程日记 2025/4/28 13:04:03

项目驱动 CAN-bus现场总线基础教程》随笔

阅读：《项目驱动 CAN-bus现场总线基础教程》仲裁段的实现有感而发感觉出人意外之处感觉出人意外之处最近在阅读入门的CAN相关书籍时，在介绍仲裁段是如何实现各节点之间，通讯仲裁功能的章节中，有如下一段描述： …...

编程日记 2025/4/28 13:04:02

WPF之XAML基础

文章目录 XAML基础：深入理解WPF和UWP应用开发的核心语言1. XAML简介XAML与XML的关系 2. XAML语法基础元素语法属性语法集合语法附加属性 3. XAML命名空间命名空间映射关系 4. XAML标记扩展静态资源引用数据绑定相对资源引用常见标记扩展对比 5. XAML与代码的关系XAM…...

编程日记 2025/4/28 13:02:55

测试基础笔记第十四天

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档文章目录一、字符串1.字符串2.字符串切片3.查找find（）4.去除两端空白字符 strip5.字符串转换大小写 lower、upper5.拆分 split()6.字符串的其他常见方…...

编程日记 2025/4/28 13:02:54

Java详解LeetCode 热题 100(01):LeetCode 1. 两数之和（Two Sum）详解

文章目录 1. 题目描述2. 理解题目3. 解法一：暴力枚举法3.1 思路3.2 Java代码实现3.3 代码详解3.4 复杂度分析3.5 适用场景 4. 解法二：哈希表法4.1 思路4.2 Java代码实现4.3 代码详解4.4 复杂度分析4.5 适用场景 5. 解法三：两遍哈希表法5.1 思…...

编程日记 2025/4/28 13:01:50

机器学习之三：归纳学习

正如人们有各种各样的学习方法一样，机器学习也有多种学习方法。若按学习时所用的方法进行分类，则机器学习可分为机械式学习、指导式学习、示例学习、类比学习、解释学习等。这是温斯顿在1977年提出的一种分类方法。有关机器学习的基本概念，…...

编程日记 2025/4/28 12:57:33

AI声像融合守护幼儿安全——打骂/异常声音报警系统的智慧防护

幼儿园是孩子们快乐成长的摇篮，但打骂、哭闹或尖叫等异常事件可能打破这份宁静，威胁幼儿的身心安全。打骂/异常声音报警系统，依托尖端的AI声像融合技术，结合语音识别、情绪分析与视频行为检测，为幼儿园筑起一道智能安全…...

编程日记 2025/5/20 21:42:48

2024ICPC网络赛第二场题解

文章目录 F. Tourist(签到)I. Strange Binary(思维)J. Stacking of Goods(思维)A. Gambling on Choosing Regionals(签到)G. Game(数学)L. 502 Bad Gateway(数学)E. Escape(BFS)C. Prefix of Suffixes(kmp结论)K. match(01trie分治多项式乘法组合数) 题目链接 F. Tourist(签到…...

编程日记 2025/4/28 12:56:25

风控策略引擎架构设计全解析：构建智能实时决策系统

摘要本文深入探讨现代风控策略引擎的核心架构设计，结合金融反欺诈、电商交易风控等典型场景，详细解析实时决策、规则引擎、特征计算等关键技术模块的实现方案。通过分层架构设计、分布式计算优化、策略动态编排等创新方法，展示如何构建支撑每秒万级决策的高可用风控系统。…...

编程日记 2025/4/28 12:55:18

TensorFlow 安装全攻略

选择 TensorFlow 的原因： TensorFlow 是一个端到端平台，它提供多个抽象级别，因此您可以根据自己的需求选择合适的级别。您可以使用高阶 Keras API 构建和训练模型，该 API 让您能够轻松地开始使用 TensorFlow 和机器学习。如果您需…...

编程日记 2025/4/28 12:55:16

Dijkstra 算法代码步骤[leetcode.743网络延迟时间]

有 n 个网络节点，标记为 1 到 n。给你一个列表 times，表示信号经过有向边的传递时间。 times[i] (ui, vi, wi)，其中 ui 是源节点，vi 是目标节点， wi 是一个信号从源节点传递到目标节点的时间。现在，…...

编程日记 2025/4/28 12:54:14

Ubuntu22.04/24.04 P104-100 安装驱动和 CUDA Toolkit

硬件环境使用一块技嘉 B85m-DS3H 安装 P104-100, CPU是带集成显卡的i5-4690. 先在BIOS中设置好显示设备优先使用集成显卡(IGX). 然后安装P104-100开机. 登入Ubuntu 后查看硬件信息, 检查P104-100是否已经被检测到 # PCI设备 lspci -v | grep -i nvidia lspci | grep NVIDIA …...

编程日记 2025/4/28 12:53:07

Golang 学习指南

目录变量与常量数据类型与控制结构常用数据结构函数与错误处理指针与并发Gin 框架与 go mod小结与参考资料 1. 变量与常量变量（var） 用于定义可变的值。可以指定类型，也可以自动推断类型。示例：var name string "Golang…...

编程日记 2025/4/28 12:53:02

Ubuntu 磁盘空间占用清理（宝塔）

目录前言1. 基本知识2. 实战前言 🤟 找工作，来万码优才：👉 #小程序://万码优才/r6rqmzDaXpYkJZF 爬虫神器，无代码爬取，就来：bright.cn 本身自搭建了一个宝塔，突然一下子多了好些空…...

编程日记 2025/4/28 12:51:59

AntBio: 2025 AACR Meeting - Charting New Oncology Frontiers Together

AntBio cordially invites you to attend the 2025 AACR Annual Meeting and jointly chart a new course in oncology research! The global benchmark for cancer research and therapeutics—the 2025 American Association for Cancer Research (AACR) Annual Meeting—wi…...

编程日记 2025/4/28 12:51:53