這篇文章主要介紹了C#使用Socket發(fā)送和接收TCP數(shù)據(jù)的實(shí)現(xiàn)方法,以實(shí)例的形式詳細(xì)講述了C#實(shí)現(xiàn)socket通信的完整實(shí)現(xiàn)過(guò)程,非常具有實(shí)用價(jià)值,需要的朋友可以參考下

本文實(shí)例講述了Asp.net中C#使用Socket發(fā)送和接收TCP數(shù)據(jù)的方法，分享給大家供大家參考。具體實(shí)現(xiàn)方法如下：

具體程序代碼如下：

復(fù)制代碼代碼如下:

using System;

using System.Collections.Generic;

using System.Net;

using System.Net.Sockets;

using System.Text;

namespace ConsoleApplication1

{

    public static class SocketTest

    {

        private static Encoding encode = Encoding.Default;

        /// <summary>

        /// 監(jiān)聽(tīng)請(qǐng)求

        /// </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>

        /// 發(fā)送數(shù)據(jù)

        /// </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>

        /// 接收數(shù)據(jù)

        /// </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對(duì)象

        /// </summary>

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

        private static void DestroySocket(Socket socket)

        {

            if (socket.Connected)

            {

                socket.Shutdown(SocketShutdown.Both);

            }

            socket.Close();

        }

    }

}