数据查询网站如何做,全站仪为什么要建站,北京品牌建设网站公司排名,最新项目前言 以采集数据处理逻辑为例#xff0c;数据采集分为不同种类如#xff1a;MQTT、MODBUS、HTTP等#xff0c;不同的采集数据有不同的解析处理逻辑。但总体解析处理步骤是固定的。可以使用工厂方法设计模式简化代码#xff0c;让代码变得更加优雅。 代码实践
抽象类
总体…前言 以采集数据处理逻辑为例数据采集分为不同种类如MQTT、MODBUS、HTTP等不同的采集数据有不同的解析处理逻辑。但总体解析处理步骤是固定的。可以使用工厂方法设计模式简化代码让代码变得更加优雅。 代码实践
抽象类
总体步骤一致先声明一个抽象类包含所有处理步骤具体处理步骤由不同子类自行实现。【大体处理框架】
public abstract class AbstractCollectService {protected abstract Boolean handleAlarm(CollectDataMessage message);protected abstract Boolean handleCollect(CollectDataMessage message);public CollectDataMessage parseKafkaMessage(String kafkaMessage, CollectTypeEnum collectTypeEnum){// 工厂方法return CollectFactory.getInstance(collectTypeEnum).parseKafkaMessage2DataMessage(kafkaMessage);}protected abstract CollectDataMessage parseKafkaMessage2DataMessage(String kafkaMessage);public Boolean doHandle(CollectDataMessage message) {Boolean ret;switch (message.getHandleTypeEnum()){case ALARM:ret handleAlarm(message) ;break ;case COLLECT:ret handleCollect(message) ;break ;default:ret false ;}return ret ;}}枚举类
采集数据枚举类与子实现类一一对应
public enum CollectTypeEnum {MQTT,MODBUS,HTTP;
}子实现类
不同采集数据的子类处理逻辑各自实现抽象类中抽象方法核心逻辑。 工厂方法
定义工厂方法使用枚举做判断条件真正处理不同逻辑时需要显示地传出对应枚举参数以便得到对应实现类对象。
public class CollectFactory {public static AbstractCollectService getInstance(CollectTypeEnum collectTypeEnum) {switch (collectTypeEnum) {case MQTT:return MqttCollectService.getInstance();case MODBUS:return ModbusCollectService.getInstance();case HTTP:return HttpCollectService.getInstance();default:throw new IllegalArgumentException(Unknown collect type);}}
}具体子类对象都是采用【基于类初始化】获取的单例对象。随便一个为例其他子类同理。 简单的工厂方法设计模式就这样实现了~
最终使用
显示指定枚举参数 处理函数
public class KafkaMsg2CollectMsgRichMapFunction extends RichMapFunctionString, CollectDataMessage {private static final Logger log LoggerFactory.getLogger(KafkaMsg2CollectMsgRichMapFunction.class) ;private final CollectTypeEnum collectTypeEnum;public KafkaMsg2CollectMsgRichMapFunction(CollectTypeEnum collectTypeEnum) {this.collectTypeEnum collectTypeEnum;}Overridepublic void open(Configuration parameters) throws Exception {}Overridepublic CollectDataMessage map(String kafkaMessage) {try {// 根据显示指定的枚举类获取对应子类实现相应逻辑AbstractCollectService collectService CollectFactory.getInstance(collectTypeEnum);return collectService.parseKafkaMessage(kafkaMessage, collectTypeEnum);} catch (RuntimeException e) {log.info(解析采集数据异常, e);throw new RuntimeException(e);}}Overridepublic void close() throws Exception {}
}
