在專案中,往往要手動設定一個Jetty伺服器進行各種引數處理,比如之前在遊戲公司,用的就是遊戲服內部搭建Jetty伺服器,然後方便外部訪問.

主要用到這幾塊.

本身就是Web應用了,還用Jetty幹嘛,當然,我這只是做個示例,以後做app或者平臺級應用都可以用Jetty搭建外部訪問Servlet.

首先,我們設定WebServer,並且設定在監聽器裡,使得WEB伺服器啟動的時候可以載入Jetty伺服器,

這裡是WebServer程式碼:

package com.dc.web;

/**
 * Date: 2014-2-17
 *
 * Copyright (C) 2013-2015 7Road. All rights reserved.
 */


import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.Servlet;

import org.dom4j.DocumentException;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.HandlerList;
import org.eclipse.jetty.server.handler.ResourceHandler;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.road.pitaya.web.WebHandleAnnotation;
import com.road.util.ClassUtil;

/**
 * 
 * @author Tower
 */
public class WebServer
{
    private static final Logger LOGGER = LoggerFactory
            .getLogger(WebServer.class);

    /**
     * jetty自帶的server
     */
    private Server server;

    /**
     * 觸發的處理器
     */
    private ServletContextHandler context;

    /**
     * 處理器列表
     */
    private HandlerList handlerList = new HandlerList();

    /**
     * 觸發的資源處理器
     */
    private ResourceHandler resourceHandler;
    
    /**
     * 單例載入器
     */
    private static class LazyHolder
    {
        private static final WebServer INSTANCE = new WebServer();
    }

    /**
     * 獲取例項
     * 
     * @return
     */
    public static WebServer getInstance()
    {
        return LazyHolder.INSTANCE;
    }
    
    public boolean start()
    {
        LOGGER.info("WebServer is starting...");
        server = new Server(7039);

        try
        {
            context = new ServletContextHandler(ServletContextHandler.SESSIONS);
            context.setContextPath("/");
            context.setResourceBase("");

            resourceHandler = new ResourceHandler();
            resourceHandler.setResourceBase("/webResource/");

            handlerList.addHandler(context);
            handlerList.addHandler(resourceHandler);

            server.setHandler(handlerList);

            loadServletByWebServerConfig();

            server.start();
        }
        catch (DocumentException e)
        {
            LOGGER.error("load Xml Failed");
            e.printStackTrace();
            return false;
        }
        catch (Exception e)
        {
            e.printStackTrace();
            return false;
        }
        LOGGER.info("WebServer has started successfully");
        return true;
    }
    
    /**
     * 載入Servlet的不同介面
     * 
     * @return
     */
    public Map<String, Class<?>> resetMapHandle()
    {
        Map<String, Class<?>> HandleMap = new HashMap<String, Class<?>>();

        // 從相應的包載入Servlet的不同介面
        List<Class<?>> activityClass = ClassUtil
                .getClasses("com.dc.servlet");

        for (Class<?> class1 : activityClass)
        {
            WebHandleAnnotation annotation = class1
                    .getAnnotation(WebHandleAnnotation.class);
            if (annotation != null)
            {
                HandleMap.put(annotation.cmdName(), class1);
            }
        }

        return HandleMap;
    }

    /**
     * 使用WebServerConfig載入Servlet類
     * 
     * @return
     * @throws DocumentException
     */
    private boolean loadServletByWebServerConfig()
    {

        Map<String, Class<?>> HandleMap = resetMapHandle();
        for (Map.Entry<String, Class<?>> one : HandleMap.entrySet())
        {
            try
            {
                String path = one.getKey();
                Servlet servlet = (Servlet) one.getValue().newInstance();
                context.addServlet(new ServletHolder(servlet), path);
            }
            catch (InstantiationException e)
            {
                e.printStackTrace();
                continue;
            }
            catch (IllegalAccessException e)
            {
                e.printStackTrace();
                continue;
            }
        }
        return true;

    }
    
    public boolean close()
    {
        LOGGER.info("WebServer is closing...");
        try
        {
            server.stop();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        LOGGER.info("WebServer has closed successfully");
        return true;
    }

}
 

package com.dc.servlet;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.gson.Gson;
import com.road.entity.info.UserInfo;
import com.road.pitaya.component.LanguageComponent;
import com.road.pitaya.database.DataOption;

/**
 * 中控介面繼承用
 * 
 * @author Tower
 */
public abstract class AbstractServlet extends HttpServlet
{
	private static final long serialVersionUID = 2421477169746085074L;
	@SuppressWarnings("unused")
	private Logger LOGGER = LoggerFactory.getLogger(AbstractServlet.class);
    /**
     * 用於處理實體類的Gson例項
     */
    protected final Gson gson = new Gson();
    /** 請求客戶端的IP */
    protected String requestIP = null;
    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException
    {
        doPost(request, response);
    }

    @Override
    protected void doPost(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException
    {
    	String result = null;
    	try
        {
    		requestIP = com.dc.util.ServletUtil.getRequestIP(request);
    		result = execute(request, response);
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    	response.setCharacterEncoding("UTF-8");

        response.setContentType("text/html");
        response.setStatus(HttpServletResponse.SC_OK);

        PrintWriter out = response.getWriter();
        out.print(result);
        out.flush();
        out.close();
    }

    public abstract String execute(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException;
    
    /**
	 * 建立一個新的賬號
	 * @return
	 */
	protected UserInfo newUserInfo(String site, String iuid, String pssd, Date createTime)
	{
		UserInfo userInfo = new UserInfo();
		userInfo.setOp(DataOption.INSERT);
		userInfo.setSite(site);//所屬平臺
		userInfo.setIuid(iuid);//賬號
		userInfo.setPssd(pssd);//密碼
		userInfo.setCreateTime(createTime);//建立時間
		userInfo.setServerId(0);// 賬號所在服編號（這裡暫不分服）
		return userInfo;
	}
	
	protected String formatTime(long millis)
	{
		int m = (int)(millis/1000);
		int ss = m%60;
		int mm = m/60%60;
		int hh = m/3600%24;
		int dd = m/86400;
		String time = "";
		if(dd > 0)
			time = LanguageComponent.getResource("Login.ServerStatusdd", dd, hh, mm, ss);
		else if(hh > 0)
			time = LanguageComponent.getResource("Login.ServerStatushh", hh, mm, ss);
		else if(mm > 0)
			time = LanguageComponent.getResource("Login.ServerStatusmm", mm, ss);
		else if(ss > 0)
			time = LanguageComponent.getResource("Login.ServerStatusss", ss);
		return time;
	}

    
}
 

中控介面繼承用

然後就是我們測試的Servlet

package com.dc.servlet;

import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.road.pitaya.web.WebHandleAnnotation;

/**
 * 測試介面
 * @author Tower
 *
 */
@WebHandleAnnotation(cmdName = "/doSomething", description = "測試介面.")
public class DoSomethingServlet extends AbstractServlet{

	/**
	 * 
	 */
	private static final long serialVersionUID = -7574673387670968292L;

	@Override
	public String execute(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		System.out.println(111111111);
		return null;
	}

}
 

對於webResources可以看到有個配置檔案:

名字叫:crossdomain.xml

從名字可以看出來,這個是跨域策略,方便跨域訪問.

<?xml version="1.0"?>
<cross-domain-policy>
  <allow-access-from domain="*" />
</cross-domain-policy>

Jetty正常啟動.

我們之前設定的埠是7039

我們在doSomething設定一個斷點,然後我們訪問localhost:7039/doSomething 可以看到,斷點進去,

控制檯輸出,於是,我們一個簡單的Jetty伺服器就搭建完成了,以後可以根據這個Jetty伺服器進行其他各項操作.