c#获取服务器数据到客户端-CSDN问答

c#服务器段测量数据，多个客户端实时同步显示

我有一台服务器，运行用c#写的程序通过串口连接设备实时采集数据。我希望从其他任何电脑利用客户端程序实时动态的显示服务器上采集的数据。如果用数据库实现的话，客户端程序不方便判断哪些数据是新数据，而且效率也很低。于是想用Socket实现。本人小白啦，对Socket只是有耳闻而已。在网上查了查资料，好像基本上就是两种模式。 1.Socket广播。我的理解就是服务器向网内广播地址发送一条消息，路由器会在网内自动转发。网内的客户端被动的接收消息，刷新数据就可以了。 2.服务器打开并监听端口，被动接收客户端的请求，再响应。但是第一种的做法，我担心当数据采集频率较高，或未来有多台以此种方式实现的服务器时，大量的广播信息会不会对网络造成负担。而且我们公司的内网是多个网段，用多台三层交换机连接到一起的。虽然IP互相都能Ping通，但是不知道广播数据能否转发到其他网段。而且广播貌似用UDP协议，看网上的解释，好像这种协议不能保证数据的先后，但我需要客户端就像心电图一样，显示一个连续的波形。第二种做法的话，需要客户端不停的发送请求，当客户端请求的频率和数据采集的频率不一致时，服务器端还要考虑是否已给给此客户端发送过最新的数据。而且当客户端数量较多的时候，会不会对服务器端程序造成压力，影响数据采集进程。我理想的模式就是，服务器采集到数据之后，直接将数据发送到某个端口。客户端监听服务器的端口，当服务器端口数据有变化时，就将数据获取并显示出来。看起来和上面第一种模式有些类似。但是我不希望广播，是通过客户端监听实现。

新手来求助，关于C#服务器端与客户端通讯的问题

string strReceive = System.Text.Encoding.Default.GetString(ReceiveBuff, 0, 256);//strReceive是接收到的客户端发的消息内容 char[] ch1 = strReceive.ToCharArray(0, 1);//取这条消息的第一个字符 if (ch1[0]!='d')//如果第一个字符为d { （补充说明：客户端发的d开头的消息的格式，就是d**, **指代一个用户名）这里的内容：获取strReceive字符串自第2个字符开始至最后，即获取用户名，把获取的新的字符串赋给string sss;连接数据库，执行SQL命令，就是把该用户名的状态设置成下线。 } if（ch1[0]!='d'）//如果第一个字符不为'd' { （补充说明：客户端发的不为d开头的消息的格式，就是 **，## 其中**指代用户名，##指代密码）这里的内容：分别获取strReceive字符串的 **，##，赋给新的变量，连接数据库，执行SQL命令，对用户进行登录验证，若验证通过则把其状态设置成上线。否则返回登录失败给客户端。 } 感觉这样子，逻辑上没有问题了呀，接下来说说运行结果。 1.客户端发送消息 d陈杰给服务器服务器端的界面上有设置了一个按钮，单击后能导出当前数据库的内容，所以当服务器收到客户端的这条消息后，服务器上导出的数据库中陈杰的状态更改为下线了。 2.客户端发送消息陈杰,cj 给服务器 .验证通过，服务器则给客户端返回成功的消息，并且服务器上导出的数据库里陈杰的状态也更改为上线了。【这样子的顺序是OK的，但不是我想要的结果，我想要先客户端发送用户名和密码，然后客户端再发该用户要下线的消息，但是问题来了，请看下面】 .{我把上面这样子执行过的关掉，所有都重新开始运行} .1.客户端发送消息张明,zm 给服务器 . .通过验证了，服务器端导出的数据库，张明的状态也显示为上线了。但是发现：我在服务器界面上放的一个textbox, 里面代码 if(ch1[0]=='d') { string sss = strReceive.Substring(1, revLength - 1);textBox1.Text = sss;UserDown(sss);} 它是在这段里用的，不是当ch1[0]=='d'时，它才会有内容吗？明明发的不是d开头的，它为什么还显示内容，而且显示的吧，张明和zm中间没了逗号，也不是客户端发的内容。下面客户端将要发送用户下线的消息了。 2.客户端发送消息 d张明给服务器 .点击服务器上的导出按钮，显然导出的数据库上张明的状态并没更新为下线。 . .【整个运行过程都没有报一点错，但是为什么2次客户端发送的消息顺序不一样，就导致它判断客户端发送的消息是否是d开头判断错误了呢。】 .帮忙看看它究竟是哪里产生了问题呢。这是关于什么阻塞么，但是同样的内容只有执行的顺序不一样呀。本人第一次接触这上面，不懂究竟是哪里的问题，怎么解决了，求大神指点一下撒。

C# 的服务器向之前登陆的时候保存的客户端Socket发送数据的时候报错了

报错：The operation is not allowed on non-connected sockets. 问题是这样的，制作添加好友模块时，遇到了一个问题，就是在登录的时候，服务端会通过ID绑定那个Socket： ``` //目前在线的客户端字典，与ID绑定 Dictionary<int, Socket> DicOnlineClients; ``` 绑定： ``` //向目前在线的客户端列表添加这个客户端 DicOnlineClients.Add(playerID, packet._peer); ``` 然后发送好友请求的时候会通过这个ID发到与这个ID绑定的Socket上，前提是这个客户端没有离线 ``` //获取此ID的Socket Socket socket; if (DicOnlineClients.TryGetValue(FriendID,out socket)) { _server.Send(SendStream, socket); } ``` 但是问题出在，在Send的时候，报错了 The operation is not allowed on non-connected sockets. 可是我客户端的socket明明是在线的啊请大神帮忙解答下。或者有没有其他的方法，用于向指定的客户端发送数据的，我这里用的是通过玩家ID辨识

c# 做TCP服务器端接受数据时无法获取发送的数据，当客户端断连后数据才上传

private void Listen() { Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); listener.Bind(new IPEndPoint(serverIP, 3588)); //不断监听端口 while (true) { listener.Listen(1); Socket socket = listener.Accept();//监听到连接 //Socket socket = listener.BeginAccecpt(new AsyncCallback(Accept), listener); //listener.BeginAccept(new AsyncCallback(AcceptCallBack), listener);//监听连接状态 //while(true) //{ // NetworkStream ntwStream = new NetworkStream(socket); // StreamReader strmReader = new StreamReader(ntwStream); // Invoke(new PrintRecvMssgDelegate(PrintRecvMssg), // new object[] { strmReader.ReadToEnd() }); // listener.Listen(1); // socket = listener.Accept(); //} NetworkStream ntwStream = new NetworkStream(socket);//监听到连接 StreamReader strmReader = new StreamReader(ntwStream); Invoke(new PrintRecvMssgDelegate(PrintRecvMssg), new object[] { strmReader.ReadToEnd() }); socket.Close(); //MessageBox.Show("11"); } //程序的listener一直不关闭 //listener.Close(); }

C#通过Socket实现多文件传输

大概需求是客户端发送一个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# Socket服务器接收HTTP请求,不能全部做出响应

使用Socket作为服务器,接收HTTP请求,在Socket socket = socketListen.Accept();之后启动一个线程处理接收数据和发送数据,如果不调用socket.Receive(data);接收客户数据的话,那么客户端(也就是HTTP请求)请求多少次, 服务端的Socket socket = socketListen.Accept();就会被调用多少次,就是能百分百接收到客户端请求, 但是通过socket.Send(head)作为HTTP请求返回数据,HTTP请求那边几乎获取不到返回的数据, 偶尔还是能获取到的,相反,不调用socket.Receive(data);方法,就会出现比如 HTTP请求了100次, socketListen.Accept();可能就被执行了80次,但是这80次调用socket.Send(head)返回给http的数据,http那边都能获取到服务端返回的数据,注：客户端每次发送的数据很少,代码如下public partial class MainWindow : Window { private Socket socketWatch; private Thread listenThread = null; private bool isRun = false; private int pointer = 0; public MainWindow() { InitializeComponent(); init(); } private void init() { socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); socketWatch.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 80)); socketWatch.Listen(10); // 参数表示最多可容纳的等待接受的传入连接数，不包含已经建立连接的 listenThread = new Thread(new ParameterizedThreadStart(run)); listenThread.IsBackground = true; } private void run(Object o) { Socket socketListen = (Socket)o; while (isRun) { Socket socket = socketListen.Accept(); pointer = pointer + 1; Thread thread = new Thread(new ParameterizedThreadStart(task)); thread.IsBackground = true; thread.Start(socket); } } private void bn_start_Click(object sender, RoutedEventArgs e) { isRun = true; bn_start.IsEnabled = false; bn_stop.IsEnabled = true; listenThread.Start(socketWatch); } private void bn_stop_Click(object sender, RoutedEventArgs e) { System.Environment.Exit(0); } private void Window_Closed(object sender, EventArgs e) { System.Environment.Exit(0); } private void task(object o) { Socket socket = (Socket)o; byte[] data = new byte[1024 * 2]; // 浏览器发来的数据 int reciverNumber = socket.Receive(data); string resdata = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " server request time:" + pointer; byte[] body = Encoding.UTF8.GetBytes(resdata); byte[] head = Encoding.UTF8.GetBytes(@"HTTP/1.1 200 OK Content-Length: " + body.Length + @" Content-Type: text/plain Date: " + string.Format("{0:R}", DateTime.Now) + @" Server: Cftea Web Server " + resdata); socket.Send(head); socket.Shutdown(SocketShutdown.Both); socket.Close(); } } ``` ```

C# 客户端远程访问IIS服务器出现:远程服务器返回错误: (404) 未找到。

