微服务项目之电商--24.Spring AMQP及项目改造

àì夳堔傛蜴生んèń 2021-10-18 22:28 390阅读 0赞

**目录**

1.Spring AMQP

1.1.简介

2.2.依赖和配置

2.3.监听者

2.4.AmqpTemplate

2.5.测试代码

3.项目改造

3.1.思路分析

3.2.商品服务发送消息

3.2.1.引入依赖

3.2.2.配置文件

3.2.3.改造GoodsService

3.3.搜索服务接收消息

3.3.1.引入依赖

3.3.2.添加配置

3.3.3.编写监听器

3.3.4.编写创建和删除索引方法

3.4.静态页服务接收消息

3.4.1.引入依赖

3.4.2.添加配置

3.4.3.编写监听器

3.4.4.添加删除页面方法

3.5.测试

3.5.1.查看RabbitMQ控制台

--------------------

# 1.Spring AMQP #

## 1.1.简介 ##

Sprin有很多不同的项目，其中就有对AMQP的支持：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70][]

Spring AMQP的页面：[http://spring.io/projects/spring-amqp][http_spring.io_projects_spring-amqp]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 1][]

注意这里一段描述：

![20190813110152307.png][]

Spring-amqp是对AMQP协议的抽象实现，而spring-rabbit 是对协议的具体实现，也是目前的唯一实现。底层使用的就是RabbitMQ。

## 2.2.依赖和配置 ##

添加AMQP的启动器：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

在`application.yml`中添加RabbitMQ地址：

spring:
      rabbitmq:
        host: 192.168.56.101
        username: leyou
        password: leyou
        virtual-host: /leyou

## 2.3.监听者 ##

在SpringAmqp中，对消息的消费者进行了封装和抽象，一个普通的JavaBean中的普通方法，只要通过简单的注解，就可以成为一个消费者。

@Component
    public class Listener {
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "spring.test.queue", durable = "true"),
                exchange = @Exchange(
                        value = "spring.test.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC
                ),
                key = {"#.#"}))
        public void listen(String msg){
            System.out.println("接收到消息：" + msg);
        }
    }

*  `@Componet`：类上的注解，注册到Spring容器
 *  `@RabbitListener`：方法上的注解，声明这个方法是一个消费者方法，需要指定下面的属性：
    
     *  `bindings`：指定绑定关系，可以有多个。值是`@QueueBinding`的数组。`@QueueBinding`包含下面属性：
        
         *  `value`：这个消费者关联的队列。值是`@Queue`，代表一个队列
         *  `exchange`：队列所绑定的交换机，值是`@Exchange`类型
         *  `key`：队列和交换机绑定的`RoutingKey`

类似listen这样的方法在一个类中可以写多个，就代表多个消费者。

## 2.4.AmqpTemplate ##

Spring最擅长的事情就是封装，把他人的框架进行封装和整合。

Spring为AMQP提供了统一的消息处理模板：AmqpTemplate，非常方便的发送消息，其发送方法：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 2][]

红框圈起来的是比较常用的3个方法，分别是：

*  指定交换机、RoutingKey和消息体
 *  指定消息
 *  指定RoutingKey和消息，会向默认的交换机发送消息

## 2.5.测试代码 ##

@RunWith(SpringRunner.class)
    @SpringBootTest(classes = Application.class)
    public class MqDemo {
    
        @Autowired
        private AmqpTemplate amqpTemplate;
    
        @Test
        public void testSend() throws InterruptedException {
            String msg = "hello, Spring boot amqp";
            this.amqpTemplate.convertAndSend("spring.test.exchange","a.b", msg);
            // 等待10秒后再结束
            Thread.sleep(10000);
        }
    }

运行后查看日志：

![20190813151200498.png][]

# 3.项目改造 #

## 3.1.思路分析 ##

> 发送方：商品微服务

