C#教程之也说Socket

当前位置:

首页 > Python基础教程 >

C#教程之也说Socket

网上有大量socket相关文章，茫茫多，大多交代不清，最近自我整理了一下socket相关知识，附加了大量代码注释，先看效果。

上代码，客户端：

       Socket socket1 = null;//一个全局的socket对象

       private void btnConnect_Click(object sender, EventArgs e)
       {
           //获得服务器ip和端口号
           IPAddress ip = IPAddress.Parse(textBox1.Text);
           int port =Convert.ToInt32( textBox2.Text);

           //构造客户端socket，设置为tcp协议模式
           socket1 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

           //连接
           socket1.Connect(ip,  port);
           if (socket1.Connected)//如果连接成功
           {
               textBox3.Text += "连接成功\r\n";
               SendMsg(socket1, "发成功");

               string recMsg= "";
               //接收
               ReceiveMsg(socket1, ref recMsg);
               textBox3.Text +=recMsg;//文本显示
           }
           else
           {
               textBox3.Text += "连接不成功\r\n";
           }
       }

       private void btnSendMessage_Click(object sender, EventArgs e)
       {
           if (socket1.Connected)
           {
               string sendMsg = textBox4.Text;

               //依据长度判断是否发送
               if (sendMsg.Length <= 0)
               {
                   return;
               }

               //拿到发送是否成功的标记
               bool isSendSuccess = SendMsg(socket1, textBox4.Text);

               string recMsg = "";
               bool isReceiveSuccess = ReceiveMsg(socket1, ref recMsg);
               textBox3.Text += recMsg;

               if (!(isSendSuccess&&isReceiveSuccess))
               {
                   textBox3.Text += "连接已断开，请重连";
               }
           }
       }

       /// <summary>
       /// 发送内容，并显示
       /// </summary>
       /// <param name="socket">发送内容的socket</param>
       /// <param name="msg">输入字符串</param>
       /// <returns>发送是否成功</returns>
       private bool SendMsg(Socket socket, string msg)
       {
           try {
               socket.Send(Encoding.UTF8.GetBytes(msg));
               return true;
           }
           catch (Exception e)
           {
               socket.Close();
               return false;
           }
       }

       /// <summary>
       /// 接收内容，并显示
       /// </summary>
       /// <param name="socket">接受内容的socket</param>
       /// <param name="msg">输出字符串</param>
       /// <returns>接收是否成功</returns>
       private static bool ReceiveMsg(Socket socket ,ref string  msg)
       {
           try
           {
               int recNumber;//接收到的字节数量
               byte[] recBytes = new byte[1024];//缓冲字节数组
               recNumber = socket.Receive(recBytes);//接收行为
               byte[] recBytesForShort = new byte[recNumber];//byteArrayForDestination
               Array.Copy(recBytes, recBytesForShort, recNumber);//拷贝

               //显示文本构造
               msg += (Encoding.UTF8.GetString(recBytesForShort) + "\r\n");

               return true;
           }
           catch (Exception e)
           {
               socket.Close();

               return false;
           }

       }    

服务端：

       static void Main(string[] args)
       {
           //设置监听的ip和端口号
           IPAddress ip = IPAddress.Parse("192.168.120.56");
           IPEndPoint ipEP = new IPEndPoint(ip, 8088);

           //迎宾socket
           Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
           //绑定
           serverSocket.Bind(ipEP);
           //监听
           serverSocket.Listen(10);
           Console.WriteLine("监听已开\r\n");

           while (true)
           {
               //这里会阻塞当前线程，以等待连接
               Socket socketTemp = serverSocket.Accept();

               //开启其他线程处理数据
               ParameterizedThreadStart pts = new ParameterizedThreadStart(ReceiveAndSend);//这里传入的方法必须是静态
               new Thread(pts).Start(socketTemp);
           }

       }

       /// <summary>
       /// socket循环读取和发送的方法，建议用于多线程异步处理
       /// </summary>
       /// <param name="socketTemp">单用户Socket对象</param>
       private static void ReceiveAndSend(object socketTemp)
       {
           Socket socket = (Socket)socketTemp;
           IPEndPoint ipep = ((IPEndPoint)(socket.RemoteEndPoint));
           string ip = ipep.Address.ToString();//获得对方ip
           string port = ipep.Port.ToString();//获得对方端口
           byte[] buffer = new byte[1024];

           while (true)//循环接收和发送
           {
               //接收并显示
               string result="";
               bool isReceiveMsgSuccess = ReceiveMsg(socket, ref result);
               if (isReceiveMsgSuccess)
               {
                   Console.WriteLine(DateTime.Now.ToLongDateString()+" "+ DateTime.Now.ToLongTimeString());
                   Console.WriteLine(ip + " _ " + port + "：" + result);
               }

               //回发
               string sendBackStr = "服务端已接收:" + result;
               SendMsg(socket, sendBackStr);

               //socket.Shutdown(SocketShutdown.Both);
               //socket.Close();
               //socket.Dispose();
           }
       }

       /// <summary>
       /// 接收内容（如果失败，会释放socket）
       /// </summary>
       /// <param name="socket">接受内容的socket</param>
       /// <param name="msg">输出字符串</param>
       /// <returns>接收是否成功</returns>
       private static bool ReceiveMsg(Socket socket,ref string msg)
       {
           try
           {
               int recNumber;//接收到的字节数量
               byte[] recBytes = new byte[1024];//缓冲字节数组
               recNumber = socket.Receive(recBytes);//接收行为
               byte[] recBytesForShort = new byte[recNumber];
               Array.Copy(recBytes, recBytesForShort, recNumber);//拷贝

               //显示
               msg += Encoding.UTF8.GetString(recBytesForShort) + "\r\n";

               return true;
           }
           catch (Exception e)
           {
               socket.Close();

               return false;
           }

       }

       /// <summary>
       /// 发送内容（如果失败，会释放socket）
       /// </summary>
       /// <param name="socket">发送内容的socket</param>
       /// <param name="msg">输入字符串</param>
       /// <returns>接收是否成功</returns>
       private static bool SendMsg(Socket socket, string msg)
       {
           try
           {
               socket.Send(Encoding.UTF8.GetBytes(msg));
               return true;
           }
           catch (Exception e)
           {
               socket.Close();
               return false;
           }
       }    

栏目列表