nifi+redis生成一个奇怪的缓存键/val-如何正确地序列化/反序列化？

Question

我的Nifi处理器实现生成了一个奇怪的缓存键和值，类似于'\xac\xed\x00\x05t\x00\x06'的内容被前置到每个键/val。例如，插入'key':'val'生成“\xac\xed\x00\x05t\x00\x03key”：“\xac\xed\x00\x05t\x00\x03val”。

我没有spring配置可用于编辑或spring数据类，这都是在NIFI的实现中完成的。我所拥有和必须提供的就是序列化器和反序列化器：

void serialize(T value, OutputStream output) throws SerializationException, IOException;
T deserialize(byte[] input) throws DeserializationException, IOException;

例如，GetAndPutIfAbst方法如下所示：

cache.getAndPutIfAbsent(key, value, keySerializer, valueSerializer, valueDeserializer);

我的字节序列化/反序列化很简单：

 public static byte[] serialize(Object obj) throws IOException {
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        ObjectOutputStream os = new ObjectOutputStream(out);
        os.writeObject(obj);
        return out.toByteArray();
    }

    public static Object deserialize(byte[] data) {
        if (data == null || data.length == 0) return null;
        try {
            ByteArrayInputStream in = new ByteArrayInputStream(data);
            ObjectInputStream is = new ObjectInputStream(in);
            return is.readObject();
        } catch (Exception e) {
            // log
        }
        return null;
    }

我的目标是在没有预置字符和工作一致的情况下获得密钥/瓦尔斯。我不能修补spring配置和类。如何进行？

Answer 1

对字符串使用以下de/serialization解决了这两个问题：

value.getBytes(StandardCharsets.UTF_8)
new String(value, StandardCharsets.UTF_8);

不知道为什么，但现在管用了。