解决 RabbitMQ 集群 Channel shutdown: connection error 错误（HAProxy 负载均衡）

原文: 解决 RabbitMQ 集群 Channel shutdown: connection error 错误（HAProxy 负载均衡）

具体错误信息：spring

2018-05-04 11:21:48.116 ERROR 60848 --- [.168.0.202:8001] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: connection error
2018-05-04 11:21:48.116 ERROR 60848 --- [.168.0.202:8001] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: connection error
2018-05-04 11:21:48.125  INFO 60848 --- [nge.consumer1-8] o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@5196e177: tags=[{amq.ctag-d_wIlZIGxM3f0fsxkmYQfA=my_test_exchange.consumer1}], channel=Cached Rabbit Channel: AMQChannel(amqp://admin@192.168.0.202:8001/,1), conn: Proxy@25a73de1 Shared Rabbit Connection: SimpleConnection@25fca927 [delegate=amqp://admin@192.168.0.202:8001/, localPort= 56258], acknowledgeMode=AUTO local queue size=0
2018-05-04 11:21:48.126  INFO 60848 --- [nge.consumer1-9] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [manager1:8001]
2018-05-04 11:21:48.393  INFO 60848 --- [nge.consumer1-9] o.s.a.r.c.CachingConnectionFactory       : Created new connection: rabbitConnectionFactory#2b8bd14b:12/SimpleConnection@3fb9795a [delegate=amqp://admin@192.168.0.202:8001/, localPort= 56260]
2018-05-04 11:21:49.059  INFO 60848 --- [nge.consumer1-8] o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@58b42519: tags=[{amq.ctag-T1HyrOd5Ykr_VQZDwxRslA=stream_exchange.consumer1}], channel=Cached Rabbit Channel: AMQChannel(amqp://admin@192.168.0.202:8001/,2), conn: Proxy@25a73de1 Shared Rabbit Connection: SimpleConnection@3fb9795a [delegate=amqp://admin@192.168.0.202:8001/, localPort= 56260], acknowledgeMode=AUTO local queue size=0

Spring Boot 配置 RabbitMQ（使用 HAProxy 负载均衡）：centos

spring:
  application:
    name: stream-rabbitmq-producer
  rabbitmq:
    host: manager1
    port: 8001
    username: admin
    password: admin123456

最近使用 RabbitMQ 集群的时候（HAProxy 负载均衡），频繁的出现上面错误信息，可是消息能够正常被消费掉，若是只使用单机版 RabbitMQ 的话（不使用 HAProxy），是没有任何错误的。bash

被这个问题困扰了好久，Google 找了不少资料，也没有找到解决方案，无心间找到一篇文章：RabbitMQ and HAProxy: a timeout issue服务器

文章说，若是使用 HAProxy 配置 RabbitMQ 高可用集群的话，则会遇到客户端链接超时问题。app

为何会出现此问题呢？由于 HAProxy 配置了客户端链接超时参数（timeout client ms），若是客户端链接超过配置的此参数，那么 HAProxy 将会删除这个客户端链接。负载均衡

RabbitMQ 客户端使用永久链接到代理，从不超时，那为何还会出现问题？由于若是 RabbitMQ 在一段时间内处于非活动状态，那么 HAProxy 将自动关闭链接（有点坑呀😂）。tcp

那如何解决这个问题呢？咱们看到 HAProxy 提供了一个clitcpka参数配置，它能够从客户端发送TCP keepalive数据包。wordpress

咱们就使用它，但发现配置了以后，仍是出现了上面的问题。测试

为何呢？

[…]the exact behaviour of tcp keep-alive is determined by the underlying OS/Kernel configuration[…]

什么意思？意思就是TCP keepalive数据包的发送，取决于操做系统/内核配置。

咱们可使用命令查看（HAProxy 所在服务器中的tcp_keepalive_time配置）：

[root@manager1 ~]# cat /proc/sys/net/ipv4/tcp_keepalive_time
7200

tcp_keepalive_time默认配置时间 2 个小时，表示发送TCP keepalive数据包的间隔时间是 2 个小时，或者说每隔 2 个小时发送TCP keepalive数据包。

这么说就清楚了吧，虽然咱们在 HAProxy 中，配置了clitcpka参数，但由于系统发送TCP keepalive数据包的间隔时间过长，远远超过 HAProxy 中的 timeout client超时时间（默认好像是 2 秒），因此客户端链接每隔 2 秒，就被 HAProxy 无情的给删除掉，而后不断的被重建。

说了那么多，咱们该怎么解决此问题呢？

两种方案：

修改系统的tcp_keepalive_time配置，间隔时间低于 HAProxy 配置的timeout client超时时间（由于有可能影响其余系统服务，不推荐）。
修改 HAProxy 中的timeout client超时时间，配置大于系统的tcp_keepalive_time间隔时间（推荐）

由于系统tcp_keepalive_time发送TCP keepalive数据包间隔时间是 2 个小时，因此，咱们将 HAProxy 中的timeout client超时时间，设置为 3 个小时：

timeout client  3h
timeout server  3h

完整示例配置：

[root@manager1 ~]# cat /etc/haproxy/haproxy.cfg
global
    log     127.0.0.1  local0 info
global
    log     127.0.0.1  local1 notice
    daemon
global
    maxconn 4096

defaults
    log     global
    mode    tcp
    option  tcplog
    option  dontlognull
    retries 3
    option  abortonclose
    maxconn 4096
    timeout connect  5000ms
    timeout client  3000ms
global
    timeout server  3000ms
    balance roundrobin

listen private_monitoring
    bind    0.0.0.0:8000
    mode    http
    option  httplog
    stats   refresh  5s
    stats   uri  /stats
    stats   realm   Haproxy
    stats   auth  admin:admin

listen rabbitmq_admin
    bind    0.0.0.0:8002
    server  manager1 manager1:15672
    server  manager2 manager2:15672
    server  manager3 manager3:15672

listen rabbitmq_cluster
    bind    0.0.0.0:8001
    mode    tcp
    option  tcplog
    balance roundrobin
    timeout client  3h
    timeout server  3h
    server  manager1  manager1:5672  check  inter  5000  rise  2  fall  3
    server  manager2  manager2:5672  check  inter  5000  rise  2  fall  3
    server  manager3  manager3:5672  check  inter  5000  rise  2  fall  3

从新运行 HAProxy，而后 RabbitMQ 测试成功：