Superpippo’s Lifebackup

今天无意登到WP后台逛了逛，一巨干尸赫然在目。。。扫了一眼，貌似重见天日沿能存活，赶紧发出这篇两个月前写的draft。

============================不愿烂在草稿堆里的分割线=================================

书接上回，补上上次没写完的。

他山之石，可以攻玉

通过自己动手写的client和socket能细致地了解一些细节，但这个山寨版的产品还远远不能放到项目的生产环境上去。而成熟的开源API能为我们省去重复制造轮子的时间。

HttpClient

这个出自Apache的API包很好地封装了一个Http Client的全部细节。比如Header的拼装，发送正文的数据，接收回来报文的解析。有些动作是隐式的，看一些源代码会更清楚些，比如如果设置了Content-Type，它会用这个来编码正文流；并进而设置Content-Length的字节数。

1. 尽量不要用deprecated的方法。比如setRequestBody(String s)，然后你send一个UTF-8的流，那么HttpClient做的动作就是给Content-Length的值设置为s.lengh()，这显然是不对的。length。既然length都没设置正确，要是还能在server端得到正确流就是奇闻了。正确的做法是使用**RequestEntity，例如这样：

RequestEntity entity = new ByteArrayRequestEntity(s.getBytes("UTF-8"));
postMethod.setRequestEntity(entity);

类似不被推荐的方法还有一样，这些大多是基于ASCII设计的，而现在的做法更好考虑了I18N编码的需求。

Servlet

用Servlet来当做你的Server当然是很方便的了，就它来当做客户端access的service。doGet()和doPost()方法接收客户端，然后Servlet规范提供了足够傻瓜的方法供你调用，比如servlet.getInpuStream()。这个方法和jdk socket API提供的socket.getInputStream()相比，区别在上篇文章中已经从实践结果上看到了。如果要问为什么会这样，就只能看看各web/app server对Servlet规范的实现源码了，比如Tomcat中的CoyoteInputStream。作为Servlet规范中request.getInputStream()方法的具体实现，CoyoteInputStream里的read()及相关方法都可以看看。

PS: 本想把Tomcat的这段代码实现贴些上来，可是看了一晚上仅仅是有些眉目，离清晰地剖析实现还是有段距离，所以也没能完全佐证那些结果。今晚的最大收获就是把tomcat在eclipse编译了一遍，然后打下断点，单步跟踪，还是能发现一些tomcat的原理，诸如启动流程，收到请求的处理周期等等。这些经验总结还是等有精力了再来做吧。

雕虫小技

Https

如果server端要求SSL的连接方式，在client端需要首先得到server端的证书，然后用jre的一个工具导入，然后在运行时将这个值设为临时的某个system property。这方面的文章google就有一大把，就不在此赘述了。

Concurrency

作为server端，要么用Servlet来做，它本身是多线程的。要么自己写一个standalone的java application来做server端，也不费事，这部分就不说了。

而作为client端，可以尝试一下jdk 1.5引入的Doug Lea的concurrent包。我在项目中是这样实现的，send处理逻辑部分：

public void run() {
    while (!stopFlag) {
        try {
            // judge condition
            if (…..) {
                /* access to the pool */
                semaphore.acquire();
                Runnable run = new Runnable() {
                    public void run() {
                        // sending reqeust logic ……
                    }
                };
                pool.execute(run);
            }
            else {
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    getLogger().warn("Thread is interrupted.");
                }
            }
        } catch (Exception e) {
            getLogger().fatal("***", e);
            this.stopFlag = true;
        }
    }
    pool.shutdown();
    getLogger().info("*** is terminated.");
}

而semaphore和pool在这个类的构造方法里初始化：

public class *** implements Runnable {   
    ……
    private int poolSize;
    private final Semaphore semaphore;    /* initial a thread pool */
    private ExecutorService pool;    /* set the limit to access the pool */
    public ***() {
        super();
        ……
        poolSize = Integer.parseInt(propService.getProperty(
                "***_pool_size", "4"));
        pool = Executors.newFixedThreadPool(poolSize);
        semaphore = new Semaphore(poolSize);
    }
    ……
}

Concurrent包还有很多实用的功能与技巧，遇到再与大家分享:D