脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Springboot 整合 RabbitMQ

Springboot 整合 RabbitMQ 消息队列 详情

 更新时间：2022年08月17日 15:25:34   作者：苦糖?  
这篇文章主要介绍了Springboot整合RabbitMQ 消息队列详情，文章为荣啊主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下

生产者工程

POM依赖

可以在创建工程时直接选择添加依赖。

application文件

因为rabbitmq具有默认地址及用户信息，所以如果是本地rabbitmq可以不需要进行配置。

RabbitMQ配置文件：

在使用相关交换机及队列时，我们需要实现声明交换机及队列，如果没有对应信息，则启动项目会失败。所以在使用springboot整合rabbitmq时，我们可以通过配置文件来进行交换机、队列的声明及二者之间的关系绑定。 由于目前在演示Fanout模式，所以使用FanoutExchange来声明交换机，其他模式则使用相对应的TopicExchange，DirectExchange来声明。

@Configuration
public class RabbitMQConfiguration {

//声明fanout模式的交换机
@Bean
public FanoutExchange fanoutExchange() {
    return new FanoutExchange("fanout_order_exchange", true, false);
}

//声明队列
@Bean
public Queue smsQueue() {
    return new Queue("sms.fanout.queue", true);
}

@Bean
public Queue emailQueue() {
    return new Queue("email.fanout.queue", true);
}

@Bean
public Queue duanxinQueue() {
    return new Queue("duanxin.fanout.queue", true);
}
//绑定

@Bean
public Binding smsBinding() {
    return BindingBuilder.bind(smsQueue()).to(fanoutExchange());
}

@Bean
public Binding emailBinding() {
    return BindingBuilder.bind(emailQueue()).to(fanoutExchange());
}

@Bean
public Binding duanxinBinding() {
    return BindingBuilder.bind(duanxinQueue()).to(fanoutExchange());
}
}

生产者业务代码

这部分代码就简单的通过调用rabbitTemplate来进行消息的分发。@Service public class OrderService {

@Autowired
private RabbitTemplate rabbitTemplate;

public void makeOrder() {
    // 保存订单
    String orderId = UUID.randomUUID().toString();
    System.out.println("下单成功：" + orderId);
    // 通过MQ完成消息的分发
    // 参数1：交换机 ；参数2：路由key/队列名；参数3：消息内容
    String exchangeName = "fanout_order_exchange";
    rabbitTemplate.convertAndSend(exchangeName, "", orderId);
}
}

消费者：

消费者工程和生产者工程类似，我们首先需要引入依赖，然后在application文件中进行相关的配置即可开始编写代码。 在消费者工程中我们也可以编写rabbitmq的配置文件来进行交换机及队列的声明。建议在消费端编写配置文件，因为消费端是先启动的工程，如果交换机和队列未创建会导致工程启动失败。 消息监听

我们通过RabbitListener注解来监听消息队列。需要注意的是我们需要通过Component注解将该监听交给spring管理，否则不能正常接收服务端的消息。 这边只给出一个email的消息监听，上文生产者声明的duanxin,sms队列可以自行创建，只需要修改队列名即可。@Service public class OrderService {

@RabbitListener(queues = {"email.fanout.queue"})
@Component
public class FanoutEmailService {
    @RabbitHandler
    public void receive(String message) {
        System.out.println("email fanout -----》接收到" + message);
    }
}

测试

首先启动消费者工程，然后在生产者工程中创建测试类发送消息即可。

@SpringBootTest class SpringbootOrderRabbitmqProducerApplicationTests {

@Autowired
private OrderService orderService;

@Test
void contextLoads() {
    orderService.makeOrder();
}
}

当发送消息后，我们可以在控制台中发现消费者成功接受消息。

Direct 模式

生产者

建立工程的步骤和上文相同。

配置文件

配置和上文基本相同，由于该部分测试direct模式，所以需要使用DirectExchange创建交换机。需要注意的是该类中的方法名不能和上文rabbitmq的配置文件中的方法名相同，因为我们使用bean注解将其交给spring管理，如果名字相同，则会启动项目失败。

@Configuration
public class DirectRabbitMQConfiguration {

//声明direct模式的交换机
@Bean
public DirectExchange directExchange() {
    return new DirectExchange("direct_order_exchange", true, false);
}

//声明队列
@Bean
public Queue smsDirectQueue() {
    return new Queue("sms.direct.queue", true);
}

@Bean
public Queue emailDirectQueue() {
    return new Queue("email.direct.queue", true);
}

@Bean
public Queue duanxinDirectQueue() {
    return new Queue("duanxin.direct.queue", true);
}
//绑定

@Bean
public Binding smsDirectBinding() {
    return BindingBuilder.bind(smsDirectQueue()).to(directExchange()).with("sms");
}

@Bean
public Binding emailDirectBinding() {
    return BindingBuilder.bind(emailDirectQueue()).to(directExchange()).with("email");
}

@Bean
public Binding duanxinDirectBinding() {
    return BindingBuilder.bind(duanxinDirectQueue()).to(directExchange()).with("duanxin");
}
}

业务代码

@Service
public class OrderService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void makeOrderDirect() {
        // 保存订单
        String orderId = UUID.randomUUID().toString();
        System.out.println("下单成功：" + orderId);
        String exchangeName = "direct_order_exchange";
        rabbitTemplate.convertAndSend(exchangeName, "sms", orderId);
        rabbitTemplate.convertAndSend(exchangeName, "email", orderId);
    }

}

