视频61（策略模块责任链）

beacon-cache/src/main/java/com/mashibing/cache/CacheStarterApp.java

@@ -5,12 +5,17 @@ import org.redisson.client.RedisClient;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.context.annotation.ComponentScan;
 
 /**
  * @author zjw
  * @description
  */
 @SpringBootApplication
+@ComponentScan(basePackages = {
+        "com.msb.framework.redis",
+        "com.mashibing.cache"
+})
 @EnableDiscoveryClient
 public class CacheStarterApp {
 

beacon-cache/src/main/java/com/mashibing/cache/controller/TestController.java

@@ -2,9 +2,11 @@ package com.mashibing.cache.controller;
 
 import com.msb.framework.redis.RedisClient;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.HashMap;
 import java.util.Map;
 
 /**
@@ -29,4 +31,17 @@ public class TestController {
         Map<String, Object> result = redisClient.getMap(key);
         return result;
     }
+    @GetMapping("/test/xxx")
+    public Map xxx(){
+        Map<String,Object> maps = new HashMap<>();
+        maps.put("1801003","北京 北京,电信");
+        maps.put("1734310","北京 北京,电信");
+        redisClient.pipelined(operations -> {
+            for (Map.Entry<String, Object> entry : maps.entrySet()) {
+                operations.opsForValue().set(entry.getKey(),entry.getValue());
+            }
+        });
+        return null;
+    }
+
 }

beacon-common/src/main/java/com/mashibing/common/model/StandardSubmit.java

@@ -114,6 +114,8 @@ public class StandardSubmit implements Serializable {
      * 签名的id
      */
     private Long signId;
+
+
     // 后续再做封装~~~~
 
 

beacon-strategy/pom.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>beacon-cloud</artifactId>
+        <groupId>com.mashibing</groupId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>beacon-strategy</artifactId>
+
+    <dependencies>
+        <!--        start-web-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <!--        nacos-dis-->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
+        </dependency>
+        <!--        nacos-config-->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+        </dependency>
+        <!--        公共组件，common-->
+        <dependency>
+            <groupId>com.mashibing</groupId>
+            <artifactId>beacon-common</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+        <!--        RabbitMQ依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+        <!--        openFeign-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+    </dependencies>
+
+
+</project>

beacon-strategy/src/main/java/com/mashibing/strategy/StrategyStarterApp.java

@@ -0,0 +1,21 @@
+package com.mashibing.strategy;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+/**
+ * @author zjw
+ * @description
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+@EnableFeignClients
+public class StrategyStarterApp {
+
+    public static void main(String[] args) {
+        SpringApplication.run(StrategyStarterApp.class,args);
+    }
+
+}

beacon-strategy/src/main/java/com/mashibing/strategy/client/BeaconCacheClient.java

@@ -0,0 +1,16 @@
+package com.mashibing.strategy.client;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+
+/**
+ * @author zjw
+ * @description
+ */
+@FeignClient(value = "beacon-cache")
+public interface BeaconCacheClient {
+
+    @GetMapping("/cache/hget/{key}/{field}")
+    String hget(@PathVariable(value = "key")String key, @PathVariable(value = "field")String field);
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/StrategyFilter.java

@@ -0,0 +1,16 @@
+package com.mashibing.strategy.filter;
+
+import com.mashibing.common.model.StandardSubmit;
+
+/**
+ * @author zjw
+ * @description
+ */
+public interface StrategyFilter {
+
+    /**
+     * 校验！！！！
+     * @param submit
+     */
+    void strategy(StandardSubmit submit);
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/StrategyFilterContext.java

@@ -0,0 +1,53 @@
+package com.mashibing.strategy.filter;
+
+import com.mashibing.common.constant.CacheConstant;
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.client.BeaconCacheClient;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * 策略模块校验链的执行
+ * @author zjw
+ * @description
+ */
+@Component
+@Slf4j
+public class StrategyFilterContext {
+
+    // 泛型注入，拿到所有的校验信息。
+    @Autowired
+    private Map<String,StrategyFilter> stringStrategyFilterMap;
+
+    // 注入CacheClient
+    @Autowired
+    private BeaconCacheClient cacheClient;
+
+    private final String CLIENT_FILTERS = "clientFilters";
+
+
+    /**
+     * 当前check方法用于管理校验链的顺序
+     */
+    public void strategy(StandardSubmit submit) {
+        //1、 基于Redis获取客户对应的校验信息
+        String filters = cacheClient.hget(CacheConstant.CLIENT_BUSINESS + submit.getApikey(), CLIENT_FILTERS);
+
+        //2、健壮性校验后，基于逗号分隔遍历
+        String[] filterArray;
+        if(filters != null && (filterArray = filters.split(",")).length > 0){
+            // 到这，filterArray不为null，并且有数据
+            for (String strategy : filterArray) {
+                //3、 遍历时，从stringStrategyFilterMap中获取到需要执行的校验信息，执行
+                StrategyFilter strategyFilter = stringStrategyFilterMap.get(strategy);
+                if(strategyFilter != null){
+                    strategyFilter.strategy(submit);
+                }
+            }
+        }
+    }
+
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/impl/BlackStrategyFilter.java

@@ -0,0 +1,20 @@
+package com.mashibing.strategy.filter.impl;
+
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.filter.StrategyFilter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 黑名单校验
+ * @author zjw
+ * @description
+ */
+@Service(value = "black")
+@Slf4j
+public class BlackStrategyFilter implements StrategyFilter {
+    @Override
+    public void strategy(StandardSubmit submit) {
+        log.info("【策略模块-黑名单校验】   校验ing…………");
+    }
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/impl/DirtyWordStrategyFilter.java

@@ -0,0 +1,20 @@
+package com.mashibing.strategy.filter.impl;
+
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.filter.StrategyFilter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 敏感词校验
+ * @author zjw
+ * @description
+ */
+@Service(value = "dirtyword")
+@Slf4j
+public class DirtyWordStrategyFilter implements StrategyFilter {
+    @Override
+    public void strategy(StandardSubmit submit) {
+        log.info("【策略模块-敏感词校验】   校验ing…………");
+    }
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/impl/PhaseStrategyFilter.java

@@ -0,0 +1,21 @@
+package com.mashibing.strategy.filter.impl;
+
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.filter.StrategyFilter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 号段补全：获取手机号的运营商以及对应的归属地
+ * @author zjw
+ * @description
+ */
+@Service(value = "phase")
+@Slf4j
+public class PhaseStrategyFilter implements StrategyFilter {
+
+    @Override
+    public void strategy(StandardSubmit submit) {
+        log.info("【策略模块-号段补齐】   校验ing…………");
+    }
+}

beacon-strategy/src/main/java/com/mashibing/strategy/filter/impl/RouteStrategyFilter.java

@@ -0,0 +1,20 @@
+package com.mashibing.strategy.filter.impl;
+
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.filter.StrategyFilter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 路由策略，选择合适的运营商通道
+ * @author zjw
+ * @description
+ */
+@Service(value = "route")
+@Slf4j
+public class RouteStrategyFilter implements StrategyFilter {
+    @Override
+    public void strategy(StandardSubmit submit) {
+        log.info("【策略模块-路由策略】   校验ing…………");
+    }
+}

beacon-strategy/src/main/java/com/mashibing/strategy/mq/PreSendListener.java

@@ -0,0 +1,44 @@
+package com.mashibing.strategy.mq;
+
+import com.mashibing.common.constant.RabbitMQConstants;
+import com.mashibing.common.model.StandardSubmit;
+import com.mashibing.strategy.filter.StrategyFilterContext;
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+
+/**
+ * 监听接口模块推送过来的消息
+ * @author zjw
+ * @description
+ */
+@Component
+@Slf4j
+public class PreSendListener {
+
+
+    /**
+     * 整个策略模块的校验
+     */
+    @Autowired
+    private StrategyFilterContext filterContext;
+
+    @RabbitListener(queues = RabbitMQConstants.SMS_PRE_SEND)
+    public void listen(StandardSubmit submit, Message message, Channel channel) throws IOException {
+        log.info("【策略模块-接收消息】 接收到接口模块发送的消息 submit = {}",submit);
+        // 处理业务…………
+        try {
+            filterContext.strategy(submit);
+            log.info("【策略模块-消费完毕】手动ack");
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
+        } catch (IOException e) {
+            e.printStackTrace();
+            log.error("【策略模块-消费失败】凉凉~~~");
+        }
+    }
+}

beacon-strategy/src/main/resources/bootstrap.yml

@@ -0,0 +1,19 @@
+# 服务名称
+spring:
+  application:
+    name: beacon-strategy
+# 多环境
+  profiles:
+    active: dev
+# nacos注册中心地址
+  cloud:
+    nacos:
+      discovery:
+        server-addr: 114.116.226.76:8848
+      # nacos配置中心地址:
+      config:
+        server-addr: 114.116.226.76:8848
+        file-extension: yml
+        # beacon-api-dev.yml
+
+

pom.xml

@@ -8,6 +8,7 @@
         <module>beacon-common</module>
         <module>beacon-cache</module>
         <module>beacon-test</module>
+        <module>beacon-strategy</module>
     </modules>
     <parent>
         <groupId>org.springframework.boot</groupId>