一种可扩展的消息路由实现方式

柔情只为你懂 2023-10-04 09:03 10阅读 0赞

### 一、引言 ###

> 最近在实现微信小程序时，需要处理微信服务器推送来的不同的消息，消息类型多种多样，包括订阅消息、图文消息等等。在借鉴一些大神的设计模式后，简单实现了一种消息路由模型，可满足多种类型的消息、多种路由匹配、多种消息处理。

### 二、模型 ###

![image.png][]

*  消息本身有一些特征量，可作为消息路由规则匹配的依据。
 *  一个消息路由器包含多个消息路由规则。
 *  一个消息路由规则包含拦截器、匹配器，多个处理器。

### 三、代码 ###

3.1 消息定义

源码：[https://segmentfault.com/a/1190000039689926][https_segmentfault.com_a_1190000039689926]

**待消费的消息**

@Builder
    @Getter
    @ToString
    public class Message {
        private String event;
        private String msgType;
        private String content;
        private String fromUser;
        private String toUser;
        private Instant createTime;
        //... as you wish
    }

待消费消息对象包含一些`Trait`字段，包括`event`，`msgType`，`content`。这些字段既可以作为路由规则匹配的依据，也能作为具体消息处理的条件。可根据不同的业务类型去扩展。

**消息处理结果**

@Builder
    @ToString
    public class OutMessage {
        private String msgType;
        private String fromUser;
        private String toUser;
        private Instant createTime;
    }

消息处理结果，根据具体业务自行定义吧。

3.2 消息处理器

抽象类型

public interface MessageHandler {
        OutMessage handle(Message message, Map<String,Object> context);
    }

这是所有消息处理器的抽象类型，自定义的处理器都必须实

[image.png]: https://img-blog.csdnimg.cn/img_convert/0b8b820e0c8e460b5710fbb897639f27.png
[https_segmentfault.com_a_1190000039689926]: https://segmentfault.com/a/1190000039689926