解(集群部署)

消息的消费者用于从队列中获取消息.消费者只需关注队列即可不需要关注交换机和路由键。

消费者可以通过basicConsume(订阅模式可以从队列中一直持续的自动的接收消息)或者basicGet(先订阅消息,然后获取单条消息再然后取消订阅。

也就是说basicGet一次只能获取一条消息如果还想再获取下一条还要再次调用basicGet)来从队列中获取消息。

RabbitMQ

生产者会将消息发送到交换机然后交换机通过路由策略(规则)将消息路由到匹配的队列中去。

ExchangeType决定了Exchange路由消息的行为在RabbitMQ中ExchangeType有direct、Fanout、Topic和Header

在RabbitMQ

绑定起来,所以Binding不是一个概念而是一种操作。

RabbitMQ中通过绑定,以路由键作为桥梁将Exchange与Queue关联起来()Exchange—Routing

Key—Queue这样RabbitMQ就知道如何正确地将消息路由到指定的队列了通过queueBind()方法将Exchange、Routing

Queue

key进行绑定联系的这个关系是固定的。

初始化的时候我们就会建立该队列。

Routing

它是一个String值用于定义路由规则。

生产者在将消息发送给Exchange的时候一般会指定一个routing

key来指定这个消息的路由规则。

在队列绑定的时候需要指定路由键在生产者发布消息的时候需要指定路由键当消息的路由键和队列绑定的路由键匹配时消息就会发送到该队列。

Message

用于存储消息的容器,可以看成一个有序的数组,生产者生产的消息会发送到交换机中,最终交换机将消息存储到某个或某些队列中。

队列可被消费者订阅,消费者从订阅的队列中获取消息。

Message

消息队列,我们发送给RabbitMQ的消息最后都会到达各种queue,并且存储在其中(如果路由找不到相应的queue则数据会丢失),等待消费者来取.

FIFO

每一个RabbitMQ服务器都能创建多个虚拟消息服务器,我们称之为虚拟主机.每一个vhost本质上是一个mini版的RabbitMQ服务器,拥有自己的交换机、队列、绑定等,拥有自己的权限机制.vhost相对于RabbitMQ就像虚拟机之于物理机一样.他们通过在各个实例间提供逻辑上的分离,允许不同的应用程序安全保密的运行数据,这很有用,它既能将同一个Rabbit的众多客户区分开来,又可以避免队列和交换器的命名冲突.RabbitMQ提供了开箱即用的默认的虚拟主机“/”,如果不需要多个vhost可以直接使用这个默认的vhost,通过使用缺省的guest用户名和guest密码来访问默认的vhost.

vhost之间是相互独立的,这避免了各种命名的冲突,就像App中的沙盒的概念一样,每个沙盒是相互独立的,且只能访问自己的沙盒,以保证非法访问别的沙盒带来的安全隐患.

二、RabbitMQ部署

rabbitmq部署有三种模式单机模式普通集群模式镜像集群模式

RabbitMQ

由于rabbitmq是基于erlang语言开发的所以必须先安装erlang。

wget

http://erlang.org/download/otp_src_20.0.tar.gz

tar

PATH$PATH:/usr/local/erlang/bin

source

https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.11.6/rabbitmq-server-3.11.6.tar.xz

rabbitmq-server-generic-unix-3.11.6.tar.xz

tar

rabbitmq-server-generic-unix-3.6.10.tar

/usr/local/rabbitmq

注该方式安装的RabbitMQ是没有配置文件的如需要配置文件需手动进行配置文件置于自己Rabbitmq安装路径下的

/usr/local/rabbitmq/sbin/rabbitmq-server

-detached

/usr/local/rabbitmq/sbin/rabbitmq-server

-detached

/usr/local/rabbitmq/sbin/rabbitmq-plugins

enable

在本地主机中使用浏览器访问Linux实例的公网IP:15672。

但是你创建的queue只会放在一个rabbtimq实例上但是每个实例都同步queue的元数据(存放含queue数据的真正实例位置)。

消费的时候实际上如果连接到了另外一个实例那么那个实例会从queue所在实例上拉取数据过来。

三、配置文件详解

​类似ini的sysctl配置文件格式​​。

该文件通常命名为Rabbitmq.conf。

rabbitmq.conf

​主配置文件​​。

应该用于大多数设置。

对于人类来说阅读和机器部署工具的生成更容易。

并非所有设置都可以这种格式表示。

advanced.config

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId

/dependency

org.springframework.amqp.core.*;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;/*rabbitMq基本配置*/

Configuration

FanoutExchange(productExchange);}public

TopicExchange

TopicExchange(topicExchangeName);}Beanpublic

DirectExchange

BindingBuilder.bind(productQueue).to(productExchange);}

3、生产者:

LoggerFactory.getLogger(ProductProducer.class);AutowiredRabbitTemplate

gson;public

gson.toJson();logger.info(###消息发送者:

json

rabbitTemplate.convertAndSend(RabbitmqConfig.Product_EXCHANGE,

null,

LoggerFactory.getLogger(TransproductConsumer.class);AutowiredRabbitTemplate

rabbitTemplate;AutowiredErrorProducer

errorProducer;AutowiredProductService

productService;RabbitHandlerRabbitListener(queues

)public

{logger.info(##start##消费者TransProductConsumer

接收到消息json

e);errorProducer.push(RabbitmqConfig.ERROR_PROFIT_CACULATE_QUEUE,

json);}}

LoggerFactory.getLogger(TransDetailProducer.class);AutowiredRabbitTemplate

gson;public

errorJson);rabbitTemplate.convertAndSend(RabbitmqConfig.ERROR_EXCHANGE,

queueName,

gson.toJson(obj);logger.info(###异常消息发送者:

queueName

errorJson);rabbitTemplate.convertAndSend(RabbitmqConfig.ERROR_EXCHANGE,

queueName,