|
我们的项目是用DotNet实现Socket连接用多线程处理多用户我就谈一下在实现过程中遇到的问题下面是我服务器的简化实现 private Socket clientSocket; public void Start() { Threadthread=new Thread(new ThreadStart(MainService)); threadStart(); } void MainService() { listener=new TcpListener(); listenerStart(); while(true) { Socket s= listenerAcceptSocket();//帧听客户连接 clientSocket=s; Threadclientservice = new Thread(new ThreadStart(ClientService)); clientserviceStart(); ThreadSleep();//等待传值给线程中的变量防止多用户造成沖突 } } void ClientService() { string command; string receiveStr; string fileNamefileSize; Socket sock=clientSocket; EndPoint oldEP=sockRemoteEndPoint; byte[] bb=new byte[]; while(true) { ii=sockReceiveFrom(bbref oldEP);//接收数据 if(ii==)//客户端连接断开就会不停接收个字节 { break; } receiveStr=EncodingDefaultGetString(bbbbLength); command=ReadLineFrom(receiveStr)ToLower();//ReadLineFrom读取字符串中的一行数据 Switch(command) { cace upload: fileName=ReadLineFrom(receiveStr); fileSize=ReadLineFrom(receiveStr); uploadFile(sockfileNameIntParse(fileSize));//接受数据方法 break;
} } void uploadFile(Socket sockstring fileNameint fileSize) { int loadSize=; byte[] bb; int blen=; NetworkStream stream=new NetworkStream(sock); FileStream fs=FileOpenWrite(tempstr); while(loadSize{if(loadSize>fileSize-102400) blen=fileSize-loadSize; bb=new byte[blen]; int ii=stream.Read(bb,0,bb.Length);//3、实际接受数据时每次可能没有10240个字节 fs.Write(bb,0,ii); loadSize+=ii; } fs.Close(); stream.Close(); } 1、等待传值给线程中的变量，防止多用户造成沖突 2、客户端连接断开，就会不停接收0个字节 判断客户端是否断开要用这个方法实现，Sokcet里带的Connected不起作用，只要连接上，中途不出现发送和或接收数据错误，客户断开与否都是返回true。tW.wINgWIt.cOMPoll(100,SelectMode...)返回任何模式都是true。 3、实际接受数据时每次可能没有10240个字节 客户端我就不写了，用TcpClient连接就可以了，当然实际应用中，可能就要自己写规则了 这些问题解决了，只要做适当的处理，视频，声音都不是问题了。 |