*  什么时候发？
    
    当商品服务对商品进行写操作：增、删、改的时候，需要发送一条消息，通知其它服务。
 *  发送什么内容？
    
    对商品的增删改时其它服务可能需要新的商品数据，但是如果消息内容中包含全部商品信息，数据量太大，而且并不是每个服务都需要全部的信息。因此我们**只发送商品id**，其它服务可以根据id查询自己需要的信息。

> 接收方：搜索微服务、静态页微服务

接收消息后如何处理？

*  搜索微服务：
    
     *  增/改：添加新的数据到索引库
     *  删：删除索引库数据
 *  静态页微服务：
    
     *  增：创建新的静态页
     *  删：删除原来的静态页
     *  改：创建新的静态页并删除原来的

## 3.2.商品服务发送消息 ##

我们先在商品微服务`leyou-item-service`中实现发送消息。

### 3.2.1.引入依赖 ###

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

### 3.2.2.配置文件 ###

我们在application.yml中添加一些有关RabbitMQ的配置：

spring:
      rabbitmq:
        host: 192.168.56.101
        username: leyou
        password: leyou
        virtual-host: /leyou
        template:
          exchange: leyou.item.exchange
        publisher-confirms: true

*  template：有关`AmqpTemplate`的配置
    
     *  retry：失败重试
        
         *  enabled：开启失败重试
         *  initial-interval：第一次重试的间隔时长
         *  max-interval：最长重试间隔，超过这个间隔将不再重试
         *  multiplier：下次重试间隔的倍数，此处是2即下次重试间隔是上次的2倍
     *  exchange：缺省的交换机名称，此处配置后，发送消息如果不指定交换机就会使用这个
 *  publisher-confirms：生产者确认机制，确保消息会正确发送，如果发送失败会有错误回执，从而触发重试

### 3.2.3.改造GoodsService ###

在GoodsService中封装一个发送消息到mq的方法：

private void sendMessage(Long id, String type){
        // 发送消息
        try {
            this.amqpTemplate.convertAndSend("item." + type, id);
        } catch (Exception e) {
            logger.error("{}商品消息发送异常，商品id：{}", type, id, e);
        }
    }

这里没有指定交换机，因此默认发送到了配置中的：`leyou.item.exchange`

**注意：这里要把所有异常都try起来，不能让消息的发送影响到正常的业务逻辑**

然后在新增的时候调用：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 3][]

修改的时候调用：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 4][]

## 3.3.搜索服务接收消息 ##

搜索服务接收到消息后要做的事情：

*  增：添加新的数据到索引库
 *  删：删除索引库数据
 *  改：修改索引库数据

因为索引库的新增和修改方法是合二为一的，因此我们可以将这两类消息一同处理，删除另外处理。

### 3.3.1.引入依赖 ###

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

### 3.3.2.添加配置 ###

spring:
      rabbitmq:
        host: 192.168.56.101
        username: leyou
        password: leyou
        virtual-host: /leyou

这里只是接收消息而不发送，所以不用配置template相关内容。

### 3.3.3.编写监听器 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 5][]

代码：

@Component
    public class GoodsListener {
    
        @Autowired
        private SearchService searchService;
    
        /**
         * 处理insert和update的消息
         *
         * @param id
         * @throws Exception
         */
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "leyou.create.index.queue", durable = "true"),
                exchange = @Exchange(
                        value = "leyou.item.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC),
                key = {"item.insert", "item.update"}))
        public void listenCreate(Long id) throws Exception {
            if (id == null) {
                return;
            }
            // 创建或更新索引
            this.searchService.createIndex(id);
        }
    
        /**
         * 处理delete的消息
         *
         * @param id
         */
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "leyou.delete.index.queue", durable = "true"),
                exchange = @Exchange(
                        value = "leyou.item.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC),
                key = "item.delete"))
        public void listenDelete(Long id) {
            if (id == null) {
                return;
            }
            // 删除索引
            this.searchService.deleteIndex(id);
        }
    }

