Java中 TCP 使用 ProtoBuf 进行序列化请求服务器 返回消息解 码 参 靠 使 用 Base 128 Varints，请写一个请求服务器的示例

当然，我可以为您提供一个使用Java中的TCP和ProtoBuf进行序列化请求服务器并使用Base 128 Varints解码返回消息的示例。以下是一个简单的示例代码：

import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.google.protobuf.MessageLite;
import com.google.protobuf.Parser;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class TCPClient {
    private static final String SERVER_IP = "127.0.0.1";
    private static final int SERVER_PORT = 8080;

    public static void main(String[] args) {
        // 创建请求消息
        PersonProto.Person person = PersonProto.Person.newBuilder()
                .setId(123)
                .setName("John Doe")
                .setEmail("johndoe@example.com")
                .build();

        // 序列化请求消息
        byte[] requestBytes = person.toByteArray();

        try (Socket socket = new Socket(SERVER_IP, SERVER_PORT)) {
            // 发送请求消息
            DataOutputStream out = new DataOutputStream(socket.getOutputStream());
            out.writeInt(requestBytes.length);
            out.write(requestBytes);
            out.flush();

            // 接收并解码返回消息
            DataInputStream in = new DataInputStream(socket.getInputStream());
            int responseLength = in.readInt();
            byte[] responseBytes = new byte[responseLength];
            in.readFully(responseBytes);

            PersonProto.Person responsePerson = decodeResponse(responseBytes, PersonProto.Person.parser());
            System.out.println("Received response: " + responsePerson);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private static <T extends MessageLite> T decodeResponse(byte[] responseBytes, Parser<T> parser)
            throws InvalidProtocolBufferException {
        // 使用Base 128 Varints解码返回消息
        ByteString byteString = ByteString.copyFrom(responseBytes);
        return parser.parseFrom(byteString);
    }
}

请确保您已经导入了Google的protobuf库，并且已经定义了您的Person消息类型（示例中使用名为PersonProto的Proto文件）。您可以根据自己的需求进行相应的修改。