使用java通过UDP发送/接收不同的对象

Question

我正在用 Java 编写一个程序，其中两台或多台机器之间使用 UDP 进行通信。我的应用程序将对象序列化后通过网络发送到另一台机器，在那里它将被反序列化并处理。到目前为止我已经成功发送了一种对象。

我的问题是我希望发送者能够发送不同类型的对象，并且接收者能够接收它们并将它们再次转换为适当的类型。然而，由于UDP分配一个字节缓冲区然后将数据接收到缓冲区中，因此不可能强制转换或检测接收到的对象的类型，因为不同的对象具有不同的大小。

有没有一种方法可以让我使用 UDP 发送不同类型的对象，然后在另一端接收它们？ （我在这里不要求代码，只是一些想法）

谢谢

编辑： 我正在寻找发送/接收不同对象类型的最佳方法，而不知道下一个预期对象的类型是什么。假设我有三种对象类型，我希望在任何给定时间收到其中任何一种。 在 Brian 发表评论后，我想到的另一件事是：如何为可变大小的数据类型（如字符串、数组等）设置缓冲区大小。当接收 UDP 数据包时，您必须首先分配一个大小的缓冲区来接收该对象。这在某种程度上与我原来的问题有关。

Answer 1

您序列化的内容（使用 ObjectOutputStream）也可以反序列化（使用 ObjectInputStream）。然后你检索一个对象。如果您通过 UDP、TCP、管道、本地文件或其他方式传输它，它就不起作用。序列化写入OutputStream，反序列化从InputStream读取。

您 myObject.getClass() 来检测您收到的内容。

Answer 2

为什么不将它们包装在具有 Object 类型有效负载的已知类型（Packet）中？然后，您可以反序列化您的Packet并询问生成的有效负载的类型。

Answer 3

基本上，它会反序列化对象，然后执行 instanceof 检查。然而，由于您在使用 UDP 时明确提到了字节缓冲区的问题，我建议看看一个消息传递库，它已经执行了这种字节缓冲区的管理：JGroups

在伪代码中，使用 jgroups 看起来像这样：

JChannel channel = new JChannel("myapp");
Customer c = new Customer("IniTrodeInc.);
Book b = new Book("Twilight");
channel.send(new Message(c));
channel.send(new Message(b));

在接收端

JChannel channel = new JChannel("myapp");
channel.addListener(new Listener(){
 public void onMessage(Message m) {
   if (m.getObject() instanceof Customer) {
     handleNewCustomer((Customer)m.getObject()));
   } else if (m.getObject() instanceof Book) {
     handleNewBook((Book)m.getObject()));
   } else {
     // Ups, we received s.t.h else
   }
 }
});

JGroups 自动执行消息传递通道的抽象，您可以这样做不需要知道这是UDP、TCP还是多播等。JGroups还将处理对等通信，例如向尚未收到消息的对等节点发送消息等。