(client) feat: Implement ProtoBuf and gRPC Client (#25)

Client/Assets/Plugins/Google.Protobuf.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: 58793fbd79d5dc64fb809643ce24f665

Client/Assets/Plugins/Grpc.Core.Api.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: b1e08ff72cdd6064883254a020cad051

Client/Assets/Plugins/Grpc.Net.Client.Web.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: d7e4bcae5efb0b14bad366d9e2cbfc3d

Client/Assets/Plugins/Grpc.Net.Client.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: c61f603b1eefa51489d220166ce921ba

Client/Assets/Plugins/Grpc.Net.Common.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: 992230fc9ae81744aa9c6d6f1998273f

Client/Assets/Plugins/Microsoft.Extensions.DependencyInjection.Abstractions.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: b719d2506760e4e43954921863684f40

Client/Assets/Plugins/Microsoft.Extensions.Logging.Abstractions.dll.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: 081ac1838dc3211419aad66a1ea6a883

Client/Assets/Scenes/Test.unity

@@ -303,50 +303,6 @@ Transform:
   - {fileID: 9462743}
   m_Father: {fileID: 0}
   m_LocalEulerAnglesHint: {x: 0, y: 0, z: 0}
---- !u!1 &912467177
-GameObject:
-  m_ObjectHideFlags: 0
-  m_CorrespondingSourceObject: {fileID: 0}
-  m_PrefabInstance: {fileID: 0}
-  m_PrefabAsset: {fileID: 0}
-  serializedVersion: 6
-  m_Component:
-  - component: {fileID: 912467178}
-  - component: {fileID: 912467179}
-  m_Layer: 0
-  m_Name: NetworkConnectionTest
-  m_TagString: Untagged
-  m_Icon: {fileID: 0}
-  m_NavMeshLayer: 0
-  m_StaticEditorFlags: 0
-  m_IsActive: 0
---- !u!4 &912467178
-Transform:
-  m_ObjectHideFlags: 0
-  m_CorrespondingSourceObject: {fileID: 0}
-  m_PrefabInstance: {fileID: 0}
-  m_PrefabAsset: {fileID: 0}
-  m_GameObject: {fileID: 912467177}
-  serializedVersion: 2
-  m_LocalRotation: {x: 0, y: 0, z: 0, w: 1}
-  m_LocalPosition: {x: 0, y: 0, z: 0}
-  m_LocalScale: {x: 1, y: 1, z: 1}
-  m_ConstrainProportionsScale: 0
-  m_Children: []
-  m_Father: {fileID: 0}
-  m_LocalEulerAnglesHint: {x: 0, y: 0, z: 0}
---- !u!114 &912467179
-MonoBehaviour:
-  m_ObjectHideFlags: 0
-  m_CorrespondingSourceObject: {fileID: 0}
-  m_PrefabInstance: {fileID: 0}
-  m_PrefabAsset: {fileID: 0}
-  m_GameObject: {fileID: 912467177}
-  m_Enabled: 1
-  m_EditorHideFlags: 0
-  m_Script: {fileID: 11500000, guid: 289a7efc822fe7347adfbf218522e8a2, type: 3}
-  m_Name: 
-  m_EditorClassIdentifier: 
 --- !u!1 &1057087086
 GameObject:
   m_ObjectHideFlags: 0
@@ -479,7 +435,6 @@ Transform:
   serializedVersion: 2
   m_LocalRotation: {x: 0, y: 0, z: 0, w: 1}
   m_LocalPosition: {x: 0, y: 0, z: -10}
-  m_LocalPosition: {x: 0, y: 0, z: -10}
   m_LocalScale: {x: 1, y: 1, z: 1}
   m_ConstrainProportionsScale: 0
   m_Children: []
@@ -696,6 +651,50 @@ MonoBehaviour:
   m_Script: {fileID: 11500000, guid: 757576bb4354ac54da09868e1be02eec, type: 3}
   m_Name: 
   m_EditorClassIdentifier: 
+--- !u!1 &2104915506
+GameObject:
+  m_ObjectHideFlags: 0
+  m_CorrespondingSourceObject: {fileID: 0}
+  m_PrefabInstance: {fileID: 0}
+  m_PrefabAsset: {fileID: 0}
+  serializedVersion: 6
+  m_Component:
+  - component: {fileID: 2104915508}
+  - component: {fileID: 2104915507}
+  m_Layer: 0
+  m_Name: GrpcClientTest
+  m_TagString: Untagged
+  m_Icon: {fileID: 0}
+  m_NavMeshLayer: 0
+  m_StaticEditorFlags: 0
+  m_IsActive: 1
+--- !u!114 &2104915507
+MonoBehaviour:
+  m_ObjectHideFlags: 0
+  m_CorrespondingSourceObject: {fileID: 0}
+  m_PrefabInstance: {fileID: 0}
+  m_PrefabAsset: {fileID: 0}
+  m_GameObject: {fileID: 2104915506}
+  m_Enabled: 1
+  m_EditorHideFlags: 0
+  m_Script: {fileID: 11500000, guid: 98c1b145899d4d97bd981b177b5c45a9, type: 3}
+  m_Name: 
+  m_EditorClassIdentifier: 
+--- !u!4 &2104915508
+Transform:
+  m_ObjectHideFlags: 0
+  m_CorrespondingSourceObject: {fileID: 0}
+  m_PrefabInstance: {fileID: 0}
+  m_PrefabAsset: {fileID: 0}
+  m_GameObject: {fileID: 2104915506}
+  serializedVersion: 2
+  m_LocalRotation: {x: 0, y: 0, z: 0, w: 1}
+  m_LocalPosition: {x: 0, y: 0, z: -0}
+  m_LocalScale: {x: 1, y: 1, z: 1}
+  m_ConstrainProportionsScale: 0
+  m_Children: []
+  m_Father: {fileID: 0}
+  m_LocalEulerAnglesHint: {x: 0, y: 0, z: 0}
 --- !u!1660057539 &9223372036854775807
 SceneRoots:
   m_ObjectHideFlags: 0
@@ -703,6 +702,5 @@ SceneRoots:
   - {fileID: 1371068282}
   - {fileID: 1057087090}
   - {fileID: 613797070}
-  - {fileID: 912467178}
-  - {fileID: 1485465861}
   - {fileID: 1485465861}
+  - {fileID: 2104915508}

Client/Assets/Scripts/Network.meta

@@ -1,8 +1,3 @@
 fileFormatVersion: 2
-guid: 36bb272d9a70ff347965919811a887de
-folderAsset: yes
-DefaultImporter:
-  externalObjects: {}
-  userData: 
-  assetBundleName: 
-  assetBundleVariant: 
+guid: 178450a3675642d799764a426bcb236f
+timeCreated: 1752480692

Client/Assets/Scripts/Network/GrpcClient.cs

@@ -0,0 +1,48 @@
+using System.Net.Http;
+using System.Threading.Tasks;
+using Grpc.Net.Client;
+using Grpc.Net.Client.Web;
+using Protocol;
+using Utils;
+
+namespace Network
+{
+    public class GrpcClient : Singleton<GrpcClient>
+    {
+        // The address must adopt HTTP.
+        private const string ServerAddress = "http://127.0.0.1:12345";
+
+        private readonly GrpcChannel _channel;
+        private readonly GameService.GameServiceClient _game;
+        private readonly GeneralService.GeneralServiceClient _general;
+
+        public GrpcClient()
+        {
+            var httpHandler = new GrpcWebHandler(GrpcWebMode.GrpcWeb, new HttpClientHandler());
+            var channelOptions = new GrpcChannelOptions
+            {
+                HttpHandler = httpHandler
+            };
+
+            _channel = GrpcChannel.ForAddress(ServerAddress, channelOptions);
+
+            _general = new GeneralService.GeneralServiceClient(_channel);
+            _game = new GameService.GameServiceClient(_channel);
+        }
+
+        ~GrpcClient()
+        {
+            _channel.ShutdownAsync().Wait();
+        }
+
+        public async Task<ServerInfo> GetServerInfo()
+        {
+            return await _general.GetServerInfoAsync(new Empty());
+        }
+
+        public async Task<LoginResponse> Login(string username, string password)
+        {
+            return await _game.LoginAsync(new LoginRequest { Username = username, Password = password });
+        }
+    }
+}

Client/Assets/Scripts/Network/GrpcClient.cs.meta

@@ -0,0 +1,3 @@
+fileFormatVersion: 2
+guid: bd54dd152e0e4bbda802e9aa04078197
+timeCreated: 1752480707

Client/Assets/Scripts/Network/UnityTcpClient.cs

@@ -1,152 +0,0 @@
-using System;
-using System.Net.Sockets;
-using System.Text;
-using System.Threading.Tasks;
-using UnityEngine;
-using Utils;
-
-namespace Network
-{
-    public class UnityTcpClient : Singleton<UnityTcpClient>
-    {
-        private TcpClient _tcpClient;
-        public bool IsConnected => _tcpClient?.Connected ?? false;
-
-        /// <summary>
-        ///     尝试连接到指定的地址和端口
-        /// </summary>
-        /// <param name="address">服务器地址</param>
-        /// <param name="port">端口号</param>
-        /// <returns>连接是否成功</returns>
-        public async Task<bool> Connect(string address, int port)
-        {
-            if (IsConnected)
-            {
-                Debug.LogWarning("Already connected to a server.");
-                return true;
-            }
-
-            try
-            {
-                // 创建一个新的 TcpClient 实例
-                _tcpClient = new TcpClient();
-
-                // 尝试连接到指定的地址和端口
-                await _tcpClient.ConnectAsync(address, port);
-
-                // 如果连接成功
-                if (IsConnected)
-                {
-                    Debug.Log($"Successfully connected to server at {address}:{port}");
-                    return true;
-                }
-            }
-            catch (SocketException ex)
-            {
-                Debug.LogError($"Failed to connect to server at {address}:{port}. Error: {ex.Message}");
-            }
-            catch (Exception ex)
-            {
-                Debug.LogError($"An unexpected error occurred: {ex.Message}");
-            }
-
-            // 如果发生任何错误或连接失败
-            Disconnect();
-            return false;
-        }
-
-        /// <summary>
-        ///     断开与服务器的连接
-        /// </summary>
-        public void Disconnect()
-        {
-            if (!IsConnected)
-            {
-                Debug.LogWarning("Not currently connected to any server.");
-                return;
-            }
-
-            try
-            {
-                // 关闭 TcpClient 连接
-                _tcpClient?.Close();
-
-                Debug.Log("Disconnected from the server.");
-            }
-            catch (Exception ex)
-            {
-                Debug.LogError($"Error while disconnecting: {ex.Message}");
-            }
-        }
-
-        /// <summary>
-        ///     发送数据到服务器
-        /// </summary>
-        /// <param name="message">要发送的消息</param>
-        public async Task Send(string message)
-        {
-            if (!IsConnected)
-            {
-                Debug.LogError("Cannot send data. Not connected to any server.");
-                return;
-            }
-
-            try
-            {
-                // 获取网络流
-                var stream = _tcpClient.GetStream();
-
-                // 将消息转换为字节数组
-                var data = Encoding.UTF8.GetBytes(message);
-
-                // 发送数据
-                await stream.WriteAsync(data, 0, data.Length);
-
-                Debug.Log($"Sent message to server: {message}");
-            }
-            catch (Exception ex)
-            {
-                Debug.LogError($"Error while sending: {ex.Message}");
-            }
-        }
-
-        /// <summary>
-        ///     接收来自服务器的数据
-        /// </summary>
-        /// <returns>接收到的消息</returns>
-        public async Task<string> Receive()
-        {
-            if (!IsConnected)
-            {
-                Debug.LogError("Cannot receive data. Not connected to any server.");
-                return null;
-            }
-
-            try
-            {
-                // 获取网络流
-                var stream = _tcpClient.GetStream();
-
-                // 检查是否有可用数据
-                if (stream.DataAvailable)
-                {
-                    // 读取数据
-                    var buffer = new byte[1024];
-                    var bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length);
-
-                    // 将字节数组转换为字符串
-                    var message = Encoding.UTF8.GetString(buffer, 0, bytesRead);
-
-                    Debug.Log($"Received message from server: {message}");
-                    return message;
-                }
-            }
-            catch (Exception ex)
-            {
-                Debug.LogError($"Error while receiving: {ex.Message}");
-            }
-
-            return null;
-        }
-    }
-}

