Windows Phone 7 的Http网络库使用技巧

lang110

public>{　　public DownloadStringCompletedEventArgs(string result, bool cancelled, Exception error, object userState)
　　: base(error, cancelled, userState)
　　{
　　Result = result;
　　}
　　public string Result
　　{
　　get;
　　private set;
　　}
　　}

　　public>　　{
　　public OpenReadCompletedEventArgs(Stream result,bool cancelled,Exception error,object userState)
　　: base(error, cancelled, userState)
　　{
　　Result = result;
　　}
　　public Stream Result
　　{
　　get;
　　private set;
　　}
　　

　　}
　　public delegate void DownloadStringCompletedEventHandler(Object sender, DownloadStringCompletedEventArgs e);
　　public delegate void OpenReadCompletedEventHandler(object sender, OpenReadCompletedEventArgs e);

　　public>　　{
　　HttpWebRequest _webRequest = null;
　　private string _result = "";
　　private byte[] _buffer;
　　const int BUFFER_SIZE = 1024;
　　MemoryStream _memStream = null;
　　object _userToken = null;
　　static string cache = Guid.NewGuid().ToString();
　　public NoCacheWebClient()
　　{
　　_buffer = new byte[BUFFER_SIZE];
　　Encoding = Encoding.UTF8;
　　_memStream = new MemoryStream();
　　}
　　

　　public event DownloadStringCompletedEventHandler DownloadStringCompleted;
　　public event OpenReadCompletedEventHandler OpenReadCompleted;
　　

　　public void CancelAsync()
　　{
　　if (_webRequest != null)
　　{
　　_webRequest.Abort();
　　_result = "";
　　_userToken = null;
　　}
　　}
　　public Encoding Encoding
　　{
　　get;
　　set;
　　}
　　private Uri RequestUri
　　{
　　set;
　　get;
　　}
　　public void OpenReadAsync(Uri address)
　　{
　　RequestUri = address;
　　_webRequest = (HttpWebRequest)HttpWebRequest.Create(address.AbsoluteUri);
　　_webRequest.BeginGetResponse(StreamRespCallback, null);
　　

　　}
　　

　　private void StreamRespCallback(IAsyncResult asynchronousResult)
　　{
　　try
　　{
　　HttpWebResponse response = (HttpWebResponse)_webRequest.EndGetResponse(asynchronousResult);
　　Stream responseStream = response.GetResponseStream();
　　if (OpenReadCompleted != null)
　　{
　　System.Windows.Deployment.Current.Dispatcher.BeginInvoke(OpenReadCompleted, new object[] { this, new OpenReadCompletedEventArgs(responseStream, false, null, _userToken) });
　　}
　　}
　　catch (WebException e)
　　{
　　string message = e.Message;
　　}
　　}
　　public void DownloadStringAsync(Uri address)
　　{
　　_result = "";
　　_memStream = new MemoryStream();
　　string cacheValue = "";
　　if (address.Query.Length == 0)
　　{
　　cacheValue = "?Cache=" + cache;
　　}
　　else
　　{
　　cacheValue = "&Cache=" + cache;
　　}
　　

　　Uri newAddress = new Uri(address.AbsoluteUri + cacheValue, UriKind.RelativeOrAbsolute);
　　RequestUri = newAddress;
　　_webRequest = (HttpWebRequest)HttpWebRequest.Create(newAddress.AbsoluteUri);
　　_webRequest.BeginGetResponse(RespCallback, null);
　　}
　　public void DownloadStringAsync(Uri address,object userToken)
　　{
　　_result = "";
　　_userToken = userToken;
　　_memStream = new MemoryStream();
　　string cacheValue = "";
　　if (address.Query.Length == 0)
　　{
　　cacheValue = "?Cache=" + cache;
　　}
　　else
　　{
　　cacheValue = "&Cache=" + cache;
　　}
　　Uri newAddress = new Uri(address.AbsoluteUri + cacheValue, UriKind.RelativeOrAbsolute);
　　RequestUri = newAddress;
　　_webRequest = (HttpWebRequest)HttpWebRequest.Create(newAddress.AbsoluteUri);
　　_webRequest.BeginGetResponse(RespCallback, userToken);
　　}
　　private void RespCallback(IAsyncResult asynchronousResult)
　　{
　　try
　　{
　　HttpWebResponse response = (HttpWebResponse)_webRequest.EndGetResponse(asynchronousResult);
　　Stream responseStream = response.GetResponseStream();
　　responseStream.BeginRead(_buffer, 0, BUFFER_SIZE, new AsyncCallback(ReadCallback), responseStream);
　　}
　　catch (WebException e)
　　{
　　string message = e.Message;
　　}
　　}
　　private void ReadCallback(IAsyncResult asyncResult)
　　{
　　try
　　{
　　Stream stream = (Stream)asyncResult.AsyncState;
　　int read = stream.EndRead(asyncResult);
　　if (read > 0)
　　{
　　_memStream.Write(_buffer, 0, read);
　　stream.BeginRead(_buffer, 0, BUFFER_SIZE, new AsyncCallback(ReadCallback), stream);
　　}
　　else
　　{
　　_result = Encoding.GetString(_memStream.ToArray(), 0, (int)_memStream.Length);
　　stream.Close();
　　_memStream.Close();
　　

　　if (DownloadStringCompleted != null)
　　{
　　System.Windows.Deployment.Current.Dispatcher.BeginInvoke(DownloadStringCompleted, new object[] { this, new DownloadStringCompletedEventArgs(_result, false, null, _userToken) });
　　}
　　}
　　}
　　catch (System.Exception ex)
　　{
　　string message = ex.Message;
　　}
　　}
　　

　　private void WriteCallBack(IAsyncResult asyncResult)
　　{
　　try
　　{
　　_memStream.EndWrite(asyncResult);
　　Stream stream = (Stream)asyncResult.AsyncState;
　　stream.BeginRead(_buffer, 0, BUFFER_SIZE, new AsyncCallback(ReadCallback), stream);
　　

　　}
　　catch (System.Exception ex)
　　{
　　string message = ex.Message;
　　}
　　}
　　}