C# 客户端远程访问IIS服务器出现:远程服务器返回错误: (404) 未找到。但是服务器端可以访问URL：http://192.168.2.179:8081/webform.aspx,请问这是什么原因？ ``` private void upload_Click(object sender, System.EventArgs e) { try { //上传服务器的地址（web服务） string address = "http://192.168.2.179:8081/Default.aspx"; //上传后文件保存的名称 string saveName = DateTime.Now.ToString("yyyyMMddHHmmss"); int count = UpSound_Request(address, filePath, saveName, this.progressBar1); if (count > 0) { MessageBox.Show("上传文件成功！"); } else { MessageBox.Show("上传文件失败！"); } } catch (Exception ex) { MessageBox.Show("" + ex.GetBaseException()); } } /// <summary> /// 上传文件 /// </summary> /// <param name="address">文件上传到服务器的路径</param> /// <param name="fileNamePath">要上传的本地路径（全路径）</param> /// <param name="saveName">文件上传后的名称</param> /// <returns>成功返回1，失败返回2</returns> public int UpSound_Request(string address, string fileNamePath, string saveName, ProgressBar progressBar) { int returnValue = 0; //要上传的文件 FileStream fs = new FileStream(fileNamePath, FileMode.Open, FileAccess.Read); //二进制对象 BinaryReader r = new BinaryReader(fs); //时间戳 string strBoundary = "----------" + DateTime.Now.Ticks.ToString("x"); byte[] boundaryBytes = Encoding.ASCII.GetBytes("\r\n--" + strBoundary + "\r\n"); //请求的头部信息 StringBuilder sb = new StringBuilder(); sb.Append("--"); sb.Append(strBoundary); sb.Append("\r\n"); sb.Append("Content-Disposition: form-data; name=\""); sb.Append("file"); sb.Append("\"; filename=\""); sb.Append(saveName); sb.Append("\";"); sb.Append("\r\n"); sb.Append("Content-Type: "); sb.Append("application/octet-stream"); sb.Append("\r\n"); sb.Append("\r\n"); string strPostHeader = sb.ToString(); byte[] postHeaderBytes = Encoding.UTF8.GetBytes(strPostHeader); // 根据uri创建HttpWebRequest对象 HttpWebRequest httpReq = (HttpWebRequest)WebRequest.Create(new Uri(address)); httpReq.Method = "POST"; //对发送的数据不使用缓存 httpReq.AllowWriteStreamBuffering = false; //设置获得响应的超时时间（300秒） httpReq.Timeout = 300000; httpReq.ContentType = "multipart/form-data; boundary=" + strBoundary; long length = fs.Length + postHeaderBytes.Length + boundaryBytes.Length; long fileLength = fs.Length; httpReq.ContentLength = length; try { progressBar.Maximum = int.MaxValue; progressBar.Minimum = 0; progressBar.Value = 0; //每次上传4k int bufferLength = 4096; byte[] buffer = new byte[bufferLength]; //已上传的字节数 long offset = 0; //开始上传时间 DateTime startTime = DateTime.Now; int size = r.Read(buffer, 0, bufferLength); Stream postStream = httpReq.GetRequestStream(); //发送请求头部消息 postStream.Write(postHeaderBytes, 0, postHeaderBytes.Length); while (size > 0) { postStream.Write(buffer, 0, size); offset += size; progressBar.Value = (int)(offset * (int.MaxValue / length)); TimeSpan span = DateTime.Now - startTime; double second = span.TotalSeconds; labTime.Text = "已用时：" + second.ToString("F2") + "秒"; if (second > 0.001) { labSpeed.Text = "平均速度：" + (offset / 1024 / second).ToString("0.00") + "KB/秒"; } else { labSpeed.Text = " 正在连接…"; } labState.Text = "已上传：" + (offset * 100.0 / length).ToString("F2") + "%"; labSize.Text = (offset / 1048576.0).ToString("F2") + "M/" + (fileLength / 1048576.0).ToString("F2") + "M"; Application.DoEvents(); size = r.Read(buffer, 0, bufferLength); } //添加尾部的时间戳 postStream.Write(boundaryBytes, 0, boundaryBytes.Length); postStream.Close(); //获取服务器端的响应 //WebResponse webRespon = httpReq.GetResponse(); WebResponse webRespon; try { webRespon = httpReq.GetResponse() as WebResponse; } catch (WebException ex) { webRespon = ex.Response as WebResponse; } Stream s = webRespon.GetResponseStream(); //读取服务器端返回的消息 StreamReader sr = new StreamReader(s); String sReturnString = sr.ReadLine(); s.Close(); sr.Close(); if (sReturnString == "Success") { returnValue = 1; } else if (sReturnString == "Error") { returnValue = 0; } } catch { returnValue = 0; } finally { fs.Close(); r.Close(); } return returnValue; } } ![图片说明](https://img-ask.csdn.net/upload/201908/24/1566628122_433652.png) ```

C#获取指定ip和端口上的文件

程序分为两部分，客户端和服务端。客户端主要发送数据文件到服务器，服务端接收数据文件，像这样该这样做，推荐一些此类文章我看一下，谢谢

C#SOCKET长连接小数据程序未响应

最近由于业务的需要，Linux系统嵌入式设备往我做的服务程序发送数据。速度奇慢，而且还是程序无响应。后来自己用C#写了一个客户端用来测试。已经用了线程池，不知道用法对不对。请大家帮忙看下。服务端： using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Net.Sockets; using System.Net; namespace consoleSocketServer { class Program { static int socketCount = 0; static Socket serverSocket; static Socket clientSocket; public static int clientcount = 0; public int clientnum = 0; static int listSQL = 0; static bool asy = true; public static Int32 portServer = 0; public static string ipServer = ""; public static Thread threadSocketListen; public static Thread threadDoWork; public static Thread threadInsert; public static int countsql = 0; static void Main(string[] args) { IPAddress ipAddress; portServer = 4660; serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); ipAddress = IPAddress.Parse("192.168.33.29"); ipServer = ipAddress.ToString(); IPEndPoint localEndPoint = new IPEndPoint(ipAddress, portServer); Console.WriteLine("服务器IP：" + ipServer + " 端口:" + portServer); serverSocket.Bind(localEndPoint); serverSocket.Listen(20); //设置线程池 ThreadPool.SetMaxThreads(4, 4); //开启新的线程监听 threadSocketListen = new Thread(SocketListen); threadSocketListen.Start(); Console.WriteLine("服务启动成功"); } static void SocketListen() { while (true) { //接受客户端信息 clientSocket = serverSocket.Accept(); //开启处理线程 ThreadPool.QueueUserWorkItem(new WaitCallback(doWork)); //threadDoWork = new Thread(new ThreadStart(doWork)); //threadDoWork.Start(); } } /// <summary> /// 处理方法 /// </summary> static void doWork(object a) { //获取客户端信息 IPEndPoint ipEndPoint = (IPEndPoint)clientSocket.RemoteEndPoint; string address = ipEndPoint.Address.ToString(); //Console.WriteLine(address + ":连接成功"); //取消息 byte[] inBuffer = new byte[1024]; byte[] outBuffer = new byte[8]; string inBufferStr = ""; int rec = 0; StringBuilder sb = new StringBuilder(); while (true) { try { rec = clientSocket.Receive(inBuffer);//如果没有消息为空阻塞当前循环 //收到的长度不够忽略此次数据 if (rec <= 8) { continue; } int ll = inBuffer[4] + inBuffer[5] * 255; inBufferStr = Encoding.UTF8.GetString(inBuffer, 8, ll); Console.WriteLine(inBufferStr); //回复收到 outBuffer[4] = 0; outBuffer[5] = 0; outBuffer[6] = 0; outBuffer[7] = 0; outBuffer[3] = 0; outBuffer[2] = 0; outBuffer[1] = 0; outBuffer[0] = 1; clientSocket.Send(outBuffer, outBuffer.Length, SocketFlags.None); socketCount++; Console.WriteLine(socketCount.ToString()); //break; } catch (SocketException es) { //clientSocket.Close(); return; } } } } } 客户端： using System; using System.Collections.Generic; using System.Text; using System.Net.Sockets; using System.Net; using System.Threading; namespace SocketClient { class Program { static Socket clientSocket; static void Main(string[] args) { try { //将网络端点表示为IP地址和端口用于socket侦听时绑定 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("192.168.33.29"), 4660); clientSocket = new Socket(ipep.AddressFamily, SocketType.Stream, ProtocolType.Tcp); //将Socket连接到服务器 clientSocket.Connect(ipep); string outBufferStr; //发送消息 outBufferStr = "123456789qwe|789654123|1|2015-04-22 10:51:34|6|test1|test2| "; byte[] tempb = Encoding.UTF8.GetBytes(outBufferStr); byte[] outBuffer = new byte[tempb.Length + 8]; //加功能和长度 outBuffer[0] = 1; outBuffer[1] = 0; outBuffer[2] = 0; outBuffer[3] = 0; outBuffer[4] = Convert.ToByte(tempb.Length % 255); outBuffer[5] = Convert.ToByte(tempb.Length / 255); outBuffer[6] = 0; outBuffer[7] = 0; for (int i = 0; i < tempb.Length; i++) { outBuffer[8 + i] = tempb[i]; } // Byte[] inBuffer = new Byte[1024]; int kkk = 0; while (kkk <= 10000) { clientSocket.Send(outBuffer, outBuffer.Length, SocketFlags.None); kkk++; Thread.Sleep(1); Console.WriteLine(kkk.ToString()); //Console.WriteLine("服务器响应："); //接收服务器端信息 //clientSocket.Receive(inBuffer, 1024, SocketFlags.None); //Console.WriteLine(Encoding.ASCII.GetString(inBuffer)); } Console.WriteLine(kkk.ToString()); Console.ReadLine(); } catch (Exception exp) { Console.WriteLine(exp.Message); Console.ReadLine(); } } } } 客户端收到数据，显示出来，在回发一个byte[] 1 0 0 0 0 0 0 0 用于确认收到。实际上目前客户端没有对服务端收到的数据做处理，因为那样又要多开一个线程。但是现在问题就是这样简单的测试发送10000条数据，居然会卡死，很纳闷。我前几天见他们Linux自己写的程序发送1W条数据，就是2 3秒的时间。请大神指导。难道C#真的是不能做服务端的程序？

C#开发opc client访问艾默生的dcs服务，服务已经连上了但是读取不到值

