栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

RabbitMQ简单入门

RabbitMQ简单入门

RabbitMQ简单入门

简介: RabbitMQ

1.docker安装rbmq
docker pull rabbitmq:management
docker run 
 -e RABBITMQ_DEFAULT_USER=test #账号
 -e RABBITMQ_DEFAULT_PASS=123456 #密码
 --name mq 
 --hostname mq1 
 -p 15672:15672  
 -p 5672:5672 
 -d 
rabbitmq:management  #不带management没有控制台

运行

2.rabbitmq相关概念

1.Broker:接收和分发消息的应用

2.Virtual host:出于多租户和安全因素设计的,把 AMQP 的基本组件划分到一个虚拟的分组中,类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时,可以划分出多个vhost,每个用户在自己的 vhost 创建 exchange/queue 等

3.Connection:publisher/consumer 和 broker 之间的 TCP 连接

4.Channel:如果每一次访问 RabbitMQ 都建立一个 Connection,在消息量大的时候建立 TCP

Connection的开销将是巨大的,效率也较低。Channel 是在 connection 内部建立的逻辑连接,

如果应用程序支持多线程,通常每个thread创建单独的 channel 进行通讯,AMQP method 包含

了channel id 帮助客户端和message broker 识别 channel,所以 channel 之间是完全隔离的。

Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销

5.Exchange:message 到达 broker 的第一站,根据分发规则,匹配查询表中的 routing key,分发

消息到queue 中去。常用的类型有:direct (point-to-point), topic (publish-subscribe) and

fanout (multicast)

6.Queue:消息最终被送到这里等待 consumer 取走

7.Binding:exchange 和 queue 之间的虚拟连接,binding 中可以包含 routing key。Binding 信息

被保存到 exchange 中的查询表中,用于 message 的分发依据

3.RabbitMQ提供了6种模式:简单模式,Work queues工作队列模式,Publish/Subscribe发布与订阅模式,Routing路由模式,Topics主题模式,RPC远程调用模式 1.简单模式

2.Work queues工作队列模式

3.Publish/Subscribe发布与订阅模式

4. Routing路由模式

5.Topics通配符模式

RabbitMQ工作模式:

1**、简单模式** 一个生产者、一个消费者,不需要设置交换机(使用默认的交换机)

2**、工作队列模式** Work Queue 一个生产者、多个消费者(竞争关系),不需要设置交换机(使3****、发布订阅模式 Publish/subscribe 需要设置类型为fanout的交换机,并且交换机和队列进行4****、路由模式 Routing 需要设置类型为direct的交换机,交换机和队列进行绑定,并且指定routing

key,当发送消息到交换机后,交换机会根据routing key将消息发送到对应的队列

置类型为direct的交换机,交换机和队列进行绑定,并且指定routing

key,当发送消息到交换机后,交换机会根据routing key将消息发送到对应的队列

5**、通配符模式** Topic 需要设置类型为topic的交换机,交换机和队列进行绑定,并且指定通配符方式的routing key,当发送消息到交换机后,交换机会根据routing key将消息发送到对应的队列

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/721898.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号