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

SpringBoot整合多个Mq服务 SpringBoot配置Mq服务 2023-02-14 18:02:36 437人浏览独家记忆

Python 官方文档：入门教程 => 点击学习

摘要

目录1、自定义一个MQTemplate2、定义一个mq配置项相对应的类3、将我们自定义的mq配置定义成MQtemplate类型的bean4、使用对应的Template发送消息以Rab

1、自定义一个MqTemplate

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

在这里面我们定义了RabbitTemplate、交换机、路由，队列，如果需要其他的数据，也可以往上加

2、定义一个mq配置项相对应的类

@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;
}

这个类的作用是将我们配置文件中的信息转成实体类

3、将我们自定义的mq配置定义成MqTemplate类型的bean

@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;
    }
}

这里我们就将该mq配置加载成一个名为taskUpdateMq的bean。当需要添加其他的mq服务的时候，我们只需要在这个配置类里面定义bean即可

4、使用对应的Template发送消息

首先我们把taskUpdateMq注入到业务代码中

@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;
        });
    }
}

调用方法的时候将MqTemplate对象传入就好了。

到此这篇关于SpringBoot整合多个Mq服务做法详解的文章就介绍到这了,更多相关SpringBoot整合Mq服务内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: SpringBoot整合多个Mq服务做法详解

本文链接: https://www.lsjlt.com/news/196067.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341