zzdxxz/Gen_Hack-and-Slash-Roguelite-zzdxxz
1
0
Fork 0
forked from Roguelite-Game-Developing-Team/Gen_Hack-and-Slash-Roguelite
Code Pull Requests Activity

(client) chore:Make TCP client async

Browse Source
This commit is contained in:
CaicukunChiji
2025-07-10 22:34:23 +08:00
parent 2466275e97
commit 8a52f8fb3a
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
Client/Assets/Scripts/Network/UnityTcpClient.cs
View File

@ -1,6 +1,7 @@
using System; using System;
using System.Net.Sockets; using System.Net.Sockets;
using System.Text; using System.Text;
using System.Threading.Tasks;
using UnityEngine; using UnityEngine;
using Utils; using Utils;
@ -17,7 +18,7 @@ namespace Network
/// <param name="address">服务器地址</param> /// <param name="address">服务器地址</param>
/// <param name="port">端口号</param> /// <param name="port">端口号</param>
/// <returns>连接是否成功</returns> /// <returns>连接是否成功</returns>
public bool Connect(string address, int port) public async Task<bool> Connect(string address, int port)
{ {
if (IsConnected) if (IsConnected)
{ {
@ -31,7 +32,7 @@ namespace Network
_tcpClient = new TcpClient(); _tcpClient = new TcpClient();
// 尝试连接到指定的地址和端口 // 尝试连接到指定的地址和端口
_tcpClient.Connect(address, port); await _tcpClient.ConnectAsync(address, port);
// 如果连接成功 // 如果连接成功
if (IsConnected) if (IsConnected)
@ -82,7 +83,7 @@ namespace Network
/// 发送数据到服务器 /// 发送数据到服务器
/// </summary> /// </summary>
/// <param name="message">要发送的消息</param> /// <param name="message">要发送的消息</param>
public void Send(string message) public async Task Send(string message)
{ {
if (!IsConnected) if (!IsConnected)
{ {
@ -99,7 +100,7 @@ namespace Network
var data = Encoding.UTF8.GetBytes(message); 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}"); Debug.Log($"Sent message to server: {message}");
} }
@ -113,7 +114,7 @@ namespace Network
/// 接收来自服务器的数据 /// 接收来自服务器的数据
/// </summary> /// </summary>
/// <returns>接收到的消息</returns> /// <returns>接收到的消息</returns>
public string Receive() public async Task<string> Receive()
{ {
if (!IsConnected) if (!IsConnected)
{ {
@ -131,7 +132,7 @@ namespace Network
{ {
// 读取数据 // 读取数据
var buffer = new byte[1024]; 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); var message = Encoding.UTF8.GetString(buffer, 0, bytesRead);