涛声

在这个框架中，用jsp来做页面展示是没有什么可能了，开源的模板freemarker自然是手到擒来，这是我非常中意的一个工具。

package org.xhttpd.common;

import java.io.File;
import java.io.IOException;
import java.io.StringWriter;
import java.io.Writer;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.picocontainer.Startable;
import org.xhttpd.annotation.Inject;
import org.xlightweb.HttpResponse;
import org.xlightweb.IHttpExchange;
import org.xlightweb.IHttpResponse;

import freemarker.template.Configuration;
import freemarker.template.ObjectWrapper;
import freemarker.template.Template;
import freemarker.template.TemplateExceptionHandler;

@Inject
public class Freemarker implements Startable {
    private final static Log log = LogFactory.getLog(Freemarker.class);
    private Configuration cfg;
    private Config config;
    private Context context;

    public void setContext(Context context) {
        this.context = context;
    }

    public void setConfig(Config config) {
        this.config = config;
    }

    public void start() {
        try {
            cfg = new Configuration();
            cfg.setDirectoryForTemplateLoading(new File("templates"));
            cfg.setTemplateUpdateDelay(0);
            cfg.setTemplateExceptionHandler(TemplateExceptionHandler.HTML_DEBUG_HANDLER);
            cfg.setObjectWrapper(ObjectWrapper.BEANS_WRAPPER);
            cfg.setDefaultEncoding("utf-8");
            cfg.setLocale(Locale.CHINESE);
            cfg.setSharedVariable("sitename", config.getString("site.name"));
            cfg.setSharedVariable("sitebase", config.getString("site.base"));
            cfg.setSharedVariable("context", context);

        } catch (Exception e) {
            log.error("freemarker init error", e);
        }

    }

    public void stop() {

    }

    @SuppressWarnings( { "unchecked" })
    public IHttpResponse render(IHttpExchange http, String tmpname) {

        IHttpResponse resp = null;
        try {
            Template tmp = cfg.getTemplate(tmpname + ".html");

            Writer out = new StringWriter();

            Map content = new HashMap();

            for (String name : http.getRequest().getAttributeNameSet()) {
                content.put(name, http.getRequest().getAttribute(name));
            }
            content.put("session", http.getSession(true));
            tmp.process(content, out);

            String body = out.toString();

            resp = new HttpResponse("text/html", body.getBytes("utf-8"));

        } catch (Exception e) {
            log.error("template file render error " + tmpname, e);
            try {
                resp = new HttpResponse(500, e.getMessage());
            } catch (IOException e1) {
            }

        }
        return resp;
    }

    public String render(String tmpname, Map content) {

        try {

            Template tmp = cfg.getTemplate(tmpname + ".html");

            Writer out = new StringWriter();

            tmp.process(content, out);

            String body = out.toString();

            return body;

        } catch (Exception e) {

            log.error("template file render error " + tmpname, e);

        }
        return null;
    }

}

这是一个freemarker组件的封装，顺便basession也放进去了，里面还有一个Context组件，很普通的一个类

package org.xhttpd.common;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;

import org.xhttpd.annotation.Inject;

@Inject
public class Context {

    public Context() {
        // TODO Auto-generated constructor stub
    }

    public String substr(String src, int len) {
        if (src == null)
            return null;
        if (src.length() < = len)
            return src;

        return src.substring(0, len - 1);
    }

    public String subhtml(String src, int len) {
        if (src == null)
            return null;
        src = Utils.Html2Text(src);
        if (src.length() <= len)
            return src;

        return src.substring(0, len - 1);
    }

    public String encodeUrl(String src) {
        if (src == null)
            return null;
        try {
            return URLEncoder.encode(src, "utf-8");
        } catch (UnsupportedEncodingException e) {
            return src;
        }
    }

}

如何使用？

package org.xhttpd.actions;

import java.io.IOException;

import org.xhttpd.common.Freemarker;
import org.xlightweb.BadMessageException;
import org.xlightweb.IHttpExchange;
import org.xlightweb.IHttpRequestHandler;
import org.xlightweb.Mapping;

@Mapping("/*")
public class IndexAction implements IHttpRequestHandler {

    private Freemarker free;

    public void setFree(Freemarker free) {
        this.free = free;
    }

    @Override
    public void onRequest(IHttpExchange http) throws IOException, BadMessageException {
        // .....
        http.getRequest().setAttribute("name", "jamiesun");
        http.send(free.render(http, "index"));
    }

}

freemarker的使用就不讲了，官方有很详细的文档，中文的也有，这里的模板也就是一个html页面，显示name值只需要用${name}即可。

因为依赖注入功能的存在，setFree方法是不需要你去手工调用的。

在前一篇中，你可能已经发现了在Config类中，多了一个@Inject，明眼人立即看出这不就是个java元注解嘛，是的，这没啥奇怪的，不过这是个很重要得注释，用上了这个标记表示他是一个组件，是要被塞进Beans容器的，同时可以享受到依赖注入的好处。

Config是一个组件，处理请求的IWebHandler实例也是组件，还可能又更多各种各样的组件，甭管啥组件，统统扔进Beans里去管理。

下面是一个主框架的入口类，在这个类中，Beans容器装入并初始化所有组件，启动服务器。

package org.xhttpd;

import java.util.HashSet;

import org.apache.log4j.xml.DOMConfigurator;
import org.xhttpd.annotation.Inject;
import org.xhttpd.common.ActionSet;
import org.xhttpd.common.Beans;
import org.xhttpd.common.Config;
import org.xhttpd.common.Utils;
import org.xlightweb.Mapping;

