每次我需要在主题中添加消息时，我都会使用以下代码来创建发布者，我将运行此代码，但有时会出现错误
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://" + ip + ":" + port );
connection = connectionFactory.createConnection();
connection.setClientID(publisherName);
PooledConnectionFactory pf = new PooledConnectionFactory(connectionFactory);
pf.setMaxConnections(1000);
Session session = connection.createSession(false,session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(TopicName);
MessageProducer messageProducer = session.createProducer(topic);
错误:
javax.jms.InvalidClientIDException: Broker: localhost - Client: AthenaPublisher already connected from tcp://127.0.0.1:44448
最佳答案
在设置客户端 ID 时使用池将不可避免地导致此类错误，因为在任何给定时间只能将一个具有给定客户端 ID 的连接连接到代理。在您的情况下，您将池配置为 1000 个池连接，因此经常会创建一个新连接并产生您给出的错误。您需要不使用池化，或者使用只有 1 个池化连接的池，与您的代码共享 session 级资源。
关于java - 如何使用连接池在 JM 中使用 activeMQ 创建发布者，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56968098/