测试TestTcp请求----处理Socket,代码如下:
#region 测试TestTcp
/// <summary>
/// 测试TestTcp
/// </summary>
public static async void TestTcp()
{
var threadStart = new Thread(new ThreadStart(StartTestTcp))
{
IsBackground = true
};
threadStart.Start();
Console.WriteLine($"TestTcp开始测试数据");
int test = 1;
while (true)
{
TcpClient tcpClient = new TcpClient();
tcpClient.Connect(IPAddress.Parse("127.0.0.1"), 1122);
Console.WriteLine($"TcpClient 发送数据:{test}");
await tcpClient.GetStream().WriteAsync(Encoding.UTF8.GetBytes($"client{test}"));
var buffer = new byte[1024];
var socketConnReceCount = await tcpClient.GetStream().ReadAsync(buffer, 0, buffer.Length);
Console.WriteLine($"TcpClient 接收数据:{Encoding.UTF8.GetString(buffer, 0, socketConnReceCount)}");
test++;
Thread.Sleep(2000);
tcpClient.Dispose();
}
}
public static async void StartTestTcp()
{
TcpListener tcpListener = new TcpListener(IPAddress.Parse("127.0.0.1"), 1122);
tcpListener.Start();
int test = 1;
Console.WriteLine($"TcpListener服务端 启动监听");
while (true)
{
var tcpclient = await tcpListener.AcceptTcpClientAsync();
var bytes = new byte[1024];
var readdataCount = await tcpclient.GetStream().ReadAsync(bytes, 0, bytes.Length);
Console.WriteLine($"TcpListener服务端接收数据:{Encoding.UTF8.GetString(bytes, 0, readdataCount)}");
bytes = Encoding.UTF8.GetBytes($"服务端已处理{test}");
await tcpclient.GetStream().WriteAsync(bytes, 0, bytes.Length);
tcpclient.Dispose();
}
}
#endregion
测试结果如下:
public class Program
{
static void Main(string[] args)
{
#region 测试TestTcp
TestTcp();
#endregion
Console.Read();
}
}
![](https://img.laitimes.com/img/_0nNw4CM6IyYiwiM6ICdiwiIn5GcuQTMygjNwEDNtgDM4IzM1MjNxcTMyEDMyAjMtcjM5QTO28CXyEDMyAjMvw1NykDN5YzLcd2bsJ2Lc12bj5ycn9Gbi52YuAjMwIzZtl2Lc9CX6MHc0RHaiojIsJye.png)
龙腾一族至尊龙骑