揭阳专业网站制作公司,工程公司有哪些职位,浙江建设信息港 官网,建设银行网站账户注销介绍
RabbitMQ是一个开源的消息队列系统#xff0c;实现了高级消息队列协议#xff08;AMQP#xff09;。
#x1f340;RabbitMQ起源于金融系统#xff0c;现在广泛应用于各种分布式系统中。它的主要功能是在应用程序之间提供异步消息传递#xff0c;实现系统间的解耦和…介绍
RabbitMQ是一个开源的消息队列系统实现了高级消息队列协议AMQP。
RabbitMQ起源于金融系统现在广泛应用于各种分布式系统中。它的主要功能是在应用程序之间提供异步消息传递实现系统间的解耦和消息的可靠传递。RabbitMQ使用Erlang语言开发支持多种客户端语言如Python、Ruby、.NET、Java等。
此外RabbitMQ具有以下特点
易用性提供了简单易用的API使得生产者和消费者可以方便地发送和接收消息。扩展性可以水平扩展以处理大量的消息支持集群部署来提高系统的吞吐量和可用性。高可用性通过镜像队列等机制保证消息不会因服务器故障而丢失确保了系统的稳健运行。多种交换模式支持直接交换、扇形交换、主题交换和头交换等多种交换模式满足不同的消息路由需求。多协议支持除了AMQP协议还支持STOMP等其他消息协议。
在docker中部署RabbitMQ
首先在dockerHub中找到RabbitMQ的镜像
rabbitmq - 官方图片 (docker.com)
执行命令拉取镜像
docker pull rabbitmq
镜像拉取完成之后启动镜像
docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq
此时我们打开 http://localhost:15672/会发现无法访问这是因为管理插件还未被激活 通过docker ps -a查看部署的RabbitMQ容器id在通过使用命令 docker exec -it 容器id /bin/bash
进入容器内部再运行rabbitmq-plugins enable rabbitmq_management 此时就可以打开管理插件了第一次使用 RabbitMQ 管理界面需要使用默认的用户名和密码 guest/guest来登录 消息队列简单模式直连交换机
simple模式是RabbitMQ最简单的一种模式如下图所示只有一个生产者一个消费者和一个队列 生产者和消费者在发送和接受消息时只需要指定队列名而不需要指定发送到哪个Exchange
生产者代码
class MyClass
{public static void Main(string[] args){var factory new ConnectionFactory();factory.HostName localhost; //RabbitMQ服务在本地运行factory.UserName guest; //用户名factory.Password guest; //密码//创建连接using (var connection factory.CreateConnection()){//创建通道using (var channel connection.CreateModel()){//声明一个名称为hello的消息队列channel.QueueDeclare(hello, false, false, false, null); for (int i 0; i 5; i){string message Hello Word ! i; //传递的消息内容var body Encoding.UTF8.GetBytes(message);//此处的参数hello 就对应的就是上面声明的消息队列的路由键channel.BasicPublish(, hello, null, body); //开始传递Console.WriteLine(已发送 {0}, message);}}}}
}
消费者代码自动模式
class MyClass
{static void Main(string[] args){//创建连接工厂var factory new ConnectionFactory();factory.HostName localhost;factory.UserName guest;factory.Password guest;//创建连接using (var connection factory.CreateConnection()){//创建通道using (var channel connection.CreateModel()){//声明队列channel.QueueDeclare(hello, false, false, false, null);//事件的基本消费者var consumer new EventingBasicConsumer(channel);consumer.Received (model, ea) {var body ea.Body.ToArray();var message Encoding.UTF8.GetString(body);Console.WriteLine(已接收 {0}, message);//发送消息确认信号手动确认 //channel.BasicAck(ea.DeliveryTag,false);};//当 autoAck设置为true时也就是自动确认模式一旦消息队列将消息发送给消息消费者后就会从内存中将这个消息删除。//当autoAck设置为false时也就是手动模式如果此时的有一个消费者宕机消息队列就会将这条消息继续发送给其他的消费者这样数据在消息消费者集群的环境下就不会不丢失了。channel.BasicConsume(hello, true, consumer);Console.ReadKey();}}}
}
在消费者代码中要注意的是autoAck设置为true时也就是自动确认模式的时候要去掉手动发送确认信号代码channel.BasicAck(ea.DeliveryTag,false);
代码调试 在代码执行到
channel.QueueDeclare(hello, false, false, false, null); 声明一个消息队列时在RabbitMQ的可视化界面就可以看见多了一个名称为hello的消息队列 当执行完五次消息传递时点击上图的hello消息队列Messages:设置为5然后点击Get Messages就可以看到传递过来的5条消息队列了 此时我们执行消费者代码因为autoAck设置为true了当消息队列将消息发送给消费者后就会立马将消息删除此时再点击Get Messages就会提示Queue is empty 消费者代码手动模式
在手动模式中我们将原来声明的队列删除调然后将生产者与消费者的声明队列代码中的第二个参数都改为true意味着这个队列是持久的。在 RabbitMQ 服务器重启之后持久的队列和它的消息都不会丢失
channel.QueueDeclare(hello, true, false, false, null);
然后添加一行代码设置当前消费者的预取模式为只预取一条消息
channel.BasicQos(0, 1, false); 接着是 发送消息确认信号 与 开启手动确认模式
channel.BasicAck(ea.DeliveryTag,false);
channel.BasicConsume(hello, false, consumer);
要注意的地方是一定要在结尾处加上下方代码否则可能会出现还没发送消息确认信号进程就结束了这时就会发现将接收到的helloword打印到控制台了去RabbitMQ可视乎管理界面发现事件还未被消耗掉。
Console.ReadKey(); static void Main(string[] args){//创建连接工厂var factory new ConnectionFactory();factory.HostName localhost;factory.UserName guest;factory.Password guest;//创建连接using (var connection factory.CreateConnection()){//创建通道using (var channel connection.CreateModel()){//声明队列channel.QueueDeclare(hello, true, false, false, null);channel.BasicQos(0, 1, false);//事件的基本消费者var consumer new EventingBasicConsumer(channel);consumer.Received (model, ea) {var body ea.Body.ToArray();var message Encoding.UTF8.GetString(body);Console.WriteLine(已接收 {0}, message);//发送消息确认信号手动确认 channel.BasicAck(ea.DeliveryTag,false);};//当 autoAck设置为true时也就是自动确认模式一旦消息队列将消息发送给消息消费者后就会从内存中将这个消息删除。//当autoAck设置为false时也就是手动模式如果此时的有一个消费者宕机消息队列就会将这条消息继续发送给其他的消费者这样数据在消息消费者集群的环境下就不会不丢失了。channel.BasicConsume(hello, false, consumer);Console.ReadKey();}}}
代码调试
按照上面改成手动模式后消费者只预取一条消息如下图0、1、2被消费掉了此时再去RabbitMQ的可视乎管理界面点击GetMessage只剩下3、4的消息内容了
