MassTransit

大鸿

简介

MassTransit 是一个免费的、开源的.NET 分布式应用程序框架。MassTransit 使创建应用程序和服务变得容易，这些应用程序和服务利用基于消息的松散耦合异步通信来实现更高的可用性、可靠性和可扩展性

特点

•易于使用和理解的 API，让您专注于解决业务问题•使用 RabbitMQ、Azure 服务总线、ActiveMQ 和 Amazon SQS/SNS 部署您的解决方案，无需重写•强大的消息模式•端到端解决方案•内存测试工具，用于创建具有全面集成测试级别验证的快速单元测试•对分布式跟踪以及监控
使用

安装 MassTransit 模板

MassTransit 包括项目和项目模板，简化了新项目的创建。dotnet new -i MassTransit.Templates通过在控制台执行来安装模板。
dotnetnew-iMassTransit.Templates初始项目创建

要使用 MassTransit 创建服务，请通过命令提示符创建Worker
$dotnetnewmtworker-nGettingStarted $cdGettingStarted $dotnetnewmtconsumer代码概述

打开项目时，您会看到有 3 个类文件。Program.cs是标准入口点，在这里我们配置主机生成器。Consumers/GettingStartedConsumer.cs是运输消费者 Contracts/GettingStarted.cs是一个示例消息
添加后台服务

namespaceGettingStarted;  usingSystem; usingSystem.Threading; usingSystem.Threading.Tasks; usingContracts; usingMassTransit; usingMicrosoft.Extensions.Hosting;  publicclassWorker:BackgroundService { readonlyIBus_bus;  publicWorker(IBusbus) { _bus=bus; }  protectedoverrideasyncTaskExecuteAsync(CancellationTokenstoppingToken) { while(!stoppingToken.IsCancellationRequested) { await_bus.Publish(newGettingStarted{Value=$"Thetimeis{DateTimeOffset.Now}"},stoppingToken);  awaitTask.Delay(1000,stoppingToken); } } }注册Work

在方法Program.cs的底部ConfigureServices添加
services.AddHostedService<Worker>();更新消费者

在您的Consumers文件夹中，GettingStartedConsumer使用如下所示的日志记录语句进行编辑。
namespaceGettingStarted.Consumers;  usingSystem.Threading.Tasks; usingContracts; usingMassTransit; usingMicrosoft.Extensions.Logging;  publicclassGettingStartedConsumer: IConsumer<GettingStarted> { readonlyILogger<GettingStartedConsumer>_logger;  publicGettingStartedConsumer(ILogger<GettingStartedConsumer>logger) { _logger=logger; }  publicTaskConsume(ConsumeContext<GettingStarted>context) { _logger.LogInformation("ReceivedText:{Text}",context.Message.Value); returnTask.CompletedTask; } }###运行项目 输出应该已更改以显示生成输出的消息使用者（再次按 Control+C 退出）。
Building... info:MassTransit[0] ConfiguredendpointMessage,Consumer:GettingStarted.MessageConsumer info:MassTransit[0] Busstarted:loopback://localhost/ info:Microsoft.Hosting.Lifetime[0] Applicationstarted.PressCtrl+Ctoshutdown. info:Microsoft.Hosting.Lifetime[0] Hostingenvironment:Development info:Microsoft.Hosting.Lifetime[0] Contentrootpath:/Users/chris/Garbage/start/GettingStarted info:GettingStarted.MessageConsumer[0] ReceivedText:Thetimeis3/24/202112:02:01PM-05:00 info:GettingStarted.MessageConsumer[0] ReceivedText:Thetimeis3/24/202112:02:02PM-05:00


Github地址

https://github.com/MassTransit/MassTransit

最后大家如果喜欢我的文章，还麻烦给个关注并点个赞, 希望net生态圈越来越好！

技术群：添加小编微信并备注进群

小编微信：mm1552923
公众号：dotNet编程大全  

无以致远

占坑编辑ing