一、引入相关Jar
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
二、配置全局环境
#配置rabbitmq
spring.rabbitmq.host=192.168.43.118
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.port=5672
spring.rabbitmq.virtual-host=/
三、编写单元测试
@Autowired
RabbitTemplate rabbitTemplate;
@Test
public void contextLoads() {
rabbitTemplate.convertAndSend("exchange.direct","zhq.news",new User("张三",20));
}
@Test
public void receive(){
Object object = rabbitTemplate.receiveAndConvert("zhq.news");
System.out.println(object);
System.out.println(object.getClass());
}
默认是JDK的序列化是二字节码,可读性差:
可以自己定义序列化方式,可以通过编写自定义配置类:
@Configuration
public class MyAMQPConfig {
/**
* 注入Json序列化器
* @return
*/
@Bean
public MessageConverter messageConverter(){
return new Jackson2JsonMessageConverter();
}
}
得到: