EasyNetQ-用于使用 RabbitMQ 的 .NET API开源的工具库

Posted dotNET跨平台

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了EasyNetQ-用于使用 RabbitMQ 的 .NET API开源的工具库相关的知识,希望对你有一定的参考价值。

Part1介绍

EasyNetQ 的目标是提供一个库,用于在 .NET 中使用 RabbitMQ 尽可能简单。为了做到这一点,它通过强制执行一些简单的约定来以灵活性换取简单性。这些包括:

消息应该由 .NET 类型表示。消息应按其 .NET 类型进行路由。这意味着消息是由 .NET 类定义的。您要发送的每种不同的消息类型都由一个类表示。该类必须是公共的,必须具有默认构造函数和公共读/写属性。您通常不会在消息中实现任何功能,而是将其视为简单的数据容器或数据传输对象 (DTO)。

默认情况下,EasyNetQ 使用 Newtonsoft.Json 库将 .NET 类型序列化为 JSON。

Part2API设计

EasyNetQ 是在 RabbitMQ.Client 库之上提供服务的组件集合。它们执行序列化、错误处理、线程编组、连接管理等操作。它们由 mini-IoC 容器组成。您可以很容易地用您自己的实现替换任何组件。因此,如果您想要 XML 序列化而不是内置 JSON,只需编写 ISerializer 的实现并将其注册到容器中。

这些组件以 IAdvancedBus API 为前端。这看起来很像 AMQP 规范,实际上您可以从这个 API 运行大多数 AMQP 方法。此 API 对您隐藏的唯一 AMQP 概念是通道。这是因为通道是一个令人困惑的低级概念,一开始就不应该成为 AMQP 规范的一部分。老实说,“高级”对于这个 API 来说并不是一个很好的名字,“Iamqp”会好得多。

位于高级 API 之上的是一组消息传递模式:发布/订阅、请求/响应和发送/接收。这是 EasyNetQ 的“主见”部分。这是我们对如何实施这些模式的看法。灵活性很小;要么你接受我们的做事方式,要么你不使用它。目的是您,用户,不必花费脑力去重新发明相同的模式;您不必在每次只想发布和订阅消息时都做出选择。它旨在实现 EasyNetQ 的核心目标,即尽可能轻松地使用 RabbitMQ。

这些模式位于 IBus API 后面。再一次,这是一个糟糕的名字,它与消息总线的概念几乎没有关系。更好的名称是 IPackagedMessagePatterns。

IBus 旨在为 80% 的用户、80% 的时间工作。这并不详尽。如果您要实现的模式不是由 IBus 提供的,那么您应该使用 IAdvancedBus。这样做没有问题,EasyNetQ 就是这样设计的。

Part3为什么我需要 EasyNetQ?

RabbitMQ 不是已经有 .NET 客户端了吗?

那么为什么我需要 EasyNetQ?RabbitMQ .NET 客户端实现了 AMQP 协议的客户端(而 RabbitMQ 实现了服务器端)。AMQP 旨在作为消息传递的 HTTP。它被设计成跨平台和语言无关的。它还旨在灵活地支持基于 Exchange/Binding/Queue 模型的各种消息传递模式。

拥有这种灵活性很棒,但随着灵活性而来的是复杂性。这意味着您需要编写大量代码才能实现 RabbitMQ 客户端。通常,此代码将包括:

实现消息传递模式,例如发布/订阅或请求/响应。虽然,公平地说,.NET 客户端确实在这里提供了一些支持。实施路由策略。您将如何设计交换队列绑定,以及如何在生产者和消费者之间路由消息?实现消息序列化/反序列化。您将如何将 AMQP 中消息的二进制表示转换为您的编程语言可以理解的内容?为订阅实现消费者线程。您需要有一个专门的消费者循环来等待您订阅的消息。您将如何处理多个订阅者或临时订阅者,例如等待请求响应的订阅者?实施订户重新连接。如果连接中断或 RabbitMQ 服务器弹跳,您如何检测它并确保重建所有订阅?了解并实施服务质量设置。您需要进行哪些设置以确保您拥有可靠的客户端。实施错误处理策略。如果您的客户端收到格式错误的消息,或者抛出意外异常,您应该怎么做?实施发布者确认可靠消息传递。EasyNetQ 旨在将所有这些问题封装在一个简单易用的库中,该库位于现有 AMQP 客户端之上。它是 RabbitMQ 在大容量商业环境中几年使用经验的结晶。

Part4简单使用

接到 RabbitMQ 代理

var bus = RabbitHutch.CreateBus("host=localhost");

发布消息

await bus.PubSub.PublishAsync(message);

发布一条延迟5秒的消息

await bus.Scheduler.FuturePublishAsync(message, TimeSpan.FromSeconds(5));

订阅消息

await bus.PubSub.SubscribeAsync<MyMessage>(
        "my_subscription_id", msg => Console.WriteLine(msg.Text)
    );

RPC 服务器

await bus.Rpc.RespondAsync<TestRequestMessage, TestResponseMessage>(request =>
        new TestResponseMessage Text = request.Text + " all done!" 
    );

Part5地址

https://github.com/EasyNetQ/EasyNetQ

以上是关于EasyNetQ-用于使用 RabbitMQ 的 .NET API开源的工具库的主要内容,如果未能解决你的问题,请参考以下文章

如何使用 EasyNetQ / RabbitMQ 进行错误处理

简单易用的.NET免费开源RabbitMQ操作组件EasyNetQ

easyNetq demo

EasyNetQ异常处理

RabbitMQ完整例子+系列教程

EasyNetQ在.Net5中的应用