基于Flinkcep-1.11.2 动态规则修改实践

快来打我* 2022-12-27 09:25 544阅读 0赞

# 1，事先说明 #

这个代码搞出来说白了就是在大佬的代码参考下完成的，之前就一直想搞 cep规则动态修改，苦于对cep的源码不熟悉，没法下手。

之前有个大佬搞过 基于flink-cep 1.8版本的动态规则修改。

后来有个大佬搞过基于flink-cep 1.1.0的。

[https://mp.weixin.qq.com/s/mh--wQvAWQq2tDPKq0-m8Q][https_mp.weixin.qq.com_s_mh--wQvAWQq2tDPKq0-m8Q]

我看代码的逻辑是后者更复杂，前者更好理解，后者需要修改的地方太多，后来我仔细思考之后发现，还是前者效果更好一些。

因为可以结合配置流，或者数据里面获取新的规则，实现规则的自动更新，后者可能需要定时获取规则比对是否发现修改。

配置流这个目前还没有跟这个代码逻辑整合，不过之前已经做过，很简单的。

2，先整cep，整合源码

这里只讲几个主要的地方跟步骤，毕竟我也只是知道个大概步骤：

1） 在github下载源码到idea，只需要下载cep的源码就可以 。

[https://github.com/apache/flink/tree/master/flink-libraries/flink-cep][https_github.com_apache_flink_tree_master_flink-libraries_flink-cep]

2）在本地编译下载依赖之后，我们可以写test类测试，可能1.10之后的版本在这里会运行失败，没关系，放上依赖（就是flink-client依赖）：

>     <dependencies>
>     
>     <dependency>
>        <groupId>org.apache.flink</groupId>
>        <artifactId>flink-connector-kafka_2.11</artifactId>
>        <version>${flink.version}</version>
>     </dependency>
>     
>     <dependency>
>        <groupId>com.googlecode.aviator</groupId>
>        <artifactId>aviator</artifactId>
>        <version>5.2.1</version>
>     </dependency>
>     
>     <dependency>
>        <groupId>org.codehaus.groovy</groupId>
>        <artifactId>groovy-all</artifactId>
>        <version>${groovy.version}</version>
>     </dependency>
>     
>           
>     <dependency>
>        <groupId>org.apache.flink</groupId>
>        <artifactId>flink-clients_2.11</artifactId>
>        <version>${project.version}</version>
>        <scope>provided</scope>
>     
>     </dependency>
>     
>     <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-core</artifactId>
>               <version>${project.version}</version>
>               <scope>provided</scope>
>           </dependency>
>     
>           <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-streaming-java_${scala.version}</artifactId>
>               <version>${project.version}</version>
>               <scope>provided</scope>
>           </dependency>
>     
>     <dependency>
>        <groupId>org.apache.flink</groupId>
>        <artifactId>flink-shaded-guava</artifactId>
>     </dependency>
>     
>           
>     
>     <dependency>
>        <groupId>org.apache.flink</groupId>
>        <artifactId>flink-core</artifactId>
>        <version>${project.version}</version>
>        <type>test-jar</type>
>        <scope>test</scope>
>     </dependency>
>     
>           <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-test-utils_${scala.version}</artifactId>
>               <version>${project.version}</version>
>               <scope>test</scope>
>           </dependency>
>     
>           <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-streaming-java_${scala.version}</artifactId>
>               <version>${project.version}</version>
>               <type>test-jar</type>
>               <scope>test</scope>
>           </dependency>
>     
>          <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-runtime_${scala.version}</artifactId>
>               <version>${project.version}</version>
>               <type>test-jar</type>
>               <scope>test</scope>
>           </dependency>
>     
>     
>           <dependency>
>               <groupId>org.apache.flink</groupId>
>               <artifactId>flink-statebackend-rocksdb_${scala.version}</artifactId>
>               <version>${project.version}</version>
>               <scope>test</scope>
>           </dependency>
>     
>     <dependency>
>        <groupId>com.alibaba</groupId>
>        <artifactId>fastjson</artifactId>
>        <version>1.2.47</version>
>     </dependency>
>     <dependency>
>        <groupId>com.google.code.gson</groupId>
>        <artifactId>gson</artifactId>
>        <version>2.8.6</version>
>     </dependency>
>     
>     
>     <dependency>
>        <groupId>org.scala-lang</groupId>
>        <artifactId>scala-library</artifactId>
>        <version>2.11.8</version>
>     </dependency>
>     
>       </dependencies>

3）修改cep源码，不需要编译

为Client端API中PatternStream添加方法registerListener(CepListener cepListener) 注意必须在select方法之前调用

cepListener对象需要实现接口CepListener

都在 PatternProcessFunction：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2][]

CepOperator这个类也非常重要：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 3][]

