rabbitmq学习(四) 使用rabbitmq后台申请交换器和队列

本文主要是介绍rabbitmq学习(四) 使用rabbitmq后台申请交换器和队列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

上一遍博客中介绍了rabbitmq交换器的类型、队列和交换器的动态声明、交换器动态绑定到队列及使用队列发送和接收消息。在实际的工作中队列和交换器都是从后台管理中申请，程序中直接使用就可以了，今天介绍一下使用spring-boot连接rabbit中已存在的队列和交换器发送和接收消息。
一、管理后台中创建队列和交换器并将交换器绑定到队列
1.创建队列
登录rabbitmq 管理后台选择Queues标签，点击Add a new queue，输入要创建的队列名称然后点击Add queue 按钮
在这里插入图片描述
队列创建成功
2.创建交换器
选择Exchanges标签，点击Add a new exchange,输入交换器名称然后点击Add exchange 按钮

交换器创建成功

3.绑定交换器到队列
点击要绑定队列的交换器名字，跳转到交换器详细信息页，显示该交换器为绑定任何的队列或交换器
在这里插入图片描述

输入要绑定的队列名称和路由键(因为创建的是direc交换)，点击绑定按钮

绑定成功如下图

二、创建spring-boot应用连接rabbit收发消息
1.引入maven依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.59</version>
</dependency>

2.配置连接信息

spring:application:name: rabbit-example2rabbitmq:host: 192.168.98.23port: 5672username: rootpassword: root
server:port: 8081

3.创建消息生产者

@Component
public class RabbitProducer {@AutowiredAmqpTemplate amqpTemplate;public void sendMessage(Object object) {try {Message message= MessageBuilder.withBody(JSON.toJSONString(object).getBytes("UTF-8")).setContentType(MessageProperties.CONTENT_TYPE_JSON).setContentEncoding("UTF-8").setMessageId(UUID.randomUUID().toString()).build();// 指定exchange name 为x.test0831,路由键为 rk.testamqpTemplate.send("x.test0831","rk.test",message);} catch (UnsupportedEncodingException e) {e.printStackTrace();}}
}

4.创建rest接口发送消息

@RestController
@RequestMapping(value = "/messages")
public class MessageController {@AutowiredRabbitProducer rabbitProducer;@PostMapping(value = "/send")public Map<String,Object> sendMessage(@RequestBody Map<String,Object> paramMap) {rabbitProducer.sendMessage(paramMap);Map<String,Object> resultMap=new HashMap<>();resultMap.put("status","success");return resultMap;}
}

5.使用postman测试消息发送
在这里插入图片描述
6.查看队列中是否有收到消息

4.创建消息消费者
@Component
@RabbitListener(queues = “q.test0831”) // 监听队列q.test0831
public class RabbitConsumer {

@RabbitHandler
public void receiveMessage(Object object) {Message message=(Message)object;byte bytes[]=null;if (message != null) {bytes=message.getBody();}try {String msg=new String(bytes,"UTF-8");System.out.println("receive message is ------------------------"+msg);} catch (UnsupportedEncodingException e) {e.printStackTrace();}
}

}
启动应用，输出日志
在这里插入图片描述
源码地址
https://github.com/tangyajun/spring-boot-rabbitmq-example2