1 集群配置
1.1 环境变量配置
在 /etc/rabbitmq/ 目录下，创建 rabbitmq-env.conf配置文件
rabbitmq-env.conf 配置内容：
---------------------------------------关键参数配置-------------------------------------------
RABBITMQ_NODE_IP_ADDRESS=本机IP地址
RABBITMQ_NODE_PORT=5672
RABBITMQ_LOG_BASE=/var/lib/rabbitmq/log
RABBITMQ_MNESIA_BASE=/var/lib/rabbitmq/mnesia
RABBITMQ_NODENAME=FZTEC-240088 节点名称
RABBITMQ_NODE_IP_ADDRESS=127.0.0.1 监听IP
RABBITMQ_NODE_PORT=5672 监听端口
RABBITMQ_LOG_BASE=/data/rabbitmq/log 日志目录
RABBITMQ_PLUGINS_DIR=/data/rabbitmq/plugins 插件目录
RABBITMQ_MNESIA_BASE=/data/rabbitmq/mnesia 后端存储目录
<font color=red>更详细的配置参见：http://www.rabbitmq.com/configure.html#configuration-file </font>
1.2 配置信息
/usr/lib/rabbitmq/lib/rabbitmq_server-3.6.4/ebin/rabbit.app和rabbitmq.config配置文件配置任意一个即可
- tcp_listerners 设置rabbimq的监听端口，默认为[5672]。
- disk_free_limit 磁盘低水位线，若磁盘容量低于指定值则停止接收数据，默认值为{mem_relative, 1.0},即与内存相关联1：1，也可定制为多少byte.
- vm_memory_high_watermark，设置内存低水位线，若低于该水位线，则开启流控机制，默认值是0.4，即内存总量的40%。hipe_compile 将部分rabbimq代码用High Performance Erlang compiler编译，可提升性能，该参数是实验性，若出现erlang vm segfaults，应关掉。
- force_fine_statistics， 该参数属于rabbimq_management，若为true则进行精细化的统计，但会影响性能
<font color=red>更详细的配置参见：http://www.rabbitmq.com/configure.html </font>
2 测试运行
2.1 集群启动
设置keepalived开机启动后，则会直接运行chk_haproxy.sh脚本，从而启动haproxy服务，所以对于负载均衡和高可用层我们无需任何配置。
//启动各个MQ节点
[root@localhost ~]# rabbitmq-server -detached
2.2 集群关闭
//各节点停止MQ集群命令
[root@localhost ~]# rabbitmqctl stop_app | start_app | cluster_status | reset
//各节点停止MQ服务
[root@localhost ~]# /etc/init.d/rabbitmq-server stop | start | restart | status
2.3 查看状态
//查看集群状态
[root@localhost ~]# rabbitmqctl cluster_status
3 调用测试
3.1 生产者
package bhz.rabbitmq.helloword;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import com.rabbitmq.client.Address;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
/**
* <B>中文类名：</B>rabbitmq负载均衡测试<BR>
* <B>概要说明：</B><BR>
* @author bhz（Alienware）
* @since 2016年7月20日
*/
public class Sender {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ConnectionFactory() ;
//RabbitMQ-Server安装在本机，所以直接用127.0.0.1
connectionFactory.setHost("192.168.1.20");
connectionFactory.setPort(5672);
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel() ;
//定义Queue名称
String queueName = "queue01" ;
//为channel定义queue的属性，queueName为Queue名称
channel.queueDeclare(queueName , false, false, false, null) ;
for(int i =0; i < 100000; i ++){
//发送消息
String msg = "Hello World RabbitMQ " + i;
channel.basicPublish("", queueName , null , msg.getBytes());
System.out.println("发送数据：" + msg);
TimeUnit.SECONDS.sleep(1);
}
channel.close();
connection.close();
}
}
3.2 消费者
package bhz.rabbitmq.helloword;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.rabbitmq.client.Address;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
/**
* <B>中文类名：</B>rabbitmq 负载均衡测试<BR>
* <B>概要说明：</B><BR>
* @author bhz（Alienware）
* @since 2016年7月20日
*/
public class Receiver {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ConnectionFactory() ;
connectionFactory.setHost("192.168.1.20");
connectionFactory.setPort(5672);
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel() ;
String queueName = "queue01";
channel.queueDeclare(queueName, false, false, false, null) ;
//上面的部分，与Sender01是一样的
//配置好获取消息的方式
QueueingConsumer consumer = new QueueingConsumer(channel) ;
channel.basicConsume(queueName, true, consumer) ;
//循环获取消息
while(true){
//获取消息，如果没有消息，这一步将会一直阻塞
Delivery delivery = consumer.nextDelivery() ;
String msg = new String(delivery.getBody()) ;
System.out.println("收到消息：" + msg);
}
}
}
3.3 测试
3.3.1 发送数据
Sender程序启动发送5条数据
[图片上传失败...(image-9ec5ea-1619140733108)]
3.3.2 集群查看数据
集群管控台查看队列情况，说明生产者消息发送到MQ集群中
在这里插入图片描述
任意MQ节点执行如下命令：由下图可知我们镜像队列配置成功
[root@localhost ~]# //查看镜像队列的状态，同步到了24 25 26三个节点上
rabbitmqctl list_queues name pid slave_pids
[图片上传失败...(image-f3da48-1619140733108)]
3.3.3 消费消息
Received程序启动成功接收5条数据
在这里插入图片描述
查看集群队列消费状态：已经成功消费数据
在这里插入图片描述
4 相关信息
上一篇：MQ RabbitMQ 高可用集群（四）：Keepalived安装和配置
博文不易，辛苦各位猿友点个关注和赞，感谢
网友评论