0

我正在开发独立的多线程应用程序,其中使用纯 JMS API 使用 P2P 机制同步发送和接收消息。当多个线程正在运行时,使用消费者对象(每个线程一个消费者对象)接收数据时抛出异常,说 IllegalStateException: Session is closed。我尝试了以下两种方式。

1)在单例类中创建连接和会话对象,并在发送和接收消息时使用这些对象。同步发送和接收消息的代码。

2)创建了 SessionPool 类(单例),它创建了 5 个会话。由于我的应用程序仅限于线程池计数 20,并且每个线程从会话池中检索会话并在收到消息后返回会话。这适用于 5 个线程,后来抛出异常说会话已关闭。

请帮助我了解如何有效地使用会话对象,而无需为每个线程创建一个会话。

4

1 回答 1

0

您可能需要重新考虑您的架构。

JMS 是一种在 JMS 提供者和 JMS 消费者之间进行通信的方式。这更像是一种客户端-服务器架构。我不建议将其用于 p2p。

于 2013-03-28T21:26:59.733 回答