news 2026/3/5 5:05:57

10 分钟搞定 RabbitMQ 高可用:HAProxy 负载均衡实战指南

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
10 分钟搞定 RabbitMQ 高可用:HAProxy 负载均衡实战指南

在分布式系统中,RabbitMQ作为常用消息中间件,集群部署是保障高可用的关键。但很多开发者会遇到一个棘手问题:Java程序直接绑定RabbitMQ节点的IP和端口后,一旦该节点宕机,程序就会连接失败,只能手动修改配置恢复。

HAProxy负载均衡技术,能完美解决这个痛点——既实现请求分流,又能自动故障转移,为RabbitMQ集群搭建可靠的统一访问入口。今天就带大家一步步完成从安装到实战验证的全流程。

一、为什么一定要用HAProxy?

RabbitMQ集群即便配置了仲裁队列保证队列高可用,仍有两个核心问题:

  1. 单点依赖风险:程序绑定固定节点端口(默认5672),节点宕机直接抛出java.net.ConnectException,无法自动切换

  2. 资源浪费严重:所有请求集中在一个节点,导致该节点过载,其他节点却闲置

HAProxy的核心价值就是:作为集群“大门”,分散请求到各个节点,同时实时监控节点状态,故障时自动切换,无需手动改代码。

二、HAProxy快速安装(Ubuntu环境)

1. 更新软件源
apt-get update
2. 安装HAProxy

先查看可用版本:

apt list | grep haproxy

执行安装命令:

apt-get install haproxy
3. 验证安装

查看服务状态(显示active则成功):

systemctl status haproxy

设置开机自启:

systemctl enable haproxy

查看版本信息:

haproxy -v

三、关键配置:HAProxy核心参数设置

HAProxy配置文件路径:/etc/haproxy/haproxy.cfg,用vim编辑即可。

1. 完整配置代码(直接复制)
# 编辑配置文件 vim /etc/haproxy/haproxy.cfg

在文件末尾追加以下内容:

# HAProxy Web管理界面(方便监控) listen stats bind *:8100 # 管理界面端口 mode http # 工作模式 stats enable # 启用统计功能 stats realm Haproxy Statistics stats uri / # 访问路径 stats auth admin:admin # 登录账号密码(可自定义) # RabbitMQ负载均衡核心配置 listen rabbitmq bind *:5670 # 集群统一访问端口(避开5672默认端口) mode tcp # AMQP基于TCP协议,必须设为TCP模式 balance roundrobin # 负载均衡算法:轮询(最常用) # 集群节点配置(替换为你的实际节点IP和端口) server rabbitmq1 127.0.0.1:5672 check inter 5000 rise 2 fall 3 server rabbitmq2 127.0.0.1:5673 check inter 5000 rise 2 fall 3 server rabbitmq3 127.0.0.1:5674 check inter 5000 rise 2 fall 3
2. 关键参数说明(新手必看)
  • 负载均衡算法

    • 轮询(roundrobin):按顺序分发请求,适合节点性能一致的场景

    • 加权轮询:给高性能节点分配更高权重,处理更多请求

    • 最少连接:优先转发到连接数少的节点,提升利用率

  • 健康检查参数

    • check inter 5000:每5秒检查一次节点是否可用

    • rise 2:节点故障后,连续2次检查通过恢复可用

    • fall 3:连续3次检查失败,自动移除该节点

3. 配置生效

修改后重启HAProxy:

systemctl restart haproxy

四、实战验证:负载均衡+故障转移

1. 程序连接配置修改(Java示例)

无需关注集群具体节点,只需连接HAProxy的IP和端口(5670):

spring: rabbitmq: addresses: amqp://admin:password@haproxy-ip:5670/test # 替换实际IP和密码 publisher-confirm-type: correlated listener: simple: acknowledge-mode: auto

2. 测试步骤

(1)正常场景测试

启动RabbitMQ集群和Java程序,调用接口发送消息:

@RestController @RequestMapping("/producer") public class ProducerController { @Autowired private RabbitTemplate rabbitTemplate; @RequestMapping("/test") public String test() { rabbitTemplate.convertAndSend("", "quorum.queue", "RabbitMQ+HAPorxy测试"); return "消息发送成功"; } }

访问http://127.0.0.1:8080/producer/test,消息能正常投递即成功。

(2)故障转移测试

手动停止一个RabbitMQ节点:

rabbitmqctl -n rabbit stop_app

再次调用接口,程序仍能正常发送消息,HAProxy会自动将请求转发到健康节点。

五、总结

HAProxyRabbitMQ集群带来三大核心优势:

  1. 高可用:故障自动转移,无需人工干预

  2. 高并发:请求分流,避免单点过载

  3. 易维护:集群扩容/替换节点,无需修改程序配置

这套方案适用于微服务、分布式系统等各类需要高可用消息通信的场景,新手也能快速上手。如果在配置过程中遇到问题,欢迎在评论区留言交流~

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/3/4 1:44:54

基于Java+SpringBoot+SSM物流管理系统(源码+LW+调试文档+讲解等)/物流管理软件/物流信息管理系统/供应链物流管理系统/企业物流管理系统/物流仓储管理系统/智能物流管理系统

博主介绍 💗博主介绍:✌全栈领域优质创作者,专注于Java、小程序、Python技术领域和计算机毕业项目实战✌💗 👇🏻 精彩专栏 推荐订阅👇🏻 2025-2026年最新1000个热门Java毕业设计选题…

作者头像 李华
网站建设 2026/3/5 10:56:55

计算机毕设 java 基于 Android 的医疗预约系统的设计与实现 移动医疗预约服务平台 医患对接信息化系统

计算机毕设 java 基于 Android 的医疗预约系统的设计与实现 53m069(配套有源码 程序 mysql 数据库 论文)本套源码可以先看具体功能演示视频领取,文末有联 xi 可分享 随着医疗需求的增长和移动互联网的普及,传统医疗预约存在流程繁…

作者头像 李华
网站建设 2026/3/3 8:44:15

nginx的重定向

nginx的重定向(rewrite) 一、location 1、 location匹配 location匹配的就是后面的URI /wordpress 192.168.100.11/wordpress 2、 location匹配的分类 2.1 精确匹配 location / 对字符串进行完全匹配,必须完全符合 2.2 正则匹配 ^~ 前缀匹配…

作者头像 李华
网站建设 2026/3/4 3:12:47

nginx服务器实现上传文件功能_使用nginx-upload-module模块

目录 conf文件内容如下html文件内容如下上传文件功能展示 conf文件内容如下 #user nobody; worker_processes 1;error_log /usr/logs/error.log; #error_log /usr/logs/error.log notice; #error_log /usr/logs/error.log info;#pid /usr/logs/nginx.pid;even…

作者头像 李华
网站建设 2026/3/4 12:11:42

揭秘曲线上的点:Python中的插值技巧

在数据科学和科学计算中,插值是一种常用的方法,用于估算已知数据点之间的值。在本文中,我们将探讨如何使用Python的scipy库来实现二维函数的插值,结合实际例子来展示其应用。 背景介绍 假设我们有一个已知的二维函数 f(x, y),其在某些点 (x, y) 上的值已经计算好。同时,…

作者头像 李华