RabbitMQ
【黑马程序员RabbitMQ全套教程，rabbitmq消息中间件到实战】
文章目录
- RabbitMQ
- 第二天 高级
- 9 RabbitMQ 集群搭建
- 9.3 集群管理
- 9.5 负载均衡-HAProxy
- 9.5.1 安装HAProxy
- 9.5.2 配置HAProxy
第二天 高级
9 RabbitMQ 集群搭建
9.3 集群管理
rabbitmqctl join_cluster {cluster_node} [–ram]
将节点加入指定集群中。在这个命令执行前需要停止RabbitMQ应用并重置节点。
rabbitmqctl cluster_status
显示集群的状态。
rabbitmqctl change_cluster_node_type {disc|ram}
修改集群节点的类型。在这个命令执行前需要停止RabbitMQ应用。
rabbitmqctl forget_cluster_node [–offline]
将节点从集群中删除，允许离线执行。
rabbitmqctl update_cluster_nodes {clusternode}
在集群中的节点应用启动前咨询clusternode节点的最新信息，并更新相应的集群信息。这个和join_cluster不同，它不加入集群。考虑这样一种情况，节点A和节点B都在集群中，当节点A离线了，节点C又和节点B组成了一个集群，然后节点B又离开了集群，当A醒来的时候，它会尝试联系节点B，但是这样会失败，因为节点B已经不在集群中了。
rabbitmqctl cancel_sync_queue [-p vhost] {queue}
取消队列queue同步镜像的操作。
rabbitmqctl set_cluster_name {name}
设置集群名称。集群名称在客户端连接时会通报给客户端。Federation和Shovel插件也会有用到集群名称的地方。集群名称默认是集群中第一个节点的名称，通过这个命令可以重新设置。
9.5 负载均衡-HAProxy
HAProxy提供高可用性、负载均衡以及基于TCP和HTTP应用的代理，支持虚拟主机，它是免费、快速并且可靠的一种解决方案,包括Twitter，Reddit，StackOverflow，GitHub在内的多家知名互联网公司在使用。HAProxy实现了一种事件驱动、单一进程模型，此模型支持非常大的并发连接数。
9.5.1 安装HAProxy
//下载依赖包
yum install gcc vim wget
//上传haproxy源码包
//解压
tar -zxvf haproxy-1.6.5.tar.gz -C /usr/local
//进入目录、进行编译、安装
cd /usr/local/haproxy-1.6.5
make TARGET=linux31 PREFIX=/usr/local/haproxy
make install PREFIX=/usr/local/haproxy
mkdir /etc/haproxy
//赋权
groupadd -r -g 149 haproxy
useradd -g haproxy -r -s /sbin/nologin -u 149 haproxy
//创建haproxy配置文件
mkdir /etc/haproxy
vim /etc/haproxy/haproxy.cfg
课前资料，永远滴神！！！！
直接甩 到服务器上
解压
进入目录、进行编译、安装
OK，赋权
创建haproxy配置文件
9.5.2 配置HAProxy
配置文件路径：/etc/haproxy/haproxy.cfg
#logging options
global
log 127.0.0.1 local0 info
maxconn 5120
chroot /usr/local/haproxy
uid 99
gid 99
daemon
quiet
nbproc 20
pidfile /var/run/haproxy.pid
defaults
log global
mode tcp
option tcplog
option dontlognull
retries 3
option redispatch
maxconn 2000
contimeout 5s
clitimeout 60s
srvtimeout 15s
#front-end IP for consumers and producters
listen rabbitmq_cluster
bind 0.0.0.0:5672
mode tcp
#balance url_param userid
#balance url_param session_id check_post 64
#balance hdr(User-Agent)
#balance hdr(host)
#balance hdr(Host) use_domain_only
#balance rdp-cookie
#balance leastconn
#balance source //ip
balance roundrobin
server node1 127.0.0.1:5673 check inter 5000 rise 2 fall 2
server node2 127.0.0.1:5674 check inter 5000 rise 2 fall 2
listen stats
bind xxxxxxxxxxxxxxx:8100 ## 记得换成自己的服务器IP
mode http
option httplog
stats enable
stats uri /rabbitmq-stats
stats refresh 5s
OK。
启动HAproxy负载
启动HAproxy负载
/usr/local/haproxy/sbin/haproxy -f /etc/haproxy/haproxy.cfg
//查看haproxy进程状态
ps -ef | grep haproxy
访问如下地址对mq节点进行监控
http://172.16.98.133:8100/rabbitmq-stats
记得是内网 IP
OK，启动成功
代码中访问mq集群地址，则变为访问haproxy地址:5672
OK， 看到这样的界面 就说明安装 成功了 【访问的时候 记得用公网IP 进行访问】
【简单使用一下】
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import javax.swing.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
/**
* ClassName: HelloWorld
* date: 2022/11/17 17:56
*
* @author DingJiaxiong
*/
public class HelloWorld {
public static void main(String[] args) throws IOException, TimeoutException {
//1. 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
//2. 设置参数
factory.setHost("xxxxxxxxxxxx"); //HAproxy 的ip
factory.setPort(5672);
//3. 创建连接 Connection
Connection connection = factory.newConnection();
//4. 创建Channel
Channel channel = connection.createChannel();
//5. 创建队列Queue
channel.queueDeclare("hello_world1",true,false,false,null);
//6. 发送消息
String body = "hello rabbitmq";
channel.basicPublish("","hello_world1",null,body.getBytes());
//7. 释放资源
channel.close();
connection.close();
System.out.println("发送成功!");
}
}
直接运行
OK，发送成功
直接看看管控台
OK，两边 队列和消息 都有了
现在把第一个节点关掉
OK
再 运行一次方法
还是发送成功 了
看看管控台
没毛病
重启5673
再次查看管控台
效果很明显，同步了！！！！这就是 HAproxy 的负载均衡。
OK，RabbitMQ 完结撒花，谢谢老师【黑马 牛逼！！！！！】
