设为首页 收藏本站
查看: 1216|回复: 0

[经验分享] jetty 介绍之handler

[复制链接]

尚未签到

发表于 2017-2-26 09:38:31 | 显示全部楼层 |阅读模式
  文章参考
  http://ipjmc.iteye.com/blog/1839999
  http://blog.csdn.net/huangmin2050/article/details/7487922
  嵌入一个jetty服务一般会有下面几步,创建Server,加载Connectors,加载handlers,加载Servlets等,启动服务start,最后加入服务器join
  一个Jetty Server可以看成由一下几部分组成,其中Connector负责接收客户端的HTTP请求,请求的处理是由Handler来完成的
DSC0000.png

  Handler在Jetty中是一个非常重要的东西,Jetty内部实现了一些Handler,可以分为一下几类:
  1.协调Handler:负责将request路由到其他Handler的Handler(如:HandlerConnection, ContextHandlerConnection)
  2.过滤Handler:负责向request中设置一些参数,然后再把请求转交给其他Handler(如:HandlerWapper, ContextHandler, SessionHandler)
  3.生成Handler:负责生成响应的内容(如:ResourceHandler, ServletHandler)
  当jetty只起一个服务,没有任何handlers和Connectors等时,浏览器访问会返回404。很容易理解,就是有服务,但是服务没有返回response,所以会返回404。

public static void main(String[] args) throws Exception
{
Server server = new Server(8081);
// server.setHandler(new HelloHandler());
server.start();
server.join();
}
  该服务启动后,由于没有任何针对服务的操作,会对所有request返回404。
  再看一个简单HelloHandler的介绍和handle方法的参数介绍:

public class HelloHandler extends AbstractHandler
{
public void handle(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
throws IOException, ServletException
{
response.setContentType("text/html;charset=utf-8");
response.setStatus(HttpServletResponse.SC_OK);
baseRequest.setHandled(true);
response.getWriter().println("<h1>Hello World2</h1>");
}
}
  target——request的目标,可以是一个url或者一个适配器。
  baseRequest——jetty可变的request对象,可以不封装。
  request——不可变的request对象,可以被封装。
  response——response对象,可以被封装
  如上代码handle设置response的状态,ContentType和标记request是否被处理等。。复杂的处理可以用多个Handler结合使用,达到复杂的处理结果。jetty的一些handler可以在org.eclipse.jetty.server.handler中查找
  Handler的强大的地方是可以为Jetty Server设置若干Handler,每个Handler完成自己的功能,Handler的处理过程如下
DSC0001.png

  HandlerList和HandlerConnection内部都可以设置若干Handler, Handler按顺序一个接一个的执行。对于HandlerList而言,只要有一个Handler将请求标记为已处理,或抛出异常,Handler的调用就到此结束。而HandlerConnection则不会结束,一直调用到最后一个Handler。
  多个handler的处理:

public static void main(String[] args) throws Exception
{
Server server = new Server(8081);
server.setHandler(new HelloHandler());//无效的
server.setHandler(new HelloHandler());//两次setHandler只有后面这次有用
server.start();
server.join();
}
  server调用了两次setHandler,但是只有最后一次setHandler有效,所以上面代码是不行的。
  针对多个handler的处理,如下方才是正道:
  1、HandlerCollection会按照顺序分别执行每个handler,并把结果拼凑到response,返回。如下:

public static void main(String[] args) throws Exception
{
Server server = new Server(8081);
HandlerCollection hc =new HandlerCollection();
hc.setHandlers(new Handler[]{new HelloHandler(),new HelloHandlerScond()});
server.setHandler(hc);
server.start();
server.join();
}
  2、HandlerList顺序执行handler,如果抛出错误才执行下一个handler,否则不执行。如:

public static void main(String[] args) throws Exception
{
Server server = new Server();
SelectChannelConnector connector = new SelectChannelConnector();
connector.setPort(8080);
server.addConnector(connector);
ResourceHandler resource_handler = new ResourceHandler();
resource_handler.setDirectoriesListed(true);
resource_handler.setWelcomeFiles(new String[]{ "index.html" });
resource_handler.setResourceBase(".");
HandlerList handlers = new HandlerList();
handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
server.setHandler(handlers);
server.start();
server.join();
}
  下面以一个具体的例子来说明,需要注意HandlerList和HandlerConnection的区别,代码里有注释:

package hb.jetty;
import java.io.File;
import java.io.IOException;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.eclipse.jetty.server.NCSARequestLog;
import org.eclipse.jetty.server.Request;
import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.AbstractHandler;
import org.eclipse.jetty.server.handler.DefaultHandler;
import org.eclipse.jetty.server.handler.HandlerCollection;
import org.eclipse.jetty.server.handler.HandlerList;
import org.eclipse.jetty.server.handler.HandlerWrapper;
import org.eclipse.jetty.server.handler.RequestLogHandler;
public class ManyHandlers {
public static void main(String[] args) throws Exception {
Server server = new Server(8080);
// create the handlers
Handler param = new ParamHandler();
HandlerWrapper wrapper = new HandlerWrapper() {
@Override
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
throws IOException, ServletException {
request.setAttribute("welcome", "Wylazy");
super.handle(target, baseRequest, request, response);
}
};
Handler hello = new HelloHandler();
wrapper.setHandler(hello);
Handler dft = new DefaultHandler();
//HandlerList会依次调用每一个Handler,直到某个Handler将请求标记为已处理,即setHandled(true);
HandlerList list = new HandlerList();
list.setHandlers(new Handler[] { param, wrapper, dft });
server.setHandler(list);
RequestLogHandler log = new RequestLogHandler();
log.setRequestLog(new NCSARequestLog(File.createTempFile("demo", "log").getAbsolutePath()));
//HandlerCollection会依次调用每一个Handler,即使请求已经被处理了
//HandlerCollection handlers = new HandlerCollection();
//handlers.setHandlers(new Handler[] { list, log });
//server.setHandler(handlers);
server.start();
server.join();
}
public static class ParamHandler extends AbstractHandler {
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
throws IOException, ServletException {
Map params = request.getParameterMap();
if (params.size() > 0) {
response.setContentType("text/plain");
response.getWriter().println(params);
baseRequest.setHandled(true);
}
//baseRequest.setHandled(true);
}
}
public static class HelloHandler extends AbstractHandler {  
public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)  
throws IOException, ServletException {  
response.setContentType("text/html;charset=utf-8");  
response.setStatus(HttpServletResponse.SC_OK);  
baseRequest.setHandled(true);  
response.getWriter().println("<h1>Hello World1</h1>");  
response.getWriter().println("Request url: " + target);  
}  
}  
}

   备注:直接运行代码将handler处理后就不会继续运行了,如果想测试所有的handler都运行,这里就使用HandlerCollection处理。

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-347291-1-1.html 上篇帖子: myeclipse jetty 部署问题 下篇帖子: maven 配置jetty web容器
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表