1. 云图网首页
  2. 技术专区
  3. Java

Java培训实战教程之论Socket的重要性

• Java

Java培训中 精点、难点知识总结汇总
Socket不仅在聊天应用程序中需要用到，而且对于学习Asp.net也非常有帮助。你懂得！

实现服务端和客户端互发信息，以及服务端向多个客户端发送信息。

     服务端代码1：

  1.         public Form1()
  2.         {
  3.             InitializeComponent();
  4.             Control.CheckForIllegalCrossThreadCalls = false;
  5.         }
  7.         //创建监听用的socket
  8.         private void btnStartMonitor_Click(object sender, EventArgs e)
  9.         {
  10.             //监听的ip地址
  11.             IPAddress ip = IPAddress.Parse(txtIP.Text);
  12.             //监听的ip地址和端口号
  13.             IPEndPoint point = new IPEndPoint(ip, int.Parse(txtPortNumber.Text));
  14.             //监听用的socket
  15.             Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  17.             //通常每个套接字地址(协议/网络地址/端口)只允许使用一次
  18.             //绑定监听的ip地址和端口号
  19.             socket.Bind(point);
  20.             //监听端口   监听队列的长度:同一个时间等待的个数。
  21.             socket.Listen(10);
  22.             //点击之后，禁用掉按钮
  23.             btnStartMonitor.Enabled = false;
  24.             //提示用户程序开始运行了
  25.             ShowMsg("开始运行了…");
  27.             //监听端口，如果有客户端连接，创建通信用socket
  28.             //阻塞窗体的运行
  29.             //Socket connSocket = socket.Accept();
  30.             //用线程来解决窗体假死的问题
  31.             Thread th = new Thread(Listen);
  32.             th.IsBackground = true;//后台线程
  33.             th.Start(socket);
  34.         }
  36.         //监听是否有客户端连接
  37.         void Listen(object o)
  38.         {
  39.             //监听用的socket
  40.             Socket socket = o as Socket;
  41.             //监听端口
  42.             Socket connSocket = socket.Accept();
  43.             //显示远程连接的IP地址和端口号
  44.             ShowMsg(connSocket.RemoteEndPoint.ToString());
  45.         }
  47.         //在文本框显示信息
  48.         void ShowMsg(string msg)
  49.         {
  50.             txtShowMessage.AppendText(msg + "/r/n");
  51.         }

复制代码

以上代码只能让一个客户端连接服务端，弊端。

     服务端代码2完善——循环接收客户端连接：

  1.         //监听是否有客户端连接
  2.        void Listen(object o)
  3.         {
  4.             //监听用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客户端的连接
  8.             while (true)
  9.             {
  10.                 //负责通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //显示远程连接的IP地址和端口号
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本机的IP地址和端口号
  15.                 //connSocket.LocalEndPoint
  17.                 //接收数据
  18.                 byte[] buffer = new byte[1024 * 1023];
  19.                 //接收数据，把数据发到buffer中
  20.                 //num是实际接收到的字节个数
  21.                 int num=connSocket.Receive(buffer);
  22.                 //把实际有效的字节转换成字符串
  23.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  24.                 ShowMsg(str);
  25.             }
  26.         }

复制代码

服务端代码3完善——循环接收消息：

  1.         //监听是否有客户端连接
  2.         void Listen(object o)
  3.         {
  4.             //监听用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客户端的连接
  8.             while (true)
  9.             {
  10.                 //负责通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //显示远程连接的IP地址和端口号
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本机的IP地址和端口号
  15.                 //connSocket.LocalEndPoint
  17. //循环接收消息
  18. while(true)
  19. {
  20.                 //接收数据
  21.                 byte[] buffer = new byte[1024 * 1023];
  22.                 //接收数据，把数据发到buffer中
  23.                 //num是实际接收到的字节个数
  24.                 int num=connSocket.Receive(buffer);
  25.                 //把实际有效的字节转换成字符串
  26.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  27.                 ShowMsg(str);
  28. }
  29.             }
  30.         }

复制代码

服务端代码4完善——循环多个客户端并接收信息：

  1.         //监听是否有客户端连接
  2.         void Listen(object o)
  3.         {
  4.             //监听用的socket
  5.             Socket socket = o as Socket;
  7.             //可以不停地接受客户端的连接
  8.             while (true)
  9.             {
  10.                 //负责通信用的socket
  11.                 Socket connSocket = socket.Accept();
  12.                 //显示远程连接的IP地址和端口号
  13.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  14.                 //本机的IP地址和端口号
  15.                 //connSocket.LocalEndPoint
  17.                 //线程接收信息
  18.                 Thread th = new Thread(RecMsg);
  19.                 th.IsBackground = true;
  20.                 th.Start(connSocket);            
  21. }
  22.         }
  24.         //接收信息
  25.         void RecMsg(object o)
  26.         {
  27.             //通信用的socket
  28.             Socket connSocket = o as Socket;
  29.             //可以不停地接受客户端的内容
  30.             while (true)
  31.             {
  32.                 //接受数据
  33.                 byte[] buffer = new byte[1024 * 1024];
  34.                 //接受数据，把数据发到buffer中
  35.                 //num就是实际接受到的字节个数
  36.                 int num = connSocket.Receive(buffer);
  38. //当telnet关闭，会不停的发送空（0）字节
  40.                 //把实际有效的字节转化成字符串
  41.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  42.                 ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  43.                 }
  44.             }
  45.         }

