предисловие
В логистической отрасли это обычно включает в себя передачу сообщений EDI (файлы формата XML) и получение квитанций.Каждый раз, когда отправляется сообщение EDI, будет получена связанная с ним квитанция (идентифицирующая статус потока данных в сторонняя система).
Здесь перечислены несколько типов квитанций: MT1101, MT2101, MT4101, MT8104, MT8105, MT9999.После получения различных квитанций система выполнит соответствующую обработку бизнес-логики. Конечно, реальный бизнес-сценарий не такой общий, и здесь мы используем обработку квитанций в качестве демонстрационного примера.
Макет класса квитанций
@Data
public class Receipt {
/**
* 回执信息
*/
String message;
/**
* 回执类型(`MT1101、MT2101、MT4101、MT8104、MT8105、MT9999`)
*/
String type;
}
Моделирование генератора чеков
public class ReceiptBuilder {
public static List<Receipt> generateReceiptList(){
//直接模拟一堆回执对象
List<Receipt> receiptList = new ArrayList<>();
receiptList.add(new Receipt("我是MT2101回执喔","MT2101"));
receiptList.add(new Receipt("我是MT1101回执喔","MT1101"));
receiptList.add(new Receipt("我是MT8104回执喔","MT8104"));
receiptList.add(new Receipt("我是MT9999回执喔","MT9999"));
//......
return receiptList;
}
}
Традиционная практика - ветвь if-else
List<Receipt> receiptList = ReceiptBuilder.generateReceiptList();
//循环处理
for (Receipt receipt : receiptList) {
if (StringUtils.equals("MT2101",receipt.getType())) {
System.out.println("接收到MT2101回执");
System.out.println("解析回执内容");
System.out.println("执行业务逻辑");
} else if (StringUtils.equals("MT1101",receipt.getType())) {
System.out.println("接收到MT1101回执");
System.out.println("解析回执内容");
System.out.println("执行业务逻辑");
} else if (StringUtils.equals("MT8104",receipt.getType())) {
System.out.println("接收到MT8104回执");
System.out.println("解析回执内容");
System.out.println("执行业务逻辑");
} else if (StringUtils.equals("MT9999",receipt.getType())) {
System.out.println("接收到MT9999回执");
System.out.println("解析回执内容");
System.out.println("执行业务逻辑");
System.out.println("推送邮件");
}
// ......未来可能还有好多个else if
}
Когда бизнес-логика ветвления if-else сложна, мы привыкли извлекать метод или инкапсулировать его в вызываемый объект, чтобы вся структура if-else не выглядела слишком раздутой.
В приведенном выше примере, когда типов чеков становится все больше и больше, ветки else if будет становиться все больше и больше, и каждый раз при добавлении типа квитанции необходимо модифицировать или добавлять ветку if-else, что нарушает принцип открыт-закрыт (открыт для расширений, право на изменение закрыто)
Шаблон стратегии + словарь картМы знаем, что цель шаблона стратегии — инкапсулировать ряд алгоритмов, они имеют общие черты и могут быть заменены друг другом, то есть пусть алгоритм меняется независимо от клиента, который его использует, а клиент зависит только в интерфейсе стратегии.
В приведенном выше сценарии мы можем извлечь бизнес-логику ветки if-else в различные стратегии, но неизбежно, что клиенту все еще нужно написать некоторую логику if-else для выбора стратегии, и мы можем извлечь эту логику в фабрику. Заходим в класс, это паттерн стратегии + простая фабрика, код такой
Интерфейс политики
/**
* @Description: 回执处理策略接口
* @Auther: wuzhazha
*/
public interface IReceiptHandleStrategy {
void handleReceipt(Receipt receipt);
}
Класс реализации интерфейса стратегии, то есть конкретный обработчик
public class Mt2101ReceiptHandleStrategy implements IReceiptHandleStrategy {
@Override
public void handleReceipt(Receipt receipt) {
System.out.println("解析报文MT2101:" + receipt.getMessage());
}
}
public class Mt1101ReceiptHandleStrategy implements IReceiptHandleStrategy {
@Override
public void handleReceipt(Receipt receipt) {
System.out.println("解析报文MT1101:" + receipt.getMessage());
}
}
public class Mt8104ReceiptHandleStrategy implements IReceiptHandleStrategy {
@Override
public void handleReceipt(Receipt receipt) {
System.out.println("解析报文MT8104:" + receipt.getMessage());
}
}
public class Mt9999ReceiptHandleStrategy implements IReceiptHandleStrategy {
@Override
public void handleReceipt(Receipt receipt) {
System.out.println("解析报文MT9999:" + receipt.getMessage());
}
}
Класс контекста политики (держатель интерфейса политики)
/**
* @Description: 上下文类，持有策略接口
* @Auther: wuzhazha
*/
public class ReceiptStrategyContext {
private IReceiptHandleStrategy receiptHandleStrategy;
/**
* 设置策略接口
* @param receiptHandleStrategy
*/
public void setReceiptHandleStrategy(IReceiptHandleStrategy receiptHandleStrategy) {
this.receiptHandleStrategy = receiptHandleStrategy;
}
public void handleReceipt(Receipt receipt){
if (receiptHandleStrategy != null) {
receiptHandleStrategy.handleReceipt(receipt);
}
}
}
фабрика стратегий
/**
* @Description: 策略工厂
* @Auther: wuzhazha
*/
public class ReceiptHandleStrategyFactory {
private ReceiptHandleStrategyFactory(){}
public static IReceiptHandleStrategy getReceiptHandleStrategy(String receiptType){
IReceiptHandleStrategy receiptHandleStrategy = null;
if (StringUtils.equals("MT2101",receiptType)) {
receiptHandleStrategy = new Mt2101ReceiptHandleStrategy();
} else if (StringUtils.equals("MT8104",receiptType)) {
receiptHandleStrategy = new Mt8104ReceiptHandleStrategy();
}
return receiptHandleStrategy;
}
}
клиент
public class Client {
public static void main(String[] args) {
//模拟回执
List<Receipt> receiptList = ReceiptBuilder.generateReceiptList();
//策略上下文
ReceiptStrategyContext receiptStrategyContext = new ReceiptStrategyContext();
for (Receipt receipt : receiptList) {
//获取并设置策略
IReceiptHandleStrategy receiptHandleStrategy = ReceiptHandleStrategyFactory.getReceiptHandleStrategy(receipt.getType());
receiptStrategyContext.setReceiptHandleStrategy(receiptHandleStrategy);
//执行策略
receiptStrategyContext.handleReceipt(receipt);
}
}
}
Анализ сообщения MT2101: я — сообщение о получении MT2101 Разбор сообщения MT8104: я — сообщение о получении MT8104
Поскольку наша цель — устранить if-else, то для этого требуется фабрика политик ReceiptHandleStrateGyFactory для хранения моей стратегии, в то время как MAP имеет структуру ключ-значение, что является хорошим выбором для mapp.
Слегка преобразованный код выглядит следующим образом
/**
* @Description: 策略工厂
* @Auther: wuzhazha
*/
public class ReceiptHandleStrategyFactory {
private static Map<String,IReceiptHandleStrategy> receiptHandleStrategyMap;
private ReceiptHandleStrategyFactory(){
this.receiptHandleStrategyMap = new HashMap<>();
this.receiptHandleStrategyMap.put("MT2101",new Mt2101ReceiptHandleStrategy());
this.receiptHandleStrategyMap.put("MT8104",new Mt8104ReceiptHandleStrategy());
}
public static IReceiptHandleStrategy getReceiptHandleStrategy(String receiptType){
return receiptHandleStrategyMap.get(receiptType);
}
}
После преобразования режима стратегии + простая фабричная схема мы устранили структуру if-else, каждый раз, когда приходит новый чек, нам нужно только добавить новую стратегию обработки чека и модифицировать коллекцию Map в ReceiptHandleStrategyFactory.
Если вы хотите, чтобы программа соответствовала принципу открытия-закрытия, вам необходимо настроить метод сбора стратегии обработки в ReceiptHandleStrategyFactory, и получить все классы реализации IReceiptHandleStrategy в указанном пакете путем отражения, а затем поместить их в словарная карта.
Модель цепочки ответственности
Паттерн «Цепочка ответственности» — это паттерн поведения объекта. В шаблоне «Цепочка ответственности» многие объекты связаны в цепочку посредством ссылки каждого объекта на подчиненный ему объект. Запросы передаются по этой цепочке до тех пор, пока объект в цепочке не решит обработать запрос.
Клиент, делающий запрос, не знает, какой объект в цепочке в конечном итоге обрабатывает запрос, что позволяет системе динамически реорганизовывать и распределять обязанности, не затрагивая клиента.
Интерфейс обработчика получения
/**
* @Description: 抽象回执处理者接口
* @Auther: wuzhazha
*/
public interface IReceiptHandler {
void handleReceipt(Receipt receipt,IReceiptHandleChain handleChain);
}
Интерфейс цепочки ответственности
/**
* @Description: 责任链接口
* @Auther: wuzhazha
*/
public interface IReceiptHandleChain {
void handleReceipt(Receipt receipt);
}
Класс реализации интерфейса цепочки ответственности
/**
* @Description: 责任链实现类
* @Auther: wuzhazha
*/
public class ReceiptHandleChain implements IReceiptHandleChain {
//记录当前处理者位置
private int index = 0;
//处理者集合
private static List<IReceiptHandler> receiptHandlerList;
static {
//从容器中获取处理器对象
receiptHandlerList = ReceiptHandlerContainer.getReceiptHandlerList();
}
@Override
public void handleReceipt(Receipt receipt) {
if (receiptHandlerList !=null && receiptHandlerList.size() > 0) {
if (index != receiptHandlerList.size()) {
IReceiptHandler receiptHandler = receiptHandlerList.get(index++);
receiptHandler.handleReceipt(receipt,this);
}
}
}
}
конкретный обработчик получения
public class Mt2101ReceiptHandler implements IReceiptHandler {
@Override
public void handleReceipt(Receipt receipt, IReceiptHandleChain handleChain) {
if (StringUtils.equals("MT2101",receipt.getType())) {
System.out.println("解析报文MT2101:" + receipt.getMessage());
}
//处理不了该回执就往下传递
else {
handleChain.handleReceipt(receipt);
}
}
}
public class Mt8104ReceiptHandler implements IReceiptHandler {
@Override
public void handleReceipt(Receipt receipt, IReceiptHandleChain handleChain) {
if (StringUtils.equals("MT8104",receipt.getType())) {
System.out.println("解析报文MT8104:" + receipt.getMessage());
}
//处理不了该回执就往下传递
else {
handleChain.handleReceipt(receipt);
}
}
}
Контейнер обработчика цепочки ответственности (если используется spring, объект подкласса IReceiptHandler можно получить с помощью внедрения зависимостей)
/**
* @Description: 处理者容器
* @Auther: wuzhazha
*/
public class ReceiptHandlerContainer {
private ReceiptHandlerContainer(){}
public static List<IReceiptHandler> getReceiptHandlerList(){
List<IReceiptHandler> receiptHandlerList = new ArrayList<>();
receiptHandlerList.add(new Mt2101ReceiptHandler());
receiptHandlerList.add(new Mt8104ReceiptHandler());
return receiptHandlerList;
}
}
клиент
public class Client {
public static void main(String[] args) {
//模拟回执
List<Receipt> receiptList = ReceiptBuilder.generateReceiptList();
for (Receipt receipt : receiptList) {
//回执处理链对象
ReceiptHandleChain receiptHandleChain = new ReceiptHandleChain();
receiptHandleChain.handleReceipt(receipt);
}
}
}
Анализ сообщения MT2101: я — сообщение о получении MT2101 Разбор сообщения MT8104: я — сообщение о получении MT8104
Благодаря методу обработки цепочки ответственности мы также устраняем структуру if-else. Всякий раз, когда приходит новый чек, нам нужно только добавить класс реализации IReceiptHandler и модифицировать контейнер-обработчик ReceiptHandlerContainer. Если мы хотим, чтобы программа соответствуют принципу «открыто-закрыто». Затем вам нужно настроить метод получения обработчика в ReceiptHandlerContainer и получить все классы реализации IReceiptHandler в указанном пакете путем отражения.
Здесь используется класс инструмента отражения для получения всех классов реализации указанного интерфейса.
/**
* @Description: 反射工具类
* @Auther: wuzhazha
*/
public class ReflectionUtil {
/**
* 定义类集合（用于存放所有加载的类）
*/
private static final Set<Class<?>> CLASS_SET;
static {
//指定加载包路径
CLASS_SET = getClassSet("com.yaolong");
}
/**
* 获取类加载器
* @return
*/
public static ClassLoader getClassLoader(){
return Thread.currentThread().getContextClassLoader();
}
/**
* 加载类
* @param className 类全限定名称
* @param isInitialized 是否在加载完成后执行静态代码块
* @return
*/
public static Class<?> loadClass(String className,boolean isInitialized) {
Class<?> cls;
try {
cls = Class.forName(className,isInitialized,getClassLoader());
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
return cls;
}
public static Class<?> loadClass(String className) {
return loadClass(className,true);
}
/**
* 获取指定包下所有类
* @param packageName
* @return
*/
public static Set<Class<?>> getClassSet(String packageName) {
Set<Class<?>> classSet = new HashSet<>();
try {
Enumeration<URL> urls = getClassLoader().getResources(packageName.replace(".","/"));
while (urls.hasMoreElements()) {
URL url = urls.nextElement();
if (url != null) {
String protocol = url.getProtocol();
if (protocol.equals("file")) {
String packagePath = url.getPath().replace("%20","");
addClass(classSet,packagePath,packageName);
} else if (protocol.equals("jar")) {
JarURLConnection jarURLConnection = (JarURLConnection) url.openConnection();
if (jarURLConnection != null) {
JarFile jarFile = jarURLConnection.getJarFile();
if (jarFile != null) {
Enumeration<JarEntry> jarEntries = jarFile.entries();
while (jarEntries.hasMoreElements()) {
JarEntry jarEntry = jarEntries.nextElement();
String jarEntryName = jarEntry.getName();
if (jarEntryName.endsWith(".class")) {
String className = jarEntryName.substring(0, jarEntryName.lastIndexOf(".")).replaceAll("/", ".");
doAddClass(classSet,className);
}
}
}
}
}
}
}
} catch (IOException e) {
throw new RuntimeException(e);
}
return classSet;
}
private static void doAddClass(Set<Class<?>> classSet, String className) {
Class<?> cls = loadClass(className,false);
classSet.add(cls);
}
private static void addClass(Set<Class<?>> classSet, String packagePath, String packageName) {
final File[] files = new File(packagePath).listFiles(new FileFilter() {
@Override
public boolean accept(File file) {
return (file.isFile() && file.getName().endsWith(".class")) || file.isDirectory();
}
});
for (File file : files) {
String fileName = file.getName();
if (file.isFile()) {
String className = fileName.substring(0, fileName.lastIndexOf("."));
if (StringUtils.isNotEmpty(packageName)) {
className = packageName + "." + className;
}
doAddClass(classSet,className);
} else {
String subPackagePath = fileName;
if (StringUtils.isNotEmpty(packagePath)) {
subPackagePath = packagePath + "/" + subPackagePath;
}
String subPackageName = fileName;
if (StringUtils.isNotEmpty(packageName)) {
subPackageName = packageName + "." + subPackageName;
}
addClass(classSet,subPackagePath,subPackageName);
}
}
}
public static Set<Class<?>> getClassSet() {
return CLASS_SET;
}
/**
* 获取应用包名下某父类（或接口）的所有子类（或实现类）
* @param superClass
* @return
*/
public static Set<Class<?>> getClassSetBySuper(Class<?> superClass) {
Set<Class<?>> classSet = new HashSet<>();
for (Class<?> cls : CLASS_SET) {
if (superClass.isAssignableFrom(cls) && !superClass.equals(cls)) {
classSet.add(cls);
}
}
return classSet;
}
/**
* 获取应用包名下带有某注解的类
* @param annotationClass
* @return
*/
public static Set<Class<?>> getClassSetByAnnotation(Class<? extends Annotation> annotationClass) {
Set<Class<?>> classSet = new HashSet<>();
for (Class<?> cls : CLASS_SET) {
if (cls.isAnnotationPresent(annotationClass)) {
classSet.add(cls);
}
}
return classSet;
}
}
Затем преобразуйте ReceiptHandlerContainer
public class ReceiptHandlerContainer {
private ReceiptHandlerContainer(){}
public static List<IReceiptHandler> getReceiptHandlerList(){
List<IReceiptHandler> receiptHandlerList = new ArrayList<>();
//获取IReceiptHandler接口的实现类
Set<Class<?>> classList = ReflectionUtil.getClassSetBySuper(IReceiptHandler.class);
if (classList != null && classList.size() > 0) {
for (Class<?> clazz : classList) {
try {
receiptHandlerList.add((IReceiptHandler)clazz.newInstance());
} catch ( Exception e) {
e.printStackTrace();
}
}
}
return receiptHandlerList;
}
}
Пока решение полностью соответствует принципу открыт-закрыт, при добавлении нового типа чека нужно только добавить новый обработчик чеков, и никаких других изменений не требуется. Если добавляется новая квитанция для MT6666, код выглядит следующим образом
public class Mt6666ReceiptHandler implements IReceiptHandler {
@Override
public void handleReceipt(Receipt receipt, IReceiptHandleChain handleChain) {
if (StringUtils.equals("MT6666",receipt.getType())) {
System.out.println("解析报文MT6666:" + receipt.getMessage());
}
//处理不了该回执就往下传递
else {
handleChain.handleReceipt(receipt);
}
}
}
Шаблон стратегии + аннотация
По сути, это решение мало чем отличается от вышеописанного: для соблюдения принципа открытия и закрытия класс процессора помечается пользовательской аннотацией, а затем путем отражения получается коллекция этого класса и помещается в Map контейнер, который не будет повторяться здесь.
резюме
Метод суждения о ветвлениях if-else или case switch интуитивно понятен и эффективен для простого бизнеса с небольшой логикой ветвления. Для сложной бизнес-логики и многих ветвей использование соответствующих навыков работы с шаблонами сделает код более понятным и простым в обслуживании, но в то же время количество классов или методов будет удвоено. Нам нужно провести полный анализ бизнеса, избегать разработки шаблонов в начале и избегать чрезмерного проектирования!
Источник: cnblogs.com/DiDi516/p/11787257.html.