脚本宝典收集整理的这篇文章主要介绍了HM-SpringCloud微服务系列4.3.1【SpringAMQP简介、BasicQueue简单队列模型】，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。

1 SpringAMQP简介

• SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。

  

  

• SpringAmqp的官方地址：https://spring.io/projects/spring-amqp

  

• SpringAMQP提供了三个功能：
  • 自动声明队列、交换机及其绑定关系
  • 基于注解的监听器模式，异步接收消息
  • 封装了RabbitTemplate工具，用于发送消息
• mq主要端口
  • 4369 – erlang发现口
  • 5672 – client端通信口
  • 15672 – 管理界面ui端口
  • 25672 – server间内部通信口
• SpringAMQP课程内容

  

2 BasicQueue简单队列模型

2.1 案例

2.2 在父工程mq-demo中引入依赖

<!--AMQP依赖，包含RabbitMQ-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.3 消息发送

1. 首先配置MQ地址，在publisher服务的application.yml中添加配置：

spring:
  rabbitmq:
    host: 192.168.2.109 # 主机名
    port: 5672 # 端口
    virtual-host: / # 虚拟主机
    username: yubaby # 用户名
    password: 123321 # 密码

2. 然后在publisher服务中编写测试类SpringAmqpTest，并利用RabbitTemplate实现消息发送：

package cn.itcast.mq.spring;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSimpleQueue() {
        // 队列名称
        String queueName = "simple.queue";
        // 消息
        String message = "hello, spring amqp!";
        // 发送消息
        rabbitTemplate.convertAndSend(queueName, message);
    }
}

2.4 消息接收

1. 首先配置MQ地址，在consumer服务的application.yml中添加配置：

spring:
  rabbitmq:
    host: 192.168.2.109 # 主机名
    port: 5672 # 端口
    virtual-host: / # 虚拟主机
    username: yubaby # 用户名
    password: 123321 # 密码

2. 然后在consumer服务的cn.itcast.mq.listener包中新建一个类SpringRabbitListener，代码如下：

package cn.itcast.mq.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueueMessage(String msg) throws InterruptedException {
        System.out.println("spring 消费者接收到消息：【" + msg + "】");
    }
}

启动consumer服务；然后在publisher服务中运行测试代码，发送MQ消息；查看consumer是否能够监听到到消息

“阅后即焚”：接收完毕就从3变为0了，发布者发布的消息被消费者消费掉了

2.6 小结

2 WorkQueue工作队列模型

https://www.cnblogs.com/yppah/p/15849634.html

3 发布/订阅模型

4 发布/订阅模型-Fanout

5 发布/订阅模型-Direct

6 发布/订阅模型-Topic

7 消息转换器

脚本宝典总结

以上是脚本宝典为你收集整理的HM-SpringCloud微服务系列4.3.1【SpringAMQP简介、BasicQueue简单队列模型】全部内容，希望文章能够帮你解决HM-SpringCloud微服务系列4.3.1【SpringAMQP简介、BasicQueue简单队列模型】所遇到的问题。

如果觉得脚本宝典网站内容还不错，欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。