rabbitmq java

RabbitMQ是一个开源的消息代理，它实现了高级消息队列协议（AMQP）并支持多种消息传递模式。RabbitMQ Java版是RabbitMQ的Java客户端，可以用于在Java应用程序中发送和接收消息。以下是使用RabbitMQ Java版的一些步骤：

1. 环境配置：需要安装Rabbit Server和Erlang，并配置好Java开发环境。

2. 添加依赖：可以通过Maven添加amqp-client依赖，如下所示：

   <dependency>
     <groupId>com.rabbitmq</groupId>
     <artifactId>amqp-client</artifactId>
     <version>5.6.0</version>
   </dependency>

3. 创建连接：使用ConnectionFactory创建一个连接，如下所示：

   ConnectionFactory factory = new ConnectionFactory();
   factory.setHost("localhost");
   Connection connection = factory.newConnection();

4. 创建通道：使用Connection创建一个通道，如下所示：

   Channel channel = connection.createChannel();

5. 声明队列：使用Channel声明一个队列，如下所示：

   String queueName = "hello";
   channel.queueDeclare(queueName, false, false, false, null);

6. 发送消息：使用Channel将消息发送到队列中，如下所示：

   String message = "Hello World!";
   channel.basicPublish("", queueName, null, message.getBytes("UTF-8"));

7. 接收消息：使用Channel从队列中接收消息，如下所示：

   DeliverCallback deliverCallback = (consumerTag, delivery) -> {
       String message = new String(delivery.getBody(), "UTF-8");
       System.out.println("Received message: " + message);
   };
   channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });