java - Kryonet-如何在班级内注册班级?

原文 标签 java serialization network-programming kryonet

我有以下课程:

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);
            }
        }
    }
}

由于它包含一个容器,所以在尝试序列化QueryResults之前,这个方法一直很有效,在本例中是aHashSet(我们也尝试了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);,那么一切工作都很顺利。然而,一旦我们开始使用许多类型的容器实现更高级的类,这可能会很烦人。
我做错什么了吗?

最佳答案

使用kryo bind annotations如何:

public class QueryResults {

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

    ...
}

还要检查一组additional kryo serialisers

相关文章:

linux - 选择系统调用在n / w应用程序中无限期挂起。

java - 最佳的数据结构,用于存储子网以使IP地址与子网匹配

c++ - 如何编写一个监听网络流量的程序? (即Wireshark)[重复]

java - 在Java中将子类的创建限制为其父(或其他)类

java - 从URL构建XML对象时获取文件的过早结尾

c++ - 谷物序列化

java - 使用GSON将Java接口转换为JSON字符串而不将序列化封装在JSON对象中?

java - 错误无法在同一包中找到带有接口的符号

java - 分组时间更快的方法

linux - 序列化打印方法