最后要注意的是处理完之后的逻辑，要清空修改规则之后缓存的state：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 4][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 5][]

![20201210150557377.png][]

类SharedBuffer：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 6][]

3，groovy+aviator

有兴趣的同学可以去了解一下这2个东西，其实也不是很复杂，drools 就使用到了groovy，下面就只展示一个demo:

>     String text2 = "import com.sjb.pojo.LoginEvent;\n" +
>                     "import com.sjb.action.LogEventCondition;\n" +
>                     "import org.apache.flink.cep.pattern.Pattern;\n" +
>                     "import org.apache.flink.streaming.api.windowing.time.Time;\n" +
>     //                "def getP(){\n" +
>                     "public getPattern(){\n" +
>                     "        return Pattern.<LoginEvent>begin('begin').where(new LogEventCondition(\"getString(eventType)=='fail' && getLong(eventTime)>1558430826 && getInt(info.age)>=12\")).next('next').where(new LogEventCondition(\"getString(eventType)=='fail'\")).within(Time.seconds(3))\n" +
>                     "}";
>             System.out.println("text2 = " + text2);
>             Invocable invocable = invocable(text2);
>             Pattern<LoginEvent, LoginEvent> pattern= (Pattern<LoginEvent, LoginEvent>) invocable.invokeFunction("getPattern");
> 
>     public Invocable invocable(String script) throws Exception {
>         ScriptEngineManager factory = new ScriptEngineManager();
>         ScriptEngine engine = factory.getEngineByName("groovy");
>         engine.eval(script);
>         Invocable inv = (Invocable) engine;
>         return inv;
>     }在

初次使用的时候呢

