我在java中编写代码以连接到具有不同应用程序的RabbitMQ服务器 . 这是我的代码:

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("IP");
factory.setUsername("username");
factory.setPort(portnumber);
factory.setPassword("password");

Connection connection = factory.newConnection(); 
Channel channel = connection.createChannel();
channel.basicPublish("queue", "", null, string.getBytes());

最后关闭连接和通道

channel.close();
connection.close();

我试图通过五次尝试 Build 连接,每次都使用新的Connection和channel . 因此,在RabbitMQ服务器主机端出现了一些性能问题 . 任何人都可以帮助我在客户端实现代码