This commit is contained in:
Mili 2022-08-22 23:31:20 +08:00
parent 847d176840
commit 38b2ca9b33

32
Main.cs
View File

@ -44,7 +44,7 @@ try
new ClientSocket(socket, Running).Start(); new ClientSocket(socket, Running).Start();
}); });
// 接收客户端消息 // 接收客户端消息
Receive(socket); Read(socket);
// 发送给客户端消息 // 发送给客户端消息
Send(socket); Send(socket);
} }
@ -87,24 +87,28 @@ Console.WriteLine("服务器已关闭,按任意键退出程序。");
Console.ReadKey(); Console.ReadKey();
static void Receive(Socket socket) void Read(Socket socket)
{ {
byte[] bytes = new byte[1024]; // 接收客户端消息
//从客户端接收消息 byte[] buffer = new byte[2048];
int len = socket.Receive(bytes, bytes.Length, 0); int length = socket.Receive(buffer);
//将消息转为字符串 if (length > 0)
string recvStr = Encoding.ASCII.GetString(bytes, 0, len); {
Console.WriteLine("接收的客户端消息 {0}", recvStr); string msg = Encoding.GetEncoding("unicode").GetString(buffer, 0, length);
Console.WriteLine("收到来自:客户端 -> " + msg);
}
else
Console.WriteLine("客户端没有回应。");
} }
void Send(Socket socket) void Send(Socket socket)
{ {
string sendStr = ">> 服务器" + host + ":" + port + "连接成功"; // 发送消息给客户端
Console.WriteLine("发送给客户端消息 {0}", sendStr); string msg = ">> 已连接至服务器 -> [ " + host + " ] 连接成功";
// 将字符串消息转为数组 Console.WriteLine("发送给:客户端 <- " + msg);
byte[] bytes = Encoding.ASCII.GetBytes(sendStr); byte[] buffer = new byte[2048];
//发送消息给客户端 buffer = Encoding.GetEncoding("unicode").GetBytes(msg);
socket.Send(bytes, bytes.Length, 0); socket.Send(buffer);
} }
bool IsIP(string ip) bool IsIP(string ip)