电子科技公司网站,链交换反应,建设通官方网站,深圳著名设计网站简介MassTransit 是一个免费的、开源的.NET 分布式应用程序框架。MassTransit 使创建应用程序和服务变得容易#xff0c;这些应用程序和服务利用基于消息的松散耦合异步通信来实现更高的可用性、可靠性和可扩展性特点•易于使用和理解的 API#xff0c;让您专注于解决业务问题… 简介MassTransit 是一个免费的、开源的.NET 分布式应用程序框架。MassTransit 使创建应用程序和服务变得容易这些应用程序和服务利用基于消息的松散耦合异步通信来实现更高的可用性、可靠性和可扩展性特点•易于使用和理解的 API让您专注于解决业务问题•使用 RabbitMQ、Azure 服务总线、ActiveMQ 和 Amazon SQS/SNS 部署您的解决方案无需重写•强大的消息模式•端到端解决方案•内存测试工具用于创建具有全面集成测试级别验证的快速单元测试•对分布式跟踪以及监控使用安装 MassTransit 模板MassTransit 包括项目和项目模板简化了新项目的创建。dotnet new -i MassTransit.Templates通过在控制台执行来安装模板。dotnet new -i MassTransit.Templates初始项目创建要使用 MassTransit 创建服务请通过命令提示符创建Worker$ dotnet new mtworker -n GettingStarted
$ cd GettingStarted
$ dotnet new mtconsumer代码概述打开项目时您会看到有 3 个类文件。Program.cs是标准入口点在这里我们配置主机生成器。Consumers/GettingStartedConsumer.cs是运输消费者 Contracts/GettingStarted.cs是一个示例消息添加后台服务namespace GettingStarted;using System;
using System.Threading;
using System.Threading.Tasks;
using Contracts;
using MassTransit;
using Microsoft.Extensions.Hosting;public class Worker : BackgroundService
{readonly IBus _bus;public Worker(IBus bus){_bus bus;}protected override async Task ExecuteAsync(CancellationToken stoppingToken){while (!stoppingToken.IsCancellationRequested){await _bus.Publish(new GettingStarted { Value $The time is {DateTimeOffset.Now} }, stoppingToken);await Task.Delay(1000, stoppingToken);}}
}注册Work在方法Program.cs的底部ConfigureServices添加services.AddHostedServiceWorker();更新消费者在您的Consumers文件夹中GettingStartedConsumer使用如下所示的日志记录语句进行编辑。namespace GettingStarted.Consumers;using System.Threading.Tasks;
using Contracts;
using MassTransit;
using Microsoft.Extensions.Logging;public class GettingStartedConsumer :IConsumerGettingStarted
{readonly ILoggerGettingStartedConsumer _logger;public GettingStartedConsumer(ILoggerGettingStartedConsumer logger){_logger logger;}public Task Consume(ConsumeContextGettingStarted context){_logger.LogInformation(Received Text: {Text}, context.Message.Value);return Task.CompletedTask;}
}###运行项目 输出应该已更改以显示生成输出的消息使用者再次按 ControlC 退出。Building...
info: MassTransit[0]Configured endpoint Message, Consumer: GettingStarted.MessageConsumer
info: MassTransit[0]Bus started: loopback://localhost/
info: Microsoft.Hosting.Lifetime[0]Application started. Press CtrlC to shut down.
info: Microsoft.Hosting.Lifetime[0]Hosting environment: Development
info: Microsoft.Hosting.Lifetime[0]Content root path: /Users/chris/Garbage/start/GettingStarted
info: GettingStarted.MessageConsumer[0]Received Text: The time is 3/24/2021 12:02:01 PM -05:00
info: GettingStarted.MessageConsumer[0]Received Text: The time is 3/24/2021 12:02:02 PM -05:00Github地址https://github.com/MassTransit/MassTransit最后大家如果喜欢我的文章还麻烦给个关注并点个赞, 希望net生态圈越来越好