Client/Assets/Scripts/Network/UnityTcpClient.cs.meta

@@ -1,2 +0,0 @@
-fileFormatVersion: 2
-guid: 3cfed6461b8d6714bbc44fdac509c880

Client/Assets/Scripts/Protocol.meta

@@ -0,0 +1,8 @@
+fileFormatVersion: 2
+guid: 0aabb2c54fff484382fda9415503276b
+folderAsset: yes
+DefaultImporter:
+  externalObjects: {}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

Client/Assets/Scripts/Protocol/Message.cs.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: 8afd87f1b9f31bb44be8c224d8fc7270

Client/Assets/Scripts/Protocol/MessageGrpc.cs

@@ -0,0 +1,387 @@
+// <auto-generated>
+//     Generated by the protocol buffer compiler.  DO NOT EDIT!
+//     source: message.proto
+// </auto-generated>
+#pragma warning disable 0414, 1591, 8981, 0612
+#region Designer generated code
+
+using grpc = global::Grpc.Core;
+
+namespace Protocol {
+  public static partial class GeneralService
+  {
+    static readonly string __ServiceName = "protocol.GeneralService";
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static void __Helper_SerializeMessage(global::Google.Protobuf.IMessage message, grpc::SerializationContext context)
+    {
+      #if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
+      if (message is global::Google.Protobuf.IBufferMessage)
+      {
+        context.SetPayloadLength(message.CalculateSize());
+        global::Google.Protobuf.MessageExtensions.WriteTo(message, context.GetBufferWriter());
+        context.Complete();
+        return;
+      }
+      #endif
+      context.Complete(global::Google.Protobuf.MessageExtensions.ToByteArray(message));
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static class __Helper_MessageCache<T>
+    {
+      public static readonly bool IsBufferMessage = global::System.Reflection.IntrospectionExtensions.GetTypeInfo(typeof(global::Google.Protobuf.IBufferMessage)).IsAssignableFrom(typeof(T));
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static T __Helper_DeserializeMessage<T>(grpc::DeserializationContext context, global::Google.Protobuf.MessageParser<T> parser) where T : global::Google.Protobuf.IMessage<T>
+    {
+      #if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
+      if (__Helper_MessageCache<T>.IsBufferMessage)
+      {
+        return parser.ParseFrom(context.PayloadAsReadOnlySequence());
+      }
+      #endif
+      return parser.ParseFrom(context.PayloadAsNewBuffer());
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.Empty> __Marshaller_protocol_Empty = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.Empty.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.ServerInfo> __Marshaller_protocol_ServerInfo = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.ServerInfo.Parser));
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Method<global::Protocol.Empty, global::Protocol.ServerInfo> __Method_GetServerInfo = new grpc::Method<global::Protocol.Empty, global::Protocol.ServerInfo>(
+        grpc::MethodType.Unary,
+        __ServiceName,
+        "GetServerInfo",
+        __Marshaller_protocol_Empty,
+        __Marshaller_protocol_ServerInfo);
+
+    /// <summary>Service descriptor</summary>
+    public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor
+    {
+      get { return global::Protocol.MessageReflection.Descriptor.Services[0]; }
+    }
+
+    /// <summary>Base class for server-side implementations of GeneralService</summary>
+    [grpc::BindServiceMethod(typeof(GeneralService), "BindService")]
+    public abstract partial class GeneralServiceBase
+    {
+      /// <summary>
+      /// Get server info from server.
+      ///
+      /// This parameter actually doesn't accept any arguments,
+      /// but it is still required owing to Protobuf grammar.
+      /// </summary>
+      /// <param name="request">The request received from the client.</param>
+      /// <param name="context">The context of the server-side call handler being invoked.</param>
+      /// <returns>The response to send back to the client (wrapped by a task).</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::System.Threading.Tasks.Task<global::Protocol.ServerInfo> GetServerInfo(global::Protocol.Empty request, grpc::ServerCallContext context)
+      {
+        throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
+      }
+
+    }
+
+    /// <summary>Client for GeneralService</summary>
+    public partial class GeneralServiceClient : grpc::ClientBase<GeneralServiceClient>
+    {
+      /// <summary>Creates a new client for GeneralService</summary>
+      /// <param name="channel">The channel to use to make remote calls.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public GeneralServiceClient(grpc::ChannelBase channel) : base(channel)
+      {
+      }
+      /// <summary>Creates a new client for GeneralService that uses a custom <c>CallInvoker</c>.</summary>
+      /// <param name="callInvoker">The callInvoker to use to make remote calls.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public GeneralServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker)
+      {
+      }
+      /// <summary>Protected parameterless constructor to allow creation of test doubles.</summary>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected GeneralServiceClient() : base()
+      {
+      }
+      /// <summary>Protected constructor to allow creation of configured clients.</summary>
+      /// <param name="configuration">The client configuration.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected GeneralServiceClient(ClientBaseConfiguration configuration) : base(configuration)
+      {
+      }
+
+      /// <summary>
+      /// Get server info from server.
+      ///
+      /// This parameter actually doesn't accept any arguments,
+      /// but it is still required owing to Protobuf grammar.
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
+      /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param>
+      /// <param name="cancellationToken">An optional token for canceling the call.</param>
+      /// <returns>The response received from the server.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.ServerInfo GetServerInfo(global::Protocol.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return GetServerInfo(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      /// <summary>
+      /// Get server info from server.
+      ///
+      /// This parameter actually doesn't accept any arguments,
+      /// but it is still required owing to Protobuf grammar.
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="options">The options for the call.</param>
+      /// <returns>The response received from the server.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.ServerInfo GetServerInfo(global::Protocol.Empty request, grpc::CallOptions options)
+      {
+        return CallInvoker.BlockingUnaryCall(__Method_GetServerInfo, null, options, request);
+      }
+      /// <summary>
+      /// Get server info from server.
+      ///
+      /// This parameter actually doesn't accept any arguments,
+      /// but it is still required owing to Protobuf grammar.
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param>
+      /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param>
+      /// <param name="cancellationToken">An optional token for canceling the call.</param>
+      /// <returns>The call object.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.ServerInfo> GetServerInfoAsync(global::Protocol.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return GetServerInfoAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      /// <summary>
+      /// Get server info from server.
+      ///
+      /// This parameter actually doesn't accept any arguments,
+      /// but it is still required owing to Protobuf grammar.
+      /// </summary>
+      /// <param name="request">The request to send to the server.</param>
+      /// <param name="options">The options for the call.</param>
+      /// <returns>The call object.</returns>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.ServerInfo> GetServerInfoAsync(global::Protocol.Empty request, grpc::CallOptions options)
+      {
+        return CallInvoker.AsyncUnaryCall(__Method_GetServerInfo, null, options, request);
+      }
+      /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected override GeneralServiceClient NewInstance(ClientBaseConfiguration configuration)
+      {
+        return new GeneralServiceClient(configuration);
+      }
+    }
+
+    /// <summary>Creates service definition that can be registered with a server</summary>
+    /// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    public static grpc::ServerServiceDefinition BindService(GeneralServiceBase serviceImpl)
+    {
+      return grpc::ServerServiceDefinition.CreateBuilder()
+          .AddMethod(__Method_GetServerInfo, serviceImpl.GetServerInfo).Build();
+    }
+
+    /// <summary>Register service method with a service binder with or without implementation. Useful when customizing the service binding logic.
+    /// Note: this method is part of an experimental API that can change or be removed without any prior notice.</summary>
+    /// <param name="serviceBinder">Service methods will be bound by calling <c>AddMethod</c> on this object.</param>
+    /// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    public static void BindService(grpc::ServiceBinderBase serviceBinder, GeneralServiceBase serviceImpl)
+    {
+      serviceBinder.AddMethod(__Method_GetServerInfo, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::Protocol.Empty, global::Protocol.ServerInfo>(serviceImpl.GetServerInfo));
+    }
+
+  }
+  public static partial class GameService
+  {
+    static readonly string __ServiceName = "protocol.GameService";
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static void __Helper_SerializeMessage(global::Google.Protobuf.IMessage message, grpc::SerializationContext context)
+    {
+      #if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
+      if (message is global::Google.Protobuf.IBufferMessage)
+      {
+        context.SetPayloadLength(message.CalculateSize());
+        global::Google.Protobuf.MessageExtensions.WriteTo(message, context.GetBufferWriter());
+        context.Complete();
+        return;
+      }
+      #endif
+      context.Complete(global::Google.Protobuf.MessageExtensions.ToByteArray(message));
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static class __Helper_MessageCache<T>
+    {
+      public static readonly bool IsBufferMessage = global::System.Reflection.IntrospectionExtensions.GetTypeInfo(typeof(global::Google.Protobuf.IBufferMessage)).IsAssignableFrom(typeof(T));
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static T __Helper_DeserializeMessage<T>(grpc::DeserializationContext context, global::Google.Protobuf.MessageParser<T> parser) where T : global::Google.Protobuf.IMessage<T>
+    {
+      #if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
+      if (__Helper_MessageCache<T>.IsBufferMessage)
+      {
+        return parser.ParseFrom(context.PayloadAsReadOnlySequence());
+      }
+      #endif
+      return parser.ParseFrom(context.PayloadAsNewBuffer());
+    }
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.LoginRequest> __Marshaller_protocol_LoginRequest = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.LoginRequest.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.LoginResponse> __Marshaller_protocol_LoginResponse = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.LoginResponse.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.SignupRequest> __Marshaller_protocol_SignupRequest = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.SignupRequest.Parser));
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Marshaller<global::Protocol.SignupResponse> __Marshaller_protocol_SignupResponse = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Protocol.SignupResponse.Parser));
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Method<global::Protocol.LoginRequest, global::Protocol.LoginResponse> __Method_Login = new grpc::Method<global::Protocol.LoginRequest, global::Protocol.LoginResponse>(
+        grpc::MethodType.Unary,
+        __ServiceName,
+        "Login",
+        __Marshaller_protocol_LoginRequest,
+        __Marshaller_protocol_LoginResponse);
+
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    static readonly grpc::Method<global::Protocol.SignupRequest, global::Protocol.SignupResponse> __Method_Signup = new grpc::Method<global::Protocol.SignupRequest, global::Protocol.SignupResponse>(
+        grpc::MethodType.Unary,
+        __ServiceName,
+        "Signup",
+        __Marshaller_protocol_SignupRequest,
+        __Marshaller_protocol_SignupResponse);
+
+    /// <summary>Service descriptor</summary>
+    public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor
+    {
+      get { return global::Protocol.MessageReflection.Descriptor.Services[1]; }
+    }
+
+    /// <summary>Base class for server-side implementations of GameService</summary>
+    [grpc::BindServiceMethod(typeof(GameService), "BindService")]
+    public abstract partial class GameServiceBase
+    {
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::System.Threading.Tasks.Task<global::Protocol.LoginResponse> Login(global::Protocol.LoginRequest request, grpc::ServerCallContext context)
+      {
+        throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
+      }
+
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::System.Threading.Tasks.Task<global::Protocol.SignupResponse> Signup(global::Protocol.SignupRequest request, grpc::ServerCallContext context)
+      {
+        throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
+      }
+
+    }
+
+    /// <summary>Client for GameService</summary>
+    public partial class GameServiceClient : grpc::ClientBase<GameServiceClient>
+    {
+      /// <summary>Creates a new client for GameService</summary>
+      /// <param name="channel">The channel to use to make remote calls.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public GameServiceClient(grpc::ChannelBase channel) : base(channel)
+      {
+      }
+      /// <summary>Creates a new client for GameService that uses a custom <c>CallInvoker</c>.</summary>
+      /// <param name="callInvoker">The callInvoker to use to make remote calls.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public GameServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker)
+      {
+      }
+      /// <summary>Protected parameterless constructor to allow creation of test doubles.</summary>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected GameServiceClient() : base()
+      {
+      }
+      /// <summary>Protected constructor to allow creation of configured clients.</summary>
+      /// <param name="configuration">The client configuration.</param>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected GameServiceClient(ClientBaseConfiguration configuration) : base(configuration)
+      {
+      }
+
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.LoginResponse Login(global::Protocol.LoginRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return Login(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.LoginResponse Login(global::Protocol.LoginRequest request, grpc::CallOptions options)
+      {
+        return CallInvoker.BlockingUnaryCall(__Method_Login, null, options, request);
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.LoginResponse> LoginAsync(global::Protocol.LoginRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return LoginAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.LoginResponse> LoginAsync(global::Protocol.LoginRequest request, grpc::CallOptions options)
+      {
+        return CallInvoker.AsyncUnaryCall(__Method_Login, null, options, request);
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.SignupResponse Signup(global::Protocol.SignupRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return Signup(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual global::Protocol.SignupResponse Signup(global::Protocol.SignupRequest request, grpc::CallOptions options)
+      {
+        return CallInvoker.BlockingUnaryCall(__Method_Signup, null, options, request);
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.SignupResponse> SignupAsync(global::Protocol.SignupRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
+      {
+        return SignupAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
+      }
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      public virtual grpc::AsyncUnaryCall<global::Protocol.SignupResponse> SignupAsync(global::Protocol.SignupRequest request, grpc::CallOptions options)
+      {
+        return CallInvoker.AsyncUnaryCall(__Method_Signup, null, options, request);
+      }
+      /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary>
+      [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+      protected override GameServiceClient NewInstance(ClientBaseConfiguration configuration)
+      {
+        return new GameServiceClient(configuration);
+      }
+    }
+
+    /// <summary>Creates service definition that can be registered with a server</summary>
+    /// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    public static grpc::ServerServiceDefinition BindService(GameServiceBase serviceImpl)
+    {
+      return grpc::ServerServiceDefinition.CreateBuilder()
+          .AddMethod(__Method_Login, serviceImpl.Login)
+          .AddMethod(__Method_Signup, serviceImpl.Signup).Build();
+    }
+
+    /// <summary>Register service method with a service binder with or without implementation. Useful when customizing the service binding logic.
+    /// Note: this method is part of an experimental API that can change or be removed without any prior notice.</summary>
+    /// <param name="serviceBinder">Service methods will be bound by calling <c>AddMethod</c> on this object.</param>
+    /// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
+    [global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
+    public static void BindService(grpc::ServiceBinderBase serviceBinder, GameServiceBase serviceImpl)
+    {
+      serviceBinder.AddMethod(__Method_Login, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::Protocol.LoginRequest, global::Protocol.LoginResponse>(serviceImpl.Login));
+      serviceBinder.AddMethod(__Method_Signup, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::Protocol.SignupRequest, global::Protocol.SignupResponse>(serviceImpl.Signup));
+    }
+
+  }
+}
+#endregion

Client/Assets/Scripts/Protocol/MessageGrpc.cs.meta

@@ -0,0 +1,2 @@
+fileFormatVersion: 2
+guid: f2f787a1d94a6ae48b5586f040f0cf1b

Client/Assets/Scripts/Test/GrpcClientTest.cs

@@ -0,0 +1,19 @@
+using Network;
+using UnityEngine;
+
+namespace Test
+{
+    public class GrpcClientTest : MonoBehaviour
+    {
+        private async void Start()
+        {
+            var serverInfo = await GrpcClient.Instance.GetServerInfo();
+
+            Debug.Log($"Received info from server: {serverInfo}");
+
+            var loginResult = await GrpcClient.Instance.Login("野兽先辈", "114514");
+
+            Debug.Log($"Received login result: {loginResult.Result}");
+        }
+    }
+}

Client/Assets/Scripts/Test/GrpcClientTest.cs.meta

@@ -0,0 +1,3 @@
+fileFormatVersion: 2
+guid: 98c1b145899d4d97bd981b177b5c45a9
+timeCreated: 1752478138

Client/Assets/Scripts/Test/NetworkConnectionTest.cs

@@ -1,26 +0,0 @@
-using System.Threading.Tasks;
-using Network;
-using UnityEngine;
-
-namespace Test
-{
-    public class NetworkConnectionTest : MonoBehaviour
-    {
-        private async void Start()
-        {
-            await BasicTest();
-        }
-
-        private static async Task BasicTest()
-        {
-            var result = await UnityTcpClient.Instance.Connect("127.0.0.1", 12345);
-            if (result) Debug.Log("Connected to server!");
-            else Debug.LogError("Failed to connect to server!");
-
-            string buffer = null;
-            while (buffer is null) buffer = await UnityTcpClient.Instance.Receive();
-
-            Debug.Log($"Received contents: {buffer}");
-        }
-    }
-}

Client/Assets/Scripts/Test/NetworkConnectionTest.cs.meta

@@ -1,2 +0,0 @@
-fileFormatVersion: 2
-guid: 289a7efc822fe7347adfbf218522e8a2