SpringBoot整合RabbitMq的方法是什么

本篇内容介绍了“SpringBoot整合RabbitMq的方法是什么”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！高级消息队列协议（AMQP）是面向消息中间件的平台中立的有线协议。Spring AMQP项目将核心Spring概念应用于基于AMQP的消息传递解决方案的开发。Spring Boot为通过RabbitMQ与AMQP一起工作提供了一些便利免费云主机域名，包括spring-boot-starter-amqp “Starter”。springboot集成RabbitMQ非常简单，如果只是简单的使用配置非常少，springboot提供了spring-boot-starter-amqp项目对消息各种支持。RabbitMQ是基于AMQP协议的轻量级，可靠，可扩展，可移植的消息代理。Spring使用RabbitMQ通过AMQP协议进行通信。RabbitMQ配置由外部配置属性控制 spring.rabbitmq.*。例如，您可以在以下部分声明以下部分 application.properties：rabbitTemplate是springboot 提供的默认实现.查看控制台输出结果对上面的代码进行了小改造,接收端注册了两个Receiver,Receiver1和Receiver2，发送端加入参数计数，接收端打印接收到的参数，下面是测试代码，发送一百条消息，来观察两个接收端的执行效果添加一个队列叫 hello2给队列 hello2 发送消息,接受一个计数参数两个hello2 的接受者查看控制台输出结果:可以看到:在消息发送到63时,接受者Receiver已经收到了消息,
结论:一个发送者，N个接受者,经过测试会均匀的将消息发送到N个接收者中我们可以注入两个发送者,放在循环中,如下:运行单元测试,查看控制台输出:结论：和一对多一样，接收端仍然会均匀接收到消息首先我们创建一个实体类对象 User,注意必须实现 Serializable 接口.然后在配置文件中再创建一个队列,叫 object_queue接下里就是User对象的两个发送者ObjectSender和接受者ObjectReceiver:运行单元测试,查看控制台输出结果:topic 是RabbitMQ中最灵活的一种方式，可以根据routing_key自由的绑定不同的队列首先对topic规则配置，这里使用两个队列来测试消息发送者:都是用topicExchange,并且绑定到不同的 routing_key两个消息接受者,分别指定不同的 queue测试:发送send1会匹配到topic.#和topic.message 两个Receiver都可以收到消息，发送send2只有topic.#可以匹配所有只有Receiver2监听到消息Fanout 就是我们熟悉的广播模式或者订阅模式，给Fanout交换机发送消息，绑定了这个交换机的所有队列都收到这个消息。Fanout 相关配置:消息发送者:这里使用了A、B、C三个队列绑定到Fanout交换机上面，发送端的routing_key写任何字符都会被忽略三个消息接受者:运行单元测试,查看结果:结果说明，绑定到fanout交换机上面的队列都收到了消息.“SpringBoot整合RabbitMq的方法是什么”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注百云主机网站，小编将为大家输出更多高质量的实用文章！

相关推荐: Python第三方库管理Pip和Conda怎么用

本文小编为大家详细介绍“Python第三方库管理Pip和Conda怎么用”，内容详细，步骤清晰，细节处理妥当，希望这篇“Python第三方库管理Pip和Conda怎么用”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。1、Anacond…