4

我有以下课程：

public class QueryResults {
    protected Set<String> resultList = new HashSet<String>();
    protected long executionTime = 0;

    public long getExecutionTime() { return executionTime; }
    [...]
}

我这样注册它：

Registrar.RegisterClass(this, QueryResults.class);
------------
public class Registrar {
    public static void RegisterClass(Node n, Class theClass) {
        Map<String, Node> nodeMap = Node.getNodeMap();
        for (Map.Entry<String, Node> node : nodeMap.entrySet()) {
            if (node.getKey().equals(n.getHostname())) {
                Log.info("Registering " + theClass.getSimpleName() + " for " + node.getValue().getHostname());
                node.getValue().getServer().getConnection().getKryo().register(theClass);
                node.getValue().getClient().getConnection().getKryo().register(theClass);
            }
        }
    }
}

这在尝试 serialize 之前一直运行良好QueryResults，因为它包含一个容器，在这种情况下是 a HashSet（我们也尝试了 an ArrayList，结果相同）。

在填充并最终序列化此类以发送回调用方的端点上，我得到以下输出：

Exception in thread "Server" com.esotericsoftware.kryo.KryoException:
java.lang.IllegalArgumentException: Class is not registered: java.util.HashSet

Note: To register this class use: kryo.register(java.util.HashSet.class);

如果我明确调用Registrar.RegisterClass(this, HashSet.class);，一切都会顺利进行。但是，一旦我们开始使用多种类型的容器实现更高级的类，这可能会很烦人。

难道我做错了什么？

4

1 回答 1

1

如何使用kryo 绑定注释：

public class QueryResults {

    @CollectionSerializer.BindCollection(
         elementClass = QueryResults.class,
         elementSerializer = DefaultSerializers.StringSerializer.class) 
    protected Set<String> resultList = new HashSet<String>();

    ...
}

还要检查一组额外的 kryo 序列化器。

于 2015-09-16T12:02:40.617 回答