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

上一遍博客中介绍了rabbitmq交换器的类型、队列和交换器的动态声明、交换器动态绑定到队列及使用队列发送和接收消息。在实际的工做中队列和交换器都是从后台管理中申请，程序中直接使用就能够了，今天介绍一下使用spring-boot链接rabbit中已存在的队列和交换器发送和接收消息。
1、管理后台中建立队列和交换器并将交换器绑定到队列
1.建立队列
登陆rabbitmq 管理后台选择Queues标签，点击Add a new queue，输入要建立的队列名称而后点击Add queue 按钮

队列建立成功
2.建立交换器
选择Exchanges标签，点击Add a new exchange,输入交换器名称而后点击Add exchange 按钮

交换器建立成功

3.绑定交换器到队列
点击要绑定队列的交换器名字，跳转到交换器详细信息页，显示该交换器为绑定任何的队列或交换器


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

绑定成功以下图

2、建立spring-boot应用链接rabbit收发消息
1.引入maven依赖git

<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.配置链接信息github

spring:
  application:
    name: rabbit-example2
  rabbitmq:
    host: 192.168.98.23
    port: 5672
    username: root
    password: root
server:
  port: 8081

3.建立消息生产者web

@Component
public class RabbitProducer {
	@Autowired
	AmqpTemplate 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.test
			amqpTemplate.send("x.test0831","rk.test",message);
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
	}
}

4.建立rest接口发送消息spring

@RestController
@RequestMapping(value = "/messages")
public class MessageController {
	@Autowired
	RabbitProducer 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 {json

@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-example2app