SpringBoot整合多个Mq服务做法详解

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

@Data
@Component
public class MqTemplate {
    private RabbitTemplate rabbitTemplate;
    private String exchange;
    private String queue;
    private String routing_key;
}

@Data
@Component
class MqConfiguration {
    private String host;
    private Integer port;
    private String user;
    private String password;
    private String exchange;
    private String queue;
    private String routing_key;
}

@Configuration
public class MqConfig {
    @Bean
    @ConfigurationProperties(prefix = "mq.task-update-mq")
    public MqConfiguration taskUpdateMqConfiguration(){
        return new MqConfiguration();
    }
    @Bean
    public MqTemplate taskUpdateMq(MqConfiguration taskUpdateMqConfiguration) {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(taskUpdateMqConfiguration.getHost());
        connectionFactory.setPort(taskUpdateMqConfiguration.getPort());
        connectionFactory.setUsername(taskUpdateMqConfiguration.getUser());
        connectionFactory.setPassword(taskUpdateMqConfiguration.getPassword());
        connectionFactory.setVirtualHost("/");
        connectionFactory.setPublisherConfirms(true); //必须要设置
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        MqTemplate mqTemplate = new MqTemplate();
        mqTemplate.setRabbitTemplate(rabbitTemplate);
        mqTemplate.setExchange(taskUpdateMqConfiguration.getExchange());
        mqTemplate.setQueue(taskUpdateMqConfiguration.getQueue());
        mqTemplate.setRouting_key(taskUpdateMqConfiguration.getRouting_key());
        return mqTemplate;
    }
}

@Autowired
MqTemplate taskUpdateMq;

public interface MessageService {
    void sendDelayMessage(MqTemplate mqTemplate, String msg, Integer delay);
}

@Service
public class MessageServiceImpl implements MessageService {
    @Override
    public void sendDelayMessage(MqTemplate mqTemplate, String msg, Integer delay) {
        mqTemplate.getRabbitTemplate().convertAndSend(mqTemplate.getExchange(), mqTemplate.getRouting_key(), msg, message -> {
            message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
            message.getMessageProperties().setDelay(delay);
            message.getMessageProperties().setContentType("application/json");
            return message;
        });
    }
}