.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)--学习笔记
2024-09-23 17:12:39
2.6.6 RabbitMQ -- Masstransit 介绍
- Masstransit 是什么
- Quickstart
- 消息 Message
Masstransit 是什么
Masstransit 是一个 .NET 免费开源的分布式应用框架
- 集成多种消息中间件(Rabbitmq, Azure, Service Bus, ActiveMQ, Kafka, In-Memory)
- 强大且完整的消息模式(发布与订阅,saga,event-driven state machine,最终一致性支持)
- 端到端解决方案(消息路由,异常,重试,并发控制,连接与消费生命周期管理)
- 使用简单
- 单元测试友好
- 内置监控
Quickstart
新建控制台程序 mt-001,引入 Masstransit 包
namespace mt_001
{
class Program
{
static async Task Main(string[] args)
{
var bus = Bus.Factory.CreateUsingInMemory(sbc =>
{
sbc.ReceiveEndpoint("test_queue", ep =>
{
ep.Handler<Message>(context => Console.Out.WriteLineAsync($"Received: {context.Message.Text}"));
});
});
await bus.StartAsync();// This is important !
await bus.Publish(new Message { Text = "Hi" });
Console.WriteLine("Please input your message with enter:");
string message = Console.ReadLine();
while (message != "EXIT")
{
await bus.Publish(new Message() {Text = message});
message = Console.ReadLine();
}
await bus.StopAsync();
Console.WriteLine("Hello World!");
}
}
public class Message
{
public string Text { get; set; }
}
}
启动程序,收发消息
新建控制台程序 mt-002,引入 MassTransit.RabbitMQ 包
方法改为 CreateUsingRabbitMq,并且添加 rabbitmq host
var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
{
sbc.Host("rabbitmq://localhost");
sbc.ReceiveEndpoint("test_queue", ep =>
{
ep.Handler<Message>(context => Console.Out.WriteLineAsync($"Received: {context.Message.Text}"));
});
});
启动两个客户端,消息是轮询接收的
消息 Message
- 消息
- 消息类型
- 消息头
- 最佳实践
消息
MassTransit 使用 C# 强类型来定义,一个消息可以被定义为接口,通常我们也称之为消息契约
消息分为 command 命令与 event 事件,分别对应 send 和 publish 方法
在不同项目里面创建类来消费消息时确保命名空间一致,否则消费不到
命名空间:Company.Application.Contracts
namespace Company.Application.Contracts
{
using System;
public interface UpdateCustomerAddress
{
Guid CommandId { get; }
DateTime Timestamp { get; }
string CustomerId { get; }
string HouseNumber { get; }
string Street { get; }
string City { get; }
string State { get; }
string PostalCode { get; }
}
}
消息类型
Command
- 通过 send 发送到一个 endpoint
Event
- 通过 publish,不直接发送到 endpoint,发布到多个消费者
- 通常以名称短语(过去式的形式来命名)比如 OrderCreatedEvent, OrderSubmitted, OrderPaid, OrderDeliveried
消息头
最佳实践
尽量使用接口来定义消息类型,使用消息初始化器(有点困难)
使用类以及继承时需要特别注意:
- 通过消费基类并利用多态行为来处理,总会遇到很多问题
- 消息格式设计不是面向对象设计,消息中应该只包含状态而不应该包含行为
- 大的基类也会产生很多问题,特别是在支持消息版本的时候
https://github.com/MINGSON666/Personal-Learning-Library/tree/main/ArchitectTrainingCamp
本作品采用知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议进行许可。
欢迎转载、使用、重新发布,但务必保留文章署名 郑子铭 (包含链接: http://www.cnblogs.com/MingsonZheng/ ),不得用于商业目的,基于本文修改后的作品务必以相同的许可发布。
如有任何疑问,请与我联系 (MingsonZheng@outlook.com) 。
最新文章
- android 去掉actionbar 的虚线
- ICP 算法
- RealSense开发-Session和SenseManager的几种创建方法
- Scala练习(二)
- J2EE修炼之四书五经[转自2004年程序员]
- 【Linux_Fedora_应用系列】_5_如何安装XZ Utils 解压缩工具以及利用 xz工具来解压缩.xz文件
- MyBatis_ibatis和mybatis的区别【转】
- Codeforces Round #329 (Div. 2) D. Happy Tree Party LCA/树链剖分
- 初识DeepLearning4j
- js&;jquery验证邮箱和手机号是否正确范例
- javascript对时间的校验操作
- linux删除软链接文件【原创】
- Android Studio教程08-与其他app通信
- mybatis查询语句的背后
- 关于java中为什么尽量把受检异常转化为非受检异常
- vs2012中如何显示代码行号
- ML: 降维算法-LLE
- JSTL标签用法:<;c:choose>;<;c:forEach>;<;c:if>;<;c:when>;<;c:set>;
- 如何在taro的map循环中使用if条件渲染
- 【HTML5】实现QQ聊天气泡效果
热门文章
- 华大MCU单片机之HC32F003/HC32F005 hc32f005_ddl_Rev1.9.0 Lite精简版库使用心得
- 网站开发学习Python实现-Django的models学习-生鲜项目(6.3.2)
- P2240 【深基12.例1】部分背包问题
- Codis集群相关
- 你真的理解了java单例模式吗?讲别人都忽略的细节!
- Git简易教程-安装及简单使用
- 老吕教程--01后端Node.js框架搭建(安装调试KOA2)
- 唐诗宋词APP
- 常见的JS手写函数汇总(代码注释、持续更新)
- Java安全之初探weblogic T3协议漏洞