public class Main {
	public static void main(String[] args) throws Exception {
	    DOMConfigurator.configure("conf/log4j.xml");
	    HashSet CLASSES = Utils.loadClasses("org.xhttpd");
	    ActionSet actionSet = new ActionSet();

	    for (Class clasz : CLASSES) {
			if(clasz.getAnnotation(Inject.class)!=null)
			{
				Beans.put(clasz);
			}
			if(clasz.getAnnotation(Mapping.class)!=null)
			{
				Beans.put(clasz);
				actionSet.add(clasz);
			}
		}
	    Beans.start();
	    new Server().start(Beans.getBean(Config.class),actionSet);

	}
}

这个类设计的不够好，Server实际上应该作为组件放入Beans里的，因为我碰到了一个问题，使用picocontainer提供的组件生命周期管理的一个问题。

picocontainer提供的生命周期管理，典型的是实现一个startable接口，实现接口提供的start，stop方法即可，容器调用start时可以调用容器中所有实现此接口的start方法，stop也是。但是在start的过程中，是不能同时获取容器中的组件的，涉及到线程安全问题，我觉得深入看看源代码应该可以解决，不过这里我偷了一下懒。

Utils.loadClasses(“org.xhttpd”);这个工具方法载入所有类，然后把Inject和Mapping标注过得类全部装入容器。

Beans.start();启动所有实现startable的组件。

Mapping是xlightweb中的元注解，有一个字符串参数，主要用在处理请求的action类中，比如：

package org.xhttpd.actions;
import java.io.IOException;
import org.xlightweb.BadMessageException;
import org.xlightweb.IHttpExchange;
import org.xlightweb.IHttpRequestHandler;
import org.xlightweb.Mapping;

@Mapping("/index")
public class IndexAction implements IHttpRequestHandler{
	@Override
	public void onRequest(IHttpExchange exchange) throws IOException,
			BadMessageException {

	}
}

一看就知道实干什么的了。

现在该是把服务器架起来的时候了，xlightweb上场了，http协议封装就交给它了，请求分发也交给它了，

package org.xhttpd;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.xhttpd.common.ActionSet;
import org.xhttpd.common.Beans;
import org.xhttpd.common.Config;
import org.xlightweb.Context;
import org.xlightweb.IWebHandler;
import org.xlightweb.server.HttpServer;
import org.xsocket.connection.IConnection.FlushMode;

public class Server{

    private final static Log log = LogFactory.getLog(Server.class);
    private HttpServer hsrv = null;

    static class ServerThreadFactory implements ThreadFactory {
    	private static AtomicInteger number = new AtomicInteger(0);
        public Thread newThread(Runnable r) {
            return new Thread(r, "Server-Workerpool-Thread-"+ number.incrementAndGet());
        }

    }

	@SuppressWarnings({ "unchecked" })
	public void start(Config config,ActionSet actionSet) {
        try {
            Context rootCtx = new Context("");
    	    for (Class clasz : actionSet) {
    	    	IWebHandler action =  (IWebHandler) Beans.getBean(clasz);
    			rootCtx.addHandler(action);
    		}
            System.setProperty("org.xlightweb.showDetailedError", "true");

            hsrv = new HttpServer(config.getInt("http.port", 9000), rootCtx);
            hsrv.setWorkerpool(Executors.newCachedThreadPool(new ServerThreadFactory()));
            hsrv.setMaxConcurrentConnections(config.getInt("http.maxConn", 1024));
            hsrv.setAutoCompressThresholdBytes(2048);
            hsrv.setFlushmode(FlushMode.ASYNC);

            hsrv.setAutoUncompress(true);
            hsrv.setConnectionTimeoutMillis(600*1000);
            hsrv.setBodyDataReceiveTimeoutMillis(300*1000);
            hsrv.setRequestBodyDefaultEncoding("utf-8");
            hsrv.setStartUpLogMessage("server starting...");
            hsrv.start();
            log.info("server start.....");
        } catch (Exception e) {
            log.error("server start fail", e);
        }
	}
}

这个实例实在浅显，不需要多解释，不过需要提一下两个参数：

Config config,系统配置类，对应的类和配置文件为

package org.xhttpd.common;
import java.io.FileInputStream;
import java.util.Properties;
import org.xhttpd.annotation.Inject;

@Inject //这个注释是干嘛的
public class Config {

    private Properties cfg;

    public Config() throws Exception {
        FileInputStream fis = null;
        try {
            fis = new FileInputStream("conf/config.xml");
            cfg = new Properties();
            cfg.loadFromXML(fis);
        } finally {
            if (fis != null)
                fis.close();
        }
    }

    public int getInt(String key) {
        return Integer.parseInt(cfg.getProperty(key));
    }

    public int getInt(String key, int defaultValue) {
        return Integer.parseInt(cfg.getProperty(key, String
                .valueOf(defaultValue)));
    }

    public String getString(String key) {
        return cfg.getProperty(key);
    }

    public String getString(String key, String defaultValue) {
        return cfg.getProperty(key, defaultValue);
    }

}


< ?xml version="1.0" encoding="UTF-8"?>
< !DOCTYPE properties SYSTEM "http://java.sun.com/dtd/properties.dtd">

ActionSet actionSet

看名字知道这是一堆action/handle的集合，和struts里的action是一个概念，这里要把它们注册到server里去，每一个http请求都可以分发道义个action去处理。

这里的action是xlightweb里IWebHandler接口的实例，后面会讲到。

所有的action都是从Beans里取出来的，很显然，之前他们都被扔到Beans里去了。