服务已经连上但是DataChange没触发，安装的艾默生客户端opcwatchlt已经连上获取数据也没问题。下面是测试代码 public Form1() { InitializeComponent(); OPCServer server = new OPCServer(); String serIp = "OPC-SERVER";//服务器的IP地址 String serverName = "OPC.DeltaV.1";//OPC服务器名称 server.Connect(serverName, serIp); OPCGroups groups = server.OPCGroups; OPCGroup group = groups.Add("myGroup"); group.UpdateRate = 1000; group.IsActive = true; group.IsSubscribed = true; server.OPCGroups.DefaultGroupDeadband = 0; server.OPCGroups.DefaultGroupIsActive = true; group.DataChange += Group_DataChange; OPCItem myItem = group.OPCItems.AddItem("PI20105/AI1/PV.CV", 1); } private void Group_DataChange(int TransactionID, int NumItems, ref Array ClientHandles, ref Array ItemValues, ref Array Qualities, ref Array TimeStamps) { //此处注意i是从1开始，因为getvalue没有0.下面输出分别为数据的ClientHandles(就是上文AddItem方法的第二个参数。)，Itemvalue就是值，Qualities为质量，timestamps为时间。 listBox1.Items.Add(ItemValues.GetValue(1));//取到改变的值 }

C#中用filestream新建了一个jpg后dispose，然后用bitmap打不开了

对于其他的jpg我用bitmap可以正常打开对于我用filestream新建后又写入了数据的jpg（之后用可以在电脑文件管理器中看到并打开查看，是正确的jpg文件），然而随后我调用了dispose，因为我想再用bitmap直接打开这个文件，然而失败了。并没有报错，只是异步调用的函数一致卡在new Bitmap（filepath）这一句上。。。求解。在做一个C#的网络文件传输，客户端发给服务器再由服务器发送给所有在线的客户端。贴代码 ``` /// <summary> /// 收到图片信息 /// </summary> /// <param name="imageMsg">图片消息</param> public void ReceiveImageMessage( ImageMessage imageMsg ) { MessageDelegate imageDel = new MessageDelegate(DealImageMessage); imageDel.BeginInvoke( imageMsg , null , null ); } private void DealImageMessage( Message msg ) {//中间一大段可以不用看。文件传输没问题。 ImageMessage imageMsg = msg as ImageMessage; string ip = imageMsg.Ip; int port = imageMsg.Port; //获取客户端ip和port string filename = string.Format("{0}{1}{2}{3}{4}{5}{6}",DateTime.Now.Year,DateTime.Now.Month,DateTime.Now.Day,DateTime.Now.Hour,DateTime.Now.Minute,DateTime.Now.Second, Path.GetExtension(imageMsg.ImageName)); string username = imageMsg.UserName; IPEndPoint end = new IPEndPoint(IPAddress.Parse(ip),port); TcpClient imageClient = new TcpClient(); imageClient.Connect( end ); //connect向客户端 NetworkStream streamToClient = imageClient.GetStream(); int BufferSize = 1024; byte[] buffer = new byte[BufferSize]; FileStream outputToImage = new FileStream("../BQTemp/"+filename,FileMode.CreateNew,FileAccess.Write); int bytesread = 0; int totalbytes = 0; do { bytesread = streamToClient.Read( buffer , 0 , BufferSize ); totalbytes += bytesread; outputToImage.Write( buffer , 0 , bytesread ); } while(bytesread > 0); //读取文件 streamToClient.Dispose(); outputToImage.Dispose(); imageClient.Close(); //关闭 BroadImage( username , filename ); //广播图片 } ``` 然后在BroadImage( username , filename );调用了下面这个函数 ``` /// <summary> /// 打印图片 /// </summary> /// <param name="imageMsg"></param> public void ShowImage( ImageMessage imageMsg ) { string imageName = imageMsg.ImageName; chatBox.AppendText( imageMsg.UserName + ":\n" ); Clipboard.Clear(); Bitmap bmp = new Bitmap("../Temp/"+imageName);//嗯没错是这一句卡住了 Clipboard.SetImage( bmp ); chatBox.Paste(); Clipboard.Clear(); chatBox.AppendText( "\n" ); } ```

c#如何拦截本机发送的http请求

<p>想做一个客户端，安装在本机，可以监视所有的http请求，并且可以获取http请求中的form表单数据,还可以模拟服务器，响应请求。并截断此次请求</p> <p> </p> <p>比如浏览器访问百度，点击百度一下的时候这个程序可以获取到输入框中的关键字</p>

用c# 写的一个tcp client 发一个指令再读硬件发回来的数据,无法读取

using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; using System.Net; using System.Net.Sockets; using System.IO; using System.Threading; namespace tongbu { public partial class Form1 : Form { string sendString = null;//要发送的字符串 byte[] sendData = null;//要发送的字节数组 TcpClient client = new TcpClient();//实例化TcpClient NetworkStream stream = null;//网络流 IPAddress remoteIP = IPAddress.Parse("10.104.10.10");//远程主机IP int remotePort = 10940;//远程主机端口 public Form1() { InitializeComponent(); } private void button1_Click(object sender, EventArgs e) { try { client.Connect(remoteIP, remotePort);//连接远程主机 } catch (System.Exception ex) { Console.WriteLine("连接超时，服务器没有响应！");//连接失败 Console.ReadKey(); return; } } private void button2_Click(object sender, EventArgs e) { sendString = textBox1.Text.ToString()+"\r"; //获取要发送的字符串 sendData = Encoding.ASCII.GetBytes(sendString);//获取要发送的字节数组 stream = client.GetStream();//获取网络流 stream.Write(sendData, 0, sendData.Length);//将数据写入网络流 Thread.Sleep(10); textBox1.Clear(); Byte[] data3 = new Byte[client.ReceiveBufferSize]; Int32 bytes = stream.Read(data3, 0, data3.Length); string responseData = System.Text.Encoding.ASCII.GetString(data3, 0, bytes); listBox1.Text = responseData; //string sss = ""; //for (int i = 0; i < data3.Length; i++) //{ // sss += data3[i].ToString(); //} //listBox1.Text = sss; //Thread.Sleep(10); //这个地方加上就能获取到数据，如果去掉大部分时候都不能获取到，只有少数时候能取得 //byte[] bytes = new byte[client.ReceiveBufferSize]; //stream.Read(bytes, 0, (int)client.ReceiveBufferSize); //string returndata = Encoding.ASCII.GetString(bytes); //returndata = returndata.Substring(0, returndata.IndexOf('\0')); //listBox1.Text = returndata; stream.Close();//关闭网络流 client.Close();//关闭客户端 } } }

大神看看，我这个是C#的聊天程序，连接多个客户端以后，通讯就会乱掉，只有最后一个连接的正常通讯

代码贴出来 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Net; using System.Net.Sockets; using System.Reflection; using System.Threading; using System.IO; namespace server2 { public partial class serverMain : Form { private NetworkStream nsStream; private IPAddress ip; private int port; private TcpListener server; Thread acceptThread; Thread threadCommunicate; private List<TcpClient> clients = new List<TcpClient>(); Dictionary<string, TcpClient> dict = new Dictionary<string, TcpClient>(); public serverMain() { InitializeComponent(); ChatContent.AppendText("欢迎\n"); ip = IPAddress.Parse(IP2.Text); port = Convert.ToInt32(port_tb.Text.Trim()); } private void connect(object sender, EventArgs e)//开启服务器 { stop_btn.Enabled = true; server = new TcpListener(ip, port); server.Start();//开始侦听 ChatContent.Text = ChatContent.Text.Insert(0, "开始侦听\n"); start_btn.Enabled = false; Thread ListenClient = new Thread(RecClient); ListenClient.Start(); } void RecClient() { while (true) { TcpClient client = new TcpClient(); try { client = server.AcceptTcpClient(); clients.Add(client); } catch (Exception ex) { MessageBox.Show("服务端连接时发生异常：" + ex.Message); break; } //当有新的socket连接到服务端时就将IP添加到在线列表中,作为客户端的唯一标识 client_list.BeginInvoke(new Action(() => { client_list.Items.Add(client.Client.RemoteEndPoint.ToString());})); //将每个新产生的套接字存起来，装到键值对Dict集合中，以客户端IP:端口作为key dict.Add(client.Client.RemoteEndPoint.ToString(), client); //为每个服务端通信套接字创建一个单独的通信线程，负责调用通信套接字方法，监听客户端发来的数据 //创建通信线程 threadCommunicate = new Thread(acceptClientConnect); threadCommunicate.Start(client);//有传入参数的线程 } } private void acceptClientConnect(object client)//接收信息 { string msgUsers = "LIST"; string ipstr = null; try { TcpClient tcpClient = (TcpClient)client; nsStream = tcpClient.GetStream(); //byte[] ppp = new byte[100000]; //tcpClient.Client.Receive(ppp); string str = Convert.ToString(tcpClient.Client.RemoteEndPoint);//发消息的客户端的信息 ChatContent.BeginInvoke(new Action(() => { ChatContent.Text = ChatContent.Text.Insert(0, str + "：已连接\n"); })); //listlist(); msgUsers = "LIST"; foreach (TcpClient p in clients) { ipstr = Convert.ToString(p.Client.RemoteEndPoint);//所有客户端信息 msgUsers = msgUsers + "|" + ipstr; } foreach (TcpClient p in clients) { nsStream = p.GetStream(); Byte[] bytes = System.Text.Encoding.Default.GetBytes(msgUsers.ToCharArray()); nsStream.Write(bytes, 0, bytes.Length);//发送所有客户端信息到连接的客户端 } while (true) { try { byte[] buff = new byte[4096]; int len; string msg;// msg1 = Convert.ToString(client_list.Text); len = nsStream.Read(buff, 0, buff.Length); msg = System.Text.Encoding.Default.GetString(buff, 0, len); string[] accept = msg.Split(new char[] { '|' }); if (accept[0] == "msg")//发送到服务器 ChatContent.BeginInvoke(new Action(() => { ChatContent.Text = ChatContent.Text.Insert(0, str + "：" + accept[1] + "\n"); })); else if (accept[0] == "pmsg")//点对点发送 { nsStream = dict[accept[1]].GetStream(); Byte[] bytes2 = System.Text.Encoding.Default.GetBytes((str+"——>我："+accept[accept.Length - 1]).ToCharArray()); nsStream.Write(bytes2, 0, bytes2.Length); ChatContent.BeginInvoke(new Action(() => { ChatContent.AppendText(str + "——>" + accept[1] + "：" + accept[accept.Length - 1]); }), null);//显示在服务器列表 }//发送到指定客户端 else if (accept[0] == "STOP")//断开连接 { clients.Remove(tcpClient); //listlist(); msgUsers = "LIST"; foreach (TcpClient p in clients) { ipstr = Convert.ToString(p.Client.RemoteEndPoint);//所有客户端信息 msgUsers = msgUsers + "|" + ipstr; } foreach (TcpClient p in clients) { nsStream = p.GetStream(); Byte[] bytes = System.Text.Encoding.Default.GetBytes(msgUsers.ToCharArray()); nsStream.Write(bytes, 0, bytes.Length);//发送所有客户端信息到连接的客户端 } client_list.BeginInvoke(new Action(() => { int index = client_list.Items.IndexOf(str); client_list.Items.RemoveAt(index); } ), null); ChatContent.BeginInvoke(new Action(() => { ChatContent.Text = ChatContent.Text.Insert(0, str + "：" + accept[1] + "\n"); })); //tcpClient.Close();//关闭连接 return; } } catch (Exception ex) { ChatContent.BeginInvoke(new Action(() => { ChatContent.Text = ChatContent.Text.Insert(0, "错误信息：" + ex.Message + "\n"); }), null); break; } } } catch (Exception ) { } } private void stop_btn_Click(object sender, EventArgs e)//关闭服务器 { start_btn.Enabled = true; stop_btn.Enabled = false; ChatContent.Text = ChatContent.Text.Insert(0, "服务器已关闭\n"); server.Stop(); } private void serverMain_Load(object sender, EventArgs e) { Info.ServerListBox = this.client_list; } private void stop_btn_Click_1(object sender, EventArgs e) { } } } /* Action pAction = new Action(() => { try { while (true) { TcpClient client; client = server.AcceptTcpClient(); clients.Add(client); //this.ChatContent.AppendText("用户已连接\n"); //Socket s = client.Client; //client_ip = IPAddress.Parse(GetRemoteIP(client)); Thread listenthread = new Thread(new ParameterizedThreadStart(listenForClient)); listenthread.Start(client); } } catch (Exception ex) { //this.ChatContent.AppendText(ex.Message+"\n"); } }); //pAction.BeginInvoke(null, null); } private void listenForClient(object client) { TcpClient tcpClient = (TcpClient)client; //Socket s = tcpClient.Client; //IPAddress client_ip = IPAddress.Parse(GetRemoteIP(tcpClient)); //int port = Convert.ToInt32(GetRemotePort(tcpClient));//获取IP和端口 //ChatContent.AppendText("用户："+client_ip+":"+port+"已连接\n"); nsStream = tcpClient.GetStream(); byte[] buff = new byte[4096]; int len; string msg; //Invoke(new addHandler(add), ChatContent, msg); while (true) { try { len = nsStream.Read(buff, 0, buff.Length); msg = System.Text.Encoding.Default.GetString(buff, 0, len); ChatContent.AppendText(msg); } catch (Exception ex) { ChatContent.AppendText(ex.Message+"\n"); } }*/

c# 调用webserver上传文件时候出现的问题

``` 客户端代码 WebReference.WebService1 webserver = new WebReference.WebService1(); string path = txtPath.Text.Trim();//本地路径 byte[] bytes = GetBytesByPath(path);//获取文件byte[] string uploadPath = comdirectory.Text;//上传服务器文件夹路径 webserver.UploadFile(bytes, uploadPath, FileName); ``` webserver 上的 ``` public bool UploadFile(byte[] fs, string path, string fileName) { bool flag = false; try { path = Server.MapPath(path); if (!Directory.Exists(path)) { Directory.CreateDirectory(path); } //定义并实例化一个内存流，以存放提交上来的字节数组。 MemoryStream m = new MemoryStream(fs); //定义实际文件对象，保存上载的文件。 FileStream f = new FileStream(path + "\\" + fileName, FileMode.Create); //把内内存里的数据写入物理文件 m.WriteTo(f); m.Close(); f.Close(); f = null; m = null; flag = true; } catch (Exception ex) { flag = false; } return flag; } ``` 这里上传大点的文件(3M以上)就会报错 Not Found。和最大请求长度超过了如何解决这个问题呢？

窗口中socket通信服务器向客户端发消息,客户端自动返回:繁忙,下面是客户端代码:

// 接收数据信息 public void ReceiveMsg() { while (true) { try { byte[] date = new byte[1024]; int recv = socket.Receive(date); string str = Encoding.UTF8.GetString(date,0,recv); } catch (SocketException ex) { } } } public void listTest(Object o, EventArgs e, String str) { this.richTextBox1.Text = str; } //设置控件状态 public void Status(Object o, EventArgs e) { lblStatus.Text = "连接成功."; button1.Enabled = false; } //回调（异步调用连接请求） private static void ConnectCallback(IAsyncResult er) { try { // 获取到异步操作信息 Socket client = (Socket)er.AsyncState; UpdateStatus(new Form1(), new EventArgs()); StateObjcet state = new StateObjcet(); state.workSocket = client; client.BeginReceive(state.buffer, 0, StateObjcet.BufferSize, 0, new AsyncCallback(ReceiveCallback), state); // Receive(client); // 结束挂起异步连接操作请求 //client.EndConnect(er); } catch(Exception e) { MessageBox.Show(e.ToString()); return; } } //异步发送信息 /// <summary> /// 异步发送 /// </summary> /// <param name="er"></param> private static void SendCallback(IAsyncResult er) { try { //获取异步对象异步操作信息 Socket Client = (Socket)er.AsyncState; //挂起异步发送请求 int byteSend = Client.EndSend(er); } catch (Exception e) { MessageBox.Show(e.ToString()); } } /// <summary> ///读取Socket 套接字 /// </summary> /// <param name="client"></param> private static void Receive(Socket client) { try { StateObjcet state = new StateObjcet(); state.workSocket=client; client.BeginReceive(state.buffer,0,StateObjcet.BufferSize,0,new AsyncCallback(ReceiveCallback),state); }catch(Exception e) { MessageBox.Show(e.ToString()); } } /// <summary> /// 异步挂起 /// </summary> /// <param name="er"></param> private static void ReceiveCallback(IAsyncResult er) { try { //异步操作获取用户定义信息 StateObjcet state = (StateObjcet)er.AsyncState; Socket client = state.workSocket; //结束挂起异步读取 int bytebuffer = client.EndReceive(er); if (bytebuffer > 0) { UpdateList(new Form1(), new EventArgs(), Encoding.ASCII.GetString(state.buffer, 0, bytebuffer)); state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytebuffer)); client.BeginReceive(state.buffer, 0, StateObjcet.BufferSize, 0, new AsyncCallback(ReceiveCallback), state); } else { if (state.sb.Length > 1) { response = state.sb.ToString(); } receiveDone.Set(); client.Close(); } } catch (Exception e) { MessageBox.Show(e.ToString()); } } private void button2_Click(object sender, EventArgs e) { if (richTextBox2.Text.Trim() == "") return; else if (richTextBox2.Text.Trim().ToLower() == "clear()") { richTextBox1.Clear(); richTextBox2.Text = ""; return; } else if (Regex.IsMatch(richTextBox2.Text.Trim().ToLower(), @"^[zoom(]+[\d]+[)]$")) { string str = richTextBox2.Text.ToLower(); int size = Convert.ToInt32(str.Substring(str.LastIndexOf('(') + 1, str.IndexOf(')') - str.LastIndexOf('(') - 1)); richTextBox1.Font = new Font("宋体", size, FontStyle.Bold); return; } try { Byte[] bs; string user = null; if (txtUser.Text.Trim() == "在此输入你的名字" || txtUser.Text.Trim() == "") { user = "我"; bs = Encoding.Unicode.GetBytes(string.Format("对方说:({0})\r\n{1}\r\n", DateTime.Now.ToString(),richTextBox2.Text.Trim())); } else { bs = Encoding.Unicode.GetBytes(string.Format("{0}说:({1})\r\n{2}\r\n", txtUser.Text.Trim(),DateTime.Now.ToString(),richTextBox2.Text.Trim())); user = txtUser.Text.Trim(); } bs = System.Text.Encoding.UTF8.GetBytes(richTextBox2.Text); //发现UTF8可支持中文,就用之 socket.BeginSend(bs, 0, bs.Length, 0, new AsyncCallback(SendCallback), socket); txt = string.Format("{0}说:({1})\r\n{2}\r\n", user, DateTime.Now.ToString(), richTextBox2.Text.Trim()); int tempLen = richTextBox1.Text.Length; richTextBox1.AppendText(txt); richTextBox1.Select(tempLen, txt.Length); richTextBox1.SelectionFont = new Font("宋体", 10); richTextBox1.SelectionColor = Color.Red; richTextBox2.Clear(); } catch(Exception ex) { MessageBox.Show("连接尚未建立！无法发送数据!" + ex.Message); } } private void getlocalip(string myip) //dw20150214 { // 获取到本机IP //自动获取到本机电脑端口 IP = IPAddress.Parse(txtIP.Text.Trim()); int point = Convert.ToInt32(txtPoint.Text.Trim()); endpoint = new IPEndPoint(IP, point); } private void Form1_Load(object sender, EventArgs e) { getlocalip(GetServerIP().ToString()); //dw20150214 //建立Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); } private void txtIP_TextChanged(object sender, EventArgs e) { } private void TheradScoket() { Thread TempThread; //开启接收线程 TempThread = new Thread(new ThreadStart(this.ToConnect)); TempThread.IsBackground = true;//设置为后台线程 TempThread.Start(); TempThread.Abort();//关闭线程 Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //关闭套接字 client.Close(); } private void Form1_FormClosing(object sender, FormClosingEventArgs e) { TheradScoket(); // socket.Close(); } } }

c#异步通信代码错误问题

public void ConnectCallback(IAsyncResult ar) { Socket client = (Socket)ar.AsyncState; client.EndConnect(ar); bool connect_flag = false; connect_flag = true; ManualResetEvent connectDone = new ManualResetEvent(false); //连接的信号 connectDone.Set(); } //vs的这段代码中，bool connect_flag的connect_flag报了一个警告错误，变量connect_flag已赋值，但是其值从未使用过。如何修改？ public static MODEL.DataSourceVersionQuery BrowseDataSource_QueryVersionData() { MODEL.DataSourceVersionQuery result = new MODEL.DataSourceVersionQuery(); //获取数据包 string strPacket = BrowseDataSource_PrepareVersionPacket(); //向服务端提交查询版本信息 string str = DAL.socket.GetSocketData(strPacket); //DAL.socket.GetSocketData(strPacket) vs报了一个错误，非静态字段、方法或属性DAL.socket.GetSocketData(string)“要求对象引用。如何修改？还有这个错误![图片说明](https://img-ask.csdn.net/upload/201509/16/1442412249_893824.png) 另外我想把DAL中的socket.cs的 public byte[] bytesReceived { get; set; }这段移动到Model中而不报错要如何修改？ DAL中socket完整代码如下： using Newtonsoft.Json; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading.Tasks; using System.ComponentModel; using System.Data; using System.Windows.Forms; using System.Threading; namespace DAL { /// <summary> /// Socket接口 /// </summary> class socket { //Socket public Socket clientSocket; /// <summary> /// socket连接 /// </summary> /// <returns> /// true 成功 /// false 失败 /// </returns> public bool SocketConnect() { byte[] bytesReceived = new byte[256]; ManualResetEvent connectDone = new ManualResetEvent(false); //连接的信号 ManualResetEvent sendDone = new ManualResetEvent(false); //发送结束 //从配置文件获取IP string SocketIP = DAL.Common.ReadConfigString("Recover", "IP"); //从配置文件获取端口 int SocketPort = Convert.ToInt32(DAL.Common.ReadConfigString("Recover", "Port")); //创建IP地址 IPAddress IP = IPAddress.Parse(SocketIP); try { //创建socket实例 clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建网络端点 IPEndPoint ipEnd = new IPEndPoint(IP, SocketPort); //与目标终端连接 clientSocket.BeginConnect(ipEnd, new AsyncCallback(ConnectCallback), clientSocket);//调用回调函数 connectDone.WaitOne(); if (clientSocket.Connected) { return true; } else { return false; } } catch (Exception e) { string strError = ""; strError += "\r\n SocketIP = " + SocketIP.ToString(); strError += "\r\n SocketPort = " + SocketPort.ToString(); DAL.Common.WriteErrorLog(e, strError); return false; } } /// <summary> /// 异步连接的回调函数 /// </summary> /// <param name="ar"></param> public void ConnectCallback(IAsyncResult ar) { Socket client = (Socket)ar.AsyncState; client.EndConnect(ar); bool connect_flag = false; connect_flag = true; ManualResetEvent connectDone = new ManualResetEvent(false); //连接的信号 connectDone.Set(); } /// <summary> /// Socket发送数据 /// </summary> /// <param name="strSend"> /// 数据的内容 /// </param> public void SocketSend(string strSend) { Socket clientSocket; //发送创建套接字 int length = strSend.Length; Byte[] bytesSent = new byte[length]; clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try { bytesSent = System.Text.Encoding.Default.GetBytes(strSend); //将字符串指定到指定Byte数组 clientSocket.BeginSend(bytesSent, 0, bytesSent.Length, 0, new AsyncCallback(SendCallback), clientSocket); //异步发送数据 ManualResetEvent sendDone = new ManualResetEvent(false);//发送结束 sendDone.WaitOne(); } catch (Exception e) { string strError = ""; DAL.Common.WriteErrorLog(e, strError); } } public void SendCallback(IAsyncResult ar) //发送的回调函数 { ManualResetEvent sendDone = new ManualResetEvent(false); //发送结束 Socket client = (Socket)ar.AsyncState; int bytesSend = client.EndSend(ar); //完成发送 sendDone.Set(); } /// <summary> /// Socket接收数据 /// </summary> /// <returns> /// 收到的数据 /// </returns> public string SocketReceive() { string result = ""; try { MemoryStream stream = new MemoryStream(); Byte[] bytesReceived = new Byte[256]; clientSocket.BeginReceive(bytesReceived, 0, bytesReceived.Length, 0, new AsyncCallback(ReceiveCallback), clientSocket); ManualResetEvent sendDone = new ManualResetEvent(false); //发送结束 sendDone.WaitOne(); } catch (Exception e) { string strError = ""; DAL.Common.WriteErrorLog(e, strError); } return result; } public void ReceiveCallback(IAsyncResult ar) { Socket client = (Socket)ar.AsyncState; //获取句柄 int bytesread = client.EndReceive(ar); if (bytesread > 0) { clientSocket.BeginReceive(bytesReceived, 0, bytesReceived.Length, 0, new AsyncCallback(ReceiveCallback), client); string content = Encoding.ASCII.GetString(bytesReceived, 0, bytesReceived.Length); } else { ManualResetEvent readDone = new ManualResetEvent(false); //读信号 readDone.Set(); } } /// <summary> /// Socket通信 /// </summary> /// <param name="strSend"> /// 发送的信息 /// </param> /// <returns> /// 包体的内容 /// </returns> public string GetSocketData(string strSend) { string strDatas = ""; string strResult = ""; string strExtLength = ""; try { //Socket连接 SocketConnect(); //发送信息 SocketSend(strSend); //接收服务器的信息 strResult = SocketReceive(); //获取扩展信息的长度 strExtLength = strResult.Substring(16, 12); int ExtLength = Convert.ToInt32(strExtLength); //扩展信息，暂不使用 //string strExtInfo = strResult.Substring(32, ExtLength); //获取包体的内容 strDatas = strResult.Substring(ExtLength + 32); //strDatas = decodedString; } catch (Exception e) { string strError = ""; strError += "\r\n strResult = " + strResult; strError += "\r\n strExtLength = " + strExtLength; DAL.Common.WriteErrorLog(e, strError); strDatas = ""; } return strDatas; } public string SocketReceiveFile(string FileName) { string result = ""; try { MemoryStream streamPacketLength = new MemoryStream(); Byte[] bytesPacketLength = new Byte[16]; clientSocket.Receive(bytesPacketLength, bytesPacketLength.Length, 0); streamPacketLength.Write(bytesPacketLength, 0, bytesPacketLength.Length); result = System.Text.Encoding.Default.GetString(streamPacketLength.ToArray()); int PacketLength = Convert.ToInt32(result); streamPacketLength.Close(); MemoryStream streamExtLength = new MemoryStream(); Byte[] bytesExtLength = new Byte[12]; clientSocket.Receive(bytesExtLength, bytesExtLength.Length, 0); streamExtLength.Write(bytesExtLength, 0, bytesExtLength.Length); result = System.Text.Encoding.Default.GetString(streamExtLength.ToArray()); int ExtLength = Convert.ToInt32(result); streamExtLength.Close(); MemoryStream streamProtocol = new MemoryStream(); Byte[] bytesProtocol = new Byte[4]; clientSocket.Receive(bytesProtocol, bytesProtocol.Length, 0); streamProtocol.Write(bytesProtocol, 0, bytesProtocol.Length); result = System.Text.Encoding.Default.GetString(streamProtocol.ToArray()); string Protocol = result; streamProtocol.Close(); MemoryStream streamExtInfo = new MemoryStream(); Byte[] bytesExtInfo = new Byte[ExtLength]; clientSocket.Receive(bytesExtInfo, bytesExtInfo.Length, 0); streamExtInfo.Write(bytesExtInfo, 0, bytesExtInfo.Length); result = System.Text.Encoding.Default.GetString(streamExtInfo.ToArray()); byte[] Buffer = Convert.FromBase64String(result); string strExtInfo = UTF8Encoding.UTF8.GetString(Buffer); streamExtInfo.Close(); MODEL.FileTrackQuery ExtInfo = new MODEL.FileTrackQuery(); ExtInfo = JsonConvert.DeserializeObject<MODEL.FileTrackQuery>(strExtInfo); if (ExtInfo.code == "00") { FileInfo fi = new FileInfo(FileName); DirectoryInfo di = fi.Directory; if (!di.Exists) { di.Create(); } FileStream streamPacketInfo = new FileStream(FileName, FileMode.Create); if (PacketLength > 0) { Byte[] bytesPacketInfo = new Byte[PacketLength]; int bytes = 0; do { bytes = clientSocket.Receive(bytesPacketInfo, bytesPacketInfo.Length, 0); streamPacketInfo.Write(bytesPacketInfo, 0, bytes); } while (bytes > 0); } streamPacketInfo.Close(); } clientSocket.Close(); string strLogFile = System.AppDomain.CurrentDomain.BaseDirectory + "debug.txt"; StreamWriter sw = new StreamWriter(strLogFile, true); sw.WriteLine("PacketLength : " + PacketLength.ToString()); sw.WriteLine("ExtLength : " + ExtLength.ToString()); sw.WriteLine("strExtInfo : " + strExtInfo); sw.WriteLine("ExtInfo.code : " + ExtInfo.code); sw.WriteLine("\n------------------------------------------------------------------------\n"); sw.Flush(); sw.Close(); } catch (Exception e) { string strError = ""; DAL.Common.WriteErrorLog(e, strError); } return result; } public string GetSocketFile(string strSend, string FileName) { string strDatas = ""; string strResult = ""; string strExtLength = ""; try { //Socket连接 SocketConnect(); //发送信息 SocketSend(strSend); //接收服务器的信息 strResult = SocketReceiveFile(FileName); //获取扩展信息的长度 //strExtLength = strResult.Substring(16, 12); //int ExtLength = Convert.ToInt32(strExtLength); //扩展信息，暂不使用 //string strExtInfo = strResult.Substring(32, ExtLength); //获取包体的内容 //strDatas = strResult.Substring(ExtLength + 32); } catch (Exception e) { string strError = ""; strError += "\r\n strResult = " + strResult; strError += "\r\n strExtLength = " + strExtLength; DAL.Common.WriteErrorLog(e, strError); strDatas = ""; } return strDatas; } public byte[] bytesReceived { get; set; } } } MODEL完整代码如下： using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace MODEL { public enum ClientEditionEnum { Enterprise,//企业版 Personal,//个人版 Internal,//内部版 None,//error } /// <summary> /// 授权文件内容 /// </summary> public class AuthorizeFileInfo { public string startTime { get; set; } public string expiryTime { get; set; } public string licenseID { get; set; } public string licensePassword { get; set; } public string terminalID { get; set; } public string customName { get; set; } public string customID { get; set; } public AuthorizeFileInfo() { startTime = ""; expiryTime = ""; licenseID = ""; licensePassword = ""; terminalID = ""; customName = ""; customID = ""; } } /// <summary> /// 通用返回值 /// </summary> /// public class CommonResult { public string code { get; set; } public string message { get; set; } public CommonResult() { code = ""; message = ""; } } public class EnterpriseConfirmAuthorizeDatas { public string sessionID { get; set; } public EnterpriseConfirmAuthorizeDatas() { sessionID = ""; } } /// <summary> /// 企业版授权校验接口 /// </summary> public class EnterpriseConfirmAuthorizeResult { public string code { get; set; } public string message { get; set; } public EnterpriseConfirmAuthorizeDatas datas { get; set; } public EnterpriseConfirmAuthorizeResult() { code = ""; message = ""; datas = new EnterpriseConfirmAuthorizeDatas(); } } public class PersonalConfirmAuthorizeDatas { public string sessionID { get; set; } public string licenseInfo { get; set; } public PersonalConfirmAuthorizeDatas() { sessionID = ""; licenseInfo = ""; } } /// <summary> /// 个人版授权校验接口 /// </summary> public class PersonalConfirmAuthorizeResult { public string code { get; set; } public string message { get; set; } public PersonalConfirmAuthorizeDatas datas { get; set; } public PersonalConfirmAuthorizeResult() { code = ""; message = ""; datas = new PersonalConfirmAuthorizeDatas(); } } /// <summary> /// 鉴权信息，每次调用安全接口时使用 /// </summary> public class LicInfo { public string licenseID { get; set; } public string licensePassword { get; set; } public string terminalID { get; set; } public string deviceID { get; set; } public string sessionID { get; set; } public LicInfo() { licenseID = ""; licensePassword = ""; terminalID = ""; deviceID = ""; sessionID = ""; } } /// <summary> /// java引擎的参数 /// </summary> public class JavaEngineArg { public string licenseID { get; set; } public string licensePassword { get; set; } public string terminalID { get; set; } public string customName { get; set; } public string customID { get; set; } public string deviceID { get; set; } public JavaEngineArg() { licenseID = ""; licensePassword = ""; terminalID = ""; customName = ""; customID = ""; deviceID = ""; } } /// <summary> /// 用户登录接口（一），非安全接口 /// </summary> /// public class UserInfoUnSafe { public string userID { get; set; } public string userName { get; set; } public string departmentName { get; set; } public UserInfoUnSafe() { userID = ""; userName = ""; departmentName = ""; } } public class UserLoginUnSafe { public string code { get; set; } public string message { get; set; } public UserInfoUnSafe datas { get; set; } public UserLoginUnSafe() { code = ""; message = ""; datas = new UserInfoUnSafe(); } } /// <summary> /// 个人版用户登录接口，非安全接口 /// </summary> /// public class UserInfoForPersonal { public string userID { get; set; } public string userName { get; set; } public string departmentName { get; set; } public string licenseInfo { get; set; } public UserInfoForPersonal() { userID = ""; userName = ""; departmentName = ""; licenseInfo = ""; } } public class UserLoginForPersonal { public string code { get; set; } public string message { get; set; } public UserInfoForPersonal datas { get; set; } public UserLoginForPersonal() { code = ""; message = ""; datas = new UserInfoForPersonal(); } } /// <summary> /// 用户登录接口（二），安全接口 /// </summary> /// public class UserInfoSafe { public string userSessionID { get; set; } public string userID { get; set; } public string userName { get; set; } public string departmentName { get; set; } public string activeTime { get; set; } public UserInfoSafe() { userSessionID = ""; userID = ""; userName = ""; departmentName = ""; activeTime = ""; } } public class UserLoginSafe { public string code { get; set; } public string message { get; set; } public UserInfoSafe datas { get; set; } public UserLoginSafe() { code = ""; message = ""; datas = new UserInfoSafe(); } } /// <summary> /// 更新检查接口 /// </summary> /// public class SingleVersion { public string softID { get; set; } public int version { get; set; } public SingleVersion() { softID = ""; version = new int(); } } public class Versions { public List<SingleVersion> versions { get; set; } public Versions() { versions = new List<SingleVersion>(); } } public class VersionUpdate { public string softID { get; set; } public int version { get; set; } public string url { get; set; } public VersionUpdate() { softID = ""; version = new int(); url = ""; } } public class VersionCheck { public string code { get; set; } public string message { get; set; } public List<VersionUpdate> datas { get; set; } public VersionCheck() { code = ""; message = ""; datas = new List<VersionUpdate>(); } } /// <summary> /// 数据源信息查询接口 /// </summary> /// public class OptInfoQuery { public string createUserID { get; set; } public string createUserName { get; set; } public string createUserTime { get; set; } public OptInfoQuery() { createUserID = ""; createUserName = ""; createUserTime = ""; } } public class Period { public int cycle { get; set; } public int cycleUnit { get; set; } public string timer { get; set; } public Period() { cycle = 1; cycleUnit = 1; timer = DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"); } } public class StrategyConfig { public int backType { get; set; } public int taskType { get; set; } public Period config { get; set; } public StrategyConfig() { backType = 0; taskType = 1; config = new Period(); } } public class FilterFileSuffix { public string suffix { get; set; } public FilterFileSuffix() { suffix = ""; } } public class Scan { public int scanType { get; set; } public string root { get; set; } public bool scanHideFile { get; set; } public string verifyCompleteName { get; set; } public int verifyCompleteMaxCount { get; set; } public int verifyCompleteTimer { get; set; } public string fileAttrGainer { get; set; } public bool recordCanNotReadFileInfo { get; set; } public bool recordEmptyDirectory { get; set; } public bool recordEmptyFile { get; set; } public List<FilterFileSuffix> filterFileSuffix { get; set; } public Scan() { scanType = 2; root = ""; scanHideFile = false; verifyCompleteName = ""; verifyCompleteMaxCount = 5; verifyCompleteTimer = 10000; fileAttrGainer = "null"; recordCanNotReadFileInfo = false; recordEmptyDirectory = false; recordEmptyFile = false; filterFileSuffix = new List<FilterFileSuffix>(); } } public class DataSourceConfigQuery { public int status { get; set; } public int dataSourceType { get; set; } public string dataSourceID { get; set; } public string dataSourceName { get; set; } public string dataSourceDescription { get; set; } public Scan config { get; set; } public DataSourceConfigQuery() { status = 0; dataSourceType = 0; dataSourceID = ""; dataSourceName = ""; dataSourceDescription = ""; config = new Scan(); } } public class DatasQuery { public OptInfoQuery optInfo { get; set; } public StrategyConfig strategyConfig { get; set; } public DataSourceConfigQuery dataSourceConfig { get; set; } public DatasQuery() { optInfo = new OptInfoQuery(); strategyConfig = new StrategyConfig(); dataSourceConfig = new DataSourceConfigQuery(); } } public class DataSourceInfoQuery { public string code { get; set; } public string message { get; set; } public List<DatasQuery> datas { get; set; } public DataSourceInfoQuery() { code = ""; message = ""; datas = new List<DatasQuery>(); } } public class WebSite { public string ExpirationTime { get; set; } public string WebSiteSpace { get; set; } public bool DataBaseEnable { get; set; } public string DataBaseUserName { get; set; } public string DataBasePassword { get; set; } public string DataBaseMark { get; set; } public string WebSiteAdmin { get; set; } public string WebSitePassword { get; set; } public WebSite() { ExpirationTime = ""; WebSiteSpace = ""; DataBaseEnable = false; DataBaseUserName = ""; DataBasePassword = ""; DataBaseMark = ""; WebSiteAdmin = ""; WebSitePassword = ""; } } public class WebSiteDatasQuery { public OptInfoQuery optInfo { get; set; } public StrategyConfig strategyConfig { get; set; } public DataSourceConfigQuery dataSourceConfig { get; set; } public WebSite webSiteConfig { get; set; } public WebSiteDatasQuery() { optInfo = new OptInfoQuery(); strategyConfig = new StrategyConfig(); dataSourceConfig = new DataSourceConfigQuery(); webSiteConfig = new WebSite(); } } public class WebSiteDataSourceInfoQuery { public string code { get; set; } public string message { get; set; } public List<WebSiteDatasQuery> datas { get; set; } public WebSiteDataSourceInfoQuery() { code = ""; message = ""; datas = new List<WebSiteDatasQuery>(); } } /// <summary> /// 新增数据源接口 /// </summary> /// public class OptInfoNew { public bool forceFlag { get; set; } public OptInfoNew() { forceFlag = true; } } public class DataSourceConfigNew { public int dataSourceType { get; set; } public string dataSourceName { get; set; } public string dataSourceDescription { get; set; } public Scan config { get; set; } public DataSourceConfigNew() { dataSourceType = 0; dataSourceName = ""; dataSourceDescription = ""; config = new Scan(); } } public class DataSourceNew { public OptInfoNew optInfo { get; set; } public StrategyConfig strategyConfig { get; set; } public DataSourceConfigNew dataSourceConfig { get; set; } public DataSourceNew() { optInfo = new OptInfoNew(); strategyConfig = new StrategyConfig(); dataSourceConfig = new DataSourceConfigNew(); } } /// <summary> /// 修改数据源接口 /// </summary> /// public class DataSourceModify { public StrategyConfig strategyConfig { get; set; } public DataSourceConfigQuery dataSourceConfig { get; set; } public DataSourceModify() { strategyConfig = new StrategyConfig(); dataSourceConfig = new DataSourceConfigQuery(); } } /// <summary> /// 停用/启用数据源接口 /// </summary> /// public class DataSourceStatus { public string dataSourceID { get; set; } public int optType { get; set; } public DataSourceStatus() { dataSourceID = ""; optType = new int(); } } /// <summary> /// 数据源数据，仅用于存放数据 /// </summary> /// public class DataSourceData { public List<DatasQuery> datas { get; set; } public DataSourceData() { datas = new List<DatasQuery>(); } } /// <summary> /// WebSite数据源数据，仅用于存放数据 /// </summary> /// public class WebSiteDataSourceData { public List<WebSiteDatasQuery> datas { get; set; } public WebSiteDataSourceData() { datas = new List<WebSiteDatasQuery>(); } } /// <summary> /// 文件恢复，版本查询 /// </summary> /// public class DataSourceVersionArg { // 通讯令牌 public string secretKey { get; set; }//由token进过MD5->BASE64->MD5获得 // 任务令牌 public string token { get; set; }//客户端生成一个UUID // 前置机编号 public string terminalId { get; set; } // 操作用户编号 public string optUserID { get; set; } public DataSourceVersionArg() { secretKey = ""; token = ""; terminalId = ""; optUserID = ""; } } public class FileVersions { public int file_count { get; set; } public long space_size { get; set; } public string task_id { get; set; } public string task_time { get; set; } public int total_count { get; set; } public string version { get; set; } public FileVersions() { file_count = new int(); space_size = new long(); task_id = ""; task_time = ""; total_count = new int(); version = ""; } } public class DataSourceVersion { public Scan datasourceConfig { get; set; } public string datasourceId { get; set; } public string datasourceName { get; set; } public int datasourceStatus { get; set; } public int datasourceType { get; set; } public List<FileVersions> versions { get; set; } public DataSourceVersion() { datasourceConfig = new Scan(); datasourceId = ""; datasourceName = ""; datasourceStatus = new int(); datasourceType = new int(); versions = new List<FileVersions>(); } } /// <summary> /// 查询数据源接口 /// </summary> public class DataSourceVersionQuery { public string code { get; set; } public string message { get; set; } public List<DataSourceVersion> datas { get; set; } public DataSourceVersionQuery() { code = ""; message = ""; datas = new List<DataSourceVersion>(); } } /// <summary> /// 数据源版本信息 /// </summary> public class DataSourceVersionDatas { public List<DataSourceVersion> datas { get; set; } public DataSourceVersionDatas() { datas = new List<DataSourceVersion>(); } } /// <summary> /// 文件恢复，文件信息查询 /// </summary> /// public class QueryFileInfoArg { // 通讯令牌 public string secretKey { get; set; }//由token进过MD5->BASE64->MD5获得 // 任务令牌 public string token { get; set; }//客户端生成一个UUID // 数据源编号 public string datasourceId { get; set; } // 操作用户编号 public string optUserID { get; set; } // 目录文件编号--如果为根目录使用 DS_ROOT public string fileID { get; set; } // 查询的版本编号如果是综合分析这个字段设置为 ALL public string taskID { get; set; } public QueryFileInfoArg() { secretKey = ""; token = ""; datasourceId = ""; optUserID = ""; fileID = ""; taskID = ""; } } public class FileInfoCondition { public string datasourceId { get; set; } public string parentId { get; set; } public string taskID { get; set; } public FileInfoCondition() { datasourceId = ""; parentId = ""; taskID = ""; } } public class FileInfo { // 文件唯一编号 public string file_id { get; set; } // 源相对目录 public string file_src_path { get; set; } // 文件名 public string file_name { get; set; } // 文件后缀 public string file_suffix { get; set; } // 是否为文件 public bool is_file { get; set; } // 上级文件编号 public string parent_id { get; set; } // 是否删除 public bool is_del { get; set; } // 是否隐藏 public bool is_hide { get; set; } // 文件大小 public int size { get; set; } // 文件创建时间 public string create_time { get; set; } // 文件创建人 public string create_user { get; set; } // 文件最后修改时间 public string lm_time { get; set; } // 文件最后修改人 public string lm_user { get; set; } // 是否可读 public bool can_read { get; set; } public FileInfo() { file_id = ""; file_src_path = ""; file_name = ""; file_suffix = ""; is_file = new bool(); parent_id = ""; is_del = new bool(); is_hide = new bool(); size = new int(); create_time = ""; create_user = ""; lm_time = ""; lm_user = ""; can_read = new bool(); } } public class FileInfoAndCondition { public FileInfoCondition condition { get; set; } public List<FileInfo> fileInfos { get; set; } public FileInfoAndCondition() { condition = new FileInfoCondition(); fileInfos = new List<FileInfo>(); } } /// <summary> /// 查询文件信息接口 /// </summary> public class FileInfoQuery { public string code { get; set; } public string message { get; set; } public FileInfoAndCondition datas { get; set; } public FileInfoQuery() { code = ""; message = ""; datas = new FileInfoAndCondition(); } } /// <summary> /// 文件信息 /// </summary> public class FileInfoData { public List<FileInfo> datas { get; set; } public FileInfoData() { datas = new List<FileInfo>(); } } public class QueryFileTrackArg { // 通讯令牌 public string secretKey { get; set; }//由token进过MD5->BASE64->MD5获得 // 任务令牌 public string token { get; set; }//客户端生成一个UUID // 文件编号 public string fileID { get; set; } // 操作用户编号 public string optUserID { get; set; } // 查询的版本编号 public string taskID { get; set; } public QueryFileTrackArg() { secretKey = ""; token = ""; fileID = ""; optUserID = ""; taskID = ""; } } public class FileTrack { // 文件操作 public string act_cmd { get; set; } // 是否可读 public bool can_read { get; set; } // 文件创建时间 public string create_time { get; set; } // 文件创建人 public string create_user { get; set; } // 是否删除 public bool is_del { get; set; } // 是否隐藏 public bool is_hide { get; set; } // 文件最后修改时间 public string lm_time { get; set; } // 文件最后修改人 public string lm_user { get; set; } // 文件大小 public int size { get; set; } public string taskID { get; set; } public FileTrack() { act_cmd = ""; can_read = new bool(); create_time = ""; create_user = ""; is_del = new bool(); is_hide = new bool(); lm_time = ""; lm_user = ""; size = new int(); taskID = ""; } } public class FileTrackCondition { public string fileID { get; set; } public string taskID { get; set; } public FileTrackCondition() { fileID = ""; taskID = ""; } } /// <summary> /// 查询文件轨迹接口 /// </summary> public class FileTrackQuery { public string code { get; set; } public string message { get; set; } public FileTrackCondition condition { get; set; } public List<FileTrack> datas { get; set; } public FileTrackQuery() { code = ""; message = ""; condition = new FileTrackCondition(); datas = new List<FileTrack>(); } } /// <summary> /// 文件轨迹 /// </summary> public class FileTrackData { public List<FileTrack> datas { get; set; } public FileTrackData() { datas = new List<FileTrack>(); } } /// <summary> /// 字典item /// </summary> public class DictionaryData { public string version { get; set; } public string task_time { get; set; } public DictionaryData() { version = ""; task_time = ""; } } public class FileRecoverArg { // 通讯令牌 public string secretKey { get; set; }//由token进过MD5->BASE64->MD5获得 // 任务令牌 public string token { get; set; }//客户端生成一个UUID // 操作用户编号 public string optUserID { get; set; } public string fileID { get; set; } public string taskID { get; set; } public string password { get; set; } public FileRecoverArg() { secretKey = ""; token = ""; optUserID = ""; fileID = ""; taskID = ""; password = ""; } } }

pyhon服务器如何用websocke实现服务器和html5的通信（代码已实现成功连接客户端服务端）？

服务端代码 #coding=gbk #coding=utf-8 #-*- coding: UTF-8 -* import struct import socket import re import time #ws握手响应头 import hashlib import base64 from multiprocessing import Process #HTML_ROOT_DIR = r"C:\Users\lenovo\Desktop\html" def write_msg(message): data=struct.pack('B',129)#写入第一个字节 msg_len=len(message)#写入包长度 if(msg_len<=125): data+=struct.pack('B',msg_len) elif(mas_len<=2**16-1): data+=struct.pack('!BH',126,msg_len) elif(mas_len<=2**64-1): data+=struct.pack('!BQ',127,msg_len) else: pass data+=bytes(message,encoding="utf-8") return data def handle_client(client_socket): """ 处理客户端请求 """ # 获取客户端请求数据 #获得key request_data = client_socket.recv(1024) print(request_data) webpage_regex=re.compile('''.*Sec-WebSocket-Key:(.*)''',re.IGNORECASE) key=webpage_regex.findall(request_data.decode("utf-8")) keyy='' try: print(key[0]) keyy=key[0] keyy=keyy.strip() print(keyy) except: pass # 打开文件，读取内容 try: file = open(r"C:\html\shouji\测试\客户端原生socket.html", "rb") except IOError: response_start_line = "HTTP/1.1 404 Not Found\r\n" response_headers = "Server: My server\r\n" response_body = "The file is not found!" response = response_start_line + response_headers + "\r\n" + response_body client_socket.send(bytes(response, "utf-8")) client_socket.close() else: file_data = file.read() file.close() if(keyy==''): response_start_line = "HTTP/1.1 200 OK\r\n" response_headers = "Server: My server\r\n" response_body = file_data.decode("utf-8") response = response_start_line + response_headers + "\r\n" + response_body client_socket.send(bytes(response, "utf-8")) client_socket.close() print('https响应已发送') else: magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11' sha1 = hashlib.sha1() sha1.update((keyy+magic).encode("utf8")) keyy=base64.b64encode(sha1.digest()) print('dddddd',base64.b64encode(sha1.digest())) keyy=keyy.decode("utf8") print('***********************',keyy) response_start_line = "HTTP/1.1 101 Switching Protocols\r\n" response_headers = "Upgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept:"+keyy+"\r\n" response_body = file_data.decode("utf-8") response = response_start_line + response_headers + "\r\n" #+ response_body client_socket.send(bytes(response, "utf-8")) print('ws响应已发送') while(1): time.sleep(5) client_socket.send(bytes('dddd', "utf-8")) #client_socket.send( write_msg('www.baidu.com')) print('发送了一次') # 关闭客户端连接 #client_socket.close() if __name__ == "__main__": server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) server_socket.bind(("0.0.0.0", 8000)) server_socket.listen(128) while True: client_socket, client_address = server_socket.accept() print("[%s, %s]用户连接上了" % client_address) handle_client_process = Process(target=handle_client, args=(client_socket,)) handle_client_process.start() #client_socket.close() 客户端代码： <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title></title> </head> <body> <h2 id="t">史p 芬</h2> <script type="text/javascript" charset="utf-8"> var ws = new WebSocket("ws://127.0.0.1:8000/"); //document.write(Date()); ws.onopen = function(e) { // Check the protocol chosen by the server //console.log(echoSocket.protocol); alert('连接上了') document.write(Date()); //ws.send('已经连接') } // 接受文本消息的事件处理实例： ws.onmessage = function(e) { alert('接受到消息') if(typeof e.data === "string"){ console.log("String message received", e, e.data); } else { console.log("Other message received", e, e.data); } }; ws.onclose = function(e) { alert('连接关闭') console.log("Connection closed", e); }; </script> </body> </html>

由于套接字没有连接并且没有提供地址，发送或接收数据的请求没有被接受？

服务器往客户端发送消息的时候报这个错：错误定在：//异步发送消息请求 server_socket.BeginSend(sendData, 0, sendData.Length, SocketFlags.None, new System.AsyncCallback(SendToServer), server_socket); 但是这是我按着客户端发消息的代码一点点改的不应该有错啊，百思不得原因，希望大佬助我！！！贴上代码： ``` using UnityEngine; using System.Collections; using System.Net.Sockets; using System.Net; using System.Text; public class ServerScript : MonoBehaviour { //收到消息后的委托回调 public delegate void ReceiveCallBack(string content); private string receive_str; Socket server; string msg = ""; //服务器端收到消息的存储空间 byte[] ReceiveBuffer = new byte[1024]; //服务器收到消息后的回调委托 private ReceiveCallBack callback; private Socket server_socket; private readonly object locker = new object(); // Use this for initialization void Start() { //初始化服务器 InitServer((string content) => { receive_str = content; }); } //初始化服务器信息 public void InitServer(ReceiveCallBack cb) { this.callback = cb; // 1. server_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // 2. IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 5001); // 3. server_socket.Bind(endPoint); // 4. server_socket.Listen(10); // 5.开始异步等待客户端的请求链接 server_socket.BeginAccept(new System.AsyncCallback(Accept), server_socket); this.callback("开启服务器" + endPoint.ToString()); } void OnGUI() { if (receive_str != null) { GUILayout.Label(receive_str); } msg = GUI.TextField(new Rect(0, 0, 500, 40), msg); if (GUI.Button(new Rect(0, 50, 100, 30), "Send")) { SendMessage(msg); } } //接受到客户端的链接请求后的回调函数 void Accept(System.IAsyncResult ar) { //获取正在工作的Socket对象 Socket socket = ar.AsyncState as Socket; //存储异步操作的信息，以及用户自定义的数据 Socket worker = socket.EndAccept(ar); SocketError error; //开始异步接收客户端发送消息内容 worker.BeginReceive(ReceiveBuffer, 0, ReceiveBuffer.Length, SocketFlags.None, new System.AsyncCallback(Receive), worker); //继续异步等待新的客户端链接请求 socket.BeginAccept(new System.AsyncCallback(Accept), socket); } //服务端收到客户端的消息后的回调函数 void Receive(System.IAsyncResult ar) { //获取正在工作的Socket对象 Socket worker = ar.AsyncState as Socket; int ByteRead = 0; try { ByteRead = worker.EndReceive(ar); } catch (System.Exception ex) { this.callback(ex.ToString()); } if (ByteRead > 0) { string Content = Encoding.Default.GetString(ReceiveBuffer); this.callback(Content); } //继续异步等待客户端的发送消息请求 worker.BeginReceive(ReceiveBuffer, 0, ReceiveBuffer.Length, SocketFlags.None, new System.AsyncCallback(Receive), worker); } public void SendMessage(string message) { if (message == null) return; message += "\r\n"; byte[] sendData = Encoding.UTF8.GetBytes(message); //异步发送消息请求 server_socket.BeginSend(sendData, 0, sendData.Length, SocketFlags.None, new System.AsyncCallback(SendToServer), server_socket); } //发送消息结束的回调函数 void SendToServer(System.IAsyncResult ar) { Socket worker = ar.AsyncState as Socket; worker.EndSend(ar); } } ``` ![图片说明](https://img-ask.csdn.net/upload/201903/14/1552558158_433687.png)

终于明白阿里百度这样的大公司，为什么面试经常拿ThreadLocal考验求职者了

点击上面↑「爱开发」关注我们每晚10点，捕获技术思考和创业资源洞察什么是ThreadLocalThreadLocal是一个本地线程副本变量工具类，各个线程都拥有一份线程私有的数

程序员必须掌握的核心算法有哪些？

由于我之前一直强调数据结构以及算法学习的重要性，所以就有一些读者经常问我，数据结构与算法应该要学习到哪个程度呢？，说实话，这个问题我不知道要怎么回答你，主要取决于你想学习到哪些程度，不过针对这个问题，我稍微总结一下我学过的算法知识点，以及我觉得值得学习的算法。这些算法与数据结构的学习大多数是零散的，并没有一本把他们全部覆盖的书籍。下面是我觉得值得学习的一些算法以及数据结构，当然，我也会整理一些看过...

《奇巧淫技》系列-python！！每天早上八点自动发送天气预报邮件到QQ邮箱

此博客仅为我业余记录文章所用，发布到此，仅供网友阅读参考，如有侵权，请通知我，我会删掉。补充有不少读者留言说本文章没有用，因为天气预报直接打开手机就可以收到了，为何要多此一举发送到邮箱呢！！！那我在这里只能说：因为你没用，所以你没用！！！这里主要介绍的是思路，不是天气预报！不是天气预报！！不是天气预报！！！天气预报只是用于举例。请各位不要再刚了！！！下面是我会用到的两个场景：每日下

死磕YOLO系列，YOLOv1 的大脑、躯干和手脚

YOLO 是我非常喜欢的目标检测算法，堪称工业级的目标检测，能够达到实时的要求，它帮我解决了许多实际问题。这就是 YOLO 的目标检测效果。它定位了图像中物体的位置，当然，也能预测物体的类别。之前我有写博文介绍过它，但是每次重新读它的论文，我都有新的收获，为此我准备写一个系列的文章来详尽分析它。这是第一篇，从它的起始 YOLOv1 讲起。 YOLOv1 的论文地址：https://www.c...

知乎高赞：中国有什么拿得出手的开源软件产品？(整理自本人原创回答)

知乎高赞：中国有什么拿得出手的开源软件产品？在知乎上，有个问题问“中国有什么拿得出手的开源软件产品（在 GitHub 等社区受欢迎度较好的）？” 事实上，还不少呢~ 本人于2019.7.6进行了较为全面的回答，对这些受欢迎的 Github 开源项目分类整理如下：分布式计算、云平台相关工具类 1.SkyWalking，作者吴晟、刘浩杨等等仓库地址: apache/skywalking 更...

20行Python代码爬取王者荣耀全英雄皮肤

引言王者荣耀大家都玩过吧，没玩过的也应该听说过，作为时下最火的手机MOBA游戏，咳咳，好像跑题了。我们今天的重点是爬取王者荣耀所有英雄的所有皮肤，而且仅仅使用20行Python代码即可完成。准备工作爬取皮肤本身并不难，难点在于分析，我们首先得得到皮肤图片的url地址，话不多说，我们马上来到王者荣耀的官网：我们点击英雄资料，然后随意地选择一位英雄，接着F12打开调试台，找到英雄原皮肤的图片...

简明易理解的@SpringBootApplication注解源码解析（包含面试提问）

欢迎关注文章系列，关注我《提升能力，涨薪可待》《面试知识，工作可待》《实战演练，拒绝996》欢迎关注我博客，原创技术文章第一时间推出也欢迎关注公众号【Ccww笔记】，同时推出如果此文对你有帮助、喜欢的话，那就点个赞呗，点个关注呗！《提升能力，涨薪可待篇》- @SpringBootApplication注解源码解析一、@SpringBootApplication 的作用是什...

西游记团队中如果需要裁掉一个人，会先裁掉谁？

2019年互联网寒冬，大批企业开始裁员，下图是网上流传的一张截图：裁员不可避免，那如何才能做到不管大环境如何变化，自身不受影响呢？我们先来看一个有意思的故事，如果西游记取经团队需要裁员一名，会裁掉谁呢，为什么？西游记团队组成： 1.唐僧作为团队teamleader，有很坚韧的品性和极高的原则性，不达目的不罢休，遇到任何问题，都没有退缩过，又很得上司支持和赏识(直接得到唐太宗的任命，既给袈...

Python语言高频重点汇总

Python语言高频重点汇总 GitHub面试宝典仓库回到首页目录： Python语言高频重点汇总目录： 1. 函数-传参 2. 元类 3. @staticmethod和@classmethod两个装饰器 4. 类属性和实例属性 5. Python的自省 6. 列表、集合、字典推导式 7. Python中单下划线和双下划线 8. 格式化字符串中的%和format 9. 迭代器和生成器 10...

究竟你适不适合买Mac？

我清晰的记得，刚买的macbook pro回到家，开机后第一件事情，就是上了淘宝网，花了500元钱，找了一个上门维修电脑的师傅，上门给我装了一个windows系统。。。。。。表砍我。。。当时买mac的初衷，只是想要个固态硬盘的笔记本，用来运行一些复杂的扑克软件。而看了当时所有的SSD笔记本后，最终决定，还是买个好（xiong）看（da）的。已经有好几个朋友问我mba怎么样了，所以今天尽量客观

程序员一般通过什么途径接私活？

二哥，你好，我想知道一般程序猿都如何接私活，我也想接，能告诉我一些方法吗？上面是一个读者“烦不烦”问我的一个问题。其实不止是“烦不烦”，还有很多读者问过我类似这样的问题。我接的私活不算多，挣到的钱也没有多少，加起来不到 20W。说实话，这个数目说出来我是有点心虚的，毕竟太少了，大家轻喷。但我想，恰好配得上“一般程序员”这个称号啊。毕竟苍蝇再小也是肉，我也算是有经验的人了。唾弃接私活、做外

ES6基础-ES6的扩展

进行对字符串扩展，正则扩展，数值扩展，函数扩展，对象扩展，数组扩展。开发环境准备：编辑器（VS Code, Atom，Sublime）或者IDE（Webstorm）浏览器最新的Chrome 字符串的扩展：模板字符串，部分新的方法，新的unicode表示和遍历方法：部分新的字符串方法 padStart，padEnd，repeat，startsWith，endsWith，includes 字...

Python爬虫爬取淘宝，京东商品信息

小编是一个理科生，不善长说一些废话。简单介绍下原理然后直接上代码。使用的工具（Python+pycharm2019.3+selenium+xpath+chromedriver）其中要使用pycharm也可以私聊我selenium是一个框架可以通过pip下载 pip install selenium -i https://pypi.tuna.tsinghua.edu.cn/simple/

阿里程序员写了一个新手都写不出的低级bug，被骂惨了。

你知道的越多，你不知道的越多点赞再看，养成习惯本文 GitHub https://github.com/JavaFamily 已收录，有一线大厂面试点思维导图，也整理了很多我的文档，欢迎Star和完善，大家面试可以参照考点复习，希望我们一起有点东西。前前言为啥今天有个前前言呢？因为你们的丙丙啊，昨天有牌面了哟，直接被微信官方推荐，知乎推荐，也就仅仅是还行吧（心里乐开花）

Java工作4年来应聘要16K最后没要,细节如下。。。

前奏：今天2B哥和大家分享一位前几天面试的一位应聘者，工作4年26岁，统招本科。以下就是他的简历和面试情况。基本情况：专业技能： 1、 熟悉Sping了解SpringMVC、SpringBoot、Mybatis等框架、了解SpringCloud微服务 2、 熟悉常用项目管理工具：SVN、GIT、MAVEN、Jenkins 3、 熟悉Nginx、tomca

Python爬虫精简步骤1 获取数据

爬虫的工作分为四步： 1.获取数据。爬虫程序会根据我们提供的网址，向服务器发起请求，然后返回数据。 2.解析数据。爬虫程序会把服务器返回的数据解析成我们能读懂的格式。 3.提取数据。爬虫程序再从中提取出我们需要的数据。 4.储存数据。爬虫程序把这些有用的数据保存起来，便于你日后的使用和分析。这一篇的内容就是：获取数据。首先，我们将会利用一个强大的库——requests来获取数据。在电脑上安装

作为一个程序员，CPU的这些硬核知识你必须会！

CPU对每个程序员来说，是个既熟悉又陌生的东西？如果你只知道CPU是中央处理器的话，那可能对你并没有什么用，那么作为程序员的我们，必须要搞懂的就是CPU这家伙是如何运行的，尤其要搞懂它里面的寄存器是怎么一回事，因为这将让你从底层明白程序的运行机制。随我一起，来好好认识下CPU这货吧把CPU掰开来看对于CPU来说，我们首先就要搞明白它是怎么回事，也就是它的内部构造，当然，CPU那么牛的一个东

破14亿，Python分析我国存在哪些人口危机！

2020年1月17日，国家统计局发布了2019年国民经济报告，报告中指出我国人口突破14亿。猪哥的朋友圈被14亿人口刷屏，但是很多人并没有看到我国复杂的人口问题：老龄化、男女比例失衡、生育率下降、人口红利下降等。今天我们就来分析一下我们国家的人口数据吧！更多有趣分析教程，扫描下方二维码关注vx公号「裸睡的猪」即可查看！一、背景 1.人口突破14亿 2020年1月17日，国家统计局发布

web前端javascript+jquery知识点总结

Javascript javascript 在前端网页中占有非常重要的地位，可以用于验证表单，制作特效等功能，它是一种描述语言，也是一种基于对象（Object）和事件驱动并具有安全性的脚本语言，语法同java类似，是一种解释性语言，边执行边解释。 JavaScript的组成： ECMAScipt 用于描述: 语法，变量和数据类型，运算符，逻辑控制语句，关键字保留字，对象。浏览器对象模型（Br

Qt实践录：开篇

本系列文章介绍笔者的Qt实践之路。

在家远程办公效率低？那你一定要收好这个「在家办公」神器！

相信大家都已经收到国务院延长春节假期的消息，接下来，在家远程办公可能将会持续一段时间。但是问题来了。远程办公不是人在电脑前就当坐班了，相反，对于沟通效率，文件协作，以及信息安全都有着极高的要求。有着非常多的挑战，比如： 1在异地互相不见面的会议上，如何提高沟通效率？ 2文件之间的来往反馈如何做到及时性？如何保证信息安全？ 3如何规划安排每天工作，以及如何进行成果验收？ ......

作为一个程序员，内存和磁盘的这些事情，你不得不知道啊！！！

截止目前，我已经分享了如下几篇文章：一个程序在计算机中是如何运行的？超级干货！！！作为一个程序员，CPU的这些硬核知识你必须会！作为一个程序员，内存的这些硬核知识你必须懂！这些知识可以说是我们之前都不太重视的基础知识，可能大家在上大学的时候都学习过了，但是嘞，当时由于老师讲解的没那么有趣，又加上这些知识本身就比较枯燥，所以嘞，大家当初几乎等于没学。再说啦，学习这些，也看不出来有什么用啊！

这个世界上人真的分三六九等，你信吗？

偶然间，在知乎上看到一个问题一时间，勾起了我深深的回忆。以前在厂里打过两次工，做过家教，干过辅导班，做过中介。零下几度的晚上，贴过广告，满脸、满手地长冻疮。再回首那段岁月，虽然苦，但让我学会了坚持和忍耐。让我明白了，在这个世界上，无论环境多么的恶劣，只要心存希望，星星之火，亦可燎原。下文是原回答，希望能对你能有所启发。如果我说，这个世界上人真的分三六九等，

为什么听过很多道理，依然过不好这一生?

记录学习笔记是一个重要的习惯，不希望学习过的东西成为过眼云烟。做总结的同时也是一次复盘思考的过程。本文是根据阅读得到 App上《万维钢·精英日课》部分文章后所做的一点笔记和思考。学习是一个系统的过程，思维模型的建立需要相对完整的学习和思考过程。以下观点是在碎片化阅读后总结的一点心得总结。

B 站上有哪些很好的学习资源?

哇说起B站，在小九眼里就是宝藏般的存在，放年假宅在家时一天刷6、7个小时不在话下，更别提今年的跨年晚会，我简直是跪着看完的！！最早大家聚在在B站是为了追番，再后来我在上面刷欧美新歌和漂亮小姐姐的舞蹈视频，最近两年我和周围的朋友们已经把B站当作学习教室了，而且学习成本还免费，真是个励志的好平台ヽ(.◕ฺˇд ˇ◕ฺ;)ﾉ下面我们就来盘点一下B站上优质的学习资源：综合类 Oeasy：综合

雷火神山直播超两亿，Web播放器事件监听是怎么实现的？

Web播放器解决了在手机浏览器和PC浏览器上播放音视频数据的问题，让视音频内容可以不依赖用户安装App，就能进行播放以及在社交平台进行传播。在视频业务大数据平台中，播放数据的统计分析非常重要，所以Web播放器在使用过程中，需要对其内部的数据进行收集并上报至服务端，此时，就需要对发生在其内部的一些播放行为进行事件监听。那么Web播放器事件监听是怎么实现的呢？ 01 监听事件明细表名

3万字总结，Mysql优化之精髓

本文知识点较多，篇幅较长，请耐心学习 MySQL已经成为时下关系型数据库产品的中坚力量，备受互联网大厂的青睐，出门面试想进BAT，想拿高工资，不会点MySQL优化知识，拿offer的成功率会大大下降。为什么要优化系统的吞吐量瓶颈往往出现在数据库的访问速度上随着应用程序的运行，数据库的中的数据会越来越多，处理时间会相应变慢数据是存放在磁盘上的，读写速度无法和内存相比如何优化设计

一条链接即可让黑客跟踪你的位置！ | Seeker工具使用

搬运自：冰崖的部落阁（icecliffsnet）严正声明：本文仅限于技术讨论，严禁用于其他用途。请遵守相对应法律规则，禁止用作违法途径，出事后果自负！上次写的防社工文章里边提到的gps定位信息（如何防止自己被社工或人肉）除了主动收集他人位置信息以外，我们还可以进行被动收集（没有技术含量） Seeker作为一款高精度地理位置跟踪工具，同时也是社交工程学（社会工程学）爱好者...

作为程序员的我，大学四年一直自学，全靠这些实用工具和学习网站！

我本人因为高中沉迷于爱情，导致学业荒废，后来高考，毫无疑问进入了一所普普通通的大学，实在惭愧...... 我又是那么好强，现在学历不行，没办法改变的事情了，所以，进入大学开始，我就下定决心，一定要让自己掌握更多的技能，尤其选择了计算机这个行业，一定要多学习技术。在进入大学学习不久后，我就认清了一个现实：我这个大学的整体教学质量和学习风气，真的一言难尽，懂的人自然知道怎么回事？怎么办？我该如何更好的提升

前端JS初级面试题二 (｡•ˇ‸ˇ•｡)老铁们！快来瞧瞧自己都会了么

1. 传统事件绑定和符合W3C标准的事件绑定有什么区别？传统事件绑定 <div onclick="">123</div> div1.onclick = function(){}; <button onmouseover=""></button> 注意：如果给同一个元素绑定了两次或多次相同类型的事件，那么后面的绑定会覆盖前面的绑定（不支持DOM事...

m0_37171452

Mr星期天

相似问题