RabbitMq - Java客户端基础【简单案例 +Work模型】

import com.rabbitmq.client.*;
import java.io.IOException;
 
public class Send {
  private final static String QUEUE_NAME = "hello";
 
  public static void main(String[] argv) throws Exception {
    // 获取到连接以及mq通道
    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("UTF-8"));
      System.out.println(" [x] Sent '" + message + "'");
    }
  }
}
 
// 接收消息的代码类似上述发送消息的代码，只是在通道声明队列后，需要添加一个消息接收处理器。

以上代码演示了如何使用RabbitMQ Java客户端发送和接收消息。在发送消息的代码中，我们声明了一个名为"hello"的队列，并向该队列发送了一条文本消息。接收消息的代码也类似，只是需要在声明队列后注册一个消息处理器来接收并处理消息。