rabbitmq 单对单发消息
时间: 2023-07-03 22:26:44 浏览: 56
使用 RabbitMQ 进行单对单消息传递,需要先创建一个消息队列(queue)并将消息发送到该队列中。然后,接收方可以从该队列中获取消息并进行处理。以下是实现 RabbitMQ 单对单消息传递的示例代码:
1. 创建连接和通道
```
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
```
2. 创建队列并发送消息
```
String queueName = "my_queue"; // 队列名称
channel.queueDeclare(queueName, false, false, false, null); // 创建队列
String message = "hello, world"; // 待发送的消息内容
channel.basicPublish("", queueName, null, message.getBytes()); // 发送消息到队列
```
3. 接收消息并进行处理
```
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
System.out.println("Received message: " + message);
};
channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});
```
注意:在实际应用中,需要根据具体需求进行适当的调整,例如,设置消息的持久性、确认机制等,同时还需要考虑消息的格式和内容等问题。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)