基础通信模型

server : bind、listen、accept、read、write、read、close
client：connect、write、read、close

帮助类

public class SocketHelper : IDisposable
    {
        private Encoding Encode { get; set; }
        private Socket SocketInstance { get; set; }

        public bool ISConnect
        {
            get
            {
                return SocketInstance.Connected;
            }
        }

        public SocketHelper(Encoding encode)
        {
            Encode = encode;
            SocketInstance = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        }

        public SocketHelper(Encoding encode, Socket socket)
        {
            Encode = encode;
            SocketInstance = socket;
        }


        public int Send(string msg)
        {
            var byteStr = Encode.GetBytes(msg);

            return SocketInstance.Send(byteStr);
        }

        public void Bind(string ip, int port)
        {
            IPAddress iPAddress = IPAddress.Parse(ip);
            var ipEndPoint = new IPEndPoint(iPAddress, port);
            SocketInstance.Bind(ipEndPoint);

        }

        public void Connect(string ip, int port)
        {
            IPAddress iPAddress = IPAddress.Parse(ip);
            var ipEndPoint = new IPEndPoint(iPAddress, port);
            SocketInstance.Connect(ipEndPoint);
        }

        public void Listen()
        {
            SocketInstance.Listen();
        }

        public Socket Accept()
        {
            return SocketInstance.Accept();
        }

        public int Receive(byte[] buffer)
        {
            return SocketInstance.Receive(buffer);
        }

        public void Dispose()
        {
            if (SocketInstance.Connected)
            {
                SocketInstance.Close();
            }
            SocketInstance.Dispose();
        }
    }

服务端

static void StartServer(string ip, int port)
        {
            Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance);

            var encode = System.Text.Encoding.GetEncoding("GB2312");

            SocketHelper socketHelper = new SocketHelper(encode);
            socketHelper.Bind(ip, port);

            socketHelper.Listen();



            SocketHelper acceptSocketHelper = null;


            while (true)
            {
                var acceptSocket = socketHelper.Accept();
                acceptSocketHelper = new SocketHelper(encode, acceptSocket);

                Task.Run(() =>
                {
                    Receive(encode, acceptSocketHelper);
                });
            }
        }


private static void Receive(Encoding encode, SocketHelper acceptSocketHelper)
        {
            while (acceptSocketHelper.ISConnect)
            {
                var buffer = new byte[4096];
                var size = acceptSocketHelper.Receive(buffer);
                if (size <= 0)
                {
                    continue;
                }

                var str = encode.GetString(buffer);
                Console.WriteLine($"receive:{str}");
            }
        }

客户端

static void StartClient(string ip, int port)
        {
            Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance);

            var encode = System.Text.Encoding.GetEncoding("GB2312");

            SocketHelper socketHelper = new SocketHelper(encode);
            socketHelper.Connect(ip, port);
            while (true)
            {
                var sendStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                var size = socketHelper.Send(sendStr);
                Console.WriteLine($"send:{sendStr}");
                Thread.Sleep(1000);
            }
        }