3

I would like to use Kryo to (de-)serialize objects and send/receive them via JMS.

The problem I'm having is that both sides, sender and receiver, must register the classes with the same ID.

Kryo has a method register (Class type, int id) that I use. Unfortunately id is an int (as compared to long serialVersionUID used by the Serializable interface). It would be nice if I could use serialVersionUID to register classes.

How do you guys use Kryo over the network?

4

1 回答 1

4

您不必显式注册要使用 Kryo 序列化的每个类。注册课程的主要好处是:

  • 性能:当 Kryo 第一次看到一个类时,它会生成一个 ID,并将这个 ID 与类名一起发送到序列化流中。下一次,Kryo 只发送 ID,不发送名称。如果类是显式注册的,则 ID 是已知的,并且 Kryo 永远不会发送类的名称:您在输出流中获得了一些字节
  • 一些“安全性”:如果您设置了“需要注册”标志,Kryo 将不会发送它不知道的课程。然后,您可以过滤通过网络发送的数据

但是,当您注册课程时,您必须在各处以相同的顺序注册完全相同的课程。这并不总是可能的。

在您的情况下,JMS 规范没有定义任何关于类的序列化的内容。这将取决于您使用的实现。如果你想要一些可移植的东西,你可以在应用层做到这一点:

  • 使用 Kryo 将您的类序列化为字节数组
  • 使用BytesMessage通过 JMS 发送此字节数组
  • 在您MessageListener使用 Kryo 反序列化消息时

由于您可以控制谁序列化/反序列化,您可以在此处注册您使用的类,或者让 Kryo 自己生成 ID

ActiveMQ 不支持自定义序列化挂钩。您不能插入自己的序列化实现,因此不能告诉 ActiveMQ 在发送 ObjectMessage 时使用 Kryo(请参阅ActiveMQObjectMessage)。您必须使用此 BytesMessage。也许其他 JMS 提供者提供了这样的功能(JMS 只是一个 API 规范,它没有定义应该如何发送/序列化消息,只有 API 可访问)

于 2016-03-31T17:29:54.203 回答