2024年Java最全使用java操作rabbitmq中间件，高级Java开发必看

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
 
public class Send {
  private final static String QUEUE_NAME = "hello";
 
  public static void main(String[] argv) throws Exception {
    // 创建连接工厂
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    // 创建连接
    try (Connection connection = factory.newConnection();
         Channel channel = connection.createChannel()) {
      // 声明一个队列，如果队列不存在会被创建
      channel.queueDeclare(QUEUE_NAME, false, false, false, null);
      String message = "Hello World!";
      // 发布消息到队列中
      channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
      System.out.println(" [x] Sent '" + message + "'");
    }
  }
}

这段代码演示了如何使用RabbitMQ的Java客户端发送一条简单的消息到一个队列。首先，它创建了一个连接工厂并设置了RabbitMQ服务的主机地址。然后，它创建了一个连接和一个通道，并声明了一个名为“hello”的队列。最后，它发送了一个字符串消息到这个队列。这是进行消息队列编程的一个基本例子。