我正在开发独立的多线程应用程序,其中使用纯 JMS API 使用 P2P 机制同步发送和接收消息。当多个线程正在运行时,使用消费者对象(每个线程一个消费者对象)接收数据时抛出异常,说 IllegalStateException: Session is closed。我尝试了以下两种方式。
1)在单例类中创建连接和会话对象,并在发送和接收消息时使用这些对象。同步发送和接收消息的代码。
2)创建了 SessionPool 类(单例),它创建了 5 个会话。由于我的应用程序仅限于线程池计数 20,并且每个线程从会话池中检索会话并在收到消息后返回会话。这适用于 5 个线程,后来抛出异常说会话已关闭。
请帮助我了解如何有效地使用会话对象,而无需为每个线程创建一个会话。