C# Socket通讯入门

作者: 何向宇 | 来源:发表于2016-10-22 18:19 被阅读1722次

    网络上的两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。
    建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API),对TCP/IP的封装,TCP/IP也要提供可供程序员做网络开发所用的接口,这就是Socket编程接口;HTTP是轿车,提供了封装或者显示数据的具体形式;Socket是发动机,提供了网络通信的能力。
    更多关于Socket的详情,可以到百科了解其原理:http://baike.baidu.com/link?url=HaZW8GwMCCq9j3A5g6Umjd4iXNZMnSW69V2_95TSzqS1xT1mZ9dYUy621N4A5jCF4-ui8BdfsR6OWFCybRckTq
    本文主要是基于Socket短连接(连接→数据传输→关闭连接)异步通讯的入门代码。至于使用短连接还是长连接要具体看实际需求。
    废话不多说,直接贴上源码:
    服务端:
    新建项目后,先引用以下类库:
    using System.Net.Sockets;
    using System.Threading;

        //创建套接字  
        static Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        private static byte[] result = new byte[1024];
        static void Main(string[] args)
        {
            SocketServie();
        }
        public static void SocketServie()
        {
            Console.WriteLine("服务端已启动");
            string host = "127.0.0.1";//IP地址
            int port = 2000;//端口
            socket.Bind(new IPEndPoint(IPAddress.Parse(host), port));
            socket.Listen(100);//设定最多100个排队连接请求   
            Thread myThread = new Thread(ListenClientConnect);//通过多线程监听客户端连接  
            myThread.Start();
            Console.ReadLine();
        }
    
        /// <summary>  
        /// 监听客户端连接  
        /// </summary>  
        private static void ListenClientConnect()
        {
            while (true)
            {
                Socket clientSocket = socket.Accept();
                //clientSocket.Send(Encoding.UTF8.GetBytes("服务器连接成功"));
                Thread receiveThread = new Thread(ReceiveMessage);
                receiveThread.Start(clientSocket);
            }
        }
    
        /// <summary>  
        /// 接收消息  
        /// </summary>  
        /// <param name="clientSocket"></param>  
        private static void ReceiveMessage(object clientSocket)
        {
            Socket myClientSocket = (Socket)clientSocket;
            while (true)
            {
                try
                {
                    //通过clientSocket接收数据  
                    int receiveNumber = myClientSocket.Receive(result);
                    if (receiveNumber == 0)
                        return;
                    Console.WriteLine("接收客户端{0} 的消息:{1}", myClientSocket.RemoteEndPoint.ToString(), Encoding.UTF8.GetString(result, 0, receiveNumber));
                    //给Client端返回信息
                    string sendStr = "已成功接到您发送的消息";
                    byte[] bs = Encoding.UTF8.GetBytes(sendStr);//Encoding.UTF8.GetBytes()不然中文会乱码
                    myClientSocket.Send(bs, bs.Length, 0);  //返回信息给客户端
                    myClientSocket.Close(); //发送完数据关闭Socket并释放资源
                    Console.ReadLine(); 
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    myClientSocket.Shutdown(SocketShutdown.Both);//禁止发送和上传
                    myClientSocket.Close();//关闭Socket并释放资源
                    break;
                }
            }
        }
    

    客户端:
    新建项目后,先引用以下类库:
    using System.Net.Sockets;
    using System.Threading;

        static void Main(string[] args)
        {
            //设定服务器IP地址  
            IPAddress ip = IPAddress.Parse("127.0.0.1");
            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                clientSocket.Connect(new IPEndPoint(ip, 2000)); //配置服务器IP与端口  
                Console.WriteLine("连接服务器成功");
            }
            catch
            {
                Console.WriteLine("连接服务器失败,请按回车键退出!");
                return;
            }
    
            string sendMessage = "你好";//发送到服务端的内容
            clientSocket.Send(Encoding.UTF8.GetBytes(sendMessage));//向服务器发送数据,需要发送中文则需要使用Encoding.UTF8.GetBytes(),否则会乱码
            Console.WriteLine("向服务器发送消息:" + sendMessage);
    
            //接受从服务器返回的信息
            string recvStr = "";
            byte[] recvBytes = new byte[1024];
            int bytes;
            bytes = clientSocket.Receive(recvBytes, recvBytes.Length, 0);    //从服务器端接受返回信息 
            recvStr += Encoding.UTF8.GetString(recvBytes, 0, bytes);
            Console.WriteLine("服务端发来消息:{0}", recvStr);    //回显服务器的返回信息
            //关闭连接并释放资源
            clientSocket.Close();
            Console.ReadLine();
        }
    

    记得先启动服务端,再启动客户端。
    服务端:


    1.jpg

    客户端:

    2.jpg

    相关文章

      网友评论

      • waiwing14:我就说百度怎么这么辣鸡,翻到第二页才找到这篇文章。谷歌第四条就是了。
      • 山治先生:第一段的解释并不是很严谨,WCF同样可以现实双向通信,而连接的其中一端也不是scoket
      • 10dd2f756cbf:清晰 易懂
      • primates:非常明了。

      本文标题:C# Socket通讯入门

      本文链接:https://www.haomeiwen.com/subject/vqshuttx.html