18-基于CentOS7搭建RabbitMQ3.10.7集群镜像队列+HaProxy+Keepalived高可用架构( 五 ) _生活百科

生产者
package com.dance.redis.mq.rabbit.helloworld;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import com.rabbitmq.client.MessageProperties;import java.io.IOException;import java.util.concurrent.TimeoutException;public class RabbitProducer {private static final String EXCHANGE_NAME = "exchange-test";private static final String ROUTING_KEY = "text.*";private static final String QUEUE_NAME = "queue-test";private static final String IP_ADDRESS = "192.168.247.160";private static final int PORT = 5672; //RabbitMQ服务默认端口为5672public static void main(String[] args) throws IOException,TimeoutException, InterruptedException {ConnectionFactory factory = new ConnectionFactory();factory.setHost(IP_ADDRESS);factory.setPort(PORT);factory.setVirtualHost("/");factory.setUsername("toor");factory.setPassword("123456");Connection connection = factory.newConnection();//创建连接Channel channel = connection.createChannel();//创建信道//创建一个type="topic"、持久化的、非自动删除的交换器。channel.exchangeDeclare(EXCHANGE_NAME, "topic", true, false, null);//创建一个持久化、非排他的、非自动删除的队列channel.queueDeclare(QUEUE_NAME, true, false, false, null);//将交换机与队列通过路由键绑定channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);//发送一条持久化消息:Hello World!String message = "Hello World!";channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY,MessageProperties.PERSISTENT_TEXT_PLAIN,message.getBytes());//关闭资源channel.close();connection.close();}}我的账户和密码是toor和123456, 请改为自己的
启动消费者

文章插图
启动生产者

文章插图
查看消费者

文章插图
消费成功, ip也是160
查看控制台 exchange

文章插图
多了exchange-test 功能是ha-all

文章插图
队列也是, 到此镜像队列+高可用已经实现

文章插图
也可以在HA的控制台上查看统计
集群架构回顾我们实现的是RabbitMQ Cluster + Mirror Queue + Haproxy + Keepalived
RabbitMQ Cluster 3台
Mirror Queue RabbitMQ集群方式
Haproxy 反向代理
Keepalived Haproxy集群检测, 虚拟VIP, 实现统一IP对外提供
架构图手绘