复制代码

服务端代码5完善——限制客户端连接数：

  1.         //限制连接客户端的个数
  2.         int count=0;
  3.         void Listen(object o)
  4.         {
  5.             //监听用的socket
  6.             Socket socket = o as Socket;
  8.             //可以不停地接受客户端的连接
  9.             while (count<1000)
  10.             {
  11.                 //负责通信用的socket
  12.                 Socket connSocket = socket.Accept();
  13.                 //显示远程连接的IP地址和端口号
  14.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  15.                 //本机的IP地址和端口号
  16.                 //connSocket.LocalEndPoint
  18.                 //线程接收信息
  19.                 Thread th = new Thread(RecMsg);
  20.                 th.IsBackground = true;
  21.                 th.Start(connSocket);
  22. }
  23.         }

复制代码

服务端代码6完善——解决“当tenet关闭，会不停地发送空（0）字节”：

  1.         //接收信息
  2.         void RecMsg(object o)
  3.         {
  4.             //通信用的socket
  5.             Socket connSocket = o as Socket;
  6.             //可以不停地接受客户端的内容
  7.             while (true)
  8.             {
  9.                 //接受数据
  10.                 byte[] buffer = new byte[1024 * 1024];
  11.                 //接受数据，把数据发到buffer中
  12.                 //num就是实际接受到的字节个数
  13.                 int num = connSocket.Receive(buffer);
  15. //当telnet关闭，会不停的发送空（0）字节
  16.                     //当telnet关闭，会不停的发送（0）个字节  客户端断开
  17.                     if (num == 0)
  18.                     {
  19.                         ShowMsg(connSocket.RemoteEndPoint.ToString() + ":退出");
  20.                         connSocket.Shutdown(SocketShutdown.Receive);
  21.                         connSocket.Close();
  22.                         break;
  23.                     }
  24.                 //把实际有效的字节转化成字符串
  25.                 string str = Encoding.UTF8.GetString(buffer, 0, num);
  26.                 ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  27.                 }
  28.             }
  29.         }

复制代码

客户端代码1：

  1.         public Form1()
  2.         {
  3.             InitializeComponent();
  4.             Control.CheckForIllegalCrossThreadCalls = false;
  5.         }
  7.         //连接服务端和发送信息都要用到同一个socket，将其定义到外边
  8.         Socket socket;
  9.         //连接服务端
  10.         private void btnConnect_Click(object sender, EventArgs e)
  11.         {
  12.             //客户端连接服务器的ip地址
  13.             IPAddress ip = IPAddress.Parse(txtIP.Text);
  14.             //客户端连接的服务器的ip地址和端口号
  15.             IPEndPoint point = new IPEndPoint(ip, int.Parse(txtPortNumber.Text));
  16.             //创建连接使用的socket
  17. socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  18.             try
  19.             {
  20.                 //连接聊天服务器
  21.                 //服务器没开报错
  22.                 //由于目标计算机积极拒绝，无法连接。
  23.                 socket.Connect(point);
  24.                 ShowMsg("连接成功");
  25.             }
  26.             catch (Exception ex)
  27.             {
  28.                 ShowMsg(ex.Message);
  29.             }
  30.         }
  32.         void ShowMsg(string msg)
  33.         {
  34.             txtShowMessage.AppendText(msg + "/r/n");
  35.         }
  37.         //发送消息
  38.         private void btnSendMessage_Click(object sender, EventArgs e)
  39.         {
  40.             if (socket != null)
  41.             {
  42.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  43.                 socket.Send(buffer);
  44.             }
  45.             else
  46.             {
  47.                 MessageBox.Show("请先连接");
  48.             }
  49.         }

复制代码

