package com.zt.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import com.zt.common.message.producer.MessageProducer; import com.zt.common.message.producer.SynchronousQueueProducer; @Configuration public class MessageConfiguration { @Bean public MessageProducer messageProducer() { // 未来可以扩展其他渠道,并通过配置选择 return new SynchronousQueueProducer(); } }