eqiqiu server

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace reqiqiu_server
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        Thread threadWatch = null; //负责监听客户端的线程
         Socket socketWatch = null; //负责监听客户端的套接字
         //创建一个负责和客户端通信的套接字 
         List<Socket> socConnections = new List<Socket>();
         List<Thread> dictThread = new List<Thread>();
        private void button1_Click(object sender, EventArgs e)
        {
            
            socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);   //定义一个套接字用于监听客户端发来的信息  包含3个参数(IP4寻址协议,流式连接,TCP协议)                                                                                                        
            IPAddress ipaddress = IPAddress.Parse(textBox1.Text.Trim());                                   //服务端发送信息 需要1个IP地址和端口号，获取文本框输入的IP地址 
             IPEndPoint endpoint = new IPEndPoint(ipaddress, int.Parse(textBox2.Text.Trim()));          //将IP地址和端口号绑定到网络节点endpoint上，获取文本框上输入的端口号           
            socketWatch.Bind(endpoint);                                             //监听绑定的网络节点
            socketWatch.Listen(20);                                                //将套接字的监听队列长度限制为20 
            threadWatch = new Thread(WatchConnecting);                            //创建一个监听线程 
            threadWatch.IsBackground = true;                                     //将窗体线程设置为与后台同步
            threadWatch.Start();                                                //启动线程
            textBox4.AppendText("开始监听客户端传来的信息!"   "\r\n");            //启动线程后 txtMsg文本框显示相应提示
        }

        private void WatchConnecting()
          {
              while (true)  //持续不断监听客户端发来的请求
              {
                  Socket socConnection = socketWatch.Accept();
                textBox4.AppendText("客户端连接成功"   "\r\n");
                 //创建一个通信线程 
                ParameterizedThreadStart pts = new ParameterizedThreadStart(ServerRecMsg);
                Thread thr = new Thread(pts);
                thr.IsBackground = true;
                socConnections.Add(socConnection);                //启动线程
                 thr.Start(socConnection);
                 dictThread.Add(thr);
            }
         }

        private void ServerRecMsg(object obj)
        {
            throw new NotImplementedException();
        }

        private void button2_Click(object sender, EventArgs e)
        {
            //调用 ServerSendMsg方法  发送信息到客户端
                      ServerSendMsg(textBox3.Text.Trim());
                 }
  
          /// <summary>
          /// 发送信息到客户端的方法
        /// </summary>
         /// <param name="sendMsg">发送的字符串信息</param>
         private void ServerSendMsg(string sendMsg)
         {
             //将输入的字符串转换成 机器可以识别的字节数组
             byte[] arrSendMsg = Encoding.UTF8.GetBytes(sendMsg);
             //向客户端发送字节数组信息
             foreach (Socket socConnection in socConnections)
             {
                 socConnection.Send(arrSendMsg);
             }

            //将发送的字符串信息附加到文本框txtMsg上
            textBox4.AppendText("So-flash:"   GetCurrentTime()   "\r\n"   sendMsg   "\r\n");
             //}
 
         }

        private string GetCurrentTime()
        {
            throw new NotImplementedException();
        }
    }
}