大概需求是客户端发送一个xml文件名给服务器，服务器返回xml文件。这一步没问题。
后面客户端需要解析xml文件，根据解析出的文件名，去服务器获取指定文件。现在问题是第一次服务器发送xml文件之后就侦听不到客户端后面的请求了
服务端代码：

#region 窗体加载
        private void Form1_Load(object sender, EventArgs e)
        {
            Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//Socket设置、IPv4、Stream类型套接字、TCP协议
            IPAddress ip = IPAddress.Any;//获取本机IP
            IPEndPoint point = new IPEndPoint(ip, 18002);//设置IP和端口
            socketWatch.Bind(point);//绑定端口
            memoEdit1.Text = "开始侦听...";
            socketWatch.Listen(100);//最大连接数
            Thread th = new Thread(SendFileFuncssss);//创建新线程
            th.Start(socketWatch);//启动线程
            th.IsBackground = true;//设置后台运行线程
        }
        #endregion

        #region 根据客户端传输文件名发送指定文件
        public void SendFileFuncssss(object obj)
        {
            Socket socket = obj as Socket;
            while (true)
            {
                Socket socketServices = socket.Accept();
                byte[] buffer = new byte[1024];
                int num = socketServices.Receive(buffer);//接收到字节数
                string str = Encoding.UTF8.GetString(buffer, 1, num - 1);//接收到字符串
                if (buffer[0] == 0)//表示接收到的是消息数据
                {
                    TxtAddContent(socketServices.RemoteEndPoint + "连接成功");
                    string FileName = str;
                    if (FileName.Equals("AutoUpdater.xml"))//获取xml配置文件
                    {
                        //发送XML文件到客户端
                        using (FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + FileName, FileMode.Open))
                        {
                            byte[] arrFile = new byte[1024 * 1024 * 5];
                            int length = fs.Read(arrFile, 0, arrFile.Length);
                            byte[] arrFileSend = new byte[length + 1];
                            arrFileSend[0] = 1; // 用来表示发送的是xml文件数据
                            Buffer.BlockCopy(arrFile, 0, arrFileSend, 1, length);
                            socketServices.Send(arrFileSend);// 发送数据到客户端
                        }
                    }
                    if (!FileName.Equals("AutoUpdater.xml"))
                    {
                        //发送更新文件到客户端
                        using (FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + "\\FileFolder\\" + FileName, FileMode.Open))
                        {
                            byte[] arrFile = new byte[1024 * 1024 * 50];
                            int length = fs.Read(arrFile, 0, arrFile.Length);//获取文件长度
                            byte[] arrFileSend = new byte[length + 1];
                            arrFileSend[0] = 1; // 用来表示发送的是xml文件数据
                            Buffer.BlockCopy(arrFile, 0, arrFileSend, 1, length);
                            socketServices.Send(arrFileSend);// 发送数据到服务端
                        }
                    }
                }
            }
        }
        #endregion

