如果设计一个服务器程序,每当处理用户请求时,都开始一个线程,将会在一定程序上消耗服务器的资源。为此,一个最好的解决方法就是在服务器启动之前,事先创建一些线程对象,然后,当处理客户端请求时,就从这些建好的线程中获得线程对象,并处理请求。保存这些线程对象的结构就叫做线程池。
在C#中可以通过System.Threading.ThreadPool类来实现,在默认情况下,ThreadPool最大可建立500个工作线程和1000个I/O线程(根据机器CPU个数和.net framework版本的不同,这些数据可能会有变化)。下面是一个用C#从线程池获得线程的例子:
<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->privatestaticvoidexecute(objectstate)
{
Console.WriteLine(state);
}
staticvoidMain(string[]args)
{
intworkerThreads;
intcompletionPortThreads;
ThreadPool.GetMaxThreads(outworkerThreads,outcompletionPortThreads);
Console.WriteLine(workerThreads);
Console.WriteLine(completionPortThreads);
ThreadPool.QueueUserWorkItem(execute,"线程1");//从线程池中得到一个线程,并运行execute
ThreadPool.QueueUserWorkItem(execute,"线程2");
ThreadPool.QueueUserWorkItem(execute,"线程3");
Console.ReadLine();
}
{
Console.WriteLine(state);
}
staticvoidMain(string[]args)
{
intworkerThreads;
intcompletionPortThreads;
ThreadPool.GetMaxThreads(outworkerThreads,outcompletionPortThreads);
Console.WriteLine(workerThreads);
Console.WriteLine(completionPortThreads);
ThreadPool.QueueUserWorkItem(execute,"线程1");//从线程池中得到一个线程,并运行execute
ThreadPool.QueueUserWorkItem(execute,"线程2");
ThreadPool.QueueUserWorkItem(execute,"线程3");
Console.ReadLine();
}
下图为上面代码的运行结果。
要注意的是,使用ThreadPool获得的线程都是后台线程。
下面的程序是我设计的一个下载文件服务器的例子。这个例子从ThreadPool获得线程,并处理相应的客户端请求。
<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> -->usingSystem;
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Threading;
usingSystem.Net.Sockets;
usingSystem.IO;
namespaceMyThread
{
classFileServer
{
privateStringroot;
privateThreadlistenerThread;
privatevoidworker(objectstate)
{
TcpClientclient=stateasTcpClient;
try
{
client.ReceiveTimeout=2000;
Streamstream=client.GetStream();
System.IO.StreamReadersr=newStreamReader(stream);
Stringline=sr.ReadLine();
String[]array=line.Split('');
Stringpath=array[1].Replace('/','//');
Stringfilename=root+path;
if(File.Exists(filename))//如果下载文件存在,开始下载这个文件
{
FileStreamfileStream=newFileStream(filename,FileMode.Open,FileAccess.Read,
FileShare.Read);
byte[]buffer=newbyte[8192];//每次下载8K
intcount=0;
StringresponseHeader="HTTP/1.1200OK/r/n"+
"Content-Type:application/octet-stream/r/n"+
"Content-Disposition:attachment;filename="+
filename.Substring(filename.LastIndexOf("//")+1)+"/r/n/r/n";
byte[]header=ASCIIEncoding.ASCII.GetBytes(responseHeader);
stream.Write(header,0,header.Length);
while((count=fileStream.Read(buffer,0,buffer.Count()))>0)
{
stream.Write(buffer,0,count);
}
Console.WriteLine(filename+"下载完成");
}
else//文件不存在,输出提示信息
{
Stringresponse="HTTP/1.1200OK/r/nContent-Type:text/plain;charset=utf-8/r/n/r/n文件不存在";
byte[]buffer=ASCIIEncoding.UTF8.GetBytes(response);
stream.Write(buffer,0,buffer.Length);
}
}
catch(Exceptione)
{
Console.WriteLine(e.Message);
}
finally
{
if(client!=null)
{
client.Close();
}
}
}
privatevoidlistener()
{
TcpListenerlistener=newTcpListener(1234);
listener.Start();//开始监听客户端请求
TcpClientclient=null;
while(true)
{
client=listener.AcceptTcpClient();
client.ReceiveTimeout=2000;
ThreadPool.QueueUserWorkItem(worker,client);//从线程池中获得一个线程来处理客户端请求
}
}
publicFileServer(Stringroot)
{
this.root=root;
}
publicvoidstart()
{
listenerThread=newThread(listener);
listenerThread.Start();//开始运行监听线程
}
}
}
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Threading;
usingSystem.Net.Sockets;
usingSystem.IO;
namespaceMyThread
{
classFileServer
{
privateStringroot;
privateThreadlistenerThread;
privatevoidworker(objectstate)
{
TcpClientclient=stateasTcpClient;
try
{
client.ReceiveTimeout=2000;
Streamstream=client.GetStream();
System.IO.StreamReadersr=newStreamReader(stream);
Stringline=sr.ReadLine();
String[]array=line.Split('');
Stringpath=array[1].Replace('/','//');
Stringfilename=root+path;
if(File.Exists(filename))//如果下载文件存在,开始下载这个文件
{
FileStreamfileStream=newFileStream(filename,FileMode.Open,FileAccess.Read,
FileShare.Read);
byte[]buffer=newbyte[8192];//每次下载8K
intcount=0;
StringresponseHeader="HTTP/1.1200OK/r/n"+
"Content-Type:application/octet-stream/r/n"+
"Content-Disposition:attachment;filename="+
filename.Substring(filename.LastIndexOf("//")+1)+"/r/n/r/n";
byte[]header=ASCIIEncoding.ASCII.GetBytes(responseHeader);
stream.Write(header,0,header.Length);
while((count=fileStream.Read(buffer,0,buffer.Count()))>0)
{
stream.Write(buffer,0,count);
}
Console.WriteLine(filename+"下载完成");
}
else//文件不存在,输出提示信息
{
Stringresponse="HTTP/1.1200OK/r/nContent-Type:text/plain;charset=utf-8/r/n/r/n文件不存在";
byte[]buffer=ASCIIEncoding.UTF8.GetBytes(response);
stream.Write(buffer,0,buffer.Length);
}
}
catch(Exceptione)
{
Console.WriteLine(e.Message);
}
finally
{
if(client!=null)
{
client.Close();
}
}
}
privatevoidlistener()
{
TcpListenerlistener=newTcpListener(1234);
listener.Start();//开始监听客户端请求
TcpClientclient=null;
while(true)
{
client=listener.AcceptTcpClient();
client.ReceiveTimeout=2000;
ThreadPool.QueueUserWorkItem(worker,client);//从线程池中获得一个线程来处理客户端请求
}
}
publicFileServer(Stringroot)
{
this.root=root;
}
publicvoidstart()
{
listenerThread=newThread(listener);
listenerThread.Start();//开始运行监听线程
}
}
}
FileServer类的使用方法:
FileServer fs = new FileServer(“d://download”);
fs.start();// 端口为1234
如果d:"download目录中有一个叫aa.exe的文件,在浏览器中输入如下的地址可下载:
http://localhost:1234/aa.exe
下图为下载对话框:
相关推荐
C#线程池和文件下载服务器 如果设计一个服务器程序,每当处理用户请求时,都开始一个线程,将会在一定程序上消耗服务器的资源。为此,一个最好的解决方法就是在服务器启动之前,事先创建一些线程对象,然后,当处理...
在C#中可以通过System.Threading.ThreadPool类来实现,在默认情况下,ThreadPool最大可建立500个工作线程和1000个I/O线程(根据机器CPU个数和.net framework版本的不同,这些数据可能会有变化)...下载文件服务器的例子
C#线程系列讲座(3):线程池和文件下载服务器.pdf
C#线程系列讲座笔记整理, (1)BeginInvoke和EndInvoke方法 (2)Thread类的应用 (3)线程池和文件下载服务器 (4)同步与死锁
由于要写一个从第三方服务器拉取文件的插件,百度了很多都 不是很满意,所以自己写了一个,废话少说,看代码,欢迎拍板 断点续传,多线程下载文件,idea开发工具需要安装 lombok 插件,具体百度下吧, 不过没有也没...
基于socket实现,服务器文件下载,只有服务端代码,又线程池实现并发
Delphi线程池实现多线程FTP分段下载组件 by :renshouren mail:114032666@qq.com QQ:114032666 2019.10.05 使用的组件 1、TIdFTP Indy FTP客户端 2、TThreadsPool 线程池 工作原理及流程 调用本单元,将自动在程序...
线程池技术在网络游戏服务器中的应用,csdn上有个坏文件的,我放个好的
服务器端,使用epoll加线程池实现并发服务器,接收客户端指令。客户端使用TCP连接到服务器,实现查询单词及历史记录的功能。服务器端查询单词使用标准IO读取词典文件实现。
websphere参数必须要结合运行环境的实际情况来调整,例如Web Container的线程池大小、数据源连接池大小、语句高速缓存大小(Prepared statement cache size),这几项参数都很重要,要结合实际的并发量和服务器的资源...
基于linux+C++开发的虚拟文件服务器源码功能高仿百度网盘+开发文档说明,适合毕业设计、课程设计、项目开发。项目源码已经过严格测试,可以放心下载使用~ 基于linux+C++开发的虚拟文件服务器源码功能高仿百度网盘+...
linux线程池,c语言实现,只是文件后缀名用的是cpp方便在qt里面测试,两种版本,都是参考网上的资料做了一些处理之后的
该工程是在vs2008下建的mfc工程,服务器程序,采用线程并发,线程池,线程同步技术,允许5个客户端同时访问,已编译通过。提供客户端执行文件。
1. 把每个下载文件切成若干个块...2. HTTP Header里增加Range,如果服务器返回Cotent-Range 说明服务器支持文件定位,可以实现多线程下载 详细看这里 http://blog.csdn.net/maoxiang/archive/2010/04/02/5446293.aspx
有很多服务器应用,比如 Web 服务器,数据库服务器,文件服务器,或者邮件服务器,都会面对处理大量来自一些远程请求的小任务。请求可能会以很多种方式到达服务器,比如通过一种网络协议(比如 HTTP,FTP 或者 POP...
本系统为安全文件传输系统,主要实现客户端与服务器互传文件,包括客户端不仅 可以浏览自己本地的文件列表和服务器的文件列表,而且客户端可以将本地的文件上传 到服务器及将从服务器上下载自己需要的文件。...
ex3-Lidor Eliyahu Shelef的HTTP Server实现 http服务器根据客户端请求构造一个HTTP响应,然后构建并将响应发送给客户端。 重要文件: 服务器 线程池
线程池库适用于任何需要处理并发任务的场景,例如服务器、Web应用程序、多线程应用程序等。它可以帮助开发者更高效地管理线程,避免创建过多的线程,从而降低系统开销和资源消耗。 使用线程池库可以带来以下好处: ...
实现功能:基于HTTP协议,解析请求和拼接响应,基于NIO的非阻塞,线程池,文件传输。代码有详细注释和清晰的框架。 程序入口是: /HttpServerReactor/src/com/StartServer.Java 访问1,浏览:...
该项目是一个多线程Web服务器,具有用Java实现的线程池。 它是为Adobe招聘程序制作的。 入门 使用jar文件 您可以使用以下命令运行out/文件夹中的.jar文件: java -jar out/MultithreadedPoolingServer.jar [port] ...