初始化项目

云

2026-06-24 f4bd1f3c89d906131495a0aca5aaf82966378510

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
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);
    }
 
}