快捷導(dǎo)航

HttpResponse的Output與OutputStream、Filter關(guān)系與區(qū)別介紹

更新時(shí)間：2012年11月07日 15:13:27 作者：

在網(wǎng)上經(jīng)?？匆娪羞@樣的代碼HttpResponse response = HttpContext.Current.Response;現(xiàn)在我也來說說這幾個(gè)東東是什么吧

在網(wǎng)上經(jīng)常看見有這樣的代碼

HttpResponse response = HttpContext.Current.Response;
response.Filter = new PageFilter(response.Filter);

來攔截輸出流，自己也做個(gè)類似的東東，如asp.net中 js 合并壓縮，現(xiàn)在我也來說說這幾個(gè)東東是什么吧，需要大家對(duì)asp.net的生命周期比較熟悉，如不熟悉的朋友建議先看看ASP.NET 請(qǐng)求處理流程 ASP.NET管線與應(yīng)用程序生命周期

首先我們來看看這3個(gè)屬性的源代碼吧：

復(fù)制代碼代碼如下:

public TextWriter Output 
{ 
get 
{ 
return this._writer; 
} 
set 
{ 
this._writer = value; 
} 
} 


public Stream OutputStream 
{ 
get 
{ 
if (!this.UsingHttpWriter) 
{ 
throw new HttpException(SR.GetString("OutputStream_NotAvail")); 
} 
return this._httpWriter.OutputStream; 
} 
} 

復(fù)制代碼代碼如下:

public Stream Filter 
{ 
get 
{ 
if (this.UsingHttpWriter) 
{ 
return this._httpWriter.GetCurrentFilter(); 
} 
return null; 
} 
set 
{ 
if (!this.UsingHttpWriter) 
{ 
throw new HttpException(SR.GetString("Filtering_not_allowed")); 
} 
this._httpWriter.InstallFilter(value); 
IIS7WorkerRequest request = this._wr as IIS7WorkerRequest; 
if (request != null) 
{ 
request.ResponseFilterInstalled(); 
} 
} 
}

我們看到Filter和OutputStream都用到了一個(gè)屬性UsingHttpWriter，那這個(gè)屬性是怎么定義的了

復(fù)制代碼代碼如下:

private bool UsingHttpWriter 
{ 
get 
{ 
return ((this._httpWriter != null) && (this._writer == this._httpWriter)); 
} 
}

從這個(gè)屬性我們可以知道_writer 、_httpWriter實(shí)際上是同一個(gè)東東，它們的類型是HttpWriter ，而HttpWriter 又繼承與TextWriter?，F(xiàn)在我們可以解釋Output就是_httpWriter，而OutputStream是_httpWriter的OutputStream屬性。類HttpWriter 主要代碼如下

復(fù)制代碼代碼如下:

public Stream OutputStream 
{ 
get 
{ 
return this._stream; 
} 
} 


internal HttpWriter(HttpResponse response) : base(null) 
{ 
this._response = response; 
this._stream = new HttpResponseStream(this); 
this._buffers = new ArrayList(); 
this._lastBuffer = null; 
this._charBuffer = (char[]) s_Allocator.GetBuffer(); 
this._charBufferLength = this._charBuffer.Length; 
this._charBufferFree = this._charBufferLength; 
this.UpdateResponseBuffering(); 
} 


internal HttpResponseStream(HttpWriter writer) 
{ 
this._writer = writer; 
}

HttpResponse 在Filter屬性設(shè)置調(diào)用了HttpWriter類的InstallFilter方法，而獲取調(diào)用了該類的GetCurrentFilter

復(fù)制代碼代碼如下:

internal void InstallFilter(Stream filter) 
{ 
if (this._filterSink == null) 
{ 
throw new HttpException(SR.GetString("Invalid_response_filter")); 
} 
this._installedFilter = filter; 
} 

internal Stream GetCurrentFilter() 
{ 
if (this._installedFilter != null) 
{ 
return this._installedFilter; 
} 
if (this._filterSink == null) 
{ 
this._filterSink = new HttpResponseStreamFilterSink(this); 
} 
return this._filterSink; 
}

由以上代碼我們可以得知HttpResponse的輸出流就是Filter屬性設(shè)置的流,即HttpResponse的Output和OutputStream屬性的輸出流都是來自Filter中的流。我們來看看_writer 、_httpWriter它們是在什么時(shí)候初始化的了？在HttpResonse中有一個(gè)方法

復(fù)制代碼代碼如下:

internal void InitResponseWriter() 
{ 
if (this._httpWriter == null) 
{ 
this._httpWriter = new HttpWriter(this); 
this._writer = this._httpWriter; 
} 
} 

該方法是由HttpRuntime的ProcessRequestInternal來調(diào)用

復(fù)制代碼代碼如下:

private void ProcessRequestInternal(HttpWorkerRequest wr) 
{ 
HttpContext context; 
try 
{ 
context = new HttpContext(wr, false); 
} 
catch 
{ 
wr.SendStatus(400, "Bad Request"); 
wr.SendKnownResponseHeader(12, "text/html; charset=utf-8"); 
byte[] bytes = Encoding.ASCII.GetBytes("<html><body>Bad Request</body></html>"); 
wr.SendResponseFromMemory(bytes, bytes.Length); 
wr.FlushResponse(true); 
wr.EndOfRequest(); 
return; 
} 
wr.SetEndOfSendNotification(this._asyncEndOfSendCallback, context); 
Interlocked.Increment(ref this._activeRequestCount); 
HostingEnvironment.IncrementBusyCount(); 
try 
{ 
try 
{ 
this.EnsureFirstRequestInit(context); 
} 
catch 
{ 
if (!context.Request.IsDebuggingRequest) 
{ 
throw; 
} 
} 
context.Response.InitResponseWriter(); 
IHttpHandler applicationInstance = HttpApplicationFactory.GetApplicationInstance(context); 
if (applicationInstance == null) 
{ 
throw new HttpException(SR.GetString("Unable_create_app_object")); 
} 
if (EtwTrace.IsTraceEnabled(5, 1)) 
{ 
EtwTrace.Trace(EtwTraceType.ETW_TYPE_START_HANDLER, context.WorkerRequest, applicationInstance.GetType().FullName, "Start"); 
} 
if (applicationInstance is IHttpAsyncHandler) 
{ 
IHttpAsyncHandler handler2 = (IHttpAsyncHandler) applicationInstance; 
context.AsyncAppHandler = handler2; 
handler2.BeginProcessRequest(context, this._handlerCompletionCallback, context); 
} 
else 
{ 
applicationInstance.ProcessRequest(context); 
this.FinishRequest(context.WorkerRequest, context, null); 
} 
} 
catch (Exception exception) 
{ 
context.Response.InitResponseWriter(); 
this.FinishRequest(wr, context, exception); 
} 
}