HttpHelper异步版完整实现（附源代码）

slolitor

发下.netframework中的一些源码
public class HttpWebRequest : WebRequest, ISerializable
{
//其中一个方法
  private void SubmitRequest(ServicePoint servicePoint);
｝；

private void SubmitRequest(ServicePoint servicePoint)
{
    if (!this.Async)
    {
        this._ConnectionAResult = new LazyAsyncResult(this, null, null);
        this._ConnectionReaderAResult = new LazyAsyncResult(this, null, null);
        this.OpenWriteSideResponseWindow();
    }
    if ((this._Timer == null) && !this.Async)
    {
        this._Timer = this.TimerQueue.CreateTimer(s_TimeoutCallback, this);
    }
    try
    {
        if ((this._SubmitWriteStream != null) && this._SubmitWriteStream.IsPostStream)
        {
            if ((this._OldSubmitWriteStream == null) && !this._SubmitWriteStream.ErrorInStream)
            {
                this._OldSubmitWriteStream = this._SubmitWriteStream;
            }
            this._WriteBuffer = null;
        }
        this.m_Retry = false;
        if (this.PreAuthenticate)
        {
            if ((this.UsesProxySemantics && (this._Proxy != null)) && (this._Proxy.Credentials != null))
            {
                this.ProxyAuthenticationState.PreAuthIfNeeded(this, this._Proxy.Credentials);
            }
            if (this.Credentials != null)
            {
                this.ServerAuthenticationState.PreAuthIfNeeded(this, this.Credentials);
            }
        }
        if (this.WriteBuffer == null)
        {
            this.UpdateHeaders();
        }
        if (!this.CheckCacheRetrieveBeforeSubmit())
        {
            servicePoint.SubmitRequest(this, this.GetConnectionGroupLine());
        }
    }
    finally
    {
        if (!this.Async)
        {
            this.CheckWriteSideResponseProcessing();
        }
    }
}


internal void SubmitRequest(HttpWebRequest request, string connName)
{
    Connection connection;
    ConnectionGroup group;
    bool forcedsubmit = false;
    lock (this)
    {
        group =this.FindConnectionGroup(connName, false);
    }
    do
    {
        connection = group.FindConnection(request, connName, out forcedsubmit);
    }
    while ((connection != null) && !connection.SubmitRequest(request, forcedsubmit));
}

internal class Connection : PooledStream
{
internal void AbortSocket(bool isAbortState);
｝

internal void AbortSocket(bool isAbortState)
{
    if (isAbortState)
    {
        this.UnlockRequest();
        this.CheckIdle();
    }
    else
    {
        this.m_Error = WebExceptionStatus.KeepAliveFailure;
    }
    lock (this)
    {
       base.Close(0);
    }
}

public void Close(int timeout)
{
    Socket abortSocket = this.m_AbortSocket;
    Socket socket2 = this.m_AbortSocket6;
    this.m_NetworkStream.Close(timeout);
    if (abortSocket != null)
    {
        abortSocket.Close(timeout);
    }
    if (socket2 != null)
    {
        socket2.Close(timeout);
    }
}

slolitor

其实httpwebrequest发送请求就是通过套接字而已 而.net中的套接字如果采用异步，将会封装IOCP的实现，至于用了IOCP会有什么效果 不多说了。

lmfmcbo

受教了，学习中……

sandy1231

http没必要采用异步吧

xjwebs

请问楼主能放个简单的demo吗，加深实例使用理解

fendou

非常感谢你帮了我的大忙，真的太感谢你啦！

slolitor

什么大忙。。客气客气。。

cjkall

我调用了异步加载  然后
        private void asyncCallBackMethod(Internet.HttpResult result)
        {
            cookie = result.Cookie;
            MemoryStream ms = new MemoryStream(result.ResultByte);
            Image ii = Image.FromStream(ms);
        }
调用的callback方法  但是里面 不执行了 是怎么回事？

slolitor

跟踪下堆栈，这么模糊的说明我无法做判断

乌里扬诺夫斯

顶一下了，要