初始化项目

云

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
package cn.iocoder.yudao.module.iot.gateway.serialize.json;
 
import cn.hutool.core.lang.Assert;
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
import cn.iocoder.yudao.module.iot.core.enums.IotSerializeTypeEnum;
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
import cn.iocoder.yudao.module.iot.gateway.serialize.IotMessageSerializer;
 
/**
 * JSON 格式的消息序列化器
 *
 * 直接使用 JsonUtils 序列化/反序列化 {@link IotDeviceMessage}，不包装额外字段
 *
 * @author 芋道源码
 */
public class IotJsonSerializer implements IotMessageSerializer {
 
    @Override
    public IotSerializeTypeEnum getType() {
        return IotSerializeTypeEnum.JSON;
    }
 
    @Override
    public byte[] serialize(IotDeviceMessage message) {
        Assert.notNull(message, "消息不能为空");
        return JsonUtils.toJsonByte(message);
    }
 
    @Override
    public IotDeviceMessage deserialize(byte[] bytes) {
        Assert.notNull(bytes, "待解码数据不能为空");
        IotDeviceMessage message = JsonUtils.parseObject(bytes, IotDeviceMessage.class);
        Assert.notNull(message, "消息解码失败");
        return message;
    }
 
}