DefaultMessageListenerContainer是否停止，关闭关闭数据库连接？

Question

我有一个defaultmessagelistenercontainer，正在从队列中处理一条消息。

在处理该消息时 - 停止，在DefaultMessageListenerContainer上调用了关闭方法。这个关闭的数据库连接吗？

看起来它正在关闭数据库连接，因此正在处理的消息被完全处理中断。

我看到以下错误：

osjdbc.support.sqlerrorcodesfactory：提取数据库名称时错误 封闭连接；嵌套例外是Java.sql.sqlrecoverableException：封闭的连接

可能是因为停止并关闭了DefaultMessageListenerContainer？

---

我的代码如下。 StartStopContainer是我试图停止和关闭容器的地方。我只想在侦听器完成当前消息时关闭容器。我添加了逻辑以找出侦听器是否完成处理。

是以下逻辑是唯一的方法，还是有更好的方法来确定听众是否完成处理。请建议。谢谢。

public class MyMessageConsumerFacade {
    
    private ConnectionFactory connectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(url);
        connectionFactory.setUserName(userName);
        connectionFactory.setPassword(password);

        return connectionFactory;
    }

    @Bean
    public MessageListenerContainer listenerContainer() {
        
        DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
        container.setConnectionFactory(connectionFactory());
        container.setDestinationName(queueName);
        container.setMessageListener(new MyJmsListener());      
        return container;
    }
}

public class MyJmsListener implements MessageListener { 
  public boolean onMessageCompleted; 
  public void onMessage(Message message) { 
     onMessageCompleted = false; 
     processMessage(message); 
     onMessageCompleted = true; 
  } 
} 

private String startStopContainer(ExecutionContext etk)  {
        String response = "success";
        
        AnnotationConfigApplicationContext context = null;
        DefaultMessageListenerContainer myNewContainer = null;
        
        if (context == null) {
            context = new AnnotationConfigApplicationContext(MyMessageConsumerFacade.class);
        }   

        if (myNewContainer == null) {
            myNewContainer = context.getBean(DefaultMessageListenerContainer.class);
        }

        MyCaseMessageJmsListener messageJmsListener = (MyCaseMessageJmsListener) myNewContainer.getMessageListener();
        

        if (!myNewContainer.isRunning()) {// container not running
            myNewContainer.start();
        }
        
        //due to some business logic we need to stop listener every 5 minutes, so sleep for 5 minutes and then stop
        try {
            Thread.sleep(300000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
                                
        if (myNewContainer.isRunning()) {
            myNewContainer.stop();
            
        }
        
        //Before shutting down container , make sure listener processed all msgs completely
        if(!messageJmsListener.isOnMessageCompleted) {      
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if(messageJmsListener.isOnMessageCompleted) {
            myNewContainer.shutdown();
        }
        
        if (context != null) {
            context.destroy();          
        }
        
        return response;
    }    

有比这更好的方法吗？

Answer 1

不;该容器对JDBC或与此连接的任何连接一无所知。

停止容器只能阻止JMS消费者接收消息； 关闭（）在容器上关闭消费者。

其他东西正在关闭您的JDBC连接。