消息队列 #
-
MQ是消息队列服务器，产品：ActiveMQ，RabbitMQ，RocketMQ，Kafka……
-
消息队列（Message Queue，简称MQ），从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已
-
RabbitMQ是一个由erlang开发的基于AMQP（Advanced Message Queue Protocol）协议的开源实现。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面都非常的优秀。是当前最主流的消息中间件之一
应用场景 #
1、异步处理 #
当用户注册，给邮箱和手机都发送验证信息
用户注册需要50ms、发邮箱需要50ms、发手机需要50ms，总共需要150ms
用户注册后、将发邮箱和发手机都放到消息队列中，可以通过消息队列进行异步处理,总共可以节省50ms
2、程序解耦 #
多应用间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败
3、限流削峰 #
广泛应用于秒杀或抢购活动中，避免流量过大导致应用系统挂掉的情况
RabbitMQ选型和对比 #
1.从社区活跃度 #
按照目前网络上的资料，RabbitMQ 、activeM 、ZeroMQ 三者中，综合来看，RabbitMQ 是首选。
2.持久化消息比较 #
ZeroMq 不支持，ActiveMq 和RabbitMq 都支持。持久化消息主要是指我们机器在不可抗力因素等情况下挂掉了，消息不会丢失的机制。
3.综合技术实现 #
可靠性、灵活的路由、集群、事务、高可用的队列、消息排序、问题追踪、可视化管理工具、插件系统等等。
RabbitMq / Kafka 最好，ActiveMq 次之，ZeroMq 最差。当然ZeroMq 也可以做到，不过自己必须手动写代码实现，代码量不小。尤其是可靠性中的：持久性、投递确认、发布者证实和高可用性。
4.高并发 #
毋庸置疑，RabbitMQ 最高，原因是它的实现语言是天生具备高并发高可用的erlang 语言。
5.比较关注的比较， RabbitMQ 和 Kafka #
RabbitMq 比Kafka 成熟，在可用性上，稳定性上，可靠性上，RabbitMQ胜于 Kafka（理论上）。
另外，Kafka 的定位主要在日志等方面， 因为Kafka 设计的初衷就是处理日志的，可以看做是一个日志（消息）系统一个重要组件，针对性很强，所以 如果业务方面还是建议选择 RabbitMq 。
还有就是，Kafka 的性能（吞吐量、TPS ）比RabbitMq 要高出来很多。
安装配置 #
1、Erlang的安装及配置 #
1.1、下载 #
下载网址：http://www.erlang.org/downloads
选择自己的安装目录，全程下一步
1.2、配置环境变量 #
配置path，为ERLANG_HOME\bin
1.3、查看配置是否成功 #
cmd下输入erl
2、RabbitMQ的安装及配置 #
2.1、下载RabbitMQ #
下载网址：http://www.rabbitmq.com/download.html
2.2、安装RabbitMQ #
双击安装包，全程下一步
2.3、安装RabbitMQ-Plugins #
进入RabbitMQ的sbin目录，打开cmd
执行命令：rabbitmq-plugins enable rabbitmq_management
2.4、配置RabbitMQ环境变量 #
path环境变量中添加：%RABBITMQ_HOME%\sbin;
3、启动RabbitMQ服务 #
- cmd输入命令
- 开启服务
- net start RabbitMQ
- 关闭服务
- net stop RabbitMQ
- 开启服务
如果启动报错 #
管理员运行cmd
1、执行命令：rabbitmq-service.bat remove
2、在RabbitMq任意路径下，建立目录data
3、执行命令，路径改为刚才创建的名录：set RABBITMQ_BASE=D:\rabbitmq_server\data
4、执行命令：rabbitmq-service.bat install
5、执行命令：rabbitmq-plugins enable rabbitmq_management
6、在管理服务中启动服务就可以了、启动输入命令：services.msc
启动成功 #
4、访问RabbitMQ登录页面 #
http://localhost:15672
初始的账号密码都是：guest
登录监控平台 #
Linux下安装 #
获取RabbitMQ的镜像 #
docker pull daocloud.io/library/rabbitmq:3.7.26-management
启动RabbitMQ容器 #
-
docker run -d --net=host --name some-rabbit --privileged=true daocloud.io/library/rabbitmq:3.7.26-management -
开启完毕之后，会暴露2大端口
-
- 5672：数据访问端口
- 15672：监控平台端口
-
- –net=host：主动暴露端口 （也可以使用-p 一个一个的做映射）
-
如果没有关闭防火墙，请暴露端口
-
firewall -cmd --permanent --add-port=5672/tcp --permanentfirewall -cmd --permanent --add-port=15672/tcp --permanent
-
firewall -cmd --reload
应用中的问题 #
系统架构 #
- producer&Consumer
- p指的是消息生产者，c指消息的消费者
- Queue：消息队列
- 提供了FIFO的处理机制，具有缓存消息的能力。rabbitmq中，队列消息可以设置为持久化，临时或者自动删除。
- 设置为持久化的队列，queue中的消息会在server本地硬盘存储一份，防止系统crash，数据丢失
- 设置为临时队列，queue中的数据在系统重启之后就会丢失
- 设置为自动删除的队列，当不存在用户连接到server，队列中的数据会被自动删除
- Exchange：消息交换机
- Exchange类似于数据通信网络中的交换机，提供消息路由策略。rabbitmq中，producer不是通过信道直接将消息发送给queue，而是先发送给Exchange。
- 一个Exchange可以和多个Queue进行绑定，producer在传递消息的时候，会传递一个ROUTINGKEY，Exchange会根据这个ROUTINGKEY按照特定的路由算法，将消息路由给指定的queue。
- 和Queue一样，Exchange也可设置为持久化，临时或者自动删除。
- Binding：绑定
- 它的作用就是把exchange和queue按照路由规则绑定起来.
- Routing Key：路由关键字
- exchange根据这个关键字进行消息投递。
- Channel：消息通道
- 在客户端的每个连接里，可建立多个channel
- 信道是生产消费者与rabbit通信的渠道，生产者publish或者消费者消费一个队列都是需要通过信道来通信的。
- 信道是建立在TCP上面的虚拟链接，也就是rabbitMQ在一个TCP上面建立成百上千的信道来达到多个线程处理。
- 注意是一个TCP 被多个线程共享，每个线程对应一个信道，信道在rabbit都有唯一的ID，保证了信道的私有性，对应上唯一的线程使用。