C#线程系列讲座(3):线程池和文件下载服务器

简介:
本文为原创,如需转载,请注明作者和出处,谢谢!

上一篇:C#线程系列讲座(2):Thread类的应用

    如果设计一个服务器程序,每当处理用户请求时,都开始一个线程,将会在一定程序上消耗服务器的资源。为此,一个最好的解决方法就是在服务器启动之前,事先创建一些线程对象,然后,当处理客户端请求时,就从这些建好的线程中获得线程对象,并处理请求。保存这些线程对象的结构就叫做线程池。

    C#中可以通过System.Threading.ThreadPool类来实现,在默认情况下,ThreadPool最大可建立500个工作线程和1000I/O线程(根据机器CPU个数和.net framework版本的不同,这些数据可能会有变化)。下面是一个用C#从线程池获得线程的例子:

复制代码
private   static   void  execute( object  state)
{
    Console.WriteLine(state);      
}
static   void  Main( string [] args)
{
  
    
int  workerThreads;
    
int  completionPortThreads;
         
    ThreadPool.GetMaxThreads(
out  workerThreads,  out  completionPortThreads);
    Console.WriteLine(workerThreads);
    Console.WriteLine(completionPortThreads);    
    ThreadPool.QueueUserWorkItem(execute,
" 线程1 " );    //  从线程池中得到一个线程,并运行execute
    ThreadPool.QueueUserWorkItem(execute,  " 线程2 " );
    ThreadPool.QueueUserWorkItem(execute, 
" 线程3 " );
    Console.ReadLine();
}
复制代码

    下图为上面代码的运行结果。



    要注意的是,使用ThreadPool获得的线程都是后台线程。

    下面的程序是我设计的一个下载文件服务器的例子。这个例子从ThreadPool获得线程,并处理相应的客户端请求。


复制代码
using  System;
using  System.Collections.Generic;
using  System.Linq;
using  System.Text;
using  System.Threading;
using  System.Net.Sockets;
using  System.IO;

