g message){
System.out.println("中国队列接受消息："+message);
}
@RabbitListener(bindings = @QueueBinding(
value = @Queue(name = "topic.queue2"),
exchange = @Exchange(name = "topic.exchange",type = ExchangeTypes.TOPIC),
key = "#.news"
))
public void listenTopicQueue2(String message){
System.out.println("新闻队列接受消息："+message);
}
2.生产者
//主题类型交换机
@Test
public void testTopicExchangeQueue(){
//交换机名称
String exchangeName = "topic.exchange";
//消息
String message = "china.lala消息";
//发送，第二个参数是队列的key,在路由类型中可以使用到
rabbitTemplate.convertAndSend(exchangeName,"china.news",message);
}
3.消息转换器
Spring会把你发送的消息序列化为字节发送给MQ，接收消息的时候，还会把字节反序列化为Java对象。
默认情况下Spring采用的序列化方式是JDK序列化。众所周知，JDK序列化存在下列问题：
因此需要配置一个Json转换器
步骤
- 在publisher和consumer两个服务中都引入依赖：
<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-xml</artifactId>
<version>2.9.10</version>
</dependency>
- 配置消息转换器。在启动类中添加一个Bean即可：
@Bean
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}