如何部署运行无Web界面的EAR Java程序，实现WebSphere部署后自动运行

你现有的代码是依赖main方法启动的Java SE程序，WebSphere作为JavaEE容器不会主动执行main方法，需要改为符合JavaEE规范的自启动组件实现自动运行，具体实现步骤如下：

• 改造现有消费者代码，使用Singleton Startup EJB实现自启动
  用@Singleton标注单例Bean，@Startup标注容器启动时自动初始化该Bean，@PostConstruct标注的方法会在Bean初始化完成后自动执行，@PreDestroy标注的方法会在应用停止/容器关闭时自动执行，用来优雅关闭消费者，避免连接泄漏。
  改造后代码示例：

  // WebSphere 9+ 用jakarta包，8.5及更早版本替换为javax包即可
  import jakarta.annotation.PostConstruct;
  import jakarta.annotation.PreDestroy;
  import jakarta.ejb.Singleton;
  import jakarta.ejb.Startup;
  import org.apache.kafka.clients.consumer.ConsumerConfig;
  import org.apache.kafka.clients.consumer.ConsumerRecord;
  import org.apache.kafka.clients.consumer.ConsumerRecords;
  import org.apache.kafka.clients.consumer.KafkaConsumer;
  import org.apache.kafka.common.serialization.StringDeserializer;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import java.time.Duration;
  import java.util.Collections;
  import java.util.Properties;
  import java.util.concurrent.atomic.AtomicBoolean;
  
  @Singleton
  @Startup
  public class KafkaConsumerStartupBean {
      private static final Logger logger = LoggerFactory.getLogger(KafkaConsumerStartupBean.class);
      private KafkaConsumer<String, String> consumer;
      private Thread consumerThread;
      private final AtomicBoolean isRunning = new AtomicBoolean(true);
  
      @PostConstruct
      public void init() {
          // 初始化消费者配置
          Properties props = new Properties();
          props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka165.harishfysx.com:9092");
          props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
          props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
          props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-fourth-application");
          props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  
          consumer = new KafkaConsumer<>(props);
          consumer.subscribe(Collections.singleton("first_topic"));
  
          // 启动独立线程运行消费者轮询逻辑，避免阻塞容器初始化线程
          consumerThread = new Thread(() -> {
              while (isRunning.get()) {
                  ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
                  for (ConsumerRecord<String, String> record : records) {
                      logger.info("Value: {}", record.value());
                      logger.info("Offset: {}", record.offset());
                  }
              }
          });
          consumerThread.setName("kafka-consumer-thread");
          consumerThread.start();
      }
  
      @PreDestroy
      public void destroy() {
          // 优雅停止消费者
          isRunning.set(false);
          if (consumer != null) {
              consumer.wakeup();
              try {
                  consumerThread.join(2000);
              } catch (InterruptedException e) {
                  logger.error("消费者线程停止等待中断", e);
                  Thread.currentThread().interrupt();
              }
              consumer.close();
          }
          logger.info("Kafka消费者已正常关闭");
      }
  }
  

• 打包为EAR包
  把改造后的EJB代码打包为EJB Jar模块，再打包进EAR包即可，不需要添加任何Web模块，application.xml中仅声明EJB模块即可，无需配置上下文根等Web相关参数。

• WebSphere部署配置

  1. 部署EAR包时，不需要配置Web虚拟主机、上下文根等Web相关属性，正常完成部署流程即可
  2. Kafka客户端依赖可选择打入EJB Jar的BOOT-INF/lib目录，或配置为WebSphere共享库绑定到当前应用，避免类加载冲突
  3. 应用部署完成后启动，容器会自动初始化Startup Bean，启动Kafka消费者线程，不需要额外访问任何Web地址

• 注意事项

  1. 消费者轮询逻辑要放在独立的后台线程中执行，不能直接阻塞@PostConstruct方法，否则会导致应用启动超时
  2. 必须在@PreDestroy方法中主动关闭Kafka消费者，避免应用停止时残留连接、消费者组异常
  3. 如果需要调整消费者参数，不要硬编码在代码中，可以配置到WebSphere的资源环境变量中，运行时动态读取，方便后续修改无需重新打包

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