我在 Map 中有消息 - 作为队列名称的键和作为消息列表的值。每当我将多条消息发布到队列服务器时，都会引发异常，因为用户已达到允许的最大登录次数。
同时将消息发布到 1 个队列。下面是执行的代码：
public class MessageManager {
public static void publish(String exchange, HashMap<String, List<String>> queueNameWithMessages) throws IOException {
...
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(Constants.HOST_NAME);
factory.setUsername(Constants.USER_NAME);
factory.setPassword(Constants.PASSWORD);
factory.setPort(Constants.PORT);
Connection connection = factory.newConnection();
Channel ch = connection.createChannel();
Channel ch1 = connection.createChannel();
try {
for(Entry<String, List<String>> entry : queueNameWithMessages) {
String routingKey = entry.getKey();
for(String messageToBeSent : entry.value()) {
ch.basicPublish(exchange, routingKey, true, MessageProperties.PERSISTENT_BASIC, messageToBeSent.getValue().getBytes());
}
ExecutorService threadExecutor = Executors.newFixedThreadPool(5);
String responseKey = props.getProperty(routingKey);
if(!CLAMUtility.workingListnerToRespnseQueue.contains(responseKey)) {
Worker fast = new Worker(0, threadExecutor, ch1,responseKey, routingKey);
CLAMUtility.workingListnerToRespnseQueue.add(responseKey);
}
}
ch.close();
System.out.println("Message published successfully!\n \n");
} catch (Exception e) {
e.printStackTrace();
}
}
}