第一步：在類上加入@AllArgsConstructor

import lombok.AllArgsConstructor;

@Slf4j
@Configuration
//@RequiredArgsConstructor
@AllArgsConstructor
public class MqttServer {

第二步: 給類創(chuàng)建一個私有map(相當(dāng)于if分支)

private Map<String, Function<TopicStrategyMapDto, Boolean>> topicStrategyMap;

第三步：各類創(chuàng)建一個無參init方法，標(biāo)注@PostConstruct

/**
     * 初始化(策略模式相關(guān)操作)
     */
    @PostConstruct
    public void init() {
        //插入冷藏箱數(shù)據(jù)
        topicStrategyMap.put(MqttEnum.COLD_DEVICE_TYPE.getValue(), topicStrategyMapDto -> {
            ColdData coldData = JSONUtil.toBean(topicStrategyMapDto.getDataJson(), ColdData.class);
            coldData.setAlarmType(topicStrategyMapDto.getAlarmType());
            return dataUploadService.insertOneColdData(coldData);
        });
        //插入液氮罐數(shù)據(jù)
        topicStrategyMap.put(MqttEnum.INPTANK_DEVICE_TYPE.getValue(), topicStrategyMapDto -> {
            InptankData inptankData = JSONUtil.toBean(topicStrategyMapDto.getDataJson(), InptankData.class);
            inptankData.setAlarmType(topicStrategyMapDto.getAlarmType());
            return dataUploadService.insertOneInptankData(inptankData);
        });
        //插入超低溫冰箱
        topicStrategyMap.put(MqttEnum.ULTRA_COLD_DEVICE_TYPE.getValue(), topicStrategyMapDto -> {
            UltraColdData ultraColdData = JSONUtil.toBean(topicStrategyMapDto.getDataJson(), UltraColdData.class);
            ultraColdData.setAlarmType(topicStrategyMapDto.getAlarmType());
            return dataUploadService.insertOneUltraColdData(ultraColdData);
        });

        log.info(mqttConfig.toString());
    }

第四步：在業(yè)務(wù)中調(diào)用

  Function<TopicStrategyMapDto, Boolean> insertResult = topicStrategyMap.get(dataType);
                if (ObjectUtil.isNull(insertResult)) {
                    log.info("來自主題{}的數(shù)據(jù)插入失敗,原因：topicStrategyMap為null，添加失敗的數(shù)據(jù)為：{}", topic, dataJson);
                }

                if (insertResult.apply(TopicStrategyMapDto.builder().dataJson(dataJson).alarmType(Integer.valueOf(alarmType)).build())) {
                    log.info("來自主題{}的數(shù)據(jù),添加成功！添加的數(shù)據(jù)為：{}", topic, dataJson);
                } else {
                    log.info("來自主題{}的數(shù)據(jù),添加失敗! 添加失敗的數(shù)據(jù)為：{}", topic, dataJson);
                }