1.BasicQueue简单队列模型1.1导入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>1.2yamlspring:rabbitmq:host:192.168.150.101#主机名

快速入门在之前的案例中，我们都是经过交换机发送消息到队列，不过有时候为了测试方便，我们也可以直接向队列发送消息，跳过交换机。在入门案例中，我们就演示这样的简单模型，如图：也就是：publisher直接发送消息到队列消费者监听并处理队列中的消息:::warning注意：这种模式一般测试使

在SpringAMQP的发送方法中，接收消息的类型是 Object，也就是说我们可以发送任意对象类型的消息，SpringAMQP会帮我们序列化为字节后发送。测试发送Object类型消息1.声明队列@ConfigurationpublicclassFanoutConfig{@BeanpublicQueueobjectQueue(){return

使用SpringAMQ实现五种消息队列模型1.普通队列2.工作队列(WorkQueue)发布订阅=>根据交换机的不同分为三种3.订阅模型之Fanout(广播)4.订阅模型之Direct(路由)5.订阅模型之Topic(话题)使用前导:1.在生产者和消费者项目上分别导入RabbitMQ依赖<!--AMQP依赖，包含RabbitMQ-->

Workqueue，工作队列，可以提高消息处理速度，避免队列消息堆积 模拟WorkQueue，实现一个队列绑定多个消费者基本思路如下：在publisher服务中定义测试方法，每秒产生50条消息，发送到simple.queue在consumer服务中定义两个消息监听者，都监听simple.queue队列一个消息监听者每秒处理50条消

SpringAMQPSpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。SpringAmqp的官方地址：https://spring.io/projects/spring-amqpAdvancedMessageQueuingProtocol，是用于在应用程序之间传递业务消息的开放标准。该协议与语言和平

消息消费端和提供端需要引入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>都需要在application.yml进行如下配置spring:rabbitmq:host:192.168.230.100#r

什么是SpringAMQPSpringAMQP的官方地址：https://spring.io/projects/spring-amqpAMQP（AdvancedMessageQueuingProtocol）：是用于在应用程序或之间传递业务消息的开放标准。该协议与语言和平台无关，更符合微服务中独立性的要求。SpringAMQP：SpringAMQP是基于AMQP协议定义的一套AP

     

     

    

    

         

      

我们看下之前启动idea测试消息发送的时候在后台生成的一条消息，现在已经在消息队列里面还没有被消费。 现在我们重启下RabbitMQ，执行linux命令：dockerrestartmq看上图实时显示的错误信息，失去连接了，接下来刷新这个页面，可以发现这个对象没有了。 说明rabbit消息并不会持久化，不

                                                   

SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。SpringAmqp的官方地址：https://spring.io/projects/spring-amqp S