Socket 数据通信

  public static class SocketTest

    {

        private static Encoding encode = Encoding.Default;

        /// <summary>

        /// 监听请求

        /// </summary>

        /// <param name="port"></param>

        public static void Listen(int port)

        {

            Socket listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            listenSocket.Bind(new IPEndPoint(IPAddress.Any, port));

            listenSocket.Listen(100);

            Console.WriteLine("Listen " + port + " ...");

            while (true)

            {

                Socket acceptSocket = listenSocket.Accept();

                string receiveData = Receive(acceptSocket, 5000); //5 seconds timeout.

                Console.WriteLine("Receive：" + receiveData);

                acceptSocket.Send(encode.GetBytes("ok"));

                DestroySocket(acceptSocket); //import

            }

        }

        /// <summary>

        /// 发送数据

        /// </summary>

        /// <param name="host"></param>

        /// <param name="port"></param>

        /// <param name="data"></param>

        /// <returns></returns>

        public static string Send(string host, int port, string data)

        {

            string result = string.Empty;

            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            clientSocket.Connect(host, port);

            clientSocket.Send(encode.GetBytes(data));

            Console.WriteLine("Send：" + data);

            result = Receive(clientSocket, 5000 * 2); //5*2 seconds timeout.

            Console.WriteLine("Receive：" + result);

            DestroySocket(clientSocket);

            return result;

        }

        /// <summary>

        /// 接收数据

        /// </summary>

        /// <param name="socket"></param>

        /// <param name="timeout"></param>

        /// <returns></returns>

        private static string Receive(Socket socket, int timeout)

        {

            string result = string.Empty;

            socket.ReceiveTimeout = timeout;

            List<byte> data = new List<byte>();

            byte[] buffer = new byte[1024];

            int length = 0;

            try

            {

                while ((length = socket.Receive(buffer)) > 0)

                {

                    for (int j = 0; j < length; j++)

                    {

                        data.Add(buffer[j]);

                    }

                    if (length < buffer.Length)

                    {

                        break;

                    }

                }

            }

            catch { }

            if (data.Count > 0)

            {

                result = encode.GetString(data.ToArray(), 0, data.Count);

            }

            return result;

        }

        /// <summary>

        /// 销毁Socket对象

        /// </summary>

        /// <param name="socket"></param>

        private static void DestroySocket(Socket socket)

        {

            if (socket.Connected)

            {

                socket.Shutdown(SocketShutdown.Both);

            }

            socket.Close();

        }

    }