public getPattern()\{

//在这里可以打印，然后验证是否成功

System.out.println("1111");

至于aviator (文档：[https://www.yuque.com/boyan-avfmj/aviatorscript/guhmrc][https_www.yuque.com_boyan-avfmj_aviatorscript_guhmrc]) 就是google aviator 开源小工具，挺好用的，效率还可以。附上官网链接，说实话看官网还不好理解，就搜索aviator  案例就好了。

>     package com.aviator;
>     
>     /**
>      * @program: flinkcep
>      * @description:
>      * @author: Mr.Wang
>      * @create: 2020-11-30 18:04
>      **/
>     import java.util.Date;
>     import java.util.HashMap;
>     import java.util.Map;
>     
>     import com.alibaba.fastjson.JSON;
>     import com.alibaba.fastjson.JSONObject;
>     import com.googlecode.aviator.AviatorEvaluator;
>     import com.googlecode.aviator.Expression;
>     
>     public class TestAviator2 {
>         int i;
>         float f;
>         Date date;
>     
>         public TestAviator2(final int i, final float f, final Date date) {
>             this.i = i;
>             this.f = f;
>             this.date = date;
>         }
>     
>         public int getI() {
>             return this.i;
>         }
>     
>         public void setI(final int i) {
>             this.i = i;
>         }
>     
>         public float getF() {
>             return this.f;
>         }
>     
>         public void setF(final float f) {
>             this.f = f;
>         }
>     
>         public Date getDate() {
>             return this.date;
>         }
>     
>         public void setDate(final Date date) {
>             this.date = date;
>         }
>     
>         public static void main(final String[] args) {
>             TestAviator2 foo = new TestAviator2(100, 3.14f, new Date());
>             Map<String, Object> env = new HashMap<String, Object>();
>             env.put("foo", foo);
>             System.out.println(AviatorEvaluator.execute("'foo.i = '+foo.i", env));
>             System.out.println(AviatorEvaluator.execute("'foo.f = '+foo.f", env));
>             System.out.println(AviatorEvaluator.execute("'foo.date.year = '+ (foo.date.year+1990)", env));
>             String expression = "a>b";
>             Map<String, Object> map = new HashMap<String, Object>();
>             map.put("a",2);
>             map.put("b",1);
>             Expression execute =   AviatorEvaluator.compile(expression);
>             Object execute1 = execute.execute(map);
>     
>     
>             String valueStr ="a=='443b6ea6bc117c'&&b=='4'&&c=='/publicLog/appAttack'";
>     //        JSONObject valueStrJson = strToMap(valueStr);
>             Expression expressionBean = AviatorEvaluator.compile(valueStr,true);
>             for (int i = 0; i < 1; i++) {
>                 long start = System.currentTimeMillis();
>     
>     //            Expression expressionBean = AviatorEvaluator.compile(valueStr);
>                 // 转成Map格式
>     //        Map<String, Object> logCompareMap = JSON.parseObject(logBeanStr, Map.class);
>                 Map<String, Object> logCompareMap = new HashMap<String, Object>();
>                 logCompareMap.put("a","443b6ea6bc117c");
>                 logCompareMap.put("b","4");
>                 logCompareMap.put("c","/publicLog/appAttack");
>                 logCompareMap.put("d","aaaa");
>                 Boolean eventFlag = (Boolean) expressionBean.execute(logCompareMap);
>                 System.out.println("eventFlag = " + eventFlag);
>                 long end = System.currentTimeMillis();
>                 System.out.println("end = " + (end-start));
>             }
>     
>     
>         }
>     
>         public static JSONObject strToMap(String valueListStr) {
>             JSONObject returnJson = new JSONObject();
>             if (valueListStr.startsWith("(") && valueListStr.endsWith(")")) {
>                 String valueListStrSub = valueListStr.substring(1);
>                 String conditionValueStr = valueListStrSub.substring(0, valueListStrSub.length() - 1)
>                         .replaceAll("&&", "\001")
>                         .replaceAll("\\|\\|", "\001")
>                         .replaceAll("'", "");
>     
>     
>                 String[] keyValueList = conditionValueStr.split("\001");
>                 try {
>                     for (String keyValueStr : keyValueList) {
>     
>                         //这里只需要将数组里面包含 '=='的数据带入接口方法
>                         if (keyValueStr.contains("==")) {
>                             String[] keyValues = keyValueStr.split("==");
>                             if (keyValues.length > 1) {
>                                 returnJson.put(keyValues[0], keyValues[1]);
>                             } else {
>                                 returnJson.put(keyValues[0], "");
>                             }
>     
>                         }
>                     }
>                 } catch (Exception ex) {
>                    ex.printStackTrace();
>                 }
>     
>             }
>     
>     
>             return returnJson;
>         }
>     
>     }

最主要的是学会自定义开发就好了，参考下面的案例你基本就懂了：

>     package com.sjb.aviator;
>     
>     import com.googlecode.aviator.AviatorEvaluator;
>     import com.googlecode.aviator.runtime.function.AbstractFunction;
>     import com.googlecode.aviator.runtime.function.FunctionUtils;
>     import com.googlecode.aviator.runtime.type.AviatorDouble;
>     import com.googlecode.aviator.runtime.type.AviatorObject;
>     
>     import java.util.Map;
>     
>     /**
>      * @program: flink-cep_2.11
>      * @description: 1
>      * @author: Mr.Wang
>      * @create: 2020-12-10 09:54
>      **/
>     
>     
>     class TestAviator_IF {
>     
>        public static void main(String[] args) {
>           // 注册函数`IF`
>           AviatorEvaluator.addFunction(new Function_IF());
>           Object execute1 = AviatorEvaluator.execute(" IF(1.0==1.0,100,200)");
>           Object execute2 = AviatorEvaluator.execute("IF(1==2,IF(1>=2,10,20),IF(10<=20,50,40))");
>           System.out.println(execute1);
>           System.out.println(execute2);
>        }
>     
>     }
>     
>     /**
>      * <p>
>      * Aviator 自定义函数`IF`
>      * </p>
>      *
>      * @author : zhengqing
>      * @description : 继承`com.googlecode.aviator.runtime.function.AbstractFunction`,并覆写对应参数个数的方法即可
>      * @date : 2020/8/11 9:15
>      */
>     class Function_IF extends AbstractFunction {
>     
>        /**
>         * IF函数实现逻辑处理
>         *
>         * @param env:
>         *            当前执行的上下文
>         * @param arg1:
>         *            if函数中的判断逻辑
>         * @param arg2:
>         *            arg1为true时的结果
>         * @param arg3:
>         *            arg1为false时的结果
>         * @return: com.googlecode.aviator.runtime.type.AviatorObject
>         * @author : zhengqing
>         * @date : 2020/8/11 9:17
>         */
>        @Override
>        public AviatorObject call(Map<String, Object> env, AviatorObject arg1, AviatorObject arg2, AviatorObject arg3) {
>           Boolean ifResult = FunctionUtils.getBooleanValue(arg1, env);
>           Number ifTrue = FunctionUtils.getNumberValue(arg2, env);
>           Number ifFalse = FunctionUtils.getNumberValue(arg3, env);
>           if (ifResult) {
>              return new AviatorDouble(ifTrue.doubleValue());
>           } else {
>              return new AviatorDouble(ifFalse.doubleValue());
>           }
>        }
>     
>        /**
>         * 返回方法名
>         */
>        @Override
>        public String getName() {
>           return "IF";
>        }
>     
>     }

4，测试代码：

>     public class All_DriverTest {
>        public static void main(String[] args) throws Exception {
>           StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
>           env.setParallelism(1);
>           env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
>     
>           Properties consumerProperties = getConsumerProperties();
>           FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<String>(
>              "flinkcep2",
>              new SimpleStringSchema(),
>              consumerProperties);
>     
>           //todo 策略模式
>           kafkaConsumer.setStartFromEarliest();
>     
>           DataStreamSource<String> sourceStream = env.addSource(kafkaConsumer);
>           DataStream<LoginEvent> mapStream = sourceStream.map(new MapFunction<String, LoginEvent>() {
>              @Override
>              public LoginEvent map(String inputData) throws Exception {
>                 String[] dataArray = inputData.split(",");
>                 LoginEvent loginEvent = new LoginEvent(Long.valueOf(dataArray[0].trim()),
>                    dataArray[1].trim(),
>                    dataArray[2].trim(),
>                    Long.valueOf(dataArray[3].trim()),
>                    "{name:'zhangsan',age:12,mum:100}");
>     //                        dataArray[4].trim());
>                 return loginEvent;
>              }
>     
>     
>           }).assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor<LoginEvent>(Time.seconds(5)) {
>              @Override
>              public long extractTimestamp(LoginEvent loginEvent) {
>                 return loginEvent.getEventTime()* 1000L;
>              }
>           });
>     
>     //    mapStream.print("===>>");
>           //todo 生成pattern对象
>     
>     
>           //todo 新的消费
>           Pattern<LoginEvent, ?> pattern = Pattern.<LoginEvent>begin("start").where(new RichIterativeCondition<LoginEvent>() {
>              private String script = "";
>     
>              @Override
>              public void open(Configuration parameters) throws Exception {
>                 super.open(parameters);
>                 //todo 初始化从外部获取规则。
>                 script = "getString(eventType)=='fail' && getLong(eventTime)>1558430826 && getInt(info.age)>=12";
>                 System.out.println("script = " + script);
>              }
>     
>              @Override
>              public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                 LogEventCondition logEventCondition = new LogEventCondition(script);
>                 boolean success = logEventCondition.filter(value);
>                 //todo 这是条件
>     //              System.out.println("filter = " + filter);
>                 return success;
>              }
>           })
>              .next("middle").where(new RichIterativeCondition<LoginEvent>() {
>                 @Override
>                 public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                    boolean fail = value.getEventType().equals("fail");
>                    return fail;
>                 }
>              })
>              .next("end").where(new RichIterativeCondition<LoginEvent>() {
>                 @Override
>                 public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                    String script_end = "getInt(info.mum)>=12";
>                    LogEventCondition logEventCondition = new LogEventCondition(script_end);
>                    boolean filter_end = logEventCondition.filter(value);
>                    return filter_end;
>                 }
>              }).within(Time.minutes(5));
>     
>           PatternStream patternStream = CEP.pattern(mapStream, pattern);
>     
>     
>           PatternStream patternstream  = patternStream.registerListener(new CepListener<LoginEvent>() {
>              private String updateScript = "";
>              @Override
>              public void init() {
>                 System.out.println("初始化。。");
>                 updateScript = "getString(eventType)=='fail' && getLong(eventTime)>1558430826 && getInt(info.age)>=12";
>              }
>              @Override
>              public Boolean needChange(LoginEvent element) {
>                 String eventType = element.getEventType();
>     //          System.out.println("遇到数据为change的时候修改规则...........");
>                 return eventType.equals("change");
>              }
>     
>              @Override
>              public Pattern<LoginEvent, ?> returnPattern(LoginEvent flagElement) {
>     
>                 //todo 返回新的Pattern对象
>                 return Pattern.<LoginEvent>begin("start").where(new RichIterativeCondition<LoginEvent>() {
>                    @Override
>                    public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                       System.out.println("修改之后的updateScript = " + updateScript);
>                       LogEventCondition logEventCondition = new LogEventCondition(updateScript);
>                       boolean success = logEventCondition.filter(value);
>                       //todo 这是条件
>                       return success;
>                    }
>                 })
>                    .next("middle").where(new RichIterativeCondition<LoginEvent>() {
>                    @Override
>                    public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                       boolean success = value.getEventType().equals("success");
>                       return success;
>                    }
>                 })
>                    .next("end").where(new RichIterativeCondition<LoginEvent>() {
>                    @Override
>                    public boolean filter(LoginEvent value, Context<LoginEvent> ctx) throws Exception {
>                       String script_end = "getInt(info.mum)>=12";
>                       LogEventCondition logEventCondition = new LogEventCondition(script_end);
>                       boolean filter_end = logEventCondition.filter(value);
>                       return filter_end;
>                    }
>                 }).within(Time.minutes(5));
>                 
>              }
>           });
>     
>           patternstream.select(new RichPatternSelectFunction<LoginEvent, String>() {
>              @Override
>              public String select(Map<String, List<LoginEvent>> pattern) throws Exception {
>                 String start =  pattern.containsKey("start") ? ((ArrayList)pattern.get("start")).get(0).toString() : "" ;
>     //          System.out.println("start = " + start);
>                 String middle = pattern.containsKey("middle") ? ((ArrayList)pattern.get("middle")).get(0).toString() : "" ;
>     //          System.out.println("middle = " + middle);
>                 String end = pattern.containsKey("end") ? ((ArrayList)pattern.get("end")).get(0).toString() : "" ;
>     //          System.out.println("end = " + end);
>                 return start+"$$$"+middle+"$$$"+end;
>              }
>           }).print();
>     
>     
>     
>           env.execute("cep");
>        }
>     
>     
>        public static Invocable invocable(String script) throws Exception {
>           ScriptEngineManager factory = new ScriptEngineManager();
>           ScriptEngine engine = factory.getEngineByName("groovy");
>           engine.eval(script);
>           Invocable inv = (Invocable) engine;
>           return inv;
>        }
>     
>     
>        public static Properties getConsumerProperties() {
>           Properties properties = new Properties();
>           properties.put("bootstrap.servers", Constants.BOOTSTRAP_SERVERS);
>           properties.put("group.id", Constants.GROUP_ID);
>           properties.setProperty("flink.partition-discovery.interval-millis",300 * 1000+"");  // 自动发现消费的partition变化
>           return properties;
>        }
>     
>        public static Properties getSinkProperties() {
>           Properties props = new Properties();
>           props.setProperty("bootstrap.servers",Constants.BOOTSTRAP_SERVERS);
>           props.setProperty("buffer.memory", Constants.BUFFER_MEMORY);
>           props.setProperty("batch.size", Constants.BATCH_SIZE);
>           props.setProperty("linger.ms", Constants.LINGER_MS);
>           props.setProperty("max.request.size", Constants.MAX_REQUEST_SIZE);
>           props.setProperty("acks", Constants.ACKS);
>           props.setProperty("retries", Constants.RETRIES);
>           props.setProperty("retry.backoff.ms", Constants.RETRY_BACKOFF_MS);
>           return props;
>        }
>     }

