部署在WebLogic时Spring Integration JMX消息丢失问题求助

嘿，我碰到过类似的跨容器JMX问题，Tomcat跑好好的到WebLogic就出状况，大概率是容器特性差异搞的鬼。结合你的代码（用了Spring的MessageChannel和JMX Headers），给你梳理几个高概率的排查方向和解决办法：

1. 先排查WebLogic的类加载冲突 #

WebLogic的类加载机制比Tomcat严格得多，JMX相关的类很容易和WebLogic自带的库打架。比如你的应用里如果带了javax.management或者Spring JMX的jar包，可能和WebLogic内置的版本不一致，导致消息处理逻辑偷偷出错。

• 怎么查：
  • 看看WEB-INF/lib里有没有重复的JMX依赖；
  • 开启WebLogic的verbose-classloading日志，搜搜有没有ClassCastException或者类加载冲突的报错。
• 解决办法：
  在weblogic.xml里配置让应用优先加载自己的类，避免容器类干扰：

  <container-descriptor>
    <prefer-web-inf-classes>true</prefer-web-inf-classes>
  </container-descriptor>
  

  如果怕影响其他类，可以更精准地指定优先加载的包：

  <container-descriptor>
    <prefer-application-packages>
      <package-name>javax.management.*</package-name>
      <package-name>org.springframework.jmx.*</package-name>
    </prefer-application-packages>
  </container-descriptor>
  

2. 确认JMX MBean服务器是否匹配 #

WebLogic有好几个自己的MBean服务器（比如domain runtime、runtime），而Spring默认可能绑定的是JDK的平台MBean服务器。这就会出现你发消息到A服务器，但JConsole看的是B服务器，自然数对不上。

• 怎么查：
  在代码里加一行打印，看看当前用的是哪个MBean服务器：

  MBeanServer server = ManagementFactory.getPlatformMBeanServer();
  System.out.println("当前MBeanServer域名: " + server.getDefaultDomain());
  

  对比Tomcat和WebLogic下的输出，肯定不一样。
• 解决办法：
  配置Spring明确使用WebLogic的MBean服务器，比如绑定到runtime服务器：

  @Bean
  public MBeanServer mBeanServer() throws NamingException {
    InitialContext ctx = new InitialContext();
    // 查找WebLogic的runtime MBean服务器
    return (MBeanServer) ctx.lookup("java:comp/env/jmx/runtime");
  }
  

  这样消息就能发到WebLogic的JMX服务器上，JConsole里就能收到了。

3. 检查异步消息的线程池限制 #

如果你的MessageChannel是异步的（比如用了ExecutorChannel），WebLogic的默认线程池可能不够用，导致消息被压在队列里甚至丢弃。Tomcat的线程池配置相对宽松，所以没暴露问题。

• 怎么查：
  登录WebLogic控制台，看服务器>配置>线程池里的活跃线程数、队列长度，如果队列满了或者线程全占了，就是这个问题；
  开Spring的DEBUG日志，搜MessageChannel相关的日志，看有没有线程阻塞的提示。
• 解决办法：
  要么调大WebLogic的线程池，要么给Spring的消息通道单独配置线程池：

  @Bean
  public Executor messageTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(12);
    executor.setMaxPoolSize(20);
    executor.setQueueCapacity(150);
    executor.initialize();
    return executor;
  }
  
  @Bean
  public MessageChannel channel(Executor messageTaskExecutor) {
    return new ExecutorChannel(messageTaskExecutor);
  }
  

4. 排查JMX权限和通知过滤 #

WebLogic的安全策略默认可能限制了JMX通知的发送，或者JConsole没订阅到正确的通知类型。

• 怎么查：
  检查WebLogic的weblogic.policy文件，看有没有给应用分配JMX通知的权限；
  在JConsole里确认订阅的通知类型和你代码里JmxHeaders.NOTIFICATION_TYPE的值完全一致（大小写、拼写都不能错）。
• 解决办法：
  在weblogic.policy里添加权限：

  grant codeBase "file:/你的应用路径/WEB-INF/lib/-" {
    permission javax.management.MBeanPermission "*", "registerNotification";
    permission javax.management.MBeanPermission "*", "sendNotification";
  };
  

  同时在JConsole里重新订阅一次，确保类型匹配。

5. 检查消息序列化是否正常 #

如果你的消息payload（obj）在WebLogic下序列化失败，Spring可能悄悄丢弃消息而不抛异常（取决于配置）。Tomcat的序列化环境可能更宽松，所以没出问题。

• 怎么查：
  给消息发送代码加个try-catch，捕获所有异常：

  try {
    Message<?> message = MessageBuilder.withPayload(obj)
        .setHeader(JmxHeaders.NOTIFICATION_TYPE, notificationType)
        .build();
    boolean sent = channel.send(message);
    System.out.println("消息发送结果: " + sent);
  } catch (Exception e) {
    // 这里大概率能抓到序列化相关的异常
    e.printStackTrace();
  }
  

• 解决办法：
  确保obj实现了Serializable接口，或者给Spring配置合适的消息转换器；如果是自定义对象，检查有没有非序列化的成员变量。

按照这个顺序排查，应该能很快定位到问题。如果某个步骤里出现了具体的报错，随时补充细节再细化分析～

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