### 3.3.4.编写创建和删除索引方法 ###

这里因为要创建和删除索引，我们需要在SearchService中拓展两个方法，创建和删除索引：

public void createIndex(Long id) throws IOException {
    
        Spu spu = this.goodsClient.querySpuById(id);
        // 构建商品
        Goods goods = this.buildGoods(spu);
    
        // 保存数据到索引库
        this.goodsRepository.save(goods);
    }
    
    public void deleteIndex(Long id) {
        this.goodsRepository.deleteById(id);
    }

创建索引的方法可以从之前导入数据的测试类中拷贝和改造。

## 3.4.静态页服务接收消息 ##

商品静态页服务接收到消息后的处理：

*  增：创建新的静态页
 *  删：删除原来的静态页
 *  改：创建新的静态页并删除原来的

不过，我们编写的创建静态页的方法也具备覆盖以前页面的功能，因此：增和改的消息可以放在一个方法中处理，删除消息放在另一个方法处理。

### 3.4.1.引入依赖 ###

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

### 3.4.2.添加配置 ###

spring:
      rabbitmq:
        host: 192.168.56.101
        username: leyou
        password: leyou
        virtual-host: /leyou

这里只是接收消息而不发送，所以不用配置template相关内容。

### 3.4.3.编写监听器 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 6][]

代码：

@Component
    public class GoodsListener {
    
        @Autowired
        private GoodsHtmlService goodsHtmlService;
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "leyou.create.web.queue", durable = "true"),
                exchange = @Exchange(
                        value = "leyou.item.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC),
                key = {"item.insert", "item.update"}))
        public void listenCreate(Long id) throws Exception {
            if (id == null) {
                return;
            }
            // 创建页面
            goodsHtmlService.createHtml(id);
        }
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "leyou.delete.web.queue", durable = "true"),
                exchange = @Exchange(
                        value = "leyou.item.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC),
                key = "item.delete"))
        public void listenDelete(Long id) {
            if (id == null) {
                return;
            }
            // 创建页面
            goodsHtmlService.deleteHtml(id);
        }
    }

### 3.4.4.添加删除页面方法 ###

public void deleteHtml(Long id) {
        File file = new File("C:\\project\\nginx-1.14.0\\html\\item\\", id + ".html");
        file.deleteOnExit();
    }

## 3.5.测试 ##

### 3.5.1.查看RabbitMQ控制台 ###

重新启动项目，并且登录RabbitMQ管理界面：[http://192.168.56.101:15672][http_192.168.56.101_15672]

可以看到，交换机已经创建出来了：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 7][]

队列也已经创建完毕：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 8][]

并且队列都已经绑定到交换机：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 9][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70]: /images/20211018/94475c13399a434e84b48bf163122928.png
[http_spring.io_projects_spring-amqp]: http://spring.io/projects/spring-amqp
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 1]: /images/20211018/753fe59a3c8e4aa497e09526dddf768e.png
[20190813110152307.png]: /images/20211018/578129443dcf453c97864038847ed060.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 2]: /images/20211018/4f729ca0050e4d73baa7638d69b4af7e.png
[20190813151200498.png]: /images/20211018/2eca26129f96436997f705e652050bcd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 3]: /images/20211018/9bdb157ce5d44392968e1be9c67aafb7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 4]: /images/20211018/7dee37c5ea0c47e381870936290a1ce1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 5]: /images/20211018/7a0fe967ae334440854b8c54bab4282b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 6]: /images/20211018/a7b6d2527c1b491c9d0f8ff21b576d17.png
[http_192.168.56.101_15672]: http://192.168.56.101:15672
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 7]: /images/20211018/1a8f4511723e40c194327ac79c7da9ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 8]: /images/20211018/fd9be3d1d75e4dd59853a8cfba8749b2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3OTA5NTA4_size_16_color_FFFFFF_t_70 9]: /images/20211018/2127c2aba84f475ab47dbdf06b86a9de.png