PCB RabbitMQ的安装使用

随着公司加大力度信息化建设，PCB企业各种各样的系统软件越来越多,整个公司订单流状态监控变得越来越不可控,是时候需采用新的方式来收集各系统状态节点状态了,以下记录RabbitMQ安装使用:

一.RabbitMQ简介

RabbitMQ作为一个消息代理，主要和消息打交道，负责接收并转发消息。RabbitMQ提供了可靠的消息机制、跟踪机制和灵活的消息路由，支持消息集群和分布式部署。适用于排队算法、秒杀活动、消息分发、异步处理、数据同步、处理耗时任务、CQRS等应用场景

二.RabbitMQ环境搭建

1.安装Erlang运行环境

Rabbit MQ 是建立在强大的Erlang OTP平台上，因此安装Rabbit MQ的前提是安装Erlang

下载并安装 Erlang OTP For Windows (vR16B03)

2.安装RabbitMQ

下载并安装 Rabbit MQ Server Windows Installer (v3.2.3)

3.安装管理平台插件

rabbitmq-plugins enable rabbitmq_management

4.重启RabbitMQ服务

net stop RabbitMQ && net start RabbitMQ

5.安装RabbitMQ界面

安装插件与重启服务

MQ启动

MQ服务:

三.RabbitMQ界面

1.RabbitMQ网址:

http://localhost:15672

默认账号和密码：guest guest

2.主界面

3.增加用户

4.配置用户权限

四.C# 发送消息与接受消息

1.发送消息

        /// <summary>

        /// 连接配置

        /// </summary>

        private static readonly ConnectionFactory rabbitMqFactory = new ConnectionFactory()

        {

            HostName = "127.0.1.1",

            UserName = "pcbren",

            Password = "abc+2015",

            Port =

        };

        /// <summary>

        /// 路由名称

        /// </summary>

        const string ExchangeName = "pcbren.exchange";

        /// <summary>

        ///队列名称

        /// </summary>

        const string QueueName = "pcbren.queue";

        static void Main(string[] args)

        {

            using (IConnection conn = rabbitMqFactory.CreateConnection())

            {

                using (IModel channel = conn.CreateModel())

                {

                    channel.ExchangeDeclare(ExchangeName, "direct", durable: true, autoDelete: false, arguments: null);

                    channel.QueueDeclare(QueueName, durable: true, autoDelete: false, exclusive: false, arguments: null);

                    channel.QueueBind(QueueName, ExchangeName, routingKey: QueueName);

                    var props = channel.CreateBasicProperties();

                    props.Persistent = true;

                    string vadata = Console.ReadLine();

                    while (vadata != "exit")

                    {

                        var msgBody = Encoding.UTF8.GetBytes(vadata);

                        channel.BasicPublish(exchange: ExchangeName, routingKey: QueueName, basicProperties: props, body: msgBody);

                        Console.WriteLine(string.Format("发送时间:{0}，发送完成", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")));

                        vadata = Console.ReadLine();

                    }

                }

            }

        }

2.接收消息

        /// <summary>

        /// 连接配置

        /// </summary>

        private static readonly ConnectionFactory rabbitMqFactory = new ConnectionFactory()

        {

            HostName = "127.0.1.1",

            UserName = "pcbren",

            Password = "abc+2015",

            Port =

        };

        /// <summary>

        /// 路由名称

        /// </summary>

        const string ExchangeName = "pcbren.exchange";

        /// <summary>

        ///队列名称

        /// </summary>

        const string QueueName = "pcbren.queue";

        static void Main(string[] args)

        {

            using (IConnection conn = rabbitMqFactory.CreateConnection())

            {

                using (IModel channel = conn.CreateModel())

                {

                    channel.QueueDeclare(QueueName, durable: true, autoDelete: false, exclusive: false, arguments: null);

                    var consumer = new EventingBasicConsumer(channel);

                    consumer.Received += (model, MQ) =>

                    {

                        var msgBody = Encoding.UTF8.GetString(MQ.Body);

                        Console.WriteLine(string.Format("接收时间:{0}，消息内容：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), msgBody));

                        channel.BasicAck(deliveryTag: MQ.DeliveryTag, multiple: false); //消息确认后，MQ服务端才将此消息清除

                    };

                    channel.BasicConsume(QueueName, false, consumer: consumer);

                    Console.ReadKey();

                }

            }

        }

五.RabbitMQ消息循环调度

使用消列队列的好处就是它能够并行的处理队列。当一个消息接受端处理不过来时,我们只需要增加多个消息接收处理者。下图展示两个消息接收端，等待消息接收，再启动一个消息发送端进行消息发送。

从下图中可知，循环发送6条信息依次的分派给2个客户端,每个客户端平均接收到3条消息
默认情况下:RabbitMQ这种分发消息的方式叫做循环（round-robin）。

六.RabbitMQ消息持久化

巴特西

PCB RabbitMQ的安装使用

最新文章

热门文章