前两版DoubanFm写的太戳，第一版可以忽略，当是熟悉WP手机的一些API。。
第二版用了比较多的依赖注入，熟悉了Messenger,过后越写越大，感觉不对，赶快打住。。现在开始好好思考各模块了。
在Http请求方面，在知道了Restful后还没有机会使用它，感觉Restful应该还不错，不过我还是为我的Http请求使用了下面的设计模式
一.工厂方法
1.抽象产品
UML有空再画，先上代码，
使用Rx建立抽象的Get类产品，如下：
1 public abstract class HttpGetMethodBase<T>
2 {
3 public virtual IObservable<T> Get(string Url)//设置虚拟方法是为了多态 但是这里不用设置应该也可以
4 {
5 //多态既是为了用子类的方法
6 //其实我这里不需要用子类的方法
7 //写了应该也可以
8 //只要注意子类的Override
9 var func = Observable.FromAsyncPattern<HttpWebRequest, T>(Webrequest, WebResponse);
10 HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(Url);
11 return func(request);
12 }
13 private IAsyncResult Webrequest(HttpWebRequest request, AsyncCallback callbcak, object ob)
14 {
15 return request.BeginGetResponse(callbcak, request);
16 }
17
18 //发的请求用的是父类的get,WebResponse用的是子类的
19 protected abstract T WebResponse(IAsyncResult result);
20 }
作为抽象的产品，有些方法可以共享，比如Get方法。要重写的是WebResponse
2.具体产品
（1）返回stream的产品
1 public class HttpGetStream : HttpGetMethodBase<Stream>
2 {
3 protected override Stream WebResponse(IAsyncResult result)
4 {
5 try
6 {
7 var request = result.AsyncState as HttpWebRequest;
8 HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(result);
9 #region ignore
10 if (response.Cookies != null)
11 {
12 foreach (Cookie cookie in response.Cookies)
13 {
14 Debug.WriteLine(cookie.Value);
15 }
16 }
17 Debug.WriteLine(response.ContentType);
18 Debug.WriteLine(response.StatusDescription);
19 if (response.Headers["Set-Cookie"] != null)
20 {
21 //setting may write
22 Debug.WriteLine(response.Headers["Set-Cookie"]);
23 }
24 #endregion
25 return response.GetResponseStream();
26 }
27 catch
28 {
29 Debug.WriteLine("WEBERROR");
30 return null;
31 }
32 }
33 }
（2）返回string的产品
1 public class HttpGetString : HttpGetMethodBase<string>
2 {
3 protected override string WebResponse(IAsyncResult result)
4 {
5 try
6 {
7 var request = result.AsyncState as HttpWebRequest;
8 HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(result);
9 #region ignore
10 if (response.Cookies != null)
11 {
12 foreach (Cookie cookie in response.Cookies)
13 {
14 Debug.WriteLine(cookie.Value);
15 }
16 }
17 Debug.WriteLine(response.ContentType);
18 Debug.WriteLine(response.StatusDescription);
19 if (response.Headers["Set-Cookie"] != null)
20 {
21 //setting may write
22 Debug.WriteLine(response.Headers["Set-Cookie"]);
23 }
24 #endregion
25 Stream stream = response.GetResponseStream();
26 using (StreamReader sr = new StreamReader(stream))
27 {
28 return sr.ReadToEnd();
29 }
30 }
31 catch
32 {
33 Debug.WriteLine("WEBERROR");
34 return null;
35 }
36 }
37 }
（3）返回位图的产品
1 public class HttpGetBitmapImage : HttpGetMethodBase<BitmapImage>
2 {
3 protected override BitmapImage WebResponse(IAsyncResult result)
4 {
5 try
6 {
7 var request = result.AsyncState as HttpWebRequest;
8 HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(result);
9 #region ignore
10 if (response.Cookies != null)
11 {
12 foreach (Cookie cookie in response.Cookies)
13 {
14 Debug.WriteLine(cookie.Value);
15 }
16 }
17 Debug.WriteLine(response.ContentType);
18 Debug.WriteLine(response.StatusDescription);
19 if (response.Headers["Set-Cookie"] != null)
20 {
21 //setting may write
22 Debug.WriteLine(response.Headers["Set-Cookie"]);
23 }
24 #endregion
25 Stream stream = response.GetResponseStream();
26 BitmapImage bitmapimage = new BitmapImage();
27 bitmapimage.SetSource(stream);
28 return bitmapimage;
29 }
30 catch
31 {
32 Debug.WriteLine("WEBERROR");
33 return null;
34 }
35 }
36 }
现在主要有三种产品，如果以后有返回音频的产品，就照搬就好了，这样便于扩展。
3.接口工厂（不叫抽象工厂是怕跟抽象工厂模式冲突）
（1）用于创建对象（产品）的接口
interface IHttpGet<T>
{
HttpGetMethodBase<T> CreateHttpRequest();
}
（2）具体的工厂
具体工厂都用来创建具体的产品
1.string(get)工厂
1 public class StringHttpFactory:IHttpGet<string>
2 {
3 public HttpGetMethodBase<string> CreateHttpRequest()
4 {
5 return new HttpGetString();
6 }
7 }
2.stream（get）工厂
1 public class StreamHttpFactory : IHttpGet<Stream>
2 {
3
4 public HttpGetMethodBase<Stream> CreateHttpRequest()
5 {
6 return new HttpGetStream();
7 }
8 }
3.位图工厂
1 public class BitmapImageHttpFactory : IHttpGet<BitmapImage>
2 {
3 public HttpGetMethodBase<BitmapImage> CreateHttpRequest()
4 {
5 return new HttpGetBitmapImage();
6 }
7 }
客户端调用：
客户端调用还是得知道具体的工厂型号，所以这里我打个问号，先看看代码吧
1 IHttpGet<string> factory = new StringHttpFactory();//string 工厂
2 factory.CreateHttpRequest().Get("http://douban.fm/j/mine/playlist?from=mainsite&channel=0&kbps=128&type=n").Subscribe(
3 (result) =>
4 {
5 7 });
代码new了一个具体的工厂，这里并没有达到真正的解耦，所以我考虑看能不能以后做
1。配置文件反射处理
2.依赖注入。
//to be continued................
二.职责链
先看看背景。
虽然用Newtonsoft的json库很爽，但是面对复杂的json串，不能很好的面对它的变化，变化点在于，JToken[][][][][][][][][]，中括号的个数未知，我不知道哪天出来的json串会有几个[],如果使用到解析json串的地方很多，这个中括号的数量会非常多，看着非常恶心。。。。。。。。当然也许Newtonsoft有解决办法，但是我没摸索出来。
1.Json串的多样性
json串是由Web服务端安排的，各种命名，各种key/vaule，客户端很难应对这种变。
用职责链的效果是：客户端只用发出获得的json字符串，就可以获得与之对应的类，至于json串怎么被处理的，客户端不知道
上代码
1 public abstract class RequestorBase<T>
2 {
3 protected RequestorBase<T> Successor;
4 internal void SetSucessor(RequestorBase<T> suc)
5 {
6 Successor = suc;
7 }
8 public abstract T ProcessRequest(string json);//抽象不依赖于具体，抽象依赖于抽象
9 }
10 public class Requestor1<T> : RequestorBase<T>
11 {
12 public override T ProcessRequest(string json)
13 {
14 try
15 {
16 return JsonConvert.DeserializeObject<T>(JToken.Parse(json)["song"].ToString());
17 }
18 catch
19 {
20 Debug.WriteLine("这个是在职责链中的该有的异常");
21 return Successor.ProcessRequest(json);
22 }
23 }
24 }
25 public class Requestor2<T> : RequestorBase<T>
26 {
27 public override T ProcessRequest(string json)
28 {
29 try
30 {
31 return JsonConvert.DeserializeObject<T>(JToken.Parse(json)["song"][0].ToString());
32 }
33 catch
34 {
35 Debug.WriteLine("这个是在职责链中的该有的异常");
36 return Successor.ProcessRequest(json);
37 }
38 }
39 }
40 public class Requestor3<T> : RequestorBase<T>
41 {
42 public override T ProcessRequest(string json)
43 {
44 Debug.WriteLine("在职责链中没有能找到处理请求的方法，返回Default");
45 return default(T);
46 //NO Chain 继续下去了
47 }
48 }
不同的职责人作不同的json串解析。
然后再使用
三.单例模式
使用单例模式来创建管理职责链，使用单例管理职责链的目的是职责链只负责处理json串，他们都是无状态的，所有把他们的方法装入内存就可以了。
1 public class ManagerResponsibilityChain<T>
2 {
3 static private RequestorBase<T> _startrequestor;
4 static public RequestorBase<T> Instance_Startrequestor
5 {
6 get
7 {
8 if (_startrequestor == null)
9 {
10 Inital();
11 }
12 return _startrequestor;
13 }
14 }
15 private ManagerResponsibilityChain()
16 {
17
18 }
19 static private void Inital()
20 {
21 _startrequestor = new Requestor1<T>();
22 var secondrequestor = new Requestor2<T>();
23 var thridrequestor = new Requestor3<T>();
24 _startrequestor.SetSucessor(secondrequestor);
25 secondrequestor.SetSucessor(thridrequestor);//requestor3 is the end
26 }
27 }
今天就到这。
后面再来追加一下：
对于上面的职责链，要想增加职责者，难免会忘记增加的过程，要插入在倒数第二个地方，再重新设置后两个的职责链
1 public class ManagerResponsibilityChain<T>
2 {
3 static private RequestorBase<T> _startrequestor;
4 static public RequestorBase<T> Instance_Startrequestor
5 {
6 get
7 {
8 if (_startrequestor == null)
9 {
10 Inital();
11 }
12 return _startrequestor;
13 }
14 }
15 private ManagerResponsibilityChain()
16 {
17
18 }
19 static public List<RequestorBase<T>> RequestList=new List<RequestorBase<T>>();
20 static private void InsertARequestor(RequestorBase<T> InsertItem)
21 {
22 RequestList.Insert(RequestList.Count - 1, InsertItem);
23 InsertItem.SetSucessor(RequestList[RequestList.Count - 1]);
24 RequestList[RequestList.Count - 3].SetSucessor(InsertItem);
25
26 }
27
28
29 static private void Inital()
30 {
31
32 _startrequestor = new Requestor1<T>();
33 var secondrequestor = new Requestor2<T>();
34 var thridrequestor = new Requestor3<T>();
35 RequestList.Add(_startrequestor);
36 RequestList.Add(secondrequestor);
37 RequestList.Add(thridrequestor);
38 _startrequestor.SetSucessor(secondrequestor);
39 secondrequestor.SetSucessor(thridrequestor);//requestor3 is the end
40
41
42 InsertARequestor(new Requestor4<T>());
43 InsertARequestor(new Requestor5<T>());
44 InsertARequestor(new Requestor6<T>());
45 }
46
47 }
或者是
1 public class ManagerResponsibilityChain<T>
2 {
3 static private RequestorBase<T> _startrequestor;
4 static public RequestorBase<T> Instance_Startrequestor
5 {
6 get
7 {
8 if (_startrequestor == null)
9 {
10 Inital();
11 }
12 return _startrequestor;
13 }
14 }
15 private ManagerResponsibilityChain()
16 {
17
18 }
19
20 static private void InsertARequestor(RequestorBase<T> InsertItem, List<RequestorBase<T>> RequestList)
21 {
22 RequestList.Insert(RequestList.Count - 1, InsertItem);
23 InsertItem.SetSucessor(RequestList[RequestList.Count - 1]);
24 RequestList[RequestList.Count - 3].SetSucessor(InsertItem);
25
26 }
27
28
29 static private void Inital()
30 {
31 List<RequestorBase<T>> RequestList = new List<RequestorBase<T>>();
32 _startrequestor = new Requestor1<T>();
33 var secondrequestor = new Requestor2<T>();
34 var thridrequestor = new Requestor3<T>();
35 RequestList.Add(_startrequestor);
36 RequestList.Add(secondrequestor);
37 RequestList.Add(thridrequestor);
38 _startrequestor.SetSucessor(secondrequestor);
39 secondrequestor.SetSucessor(thridrequestor);//requestor3 is the end
40
41
42 InsertARequestor(new Requestor4<T>(), RequestList);
43 InsertARequestor(new Requestor5<T>(), RequestList);
44 InsertARequestor(new Requestor6<T>(), RequestList);
45 }
46
47 }