业务代码插件式开发实践
在学习编程初期,会接触到设计模式的概念:23种设计模式,单例模式,策略模式,… 。接触业务研发后,对设计模式的使用和实践有了更深的见解。
使用设计模式是目的为了更高效的支撑业务诉求,如何在保证代码质量的情况下变更/扩展现有功能,这里的代码质量可分为健壮性和可读性两大类,分别包含以下方面:
- 健壮性:并发控制、事务、单点变更、性能、可测试
- 可读性:业务语义、圈复杂度、认知复杂度、coding style
往往在变更/扩展一块功能时,最耗时费力的不是功能编码,而是待开发功能对已有功能影响的梳理。代码质量的好坏对该过程起着决定性作用,进一步与系统Bug率也有着强关联。
但在接触到具体业务代码时,我们往往以“屎山”代称,这里有两类原因:
- 业务处于扩张期,业务形态未完全定型,业务需求量大且急,此时代码质量并不是首要考虑因素,而是要快速支持业务。
提升代码质量不是目的,而是手段。最终目的都是为了支撑业务。
- 研发人员没有意识,研发团队没有规范且无强卡点
不设置强卡点的规范都不是规范
本文讨论了一些业务研发过程中常用的插件式开发形式,以及衍生出常用的两种设计模式:策略模式和责任链模式。
插件式开发
在说明设计模式之前,先了解以下插件式开发,插件式开发对于已有功能提供了一种扩展可能,同时在变更已有功能时不会因为逻辑耦合导致影响其他功能。
Spring官方提供了一种插件组件:Spring Plugin
在业务开发中结合Spring也可以完成可插拔的设计,我将它成为supports模式。
比如这里的用户触达场景,用户可以通过短信、邮件、站内信方式接受通知,不同的途径会生成不同的消息体。因此我们有:
1
2
3
4
5
// 通知方式
enum MessageType{ SMS,EMAIL,APP }
// 用于生成消息的输入上下文
class MessageContext {...}
在设计消息生成接口时,我们添加一个supports方法表示该实现类支持的生成方式:
1
2
3
4
5
6
7
8
9
public interface MessageGenerate {
// 生成消息字符串方法
String generate(MessageContext context);
// 支持的消息类型
boolean supports(MessageType messageType);
}
这样,支持生成何种类型消息的控制权就由实现类自行决定,比如我需要实现站内信的支持:
1
2
3
4
5
6
7
8
9
10
11
12
class APPMessageGenerate implements MessageGenerate {
@Override
public String generate(MessageContext context) {
// ...
return "";
}
@Override
public boolean supports(MessageType messageType) {
return Objects.equals(messageType, MessageType.APP);
}
}
再比如,这里的短信和邮件使用一种格式,那我们只需要一个实现类即可:
1
2
3
4
5
6
7
8
9
10
11
12
13
class SMSEmailMessageGenerate implements MessageGenerate {
@Override
public String generate(MessageContext context) {
// ...
return "";
}
@Override
public boolean supports(MessageType messageType) {
return Objects.equals(messageType, MessageType.SMS)
|| Objects.equals(messageType, MessageType.EMAIL);
}
}
这样的设计在Spring Security中尤为常见,可以参看:Spring Security 实践
策略模式
在此基础上,构建一个门面可以实现策略模式:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Component
class MessageFacade{
@Autowired
private List<MessageGenerate> generators;
// 根据MessageType生成对应的消息
public String generateByMessageType(MessageType messageType, MessageContext context) throws OperationNotSupportedException {
return generators.stream()
.filter(message -> message.supports(messageType))
.findFirst()
.map(generator -> generator.generate(context))
.orElseThrow(OperationNotSupportedException::new);
}
}
在使用时直接调用MessageFacade#generateByMessageType
即可,后续扩展,添加实现类即可,Spring可自动注入MessageGenerate
接口的所有实现类。
责任链模式
另外一个case,这里我想把所有消息类型的消息都拼接在一起,并且指定拼接顺序,我们可以构建一个责任链,不同的类型按顺序生成不同的消息,此时我们需要依赖顺序, MessageGenerate
可以继承Spring的org.springframework.core.Ordered
接口:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
// 继承自org.springframework.core.Ordered接口
public interface MessageGenerate extends Ordered {
...
}
// 实现类实现getOrder方法
class APPMessageGenerate implements MessageGenerate {
...
// 值越小顺序越靠前
@Override
public int getOrder() {
return 0;
}
}
或不需要继承Ordered接口,在实现类注解 Spring的org.springframework.core.annotation.Order
/ java的javax.annotation.Priority
:
1
2
3
4
5
6
// 实现类注解org.springframework.core.annotation.Order,值越小顺序越靠前
@Order(-100)
class APPMessageGenerate implements MessageGenerate {
...
}
在门面中构建顺序责任链:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
@Component
class MessageFacade{
// 责任链
@Autowired
private List<MessageGenerate> generators;
// 排序
@PostConstruct
private void init() {
AnnotationAwareOrderComparator.sort(generators);
}
public String generateAndConcatMessage(MessageContext context){
StringBuilder sb = new StringBuilder();
generators.forEach(generator -> sb.append(generator.generate(context)));
return sb.toString();
}
}
进一步,如果需要有复杂且可复用的support逻辑,可以单独抽象出一个匹配器接口:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
interface MessageMatcher {
boolean matches(MessageContext context);
}
// 这里以类型匹配为例
@RequiredArgsConstructor
class MessageTypeMatcher implements MessageMatcher {
private final MessageType targetMessageType;
@Override
public boolean matches(MessageContext context) {
return Objects.equals(targetMessageType, context.getMessageType());
}
}
这样实现类可以将匹配逻辑委托给MessageMatcher
,实现逻辑解耦:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Order(-100)
class APPMessageGenerate implements MessageGenerate {
private final MessageMatcher messageMatcher = new MessageTypeMatcher(MessageType.APP);
@Override
public String generate(MessageContext context) {
// ...
return "";
}
// 这里我们将support的输入扩大为整个context
@Override
public boolean supports(MessageContext messageType) {
return messageMatcher.matches(messageType);
}
}
整个UML图如下:
但是如果我们要在执行过程中控制是否继续这个责任链呢?这里Spring Security给出的解决方式是,在接口下构造一个抽象类记录责任链执行进度,实现类每次执行完都要调用 super().generate(...)
方法表示继续这个责任链,否则不继续。这样要求generate
方法返回值必须为void
,因此,将输出结果作为责任链入参传入,在执行过程中填充, 其接口变为:
1
2
3
4
5
6
7
8
9
10
11
12
interface MessageGenerate {
// 生成消息字符串方法
void generate(MessageInputContext inputContext, MessageOutputContext outputContext);
// 支持的消息类型
boolean supports(MessageInputContext context);
}
class MessageOutputContext {
List<String> messages;
}
进一步,我们可以利用void返回值,让其返回boolean值表示是否继续责任链:
1
2
3
4
5
6
interface MessageGenerate {
// boolean表示是否继续责任链
boolean generate(MessageInputContext inputContext, MessageOutputContext outputContext);
boolean supports(MessageInputContext context);
}
这样最终的Facade中的逻辑为:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
@Component
class MessageFacade{
@Autowired
private List<MessageGenerate> generators;
@PostConstruct
private void init() {
AnnotationAwareOrderComparator.sort(generators);
}
public MessageOutputContext generateMessages(MessageInputContext inputContext){
MessageOutputContext outputContext = new MessageOutputContext();
for (MessageGenerate generator : generators) {
// 返回为false表示不继续,直接break
if (!generator.generate(inputContext, outputContext)) {
break;
}
}
return outputContext;
}
}
弊端
可以看到这里所有实现类共用了一个Context
,会造成一个巨大的类,内部字段何时填充,何时使用,使用目的,使用方都会变得不清晰。