消费者

消息监听

和上文相同，只需注意队列名即可。

@RabbitListener(queues = {"email.direct.queue"})
@Component
public class DirectEmailService {
    @RabbitHandler
    public void receive(String message) {
        System.out.println("email direct -----》接收到" + message);
    }
}

Topic 模式

上文中个模式都是通过配置文件来声明交换机，队列及绑定二者之间的关系；实际上我们还可以通过注解的方式来声明交换机及注解。

生产者

由于使用注解方式声明，所以我们不需要创建配置文件，直接编写业务代码即可。测试的时候我们只需修改路由名即可，具体如何修改，请前往文章开头链接查看各模式是如何使用的。

@Service
public class OrderService {

@Autowired
private RabbitTemplate rabbitTemplate;

public void makeOrderTopic() {
    // 保存订单
    String orderId = UUID.randomUUID().toString();
    System.out.println("下单成功：" + orderId);
    String exchangeName = "topic_order_exchange";
    String routingKey = "com.email";
    rabbitTemplate.convertAndSend(exchangeName, routingKey, orderId);
}
}

消费者

代码和上文基本相同，区别在于我们直接在RabbitListener注解中将队列和交换机进行绑定。需要注意的是各参数中都是使用字符串。 value对应的是队列，相应的参数分别是队列名、持久化、自动删除。 exchange对应的交换机，相应的参数分别是交换机名以及交换机类型。 key对应的是路由名。

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = "email.topic.queue",durable = "true",autoDelete = "false"),
        exchange = @Exchange(value = "topic_order_exchange",type = ExchangeTypes.TOPIC),
        key = "*.email.#"
))
@Component
public class TopicEmailService {
    @RabbitHandler
    public void receive(String message) {
        System.out.println("email topic -----》接收到" + message);
    }
}

以上便是springboot 整合 rabbitmq的两种方式。但是在日常开发中更推荐使用配置文件的形式来实现，因为在配置文件中可以更好的处理过期时间、死信队列等消息队列中的高级特性。

到此这篇关于Springboot 整合 RabbitMQ 消息队列 详情的文章就介绍到这了,更多相关Springboot 整合 RabbitMQ 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Java SpringBoot项目如何优雅的实现操作日志记录

    Java SpringBoot项目如何优雅的实现操作日志记录

    这篇文章主要介绍了Java SpringBoot项目如何优雅的实现操作日志记录，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的朋友可以参考一下
    2022-08-08
  • Java中线程用法总结

    Java中线程用法总结

    这篇文章主要介绍了Java中线程用法,实例总结了java中线程的常见使用技巧,需要的朋友可以参考下
    2015-06-06
  • Java中SynchronousQueue的底层实现原理剖析

    Java中SynchronousQueue的底层实现原理剖析

    BlockingQueue的实现类中，有一种阻塞队列比较特殊，就是SynchronousQueue（同步移交队列），队列长度为0。本文就来剖析一下SynchronousQueue的底层实现原理，感兴趣的可以了解一下
    2022-11-11
  • Java的MyBatis框架项目搭建与hellow world示例

    Java的MyBatis框架项目搭建与hellow world示例

    MyBatis框架为Java程序的数据库操作带来了很大的便利,这里我们就从最基础的入手,来看一下Java的MyBatis框架项目搭建与hellow world示例,需要的朋友可以参考下
    2016-06-06
  • 解析Java的JNI编程中的对象引用与内存泄漏问题

    解析Java的JNI编程中的对象引用与内存泄漏问题

    这篇文章主要介绍了Java的JNI编程中的对象引用与内存泄漏问题,重点讲述了局部和全局引用时一些值得注意的地方,需要的朋友可以参考下
    2015-11-11
  • 详解Java中LinkedHashMap

    详解Java中LinkedHashMap

    本文主要介绍了Java中LinkedHashMap的相关知识，具有很好的参考价值。下面跟着小编一起来看下吧
    2017-05-05
  • mybatis3.4.6 批量更新 foreach 遍历map 的正确姿势详解

    mybatis3.4.6 批量更新 foreach 遍历map 的正确姿势详解

    这篇文章主要介绍了mybatis3.4.6 批量更新 foreach 遍历map 的正确姿势详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11
  • Java源码解析之LinkedHashMap

    Java源码解析之LinkedHashMap

    LinkedHashMap是HashMap的子类,所以也具备HashMap的诸多特性.不同的是,LinkedHashMap还维护了一个双向链表,以保证通过Iterator遍历时顺序与插入顺序一致.除此之外,它还支持Access Order, ,需要的朋友可以参考下
    2021-05-05
  • Java超详细分析讲解final关键字的用法

    Java超详细分析讲解final关键字的用法

    关于final关键字，它也是我们一个经常用的关键字，可以修饰在类上、或者修饰在变量、方法上，以此看来定义它的一些不可变性！像我们经常使用的String类中，它便是final来修饰的类，并且它的字符数组也是被final所修饰的。但是一些final的一些细节你真的了解过吗
    2022-06-06
  • Java猴子吃桃问题

    Java猴子吃桃问题

    这篇文章主要介绍了Java猴子吃桃问题,采取逆向思维的方法，从后往前推断，需要的朋友可以参考下
    2017-02-02

最新评论