namespace  MyThread
{
    
class  FileServer
    {
        
private  String root;
        
private  Thread listenerThread;

        
private   void  worker( object  state)
        {
             TcpClient client 
=  state  as  TcpClient;
             
try
             {

                 client.ReceiveTimeout 
=   2000 ;
                 Stream stream 
=  client.GetStream();
                 System.IO.StreamReader sr 
=   new  StreamReader(stream);
                 String line 
=  sr.ReadLine();
                 String[] array 
=  line.Split( '   ' );
                 String path 
=  array[ 1 ].Replace( ' / ' ' \\ ' );
                 String filename 
=  root  +  path;
                 
if  (File.Exists(filename))   //  如果下载文件存在,开始下载这个文件
                 {
                     FileStream fileStream 
=   new  FileStream(filename, FileMode.Open, FileAccess.Read, 
                                                           FileShare.Read);
                     
byte [] buffer  =   new   byte [ 8192 ];  //  每次下载8K
                      int  count  =   0 ;
                     String responseHeader 
=   " HTTP/1.1 200 OK\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    //  文件不存在,输出提示信息
                 {
                     String response 
=   " HTTP/1.1 200 OK\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  (Exception e)
             {
                 Console.WriteLine(e.Message);
             }
             
finally
             {
                 
if  (client  !=   null )
                 {
                     client.Close();
                 }
             }
        }

        
private   void  listener()
        {
            TcpListener listener 
=   new  TcpListener( 1234 );
            listener.Start();  
//  开始监听客户端请求
            TcpClient client  =   null ;

            
while  ( true )
            {
                client 
=  listener.AcceptTcpClient();
                client.ReceiveTimeout 
= 2000 ;
                ThreadPool.QueueUserWorkItem(worker, client);  
//  从线程池中获得一个线程来处理客户端请求
            }
        }
        
public  FileServer(String root)
        {
            
this .root =  root;         
        }
        
public   void  start()
        {
            listenerThread 
=   new  Thread(listener);
            listenerThread.Start();  
//  开始运行监听线程
        }
    }
}
复制代码


    FileServer类的使用方法:

    FileServer fs = new FileServer(“d:\\download”);

fs.start(); // 端口为1234

如果d:"download目录中有一个叫aa.exe的文件,在浏览器中输入如下的地址可下载:
    http://localhost:1234/aa.exe

下图为下载对话框:


要注意的是,本程序并没有处理含有中文和其他特殊字符(如空格)的url,因为,文件名要为英文名(不能有空格等特殊字符)。

 

下一篇:C#线程系列讲座(4):同步与死锁

本文转自银河使者博客园博客,原文链接http://www.cnblogs.com/nokiaguy/archive/2008/07/18/1246299.html如需转载请自行联系原作者


银河使者

相关文章
Java编程时多线程操作单核服务器可以不加锁吗?
Java编程时多线程操作单核服务器可以不加锁吗?
49 2
Java多线程优化:提高线程池性能的技巧与实践
Java多线程优化:提高线程池性能的技巧与实践
129 1
如何把阿里云ECS里的文件下载到本地(免登录免配置)
阿里云推出新功能,无需安装额外工具、不需ECS开通公网或登录ECS,仅通过控制台即可将ECS中的文件轻松下载至本地。只需开通OSS对象存储服务,按步骤创建任务,获取临时下载链接,即可在浏览器中直接下载文件。操作简便快捷,适合频繁需要从ECS下载文件的用户。
在 Java 中使用线程池监控以及动态调整线程池时需要注意什么?
【10月更文挑战第22天】在进行线程池的监控和动态调整时,要综合考虑多方面的因素,谨慎操作,以确保线程池能够高效、稳定地运行,满足业务的需求。
112 38
|
23天前
|
C# 一分钟浅谈:GraphQL 服务器端实现
本文通过C#语言从零开始构建一个简单的GraphQL服务器端实现,介绍了环境准备、项目创建、定义Schema、配置GraphQL等步骤。同时,探讨了常见问题如数据源问题、类型定义不一致、性能问题和权限控制,提供了相应的解决方法。希望帮助读者更好地理解和应用GraphQL。
25 3
|
24天前
|
.如何根据 CPU 核心数设计线程池线程数量
IO 密集型:核心数*2 计算密集型: 核心数+1 为什么加 1?即使当计算密集型的线程偶尔由于缺失故障或者其他原因而暂停时,这个额外的线程也能确保 CPU 的时钟周期不会被浪费。
29 4
|
1月前
|
线程池内部机制:线程的保活与回收策略
【10月更文挑战第24天】 线程池是现代并发编程中管理线程资源的一种高效机制。它不仅能够复用线程,减少创建和销毁线程的开销,还能有效控制并发线程的数量,提高系统资源的利用率。本文将深入探讨线程池中线程的保活和回收机制,帮助你更好地理解和使用线程池。
80 2
JAVA线程池监控以及动态调整线程池
【10月更文挑战第22天】在 Java 中,线程池的监控和动态调整是非常重要的,它可以帮助我们更好地管理系统资源,提高应用的性能和稳定性。
85 4
什么是线程池?从底层源码入手,深度解析线程池的工作原理
本文从底层源码入手,深度解析ThreadPoolExecutor底层源码,包括其核心字段、内部类和重要方法,另外对Executors工具类下的四种自带线程池源码进行解释。 阅读本文后,可以对线程池的工作原理、七大参数、生命周期、拒绝策略等内容拥有更深入的认识。
150 29
什么是线程池?从底层源码入手,深度解析线程池的工作原理
在 Java 中,如何使用线程池监控以及动态调整线程池?
【10月更文挑战第22天】线程池的监控和动态调整是一项重要的任务,需要我们结合具体的应用场景和需求,选择合适的方法和策略,以确保线程池始终处于最优状态,提高系统的性能和稳定性。
243 2
AI助理

阿里云 AI 助理已上线!

快来体验一下吧。