2020年9月16日星期三

.NET Core 下使用 RabbitMQ

介绍

RabbitMQ是一个开源的,基于AMQP(Advanced Message Queuing Protocol)协议的完整,可复用的企业级消息队列(Message Queue 一种应用程序与应用程序之间的一种通信方法)系统,RabbitMQ可以实现点对点,发布订阅等消息处理模式

  • 官网：https://www.rabbitmq.com/dotnet.html
  • 开源地址：https://github.com/rabbitmq/rabbitmq-dotnet-client

安装

  • docker下安装 RabbitMQ
  • 其他平台安装 RabbitMQ

为了开发方便，我在docker中安装了RabbitMQ，RabbitMQ安装完成后，默认端口打开地址为：

快速开始

接下来我们用RabbitMQ来完成一个比较常见的生产者和消费者模式的代码，新建两个控制台项目，RabbitMQConsumer和RabbitMQProducer。

分别在两个项目中安装组件

Install-Package RabbitMQ.Client

在RabbitMQProducer生产者项目中，添加以下代码。

using RabbitMQ.Client;using System;using System.Text;namespace RabbitMQProducer{ class Program {  static void Main(string[] args)  {   var factory = new ConnectionFactory()   {    HostName = "localhost",    Port = 5672,    UserName = "guest",    Password = "guest"   };   using var connection = factory.CreateConnection();   using var channel = connection.CreateModel();   var exchange = "msg_test";   channel.ExchangeDeclare(exchange, type: ExchangeType.Fanout);   for (int i = 0; i < 10000; i++)   {    var message = $"hello，我是生产者【{i + 1}】号";    var body = Encoding.UTF8.GetBytes(message);    channel.BasicPublish(exchange, routingKey: "", basicProperties: null, body: body);    Console.WriteLine($"- 发送消息：{message}");   }  } }}

模拟发出10000次消息，接下来在RabbitMQConsumer消费者项目中接收消息，代码如下：

using RabbitMQ.Client;using RabbitMQ.Client.Events;using System;using System.Text;namespace RabbitMQConsumer{ class Program {  static void Main(string[] args)  {   var factory = new ConnectionFactory()   {    HostName = "localhost",    Port = 5672,    UserName = "guest",    Password = "guest"   };   using var connection = factory.CreateConnection();   using var channel = connection.CreateModel();   var exchange = "msg_test";   channel.ExchangeDeclare(exchange, type: ExchangeType.Fanout);   var queueName = channel.QueueDeclare().QueueName;   channel.QueueBind(queue: queueName, exchange, routingKey: "");   Console.WriteLine("开始监听消息...");   while (true)   {    var consumer = new EventingBasicConsumer(channel);    consumer.Received += (model, ea) =>    {     byte[] body = ea.Body.ToArray();     var message = Encoding.UTF8.GetString(body);     Console.WriteLine($"- 接收到消息：{message}");    };    channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);   }  } }}

同时启动两个看看效果。

一闪而过，速度还是挺快的，更多操作可以查看官方教程：https://www.rabbitmq.com/getstarted.html

.NET Core 下使用 RabbitMQ
2016中国跨境电商大咖论坛第四季、 义乌跨境出口电商发展论坛-wish专场、 墩煌网、 纯干货，亚马逊批量上传产品步骤、 广州洋盒子、 亚马逊视频广告怎么做？5大绝招教你打造精美亚马逊视频广告！、 国产服装蹭"黑人运动"热度，公然在亚马逊出售犯众怒！、 Ali Inspector、 开通店铺、 百佬汇第二期黄埔训练营、 孙琦、 2018亚马逊黑色星期五临近，盘点英国消费者最喜爱的那些产品！、 规避高关税之中转港，你知道怎么操作吗？、 该品牌起诉了200多家店铺！主要涉及阿里国际站和亚马逊、 亚马逊开放图片位置上视频的新功能、 2018wish邮渠道汇总 、
发帖者 时间：