package cn.iocoder.yudao.module.iot.gateway.serialize;
|
|
import cn.iocoder.yudao.module.iot.core.enums.IotSerializeTypeEnum;
|
import cn.iocoder.yudao.module.iot.gateway.serialize.binary.IotBinarySerializer;
|
import cn.iocoder.yudao.module.iot.gateway.serialize.json.IotJsonSerializer;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.EnumMap;
|
import java.util.Map;
|
|
/**
|
* IoT 序列化器管理器
|
*
|
* 负责根据枚举创建和管理序列化器实例
|
*
|
* @author 芋道源码
|
*/
|
@Slf4j
|
public class IotMessageSerializerManager {
|
|
private final Map<IotSerializeTypeEnum, IotMessageSerializer> serializerMap = new EnumMap<>(IotSerializeTypeEnum.class);
|
|
public IotMessageSerializerManager() {
|
// 遍历枚举，创建对应的序列化器
|
for (IotSerializeTypeEnum type : IotSerializeTypeEnum.values()) {
|
IotMessageSerializer serializer = createSerializer(type);
|
serializerMap.put(type, serializer);
|
log.info("[IotSerializerManager][序列化器 {} 创建成功]", type);
|
}
|
}
|
|
/**
|
* 根据类型创建序列化器
|
*
|
* @param type 序列化类型
|
* @return 序列化器实例
|
*/
|
@SuppressWarnings("EnhancedSwitchMigration")
|
private IotMessageSerializer createSerializer(IotSerializeTypeEnum type) {
|
switch (type) {
|
case JSON:
|
return new IotJsonSerializer();
|
case BINARY:
|
return new IotBinarySerializer();
|
default:
|
throw new IllegalArgumentException("未知的序列化类型：" + type);
|
}
|
}
|
|
/**
|
* 获取序列化器
|
*
|
* @param type 序列化类型
|
* @return 序列化器实例
|
*/
|
public IotMessageSerializer get(IotSerializeTypeEnum type) {
|
return serializerMap.get(type);
|
}
|
|
}
|