客户端代码：

 Socket socketClient = obj as Socket;
            socketClient.Connect(ipEndPoint);

            #region 修改本地文件名称
            string Oldpath = AppDomain.CurrentDomain.BaseDirectory + "AutoUpdater.xml";//修改前名称
            string Newpath = AppDomain.CurrentDomain.BaseDirectory + "AutoUpdater_Back.xml";//修改后名称
            if (File.Exists(Oldpath))
            {
                File.Delete(Newpath);
                File.Move(Oldpath, Newpath);//更改文件名
            }
            #endregion

            if (socketClient.Connected)
            {
                try
                {
                    TxtReceiveAddContent("连接成功");
                    //发送链接成功提示
                    byte[] arrMsg = Encoding.UTF8.GetBytes("AutoUpdater.xml");
                    byte[] arrSendMsg = new byte[arrMsg.Length + 1];//加一位标识用于表示是文字消息还是文件
                    arrSendMsg[0] = 0; // 用来表示发送的是消息数据
                    Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length);
                    socketClient.Send(arrSendMsg);
                    //获取文件
                    string dirPath = Application.StartupPath;
                    byte[] buffer = new byte[1024 * 1024 * 5];
                    int lenght = socketClient.Receive(buffer);
                    if (buffer[0] == 1)
                    {
                        using (FileStream fs = new FileStream(dirPath + "\\AutoUpdater.xml", FileMode.Create))
                        {
                            fs.Write(buffer, 1, lenght - 1);
                        }
                        TxtReceiveAddContent("配置文件接收成功:AutoUpdater.xml");//追加提示备注
                    }

                    #region 获取XML里需要更新的文件和需要删除的文件
                    List<string> updatelist = new List<string>();//需要更新的文件集合
                    List<string> deletelist = new List<string>();//需要更新的文件集合
                    //获取历史xml文件更新时间以及更新版本
                    XDocument Olddocument = XDocument.Load(AppDomain.CurrentDomain.BaseDirectory + "AutoUpdater_Back.xml");
                    //获取到XML的根元素进行操作
                    XElement Oldroot = Olddocument.Root;
                    XElement Oldele = Oldroot.Element("UpdateInfo");
                    //获取旧更新时间标签的值
                    XElement OldUpdateTime = Oldele.Element("UpdateTime");
                    //获取旧版本号标签的值
                    XElement OldVersion = Oldele.Element("Version");
                    //获取最新xml文件更新时间以及更新版本
                    XDocument Newdocument = XDocument.Load(AppDomain.CurrentDomain.BaseDirectory + "AutoUpdater.xml");
                    //获取到XML的根元素进行操作
                    XElement Newroot = Newdocument.Root;
                    XElement Newele = Newroot.Element("UpdateInfo");
                    //获取旧更新时间标签的值
                    XElement NewUpdateTime = Newele.Element("UpdateTime");
                    //获取旧版本号标签的值
                    XElement NewVersion = Newele.Element("Version");
                    if (NewUpdateTime != OldUpdateTime || NewVersion != OldVersion)
                    {
                        //获取需要更新的文件列表
                        XElement NewUpList = Newroot.Element("UpdateList");
                        IEnumerable<XElement> UpList = NewUpList.Elements();
                        foreach (XElement item in UpList)
                        {
                            updatelist.Add(item.Value);
                        }
                        //获取需要删除的文件列表
                        XElement NewDelList = Newroot.Element("DeleteList");
                        IEnumerable<XElement> DelList = NewDelList.Elements();
                        foreach (XElement item in DelList)
                        {
                            deletelist.Add(item.Value);
                        }
                    }
                    #endregion

                    #region 循环获取更新文件
                    for (int i = 0; i < updatelist.Count; i++)
                    {
                        //发送链接成功提示
                        byte[] FileName = Encoding.UTF8.GetBytes(updatelist[i]);
                        byte[] SendFileName = new byte[FileName.Length + 1];//加一位标识用于表示是文字消息还是文件
                        SendFileName[0] = 0; // 用来表示发送的是消息数据
                        Buffer.BlockCopy(FileName, 0, SendFileName, 1, FileName.Length);
                        socketClient.Send(SendFileName);
                        //获取文件
                        string FilePath = Application.StartupPath + "\\WebFile";
                        byte[] bufferByFile = new byte[1024 * 1024 * 50];
                        int lenghtByFile = socketClient.Receive(bufferByFile);
                        if (bufferByFile[0] == 1)
                        {
                            using (FileStream fs = new FileStream(FilePath + "\\" + updatelist[i], FileMode.Create))
                            {
                                fs.Write(bufferByFile, 1, lenghtByFile - 1);
                            }
                            TxtReceiveAddContent("文件接收成功:" + updatelist[i]);
                        }
                    }
                    #endregion

                    #region 循环删除指定文件
                    for (int i = 0; i < deletelist.Count; i++)
                    {
                        try
                        {
                            string path = AppDomain.CurrentDomain.BaseDirectory + "\\WebFile\\" + deletelist[i];
                            File.Delete(path);
                            TxtReceiveAddContent("删除文件[" + deletelist[i] + "]成功");
                        }
                        catch (Exception)
                        {
                            TxtReceiveAddContent("删除文件[" + deletelist[i] + "]失败");
                            continue;
                        }
                    }
                    #endregion
                }
                catch (Exception ex)
                {
                    File.Move(Newpath, Oldpath);//连接失败，还原文件名
                    MessageBox.Show(ex.ToString());
                    throw;
                }

调试在客户端进循环的时候服务端侦听不到了
刚接触socket，多谢大佬们解答

C# 中foreach里面可以使用多线程吗？

wangzaihello

2个回复