RabbitMQ消息处理完整springboot代码

rabbitMQ配置

public class RabbitMQConfig {
   
    @Bean
    public MessageConverter jsonMessageConverter() {
   
        return new Jackson2JsonMessageConverter();
    }

    /**
     * 业务交换机，所有业务消息发到该交换机
     */
    @Bean
    @Qualifier("exchange")
    public TopicExchange exchange() {
   
        //创建topic交换机
        return new TopicExchange(RabbitMQContants.EXCHANGE, true, false);
    }
    }

生产者Sender

@Slf4j
@ConditionalOnBean(BaseRabbitMQTemplateConfig.class)
@Component
public class RabbitMQSender {