都在使用的《模版模式》

模版符合开闭原则，随处用于钩子方法。有的钩子方法不会改变行为，有的钩子会改变运行轨迹。框架中随处使用。

Channel中界说了需要的操作，AbstractChannel实现了核心功能，然后差别的Channel实现只需要告知具体channel的描述信息即可。
Channel 接口⬇︎⬇︎⬇︎
点击查看代码

1. package com.xxx.sales.subscription.service.pubsub;
3. import com.xxx.sales.subscription.service.pubsub.dto.SubscribersResult;
4. import com.xxx.sales.subscription.service.pubsub.enums.ChannelEnum;
6. /**
7. * 通道/频道
8. * <pre>
9. *     消息发送到指定的channel中， 各个订阅者监听channel
10. * </pre>
11. *
12. * @author huhaiyang
13. */
14. public interface Channel<K, V extends SubscribersResult> {
17.     /**
18.      * 获得信道描述
19.      *
20.      * @return {@link ChannelEnum}
21.      */
22.     ChannelEnum getChannelDescription();
25.     /**
26.      * 添加订阅者
27.      *
28.      * @param subscriber 订阅者
29.      */
30.     void addSubscriber(SafetySubscriber<K, V> subscriber);
33.     /**
34.      * 删除订阅者
35.      *
36.      * @param subscriber 订阅者
37.      */
38.     void removeSubscriber(SafetySubscriber<K, V> subscriber);
41. }

复制代码

AbstractChannel 实现重要功能⬇︎⬇︎⬇︎
点击查看代码

1. package com.xxx.sales.subscription.service.pubsub.chanels;
3. import com.xxx.sales.subscription.service.pubsub.Channel;
4. import com.xxx.sales.subscription.service.pubsub.SafetySubscriber;
5. import com.xxx.sales.subscription.service.pubsub.dto.SubscriberResult;
6. import com.xxx.sales.subscription.service.pubsub.dto.SubscribersResult;
7. import lombok.extern.slf4j.Slf4j;
9. import java.util.LinkedList;
11. /**
12. *
13. * @author huhaiyang
14. */
15. @Slf4j
16. public abstract class AbstractChannel<K, V extends SubscribersResult> implements Channel<K, V> {
18.     private LinkedList<SafetySubscriber<K, V>> subscribers = new LinkedList<>();
21.     /**
22.      * 添加订阅者
23.      *
24.      * @param subscriber 订阅者
25.      */
26.     @Override
27.     public void addSubscriber(SafetySubscriber subscriber) {
28.         if (subscribers.contains(subscriber)) {
29.             return;
30.         }else {
31.             subscribers.add(subscriber);
32.         }
34.     }
36.     /**
37.      * 删除订阅者
38.      *
39.      * @param subscriber 订阅者
40.      */
41.     @Override
42.     public void removeSubscriber(SafetySubscriber subscriber) {
43.         subscribers.remove(subscriber);
44.     }
47.     /**
48.      * 接收消息
49.      *
50.      * @param message       消息
51.      * @param collectResult 收集结果
52.      */
53.     public void  receiveMessage(K message,V collectResult){
54.         log.info("receiveMessage start...");
55.         for (SafetySubscriber<K, V> subscriber : subscribers) {
56.             subscriber.update(message, collectResult);
57.             SubscriberResult resultBySubscriber = collectResult.getResultBySubscriber(subscriber);
58.             if (!resultBySubscriber.isSuccess()) {
59.                 log.info("{}执行失败，开始失败策略...",subscriber.getClass().getSimpleName());
60.                 subscriber.failBack(message,collectResult);
61.                 log.info("{}失败策略执行结束.",subscriber.getClass().getSimpleName());
62.             }
63.         }
64.         log.info("receiveMessage end...");
65.     }
66. }

复制代码

OrderActivateChannel 订单激活channel  ⬇︎⬇︎⬇︎
点击查看代码

1. package com.xxx.sales.subscription.service.pubsub.chanels;
3. import com.xxx.sales.subscription.service.pubsub.dto.OrderActivateMessage;
4. import com.xxx.sales.subscription.service.pubsub.dto.SubscribersResult;
5. import com.xxx.sales.subscription.service.pubsub.enums.ChannelEnum;
6. import org.springframework.stereotype.Component;
8. /**
9. * 订单激活的channel
10. *
11. * @author huhaiyang
12. * @date 2022 2022/12/8
13. */
14. @Component
15. public class OrderActivateChannel extends AbstractChannel<OrderActivateMessage, SubscribersResult> {
16.     /**
17.      * 获得信道描述
18.      *
19.      * @return {@link ChannelEnum}
20.      */
21.     @Override
22.     public ChannelEnum getChannelDescription() {
23.         return ChannelEnum.ORDER_ACTIVATE;
24.     }
25. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。