zoukankan      html  css  js  c++  java
  • 测试TestTcp

    测试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();
            }
        }

  • 相关阅读:
    bzoj1453
    276D
    855E
    bzoj1458
    树莓派 自启动连接阿里云物联网平台(一)
    树莓派 实现脚本程序自启动
    树莓派4B 系统镜像安装与boot配置
    2019-2020-2《网络对抗技术》 Exp1 PC平台逆向破解
    2019-2020-2 《网络对抗技术》 Exp0 kali 安装
    kali 添加使用 KDE 桌面环境
  • 原文地址:https://www.cnblogs.com/1175429393wljblog/p/14150425.html
Copyright © 2011-2022 走看看