diff --git a/Client/Assets/Scripts/Network/UnityTcpClient.cs b/Client/Assets/Scripts/Network/UnityTcpClient.cs index 4ba982b..be2977b 100644 --- a/Client/Assets/Scripts/Network/UnityTcpClient.cs +++ b/Client/Assets/Scripts/Network/UnityTcpClient.cs @@ -1,6 +1,7 @@ using System; using System.Net.Sockets; using System.Text; +using System.Threading.Tasks; using UnityEngine; using Utils; @@ -17,7 +18,7 @@ namespace Network /// 服务器地址 /// 端口号 /// 连接是否成功 - public bool Connect(string address, int port) + public async Task Connect(string address, int port) { if (IsConnected) { @@ -31,7 +32,7 @@ namespace Network _tcpClient = new TcpClient(); // 尝试连接到指定的地址和端口 - _tcpClient.Connect(address, port); + await _tcpClient.ConnectAsync(address, port); // 如果连接成功 if (IsConnected) @@ -82,7 +83,7 @@ namespace Network /// 发送数据到服务器 /// /// 要发送的消息 - public void Send(string message) + public async Task Send(string message) { if (!IsConnected) { @@ -99,7 +100,7 @@ namespace Network var data = Encoding.UTF8.GetBytes(message); // 发送数据 - stream.Write(data, 0, data.Length); + await stream.WriteAsync(data, 0, data.Length); Debug.Log($"Sent message to server: {message}"); } @@ -113,7 +114,7 @@ namespace Network /// 接收来自服务器的数据 /// /// 接收到的消息 - public string Receive() + public async Task Receive() { if (!IsConnected) { @@ -131,7 +132,7 @@ namespace Network { // 读取数据 var buffer = new byte[1024]; - var bytesRead = stream.Read(buffer, 0, buffer.Length); + var bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length); // 将字节数组转换为字符串 var message = Encoding.UTF8.GetString(buffer, 0, bytesRead);