首页
/ 正文

使用 EasyNetQ 轻松进行 RabbitMQ 消息传递

更新时间: 2023-04-27 12:02:30

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;

《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前，星球内专栏累计输出 82w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 2800+ 小伙伴加入学习，欢迎点击围观

这篇文章是关于 EasyNetQ 的，这是一个用于将 RabbitMQ 与 .NET 结合使用的库。在撰写本文时，EasyNetQ 仍是预发布软件。尽管如此，一些人已经在生产环境中使用了一段时间。如果您在生产中使用它，则需要您自担风险。

去年八月，我写了“ 使用 .NET 开始使用 RabbitMQ ”。这说明了如何使用官方 RabbitMQ .NET 客户端库从 RabbitMQ 队列接收消息。

虽然这是一件非常好的事情，但通常更可取的是使用更高级别的库来处理小细节，并允许您以结构化的方式专注于实际的消息传递。嗯，这就是 EasyNetQ 存在的原因。使用 EasyNetQ，您不必担心序列化、消息传递模式、连接可靠性等问题。在本文的其余部分，我们将了解使用 EasyNetQ 发送和接收消息是多么容易。

我们需要做的第一件事当然是安装 EasyNetQ NuGet 包：

然后，让我们创建一个类来表示我们将要发送的消息。在这个例子中，我们假设我们正在发送游戏中玩家的位置：


 public class PlayerPosition
    {
        public int X { get; set; }
        public int Y { get; set; }
    }

一旦我们有了它，我们就可以订阅到达队列的消息。这是这样做的：


 public class PlayerPosition
    {
        public int X { get; set; }
        public int Y { get; set; }
    }

因此，您使用 RabbitHutch.CreateBus() 声明您的队列。 公共汽车 只是一个队列。那么什么是 RabbitHutch ？好吧，我能说什么呢？这是一个兔子笼子。

请注意我们如何专门订阅以接收 PlayerPosition 类型的消息。我们使用的是“MyGame”的 subscriptionId，我们还传递了一个处理程序，该处理程序指定如何处理收到的消息。如果语法看起来有点陌生，那是因为我使用了字符串插值，这是 C# 6.0 中引入的新 C# 语言功能。

当我们运行它时，我们可以看到创建了一个队列，其名称是根据消息类名和 subscriptionId 构建的：

现在为了了解队列中发生了什么，让我们暂时停止订阅者。

我们可以在队列中发送一条消息，如下所示：


 public class PlayerPosition
    {
        public int X { get; set; }
        public int Y { get; set; }
    }

请注意我们如何发送强类型对象（而不是松散字符串），我们将其作为通用参数提供。您当然可以省略通用参数，但为了清楚起见，我在上面包含了它。

我们现在可以从 RabbitMQ 管理 Web 界面的“获取消息”部分查看队列中的消息：

如您所见，我们发送的数据被序列化为 JSON，并且还附带了类型信息，以帮助 EasyNetQ 在接收端对其进行反序列化。

事实上，我们现在可以再次运行我们的订阅者，并看到它消费了消息：

因此，您可以看到 EasyNetQ 如何真正轻松地专注于消息传递并将细节留给它。自然地，您可以使用 EasyNetQ 做的事情比这篇介绍性文章所说明的要多得多。查看 EasyNetQ 文档了解更多信息。