在收到消息后关闭JMS会话和连接

Question

我有一个有状态的会话bean，我在那里发送和接收JMS消息。所有的连接设置都是手动处理的，因此bean包含javax.jms.connection和javax.jms.Session的实例。该bean还实现了MessageListener，使其能够接收消息。

注意：这是在Java EE环境(GlassFish4.0)中执行的

编辑：

import javax.ejb.LocalBean;
import javax.ejb.Stateful;
import javax.inject.Inject;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.sun.messaging.ConnectionConfiguration;
import com.sun.messaging.QueueConnectionFactory;

@LocalBean
@Stateful
public class OpenMqClient implements MessageListener{
    private Connection connection;
    private Session session;
    private MessageConsumer responseConsumer;

    public OpenMqClient(){}

    public void sendMessage(String messageContent, String jmsBrokerUri, String queueName) {
        try{
            String host = System.getProperty("foo", jmsBrokerUri);
            QueueConnectionFactory cf = new QueueConnectionFactory();
            cf.setProperty(ConnectionConfiguration.imqAddressList, host);
            connection = null;
            session = null;

            //Setup connection
            connection = cf.createConnection();
            connection.start();
            session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

            //Setup queue and producer
            Queue queue = session.createQueue(queueName);
            MessageProducer producer = session.createProducer(queue);


            //Reply destination
            Queue responseQueue = session.createTemporaryQueue();
            responseConsumer = session.createConsumer(responseQueue);
            responseConsumer.setMessageListener(this);

            //Create message
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSReplyTo(responseQueue);
            textMessage.setJMSCorrelationID("test0101");
            textMessage.setText(messageContent);

            producer.send(textMessage);
            System.out.println("Message sent");
        } catch (JMSException e) {
            e.printStackTrace();
            System.out.println("JMSException in Sender");
        }
    }

    @Override
    public void onMessage(Message arg0) {
        //On this event I want to close the session and connection, but it's not permitted
    }

}

Answer 1

就我个人而言，这就是我要做的（注意，我没有测试或添加太多错误处理到这段代码中）。

>

使连接静态化-您可以（可能应该）为所有bean重用相同的连接，除非您有特定的理由不这样做

关闭新线程中的会话

public class OpenMqClient implements MessageListener {

    private static Connection connection;
    private static final String mutex = "mutex"; 
    private Session session;
    private MessageConsumer responseConsumer;

    public OpenMqClient() {
        if(connection == null) {
            synchronized(mutex) {
                if(connection == null) {
                    String host = System.getProperty("foo", jmsBrokerUri);
                    QueueConnectionFactory cf = new QueueConnectionFactory();
                    cf.setProperty(ConnectionConfiguration.imqAddressList, host);

                    // Setup connection
                    connection = cf.createConnection();
                    connection.start();
                }
            }
        }
    }

    public void sendMessage(String messageContent, String jmsBrokerUri, String queueName) {
        try {
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // Setup queue and producer
            Queue queue = session.createQueue(queueName);
            MessageProducer producer = session.createProducer(queue);

            // Reply destination
            Queue responseQueue = session.createTemporaryQueue();
            responseConsumer = session.createConsumer(responseQueue);
            responseConsumer.setMessageListener(this);

            // Create message
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSReplyTo(responseQueue);
            textMessage.setJMSCorrelationID("test0101");
            textMessage.setText(messageContent);

            producer.send(textMessage);
            System.out.println("Message sent");
        } catch (JMSException e) {
            e.printStackTrace();
            System.out.println("JMSException in Sender");
        }
    }

    @Override
    public void onMessage(Message arg0) {
        // do stuff
        new Thread(
            new Runnable() {
                @Override
                public void run() {
                    if(session != null)
                        try {
                            session.close();
                        } catch (JMSException e) {
                            e.printStackTrace();
                        }               
                }
            }
        ).start();
    }
}