本文介绍: RabbitMQ的介绍,MQ技术对比,基础知识,work模型
1.RabbitMQ介绍
RabbitMQ是基于Erlang语言开发的开源消息通信中间件,是一个高性能的异步通讯组件
官网地址:RabbitMQ官网
2.MQ技术对比
RabbitMQ | ActiveMQ | RocketMQ | Kafka | |
---|---|---|---|---|
公司 | Rabbit | Apache | 阿里 | Apache |
开发语言 | Erlang | Java | Java | Scala&Java |
协议支持 | AMQP、XMPP、SMTP、STOMP | OpenWire、STOMP、REST、XMPP、AMQP | 自定义协议 | 自定义协议 |
可用性 | 高 | 一般 | 高 | 高 |
单机吞吐量 | 一般 | 差 | 高 | 非常高 |
消息延迟 | 微妙级 | 毫秒级 | 毫秒级 | 毫秒以内 |
消息可靠性 | 高 | 一般 | 高 | 一般 |
3.RabbitMQ的整体架构及核心概念
(1)消息发送者(publisher)
(2)消息消费者(consumer)
(3)队列(queue):存储消息
(4)交换机(exchange):负责路由和转发消息
(5)虚拟主机(Virtual host):实现数据隔离
4.work Queues(任务模型)
(1)模型作用
就是让多个消费者绑定到一个队列,共同消费队列中的消息,可以加快消息处理速度
(2)模型规则
同一条消息只会被一个消费者处理
(3)模型设置
默认情况下,RabbitMQ会将消息一次轮询投递给绑定在队列上的每一个消费者。但这并没有考虑到消费者是否已经处理完消息,可能出现消息堆积。因此我们需要修改配置文件,设置preFetch值为1,确保同一时刻最多投递给消费者1条消息
spring:
# RabbitMQ相关配置
rabbitmq:
# 配置虚拟主机名称
virtual-host: system1
# RabbitMQ管理端口号:15672;服务端口号:5672
port: 5672
# 配置使用者的名称和密码
username: guest
password: guest
# 配置消费者信息
listener:
simple:
# 设置每个监听者只能获取一条消息,处理完成才能获取下一条消息;作用:能者多劳
prefetch: 1
原文地址:https://blog.csdn.net/Lyhdreamer/article/details/135664925
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_60624.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。