C#使用Socket发送和接收TCP数据实例

2019-10-29 21:44:18

字体：大中小

来源：转载

供稿：网友

这篇文章主要介绍了C#使用Socket发送和接收TCP数据的实现方法,以实例的形式详细讲述了C#实现socket通信的完整实现过程,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了Asp.net中C#使用Socket发送和接收TCP数据的方法，分享给大家供大家参考。具体实现方法如下：

具体程序代码如下：

复制代码代码如下:

		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>
		        /// 监听请求
		        /// </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();
		        }
		    }
		}