将Java的字节数组转换为Go的结构体

在代理驱动的系统中，Java 生产者将 `messagejava` 对象转换为字节数组并发送到代理，而 Go 消费者使用 `convertafterreceiving` 方法从代理读取字节数组并将其解码为 `messagego` 结构。然而，由于 Java 和 Go 使用不同的编码方式，消费者无法正确解码字节数组，导致“编码的无符号整数超出范围”错误。

我有一个围绕代理设计的系统，我的生产者使用 java，消费者使用 go。

我使用 apache-pulsar 作为我的代理

java - 生产者

messagejava类在发送到pulsar之前被转换为字节数组：messagejava类的对象调用同一个类中定义的getbytes()方法将其转换为字节[ ] 然后这个数组被发送到apache-pulsar

class messagejava {
  string   id;
  int      entityid;
  date     timestamp;

  public byte[] getbytes() throws exception{
    bytearrayoutputstream bos = new bytearrayoutputstream();
    objectoutputstream oos = new objectoutputstream(bos);
    oos.writeobject(this);
    oos.flush();
    return bos.tobytearray();
  }
}

我的消费者是用 go 编写的。

go - 消费者

字节数组从 pulsar 读取并使用 convertafterreceiving 方法[定义如下]转换为 messagego 结构，我使用 gob 进行解码：

type MessageGo struct {
    Id            string
    EntityId      int
    Timestamp     time.Time
}

func ConvertAfterReceiving(msg pulsar.Message) *MessageGo {
    payload := msg.Payload()
    messageBytes := bytes.NewBuffer(payload)
    dec := gob.NewDecoder(messageBytes)

    var message MessageGo
    err := dec.Decode(&message)
    if err != nil {
        logging.Log.Error("error occurred in consumer while decoding message:", err)
    }
    return &message
}

问题是我无法解码 byte[] 并将其转换为 messagego 结构。它显示错误编码的无符号整数超出范围

我尝试将 messagejava.entityid 更改为短/长，将 messagego.entityid 更改为 int8/int16/int32/int64/uint8/uint16/uint32/uint64 [所有排列]，但一切都是徒劳的。

解决方案

Java ObjectOutputStream 和 Go Decoder 并不使用相同的语言，即使它们本质上都是由字节组成的；就像“这些词”和“эти слова”都是由线条组成的，但知道其中一个并不会让你知道另一个。

ObjectOutputStream 将对象转换为 Java ObjectInputStream 读取的形式，而 Go Decoder 期望数据采用 Go Encoder 创建的格式。

我们需要一种像 JSON 这样的语言，Java 和 Go 都知道如何使用它。然后，您不必将对象直接序列化为字节，而是将其转换为字符串表示形式，发送该字符串的字节并将 Go 中的该字符串转换为所需的结构。

以上就是《将Java的字节数组转换为Go的结构体》的详细内容，更多关于的资料请关注golang学习网公众号！