news 2026/6/23 7:08:31

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/6/15 17:19:23

计算机毕设 java 基于 vue 与 spring 的药品销售管理系统设计与实现 智能药品销售管控平台 医药流通信息化系统

计算机毕设 java 基于 vue 与 spring 的药品销售管理系统设计与实现 03miq9(配套有源码 程序 mysql 数据库 论文)本套源码可以先看具体功能演示视频领取,文末有联 xi 可分享随着医药行业的发展和信息化需求的提升,传统药品销售管理…

作者头像 李华
网站建设 2026/6/22 23:06:44

SpringBoot+Vue 师生共评作业管理系统平台完整项目源码+SQL脚本+接口文档【Java Web毕设】

摘要 随着教育信息化的快速发展,传统作业管理模式已无法满足现代教学的需求。师生共评作业管理系统平台旨在解决作业提交、批改、反馈等环节的效率问题,通过数字化手段优化教学流程。该系统支持多角色协同操作,包括学生提交作业、教师批改、师…

作者头像 李华
网站建设 2026/6/15 14:30:20

Java Web BB平台系统源码-SpringBoot2+Vue3+MyBatis-Plus+MySQL8.0【含文档】

摘要 随着互联网技术的快速发展,在线教育平台逐渐成为教育行业的重要组成部分。传统的教育模式受限于时间和空间,难以满足现代学习者多样化的需求。Java Web BB平台系统旨在构建一个高效、灵活且功能丰富的在线学习环境,通过整合先进的技术栈…

作者头像 李华
网站建设 2026/6/14 5:13:19

Node.JS 版本管理工具 Fnm 安装及配置(Windows)

Fnm 安装及配置(Windows) Fnm(Fast Node Manager)?? 一个快速而简单的 Node.js 版本管理工具,使用 Rust 编写。 1 安装 官网:Fnm(镜像网站 )。 下载:Fnm&#xff08…

作者头像 李华
网站建设 2026/6/19 23:51:51

Node.js NativeAddon 构建工具:node-gyp 安装与配置完全指南

Node.js NativeAddon 构建工具:node-gyp 安装与配置完全指南 node-gyp Node.js native addon build tool [这里是图片001] 项目地址: https://gitcode.com/gh_mirrors/no/node-gyp 项目基础介绍及主要编程语言 Node.js NativeAddon 构建工具(node-gyp…

作者头像 李华