Spring Cloud Stream与Solace连接异常：重启后无法自动重连

针对Solace服务器重启后Spring Boot服务无法自动重连的问题，可以通过以下几类配置强制开启自动重连机制：

1. Solace Binder专属重连配置 #

直接配置Solace binder的连接重试策略，覆盖默认的有限重试次数：

spring:
  cloud:
    stream:
      solace:
        binder:
          reconnect-retry-delay: 5000  # 每次重连的间隔时间（毫秒）
          max-reconnect-retries: -1   # 设置为-1表示无限重试（默认是10次）
          connect-retries-per-host: -1 # 每个Solace主机的连接重试次数，-1取消限制

2. 全局绑定器重试配置 #

针对生产者和消费者的消息交互环节，补充重试策略，确保连接恢复后能自动恢复消息处理：

spring:
  cloud:
    stream:
      bindings:
        # 替换为你的消费者绑定名称
        your-consumer-binding:
          consumer:
            max-attempts: -1             # 无限重试消息消费
            back-off-initial-interval: 3000 # 初始重试间隔
            back-off-multiplier: 2.0     # 间隔指数倍增
        # 替换为你的生产者绑定名称
        your-producer-binding:
          producer:
            max-attempts: -1             # 无限重试消息发送
            back-off-initial-interval: 3000

3. Solace Java API底层配置 #

Solace binder基于Solace Java API实现，直接配置底层客户端的重连参数，确保连接层的重试逻辑生效：

spring:
  cloud:
    stream:
      solace:
        binder:
          java:
            host: tcp://your-solace-host:55555
            msg-vpn: your-vpn-name
            client-username: your-username
            client-password: your-password
            reconnect-retry-wait-in-millis: 5000 # 底层重连间隔
            max-reconnect-retries: -1            # 底层无限重连
            connect-retries: -1                  # 初始连接无限重试

额外注意事项 #

• 确保使用Spring Cloud Stream Solace Binder 3.2.0及以上版本，早期版本存在重连逻辑缺陷；
• 检查Solace服务器的VPN配置，确认允许同一客户端ID重复连接；
• 代码中避免手动关闭连接后未释放资源，否则会导致重连逻辑无法触发；
• 若自定义了消息通道配置，不要覆盖默认的重连相关参数。

内容的提问来源于stack exchange，提问作者learner4life