feat: 添加责任链模式接口模板，策略执行器支持多个匹配实现

Author: cadecode

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/ExtContext.java

@@ -0,0 +1,24 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline;
+
+import com.github.cadecode.uniboot.common.core.enums.ExtTypeCode;
+import com.github.cadecode.uniboot.common.core.extension.pipeline.selector.FilterSelector;
+import lombok.Getter;
+
+/**
+ * pipeline 上下文抽象类
+ *
+ * @author Cade Li
+ * @since 2023/6/25
+ */
+@Getter
+public abstract class AbstractPipelineContext implements PipelineContext {
+
+    private final ExtTypeCode extTypeCode;
+    private final FilterSelector filterSelector;
+
+    public AbstractPipelineContext(ExtTypeCode extTypeCode, FilterSelector filterSelector) {
+        this.extTypeCode = extTypeCode;
+        this.filterSelector = filterSelector;
+    }
+
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/AbstractPipelineContext.java

@@ -0,0 +1,43 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline;
+
+import com.github.cadecode.uniboot.common.core.extension.pipeline.filter.PipelineFilter;
+import lombok.Setter;
+
+import java.util.Objects;
+
+/**
+ * 过滤器链默认实现
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public class DefaultPipelineFilterChain<T extends PipelineContext> implements PipelineFilterChain<T> {
+
+    @Setter
+    private PipelineFilterChain<T> next;
+    private final PipelineFilter<T> filter;
+
+    public DefaultPipelineFilterChain(PipelineFilterChain<T> next, PipelineFilter<T> filter) {
+        this.next = next;
+        this.filter = filter;
+    }
+
+
+    /**
+     * 当前 filter 处理
+     */
+    @Override
+    public void filter(T context) {
+        filter.doFilter(context, this);
+    }
+
+    /**
+     * 下一 filter 处理
+     */
+    @Override
+    public void next(T context) {
+        if (Objects.nonNull(this.next)) {
+            this.next.filter(context);
+        }
+    }
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/DefaultPipelineFilterChain.java

@@ -0,0 +1,20 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline;
+
+import com.github.cadecode.uniboot.common.core.enums.ExtTypeCode;
+import com.github.cadecode.uniboot.common.core.extension.pipeline.selector.FilterSelector;
+
+/**
+ * pipeline 上下文
+ *
+ * @author Cade Li
+ * @since 2023/6/23
+ */
+public interface PipelineContext {
+
+    ExtTypeCode getPipelineType();
+
+    FilterSelector getFilterSelector();
+
+    boolean continueChain();
+
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/PipelineContext.java

@@ -0,0 +1,14 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline;
+
+/**
+ * 过滤器链接口
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public interface PipelineFilterChain<T extends PipelineContext> {
+
+    void filter(T context);
+
+    void next(T context);
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/PipelineFilterChain.java

@@ -0,0 +1,31 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline;
+
+import com.github.cadecode.uniboot.common.core.extension.pipeline.filter.PipelineFilter;
+import lombok.Getter;
+
+import java.util.Objects;
+
+/**
+ * 管道构建器
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public class PipelineGenerator<T extends PipelineFilter<A>, A extends PipelineContext> {
+
+    @Getter
+    private DefaultPipelineFilterChain<A> firstChain;
+    private DefaultPipelineFilterChain<A> lastChain;
+
+    public void appendFilter(T filter) {
+        DefaultPipelineFilterChain<A> newChain = new DefaultPipelineFilterChain<>(null, filter);
+        if (Objects.isNull(firstChain)) {
+            firstChain = newChain;
+            lastChain = firstChain;
+            return;
+        }
+        lastChain.setNext(newChain);
+        lastChain = newChain;
+    }
+
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/PipelineGenerator.java

@@ -0,0 +1,32 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline.filter;
+
+import com.github.cadecode.uniboot.common.core.extension.pipeline.PipelineContext;
+import com.github.cadecode.uniboot.common.core.extension.pipeline.PipelineFilterChain;
+
+/**
+ * 过滤器抽象类
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public abstract class AbstractPipelineFilter<T extends PipelineContext> implements PipelineFilter<T> {
+
+    /**
+     * 过滤方法模板
+     */
+    @Override
+    public void doFilter(T context, PipelineFilterChain<T> filterChain) {
+        // 如果包含该 filter
+        if (context.getFilterSelector().matchFilter(this.getClass().getSimpleName())) {
+            handle(context);
+        }
+        if (context.continueChain()) {
+            filterChain.next(context);
+        }
+    }
+
+    /**
+     * 过滤处理主逻辑
+     */
+    public abstract void handle(T context);
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/filter/AbstractPipelineFilter.java

@@ -0,0 +1,15 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline.filter;
+
+import com.github.cadecode.uniboot.common.core.extension.pipeline.PipelineContext;
+import com.github.cadecode.uniboot.common.core.extension.pipeline.PipelineFilterChain;
+
+/**
+ * 过滤器接口
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public interface PipelineFilter<T extends PipelineContext> {
+
+    void doFilter(T context, PipelineFilterChain<T> filterChain);
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/filter/PipelineFilter.java

@@ -0,0 +1,16 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline.selector;
+
+import java.util.List;
+
+/**
+ * 过滤器选择器
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+public interface FilterSelector {
+
+    boolean matchFilter(String currFilterName);
+
+    List<String> getFilterNames();
+}

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/pipeline/selector/FilterSelector.java

@@ -0,0 +1,39 @@
+package com.github.cadecode.uniboot.common.core.extension.pipeline.selector;
+
+import lombok.AllArgsConstructor;
+import lombok.NoArgsConstructor;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * 基于本地 list 的过滤器选择器
+ *
+ * @author Cade Li
+ * @date 2023/6/20
+ */
+@NoArgsConstructor
+@AllArgsConstructor
+public class LocalListFilterSelector implements FilterSelector {
+
+    private List<String> filterNames = new ArrayList<>();
+
+    @Override
+    public boolean matchFilter(String currFilterName) {
+        return filterNames.stream().anyMatch(o -> Objects.equals(currFilterName, o));
+    }
+
+    @Override
+    public List<String> getFilterNames() {
+        return filterNames;
+    }
+
+    public void addFilter(String filterName) {
+        filterNames.add(filterName);
+    }
+
+    private void addFilters(List<String> filterNames) {
+        this.filterNames.addAll(filterNames);
+    }
+}