Spring Reactive Redis跨VM虚拟网络PubSub失效问题求助

看起来你遇到的是典型的跨网络环境下Redis长连接订阅失效问题，本地同机测试正常但跨VM就不行，结合Azure Redis的特性，咱们从几个核心方向排查：

一、先确认网络层面的连通性（最常见原因） #

虽然你说两个服务都能连接到Redis，但Redis的Pub/Sub依赖持久化长连接，和普通的命令请求（比如set/get）不一样——普通请求是短连接，而订阅需要一直保持TCP连接不中断。

• 检查订阅者VM的NSG规则：确保订阅者所在VM的网络安全组（NSG）允许**出站TCP 6380端口（Azure Redis默认SSL端口）**的连接，并且没有设置过短于Redis客户端心跳的超时时间（Azure NSG默认TCP超时是4分钟，如果客户端心跳间隔比这个长，连接会被强制断开）。
• Azure Redis的虚拟网络白名单：去Azure Redis门户的「网络」配置页，确认两个VM所在的虚拟网络都已经添加到允许访问的列表里。有时候可能只加了发布者的VNet，订阅者的漏加了——虽然短连接能通，但长连接可能被防火墙拦截。
• 测试长连接稳定性：在订阅者VM上用命令行工具测试到Redis的长连接：

  nc -zv your-redis-host.redis.cache.windows.net 6380
  

  保持会话5分钟以上，看是否会被断开。如果中途断开，说明网络层面有连接超时限制。

二、检查Redis客户端配置一致性 #

发布者用redisStringTemplate，订阅者用redisTemplate，要确保两个模板的配置完全一致：

• SSL连接是否开启：Azure Redis强制要求SSL连接（除非你特意关闭了，不推荐），检查订阅者的Redis配置是否指定了SSL端口6380，并且开启了SSL：

  spring.redis.host=your-redis-host.redis.cache.windows.net
  spring.redis.port=6380
  spring.redis.password=your-redis-password
  spring.redis.ssl=true
  

• 长连接心跳配置：用Lettuce客户端（Spring Boot默认）的话，要配置心跳机制防止连接被回收：

  @Bean
  public LettuceClientOptions lettuceClientOptions() {
      return LettuceClientOptions.builder()
          .pingBeforeActivateConnection(true)
          .heartbeatInterval(Duration.ofSeconds(30))
          .build();
  }
  

  这个心跳会定期向Redis发送PING，保持长连接活跃。
• 频道名称是否完全一致：Redis的频道名是大小写敏感的！确认两边的syncQueue变量值完全相同，比如有没有大小写、空格或者特殊字符的差异。

三、验证订阅逻辑的正确性 #

• 订阅是否真的启动了：检查subscriberToChannel()方法是否在服务启动时被调用。比如有没有加@PostConstruct注解，或者在ApplicationRunner/CommandLineRunner里触发？如果这个方法没执行，自然不会订阅频道。
• 用Redis CLI手动测试：在订阅者VM上用Redis CLI连接到Azure Redis，手动订阅频道：

  redis-cli -h your-redis-host.redis.cache.windows.net -p 6380 -a your-redis-password --ssl subscribe your-sync-queue-name
  

  然后让发布者发消息，如果CLI能收到，说明是代码层面的问题；如果CLI也收不到，那肯定是网络或者Redis配置的问题。

四、查看Azure Redis监控指标 #

去Azure Redis门户的「监控」页面，查看这几个指标：

• Connected Clients：确认订阅者的连接是否存在，如果订阅成功会有一个长期在线的客户端。
• Pub/Sub Messages Received：如果这个指标没有增长，说明Redis根本没把消息推给订阅者，大概率是订阅连接没建立或者断开了。
• Failed Connections：看是否有订阅者的连接失败记录。

总结可能的解决方案 #

1. 如果是网络问题：调整NSG的TCP超时时间（至少大于客户端心跳间隔），或者配置客户端心跳保持连接活跃。
2. 如果是客户端配置：统一发布者和订阅者的Redis配置，确保都用SSL连接，开启心跳。
3. 如果是代码逻辑：确认订阅方法在服务启动时被正确触发，频道名称完全一致。

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