.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

Wesley13
• 阅读 711

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; }    }}

启动程序,收发消息

.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

新建控制台程序 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}"));    });});

启动两个客户端,消息是轮询接收的

.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

消息 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

消息头

.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

最佳实践

尽量使用接口来定义消息类型,使用消息初始化器(有点困难)

使用类以及继承时需要特别注意:

  • 通过消费基类并利用多态行为来处理,总会遇到很多问题

  • 消息格式设计不是面向对象设计,消息中应该只包含状态而不应该包含行为

  • 大的基类也会产生很多问题,特别是在支持消息版本的时候

GitHub源码链接:

https://github.com/MINGSON666/Personal-Learning-Library/tree/main/ArchitectTrainingCamp

课程链接

.NET云原生架构师训练营讲什么,怎么讲,讲多久

欢迎各位读者加入微信群一起学习交流,

在公众号后台回复“加群”即可~~

.NET 云原生架构师训练营(模块二 基础巩固 RabbitMQ Masstransit 介绍)

本文分享自微信公众号 - DotNet NB(DotNetNB)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Stella981 Stella981
3年前
GitHub 上有哪些适合新手跟进的优质项目?
!(https://oscimg.oschina.net/oscnet/011f28e3bc332010e1442e6c00ed344805d.jpg)点击上方“迈微电子研发社”,选择“星标★”公众号重磅干货,第一时间送达!(https://oscimg.oschina.net/oscnet/cd44ba75f
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Stella981 Stella981
3年前
Docker 部署SpringBoot项目不香吗?
  公众号改版后文章乱序推荐,希望你可以点击上方“Java进阶架构师”,点击右上角,将我们设为★“星标”!这样才不会错过每日进阶架构文章呀。  !(http://dingyue.ws.126.net/2020/0920/b00fbfc7j00qgy5xy002kd200qo00hsg00it00cj.jpg)  2
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这