赞
踩
1.RabbitMQ工作原理
1.1 术语
Broker:消息队列服务进程,此进程包括Exchange和Queue
Exchange:消息队列交换机,按一定的规则将消息路由转发到某个队列,对消息进行过滤
Queue:消息队列,存储消息的队列,消息到达队列并转发给指定的消费方
Producer:消息生产者,生产者通过通道将消息发送Broker
Consumer:消息消费者,接收消息队列转发的消息
1.2 发布流程
i.生产者和broker建立tcp连接
ii.生产者和broker建立通道
iii.生产者通过通道将消息发送给broker,由Exchange(消息交换机)将消息进行转发到指定的queue(队列)
1.3 接收流程
i.消费者和broker建立tcp连接
ii.消费者和broker建立通道
iii.消费者监听指定的queue(队列),当有消息到达queue时,broker默认将消息推送给消费者,消费者接收消息
2.添加依赖
<dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.0</version> </dependency>
3.生产者代码
package com.ilearn.prducer; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class ProducerMsg { public static void main(String[] args) throws Exception
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。