首页 / RABBITMQ / Springboot接入RabbitMQ详细教程

Springboot接入RabbitMQ详细教程

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Springboot接入RabbitMQ详细教程，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2571字，纯文字阅读大概需要4分钟。

内容图文

本文适用于对 RabbitMQ 有所了解的人，在此不讨论MQ的原理，只讨论如何接入。其实Spring Boot 集成 RabbitMQ 非常简单，本文章使用的是Spring Boot 提供了spring-boot-starter-amqp 项目对消息各种支持。

接下来将进入正题，六步轻松教你接入RabbitMQ

1.配置pom文件所依赖的主要jar包

<dependency>
     <groupId>org.springframework.amqp</groupId>
     <artifactId>spring-rabbit</artifactId>
     <version>2.0.4.RELEASE</version>
</dependency>

 

2.配置文件（application.properties）

            ## rabbitmq
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=root
spring.rabbitmq.password=root
spring.rabbitmq.virtual-host=/

# rabbitmq消息确认
spring.rabbitmq.publisher-confirms=true
spring.rabbitmq.publisher-returns=true

## rabbitmq-config
rabbitmq.exchange-key = rabbitmq.test.exchange
rabbitmq.routing-key = rabbitmq.test.routing.key
rabbitmq.queue-name=rabbitmq.queue.name.test

 

3.交换机和队列绑定配置

@Value("${rabbitmq.queue-name}")
String queueName;

@Value("${rabbitmq.exchange-key}")
String exchangeKey;

@Value("${rabbitmq.routing-key}")
String routingKey;

@Bean(value = "${rabbitmq.queue-name}")
public Queue initOrderCancelQueue(){
    returnnew Queue(queueName) ;
}

@Bean(value = "${rabbitmq.exchange-key}")
public CustomExchange customExchange(){
    Map<String,Object> args=new HashMap<>();
    returnnew CustomExchange(exchangeKey,"topic",true,false,args);
}

@Bean
public Binding binding(@Qualifier(value = "${rabbitmq.queue-name}") Queue queue,
                       @Qualifier(value = "${rabbitmq.exchange-key}") CustomExchange exchange){
    return BindingBuilder
            .bind(queue)
            .to(exchange)
            .with(routingKey)
            .and(exchange.getArguments());
}

 

4.生产者

@Value("${rabbitmq.exchange-key}")
String exchangeKey;

@Autowired
private AmqpTemplate amqpTemplate;
/**
 * 发送MQ
 * @param routingKey
 * @param obj 参数
 */publicvoid sendNotification(String routingKey, Object obj){
    this.amqpTemplate.convertAndSend(exchangeKey,routingKey,obj);
}

 

5消费者

            @RabbitHandler
@RabbitListener(queues = "${rabbitmq.queue-name}")
publicvoid receiveRabbitmqMsg(Message msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag){
    String funcName="接收到RabbitmqMsg";
    logger.info("{}:{}",funcName,msg);
    try {

    }catch(Exception e) {

    }finally {

    }
}

 

6.测试

            @Autowired
RabbitmqProducer producer;

@Value("${rabbitmq.routing-key}")
String routingKey;

publicvoid sendMsg(){
    TestModel testModel =new TestModel();
    testModel.setName("fxx");
    testModel.setAge(18);
    testModel.setGender("girl");
    try {
        producer.sendNotification(routingKey,testModel);
    }catch (Exception e){
        logger.error("系统异常："+e.toString());
    }
}

 

搞定！就这么简单，赶快自己动手试试吧

源码下载地址

原文：https://www.cnblogs.com/renyutao/p/11222427.html

内容总结

以上是互联网集市为您收集整理的Springboot接入RabbitMQ详细教程全部内容，希望文章能够帮你解决Springboot接入RabbitMQ详细教程所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1066887.html

来源：【匿名】