最后看到这里肯定是有兴趣的：不懂的可以问我 加微信w362098077 本人技术水平有限，但是乐于分享。

[https_mp.weixin.qq.com_s_mh--wQvAWQq2tDPKq0-m8Q]: https://mp.weixin.qq.com/s/mh--wQvAWQq2tDPKq0-m8Q
[https_github.com_apache_flink_tree_master_flink-libraries_flink-cep]: https://github.com/apache/flink/tree/master/flink-libraries/flink-cep
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70]: /images/20221120/b6179efe25fd425db0847d4994644bf4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1]: /images/20221120/b43191c400ef49d1b1951f962cf9968a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2]: /images/20221120/b2a93523cf29446a8f7bc6296788d078.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 3]: /images/20221120/7f96f46057f94960b4e8d87920ea49c1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 4]: /images/20221120/ee8324d72ad94ecd9d2dbefb79120072.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 5]: /images/20221120/0ac2ea322e2c4753afa1a2e7d739823e.png
[20201210150557377.png]: /images/20221120/3445ee333baf4837a9076dba4a196397.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 6]: /images/20221120/4a7f1389f34e444182cba76e037c9789.png
[https_www.yuque.com_boyan-avfmj_aviatorscript_guhmrc]: https://www.yuque.com/boyan-avfmj/aviatorscript/guhmrc