rabbitmq序列化 生产者序列化 ,默认是jdk序列化
@Bean
@Primary
@ConditionalOnMissingBean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate template = new RabbitTemplate(connectionFactory);
template.setMessageConverter(new Jackson2JsonMessageConverter());
template.afterPropertiesSet();
template.setMandatory(true);
return template;
}
消费者序列化,不写的话,只能用字节数组接收,不能转换成实体类
@Bean
@Primary
@ConditionalOnMissingBean
MessageConverter messageConverter(){
return new Jackson2JsonMessageConverter();
}
这个注解千万别放在类上,虽然支持,会拆坑的 放在方法上
@RabbitListener