Jms在swing应用程序中发送消息时的最佳实践？

Question

在我的JavaSwing应用程序中，我实现了一个与jms服务器通信的jms客户机。这很好。

当前，当我的应用程序启动时，我创建连接和会话：

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

接下来，当我需要向主题发送消息时，我创建了一个主题（发送消息）、一个临时队列（接收回复）、一个生产者（发送消息）和一个消费者（实际读取回复）：

Destination destination = session.createTopic ...
MessageProducer producer = session.createProducer ...
Destination tempDest = session.createTemporaryQueue(); 
MessageConsumer responseConsumer = session.createConsumer(tempDest);
producer.send(msg);

我想知道在这种情况下最好的做法是什么？

当我需要发送消息时，我可以简单地创建所有内容吗？或者最好将目标、消息生产者、消息消费者保存在某个地方并重新使用它。当我决定重新使用这些对象时，有什么特别需要注意的吗？

Answer 1

您应该重用您能够重用的对象。

该连接可能会为您的整个应用程序重新使用，因为它是线程安全的。

会话对象不是线程安全的，在这种情况下，您应该坚持每个线程一个会话。

你可以作弊。使用＜code＞org.apache.activemq.pool。PooledConnectionFactory，它将设置会话、连接和生产者池。

您仍然需要编写＜code＞connection.createSession（…），但这只是从池中获取和释放对象。

如果您对并发性有细粒度的控制，实际上重用您的对象可能会更容易，但这种情况很少发生。