FlatBuffers BufferHasIdentifier 返回 false

Question

我正在尝试通过带有 Flatbuffers 的 TCP 传输数据，服务器是 java，但客户端是 C#，这使得它变得非常复杂。

我使用的架构是：

namespace NetObjects;

union NetParameters { NetLogin, NetRegister }

table NetMessage {
  parameters:NetParameters;
}

table NetLogin{
    id: int;
    email:string;
    password:string;
}

table NetRegister{
    id: int;
    email:string;
    password:string;
}

root_type NetMessage;
file_identifier "MESG";

我如何发送它 c#:

 FlatBufferBuilder fbb = new FlatBufferBuilder(1);

            String buffer = "EMAILCHE";
            StringOffset id = fbb.CreateString(buffer);
            StringOffset idd = fbb.CreateString("PasswordO?");

            NetLogin.StartNetLogin(fbb);
            NetLogin.AddEmail(fbb, id);
            NetLogin.AddPassword(fbb, idd);
            Offset<NetLogin> offset = NetLogin.EndNetLogin(fbb);

            NetMessage.StartNetMessage(fbb);

            NetMessage.AddParametersType(fbb, NetParameters.NetRegister);
            NetMessage.AddParameters(fbb, offset.Value);

            Offset<NetMessage> par = NetMessage.EndNetMessage(fbb);

            NetMessage.FinishNetMessageBuffer(fbb, par);

            _socket.Send(fbb.DataBuffer.Data, 0, fbb.DataBuffer.Data.Length, SocketFlags.None);

我是如何收到它的 java:

DataInputStream in = new DataInputStream(new BufferedInputStream(clientSocket.getInputStream()));
try (ByteArrayOutputStream os = new ByteArrayOutputStream())
                {
                    byte[] buffer = new byte[0xFFFF];

                    for (int len; (len = in.read(buffer)) != -1;) {
                        os.write(buffer, 0, len);
                        os.flush();
                        Handle(os.toByteArray());
                        System.out.println("Step: " + 4);
                    }
                }

句柄：

public void Handle(byte[] bytes){

        ByteBuffer bff = ByteBuffer.wrap(bytes);

        NetMessage.NetMessageBufferHasIdentifier(bff); // ALWAYS FALSE IS RETURNED

        NetMessage lg = NetMessage.getRootAsNetMessage(bff);

        System.out.println(lg.parametersType()); // 0 is returned
}

Answer 1

_socket.Send(fbb.DataBuffer.Data, fbb.Offset, fbb.DataBuffer.Data.Length,  SocketFlags.None);