- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我想使用 Kryo 来(反)序列化对象并通过 JMS 发送/接收它们。
我遇到的问题是发送方和接收方都必须使用相同的 ID 注册类。
Kryo 有一个我使用的方法 register (Class type, int id)
。不幸的是,id
是一个 int(与 Serializable 接口(interface)使用的 long serialVersionUID
相比)。如果我可以使用 serialVersionUID 来注册类,那就太好了。
你们如何通过网络使用 Kryo?
最佳答案
您不必显式注册要使用 Kryo 序列化的每个类。注册类(class)的主要好处是:
但是,当你注册一个类(class)时,你必须在所有地方以相同的顺序注册完全相同的类(class)。这并不总是可能的。
在您的情况下,JMS 规范没有定义任何关于类序列化的内容。这将取决于您使用的实现。如果你想要一些可移植的东西,你可以在应用层这样做:
MessageListener
中使用 Kryo 反序列化消息因为你可以控制谁序列化/反序列化,你可以在这里注册你使用的类,或者让 Kryo 自己生成 ID
ActiveMQ 不支持自定义序列化 Hook 。您无法插入自己的序列化实现,因此无法告诉 ActiveMQ 在发送 ObjectMessage 时使用 Kryo(请参阅 ActiveMQObjectMessage)。您必须使用此 BytesMessage。也许其他 JMS 提供商提供了这样的功能(JMS 只是一个 API 规范,它没有定义消息应该如何发送/序列化,只有 API 可访问)
关于java - 如何通过 JMS 发送 Kryo 序列化对象?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36272720/
WARN: [kryo] Unable to load class slade.core.Child with kryo's ClassLoader. Retrying with current...
我正在为我的 pojo 类使用 Flink 和自定义 kryo 类。但得到 Caused by: java.lang.NullPointerException at MyTreeSeriali
我需要通过添加两个新参数来修改一个类。这个类是用 Kryo 序列化的。 每次我停止流时,我目前都将与此类相关的信息保存为 RDD。 当我重新启动流时,我会加载我之前保留的信息,并使用它们在我停止和重新
我正在尝试将 kryo 序列化用于: kryo.setRegistrationRequired(true); 我不断收到以下错误消息,说某个类未注册: java.lang.IllegalArgumen
我正在使用 Kryo 进行序列化/反序列化,并且没有事先注册类(我正在研究这一点)。也就是说,在反序列化时,我遇到了异常: 无法使用 kryo 的 ClassLoader 加载类 shell.api.
我发现了两种使用 Kryo 进行读写的通用方法,我在想其中一种是更好还是更差,或者它们是否完全相同。 选项 1 - 使用 kryo 函数 writeClassAndObject (readClassA
我直接使用 Kryo IO 来执行我自己的字符串、长整型和 double 型的低级原始序列化。 我想知道的是,Kryo IO 是否有任何方法可以在读回序列化字节时自动检测它们的原始数据类型? 如果我有
我将 JSON 存储在表中(实际上是 Cassandra 列族),如下所示: ____________________________________________________________
我正在尝试使用 Kryo 序列化某些对象的列表列表(自定义类:List>)。 list2D; // List> which is already produced. Kryo k1 = new Kry
我正在尝试使用 Kryo 库将任何给定对象转换为 byteArray 并存储在数据存储或队列中供以后使用。但是是否可以序列化任何给定的对象,或者只能转换实现可序列化接口(interface)的对象。
实际项目中,我们经常需要使用序列化工具来存储和传输对象。目前用得比较多的序列化工具有:jackson、fastjson、kryo、protostuff、fst 等,本文将简单对比这几款工具序列化和反序
你如何使用 反序列化不可变集合Kryo ?除了我所做的事情之外,我还需要注册一些东西吗? 这是我的示例代码 import com.esotericsoftware.kryo.Kryo import c
在使用带有以下代码的Apache Flink时: DataStream> result = source.window(Time.of(1, TimeUnit.SECONDS)).mapWindow(
我正在尝试从此 link 运行 Chill-Scala 的示例代码 我有两个虚拟案例类 一个是用户 @SerialVersionUID(1) case class User(name :String,
我正在尝试了解以下错误,并且正在客户端 ode 中运行。 org.apache.spark.SparkException: Kryo serialization failed: Buffer ove
我有一段 Spark 代码可以在 Spark 1.3 上运行,但当我将它移至 Spark 1.5.2 时失败(集群升级超出我的控制)。失败如下: Caused by: java.io.NotSeria
通过使用 Kryo 3,每次序列化/反序列化根对象(流)时都会创建一个 Kryo 3 实例。 我想知道我可以使用什么重用概念。 从源代码来看,Kryo 实例可能仅以单线程方式使用,并且由于它使用引用,
我正在尝试使用 kryo 序列化和反序列化为二进制文件。我想我有序列化工作,但我似乎无法反序列化。下面是我正在处理的代码,但最终我想存储一个 byte[] 并稍后再次读取它。该文档仅显示如何使用文件执
我正在寻找 Kryo 自定义序列化和反序列化示例。如何检查Kryo读写函数的正确性。 我写了一些代码来检查,但它返回异常。任何帮助将不胜感激。提前致谢。 import com.esotericsoft
对于个人项目,我必须使用 Kryo-Framework 在 Java 中序列化 Collections.sychronizedMap。我绑定(bind)到该框架,因为还有其他依赖项需要它。我目前的尝试
我是一名优秀的程序员,十分优秀!