客户端代码7完善——服务端知道客户端关闭的消息：

  1.         //接收信息
  2.         void RecMsg(object o)
  3.         {
  4.             //通信用的socket
  5.             Socket connSocket = o as Socket;
  6.             //可以不停地接受客户端的内容
  7.             while (true)
  8.             {
  9.                 //接受数据
  10.                 byte[] buffer = new byte[1024 * 1024];
  11.                 //接受数据，把数据发到buffer中
  12.                 //num就是实际接受到的字节个数
  13.                 int num = -1;
  14.                 try
  15.                 {
  16.         //远程主机强迫关闭了一个现有的连接。  当客户端关闭，服务端未关闭时，报错。
  17.                     num = connSocket.Receive(buffer);
  18.                     //当telnet关闭，会不停的发送（0）个字节  客户端断开
  19.                     if (num == 0)
  20.                     {
  21.                         ShowMsg(connSocket.RemoteEndPoint.ToString() + ":退出");
  22.                         connSocket.Shutdown(SocketShutdown.Receive);
  23.                         connSocket.Close();
  24.                         break;
  25.                     }
  26.                     //把实际有效的字节转化成字符串
  27.                     string str = Encoding.UTF8.GetString(buffer, 0, num);
  28.                     ShowMsg(connSocket.RemoteEndPoint.ToString() + ":" + str);
  29.                 }
  30.                 catch (Exception ex)
  31.                 {
  32.                     ShowMsg(ex.Message);
  33.                     //出现异常，跳出循环
  34.                     break;
  35.                 }
  36.             }
  37.         }

复制代码

服务端代码8完善——服务端给客户端发送消息：

  1.         //发送消息
  2.         private void btnSendMessage_Click(object sender, EventArgs e)
  3.         {
  4.             if (connSocket!=null)
  5.             {
  6.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  7.                 try
  8.                 {
  9.                     connSocket.Send(buffer);
  10.                 }
  11.                 catch (Exception ex)
  12.                 {
  13.                     ShowMsg(ex.Message);
  14.                 }
  15.             }
  16.         }

复制代码

客户端代码2完善——客户端接收服务端发送的消息：

  1.         //接收消息
  2.         void RecMsg()
  3.         {
  4.             while (true)
  5.             {
  6.                 byte[] buffer = new byte[1024 * 1024];
  7.                 try
  8.                 {
  9.                     int num = socket.Receive(buffer);
  10.                     string str = Encoding.UTF8.GetString(buffer, 1, num );
  11.                     ShowMsg(str);
  12.                 }
  13.                 catch (Exception ex)
  14.                 {
  15.                     ShowMsg(ex.Message);
  16.                     break;
  17.                 }
  18.             }
  19.         }
  20. //由于接收消息是一个死循环，需要用到线程
  21.                 //线程接受消息
  22.                 Thread th = new Thread(RecMsg);
  23.                 th.IsBackground = true;
  24.                 th.Start();

复制代码

服务端代码9完善——服务端给指定客户端发送消息：

  1.         //存储通信用的socket字典
  2.         Dictionary<string, Socket> dic = new Dictionary<string, Socket>();
  4.         //限制连接客户端的个数
  5.         int count = 0;
  6.         //监听是否有客户端连接
  7.         void Listen(object o)
  8.         {
  9.             //监听用的socket
  10.             Socket socket = o as Socket;
  12.             //可以不停地接受客户端的连接
  13.             while (count < 100)
  14.             {
  15.                 count++;
  16.                 //监听端口，如果有客户端连接，创建通信用socket
  17.                 Socket connSocket = socket.Accept();
  18.                 //显示远程连接的IP地址和端口号
  19.                 ShowMsg(connSocket.RemoteEndPoint.ToString());
  20.                 //本机的IP地址和端口号
  21.                 //connSocket.LocalEndPoint
  23.                 //保存当前登录的客户端的socket
  24.                 string ipport = connSocket.RemoteEndPoint.ToString();
  25.                 cboUser.Items.Add(ipport);
  26.                 dic.Add(ipport, connSocket);
  28.                 //线程接收信息
  29.                 Thread th = new Thread(RecMsg);
  30.                 th.IsBackground = true;
  31.                 th.Start(connSocket);
  32.             }
  33.         }
  35.         //发送消息
  36.         private void btnSendMessage_Click(object sender, EventArgs e)
  37.         {
  38.             //获取下拉框中选择的ip和端口号
  39.             string ipport = cboUser.Text;
  40.             if (!string.IsNullOrEmpty(ipport))
  41.             {
  42.                 byte[] buffer = Encoding.UTF8.GetBytes(txtInputMessage.Text);
  43.                 try
  44.                 {
  45.                     //根据key获得socket
  46.                     Socket connSocket = dic[ipport];
  47.                     connSocket.Send(buffer);
  48.                 }
  49.                 catch (Exception ex)
  50.                 {
  51.                     ShowMsg(ex.Message);
  52.                 }
  53.             }
  54.             else
  55.             {
  56.                 MessageBox.Show("请选择客户端");
  57.             }
  58.         }

复制代码

Java培训学院始终认为你将会是最优秀的存在，你就是最棒的,看好你,加油！！！
本文版权归传智播客Java培训学院所有，

作者：传智播客Java培训学院

 Java培训实战教程之论Socket的重要性

原创文章，作者：ItWorker，如若转载，请注明出处：https://blog.ytso.com/253052.html

赞 (0)
0
上一篇 2022年5月7日
下一篇 2022年5月7日

相关推荐

发表回复

登录后才能评论