基于EasyNetQ操作 _RabbitMQ_ 的Demo项目-基于.net使用获取主题

**基于EasyNetQ操作 RabbitMQ 的 Demo项目**

在本文中，我们将展示如何使用 EasyNetQ 库来与 RabbitMQ 进行通信。EasyNetQ 是一个用于 .NET 的 RabbitMQ 客户端库，提供了一个简单易用的 API 来发送和接收消息。

**安装依赖项**

首先，我们需要安装 EasyNetQ NuGet 包：

Install-Package EasyNetQ

**创建 RabbitMQ 连接**

下一步是创建一个 RabbitMQ 连接。我们可以使用 `IBus` 接口来实现这一点：

csharpusing EasyNetQ;

public class RabbitMqConnection : IBus{
 private readonly IConnection _connection;

 public RabbitMqConnection(string host, string username, string password)
 {
 var connectionFactory = new ConnectionFactory { HostName = host };
 _connection = connectionFactory.CreateConnection(username, password);
 }

 public void Publish(T message) where T : class {
 using (var channel = _connection.CreateModel())
 {
 channel.BasicPublish(exchange: "", routingKey: typeof(T).Name, body: message);
 }
 }

 public void Subscribe(Action handler) where T : class {
 using (var channel = _connection.CreateModel())
 {
 var queue = typeof(T).Name;
 channel.QueueDeclare(queue, exclusive: true);

 channel.BasicConsume(queue: queue,
 onMessage: (model, message) =>
 {
 var body = message.Body;
 handler((T)body);
 });
 }
 }

 public void Dispose()
 {
 _connection.Dispose();
 }
}

在上面的代码中，我们创建了一个 `RabbitMqConnection` 类，实现了 `IBus` 接口。这个类负责连接到 RabbitMQ服务器，并提供发布和订阅消息的功能。

**发送消息**

要发送消息，我们可以使用 `Publish` 方法：

csharppublic class Message : IClassifyableMessage{
 public string Text { get; set; }
}

// 发送消息var message = new Message { Text = "Hello, world!" };
bus.Publish(message);

在上面的代码中，我们创建了一个 `Message` 类，实现了 `IClassifyableMessage` 接口。然后，我们使用 `Publish` 方法发送这个消息。

**接收消息**

要接收消息，我们可以使用 `Subscribe` 方法：

csharp// 订阅消息bus.Subscribe(message =>
{
 Console.WriteLine($"Received message: {message.Text}");
});

在上面的代码中，我们订阅了一个 `Message` 类型的消息，并且当接收到这个类型的消息时，会打印出消息内容。

**总结**

在本文中，我们展示了如何使用 EasyNetQ 库来与 RabbitMQ 进行通信。我们创建了一个 RabbitMQ 连接，发送和接收消息，并订阅了一个特定类型的消息。EasyNetQ 提供了一种简单易用的 API 来发送和接收消息，使得开发者可以专注于业务逻辑，而不是花费时间在底层细节上。

**参考**

* EasyNetQ NuGet 包： />* RabbitMQ 文档：