Undertow服务器基础分析 - Undertow

标签: undertow 服务器 基础分析 | 发表时间:2014-04-03 10:54 | 作者:WildFly
出处:http://www.iteye.com

Undertow是一个Web服务器,那么它就需要具备的现代Web服务器的基本特性,比如Servlet,JSP,文件服务器,代理服务器,安全认证等。undertow目前已经实现了绝大多数功能,并且因为wildfly通过了JavaEE7 TCK认证,所以可以说Undertow是一个通过Servlet 3.1认证的Web服务器和容器。这篇文章只分析Undertow的主干流程上的主要功能,即undertow-core和undertow-servlet。

在第一篇里介绍过,Undertow的一个设计目的就是为了嵌入当作web服务器使用。当前,很多Java和其他语言的开源项目,都内嵌一个小型的web server,来提供服务能力,可以是输出html,也可以是输出REST方式的json文本。支持HTTP(s)协议,对于很多应用程序已能够满足需要,所以很多框架如Netty支持到HTTP协议这一层,Undertow-core也是这样。

Servlet作为JavaEE重要规范,是目前Java端开发Web应用的首选技术,Undertow-servlet就是一个完备的Servlet容器。本文假设读者已经熟悉Servlet规范知识,并且对Websocket有所了解。

先看一个简单的内嵌WebServer的代码例子:

public class HelloWorldServer {

    public static void main(final String[] args) {
        Undertow server = Undertow.builder()
                .addHttpListener(8080, "localhost")
                .setHandler(new HttpHandler() { //设置HttpHandler回调方法
                    @Override
                    public void handleRequest(final HttpServerExchange exchange) throws Exception {
                        exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain");
                        exchange.getResponseSender().send("Hello World");
                    }
                }).build();
        server.start();
    }
}

 

和上篇XNIO相似,依然用了回调方式。在undertow里,最主要的接口就是HttpHandler,和XNIO中的ChannelListener概念相似。HttpHandler也是只有一个方法handleRequest,参数是HttpServerExchange。

这个程序内嵌一个Web服务器,打开本机的8080端口接受请求,当有浏览器连上之后,就发送一个纯文本"Hello World"。

HttpServerExchange携带所有的上下文状态信息,这个类也是目前undertow里面最长代码,有2000多行。同时包含了request和response的相关信息,可以通过getRequestHeaders()/getResponseHeaders()获取对应头部信息。

Undertow类是入口点,通过builder传入参数来构建Web容器。

再看一个稍微复杂些的构建例子:

Xnio xnio = Xnio.getInstance();

XnioWorker worker = xnio.createWorker(OptionMap.builder()
        .set(Options.WORKER_IO_THREADS, ioThreads)
        .set(Options.WORKER_TASK_CORE_THREADS, workerThreads)
        .set(Options.WORKER_TASK_MAX_THREADS, workerThreads)
        .set(Options.TCP_NODELAY, true)
        .getMap());

OptionMap socketOptions = OptionMap.builder()
        .set(Options.WORKER_IO_THREADS, ioThreads)
        .set(Options.TCP_NODELAY, true)
        .set(Options.REUSE_ADDRESSES, true)
        .getMap();

Pool<ByteBuffer> buffers = new ByteBufferSlicePool(BufferAllocator.DIRECT_BYTE_BUFFER_ALLOCATOR,bufferSize, bufferSize * buffersPerRegion);

    HttpOpenListener openListener = new HttpOpenListener(buffers, OptionMap.builder().set(UndertowOptions.BUFFER_PIPELINED_DATA, true).addAll(serverOptions).getMap(), bufferSize);
    openListener.setRootHandler(rootHandler);
    ChannelListener<AcceptingChannel<StreamConnection>> acceptListener = ChannelListeners.openListenerAdapter(openListener);
    AcceptingChannel<? extends StreamConnection> server = worker.createStreamConnectionServer(new InetSocketAddress(Inet4Address.getByName(listener.host), listener.port), acceptListener, socketOptions);
    server.resumeAccepts();

 
看到上一篇的Xnio知识全部用上。这是Undertow类入口方法构造的过程,参数全部通过OptionMap构造并传递给XnioWorker。构建一个缓冲池Pool<ByteBuffer>,用来分配服务器接收信息缓冲区。

有两个Listener:
HttpOpenListener继承于ChannelListener,作用是当有连接连入时打开端口。rootHandler是一个HttpHandler,也就是上面提过最重要的接口。
acceptListener用来侦听端口,并把openListener引用传入。

然后就可以通过AcceptingChannel来启动Web服务器了。当连接请求到来,首先acceptListener的handleEvent方法被调用:

    public void handleEvent(final AcceptingChannel<C> channel) {
        try {
            final C accepted = channel.accept();
            if (accepted != null) {
                invokeChannelListener(accepted, openListener);
            }
        } catch (IOException e) {
        }
    }
 
    public static <T extends Channel> boolean invokeChannelListener(T channel, ChannelListener<? super T> channelListener) {
        if (channelListener != null) try {
            // 进入openListener handleEvent方法
            channelListener.handleEvent(channel);
        } catch (Throwable t) {
            return false;
        }
        return true;
    }

 
接下来进入HttpOpenListener的handleEvent方法被调用:

    private final Pool<ByteBuffer> bufferPool;
    private final int bufferSize;
    private volatile HttpHandler rootHandler;
    private volatile OptionMap undertowOptions;
    private volatile HttpRequestParser parser;

    public void handleEvent(final StreamConnection channel) {
        HttpServerConnection connection = new HttpServerConnection(channel, bufferPool, rootHandler, undertowOptions, bufferSize);
        HttpReadListener readListener = new HttpReadListener(connection, parser);

        connection.setReadListener(readListener);
        readListener.newRequest();
        channel.getSourceChannel().setReadListener(readListener);
        readListener.handleEvent(channel.getSourceChannel());
    }

 
这里对传入的HttpHandler进行层层封装,HttpServerConnection是一个Http连接的概念抽象,而HttpReadListener则进一步包含了HttpRequestParser,用来解析HTTP请求内容。在readListener.newRequest()方法执行时,创建了上下文信息类HttpServerExchange。这些就绪后,进一步调用HttpReadListener.handleEvent。

处理请求数据的代码在HttpReadListener.handleEventWithNoRunningRequest方法中,整个流程很清晰,就是从缓冲池中拿到可用缓存区,从channel中读取信息,用parser进行解析,并存放到HttpServerExchange中,最后调度给最开始的HttpHandler。

    public static void executeRootHandler(final HttpHandler handler, final HttpServerExchange exchange) {
        try {
            exchange.setInCall(true);
            handler.handleRequest(exchange); //调用最初传入的HttpHandler
            exchange.setInCall(false);
            boolean resumed = exchange.runResumeReadWrite();
            if (exchange.isDispatched()) {
                if(resumed) {
                    throw new RuntimeException("resumed and dispatched");
                }
                final Runnable dispatchTask = exchange.getDispatchTask();
                Executor executor = exchange.getDispatchExecutor();
                exchange.unDispatch();
                if (dispatchTask != null) {
                    executor = executor == null ? exchange.getConnection().getWorker() : executor;
                    executor.execute(dispatchTask);
                }
            } else if(!resumed) {
                exchange.endExchange();
            }
        } catch (Throwable t) {
            exchange.setInCall(false);
            if (!exchange.isResponseStarted()) {
                exchange.setResponseCode(500);
            }
            UndertowLogger.REQUEST_LOGGER.errorf(t, "Blocking request failed %s", exchange);
            exchange.endExchange();
        }
    }

 
我们留意一下isDispatched分支是性能保障的关键,当这个调用可能阻塞时,则从线程池从获取可用线程,调配它来执行。这样就实现了异步操作,结果会放回exchange中。使用HttpServerExchange.dispatch()方法会把执行从IO线程转移到工作线程。另外需要注意exchange不是线程安全的。

如何装配一个支持Servlet的Web容器:

    DeploymentInfo servletBuilder = deployment()
            .setClassLoader(ServletServer.class.getClassLoader())
            .setContextPath(MYAPP)
            .setDeploymentName("test.war")
            .addServlets(
                    servlet("MessageServlet", MessageServlet.class)
                            .addInitParam("message", "Hello World")
                            .addMapping("/*"),
                    servlet("MyServlet", MessageServlet.class)
                            .addInitParam("message", "MyServlet")
                            .addMapping("/myservlet"));

    DeploymentManager manager = defaultContainer().addDeployment(servletBuilder);
    manager.deploy();

    HttpHandler servletHandler = manager.start();
    PathHandler path = Handlers.path(Handlers.redirect(MYAPP))
            .addPrefixPath(MYAPP, servletHandler);
    Undertow server = Undertow.builder()
            .addListener(8080, "localhost")
            .setHandler(path)
            .build();
    server.start();

 
Servlet元信息被保存到DeploymentInfo之中,这里的关键类是实现了DeploymentManager接口的DeploymentManagerImpl,在deploy方法中,将Servlet的各种信息,包括servlet,servletContext,listener,filter等都设置或者封装在对应的Handler之中。然后将其中的HttpHandler传入Undertow入口类中,完成了Servlet容器的构造。

Undertow设计之处就充分考虑了对于Websocket的支持,通过HTTP的Upgrage协议,返回101“继续”指令,Web服务器告诉浏览器要切换协议类型,随后进行Websocket的握手协商,进而完全在原有HTTP连接上同Websocket协议通信。Wildfly对于远程EJB调用,也是通过upgrade方式实现的。

目前undertow支持三种连接器:HTTP, HTTPS, 和AJP(apache httpd通信协议),预计很快会加入对SPDY的支持。

在io.undertow.server.handlers包中,有各种功能的Handler来完成不同的工作,Netty的Handler和Codec作用类似。

对于Undertow分析,还有更多的内容,比如Session, Security, Proxy等等,会逐步展开,学习其设计思路。

 



已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [undertow 服务器 基础分析] 推荐:

Undertow服务器基础分析 - Undertow

- - 开源软件 - ITeye博客
Undertow是一个Web服务器,那么它就需要具备的现代Web服务器的基本特性,比如Servlet,JSP,文件服务器,代理服务器,安全认证等. undertow目前已经实现了绝大多数功能,并且因为wildfly通过了JavaEE7 TCK认证,所以可以说Undertow是一个通过Servlet 3.1认证的Web服务器和容器.

Undertow服务器基础分析 - XNIO

- - ITeye博客
我们从名字上就能看出这是一个NIO思想为基础的IO框架,X是指这个框架可以有多种实现,我们可以从代码库 https://github.com/xnio 中发现一个项目xnio-native,里面有用C实现的nio层,就能体会到这个X的含义,可以直接基于操作系统C库. 目前在Xnio中默认的实现是nio-impl,也就是JDK的NIO.

高性能非阻塞Web 服务器Undertow

- - 互联网 - ITeye博客
WildFly 8 包含了一个全新的Web服务器(Undertow),WildFly 8 默认的Web服务器为Undertow. 一句话概括什么是Undertow - 高性能非阻塞 Web 服务器. Undertow 主要有以下几个特点:. 轻量化 - Undertow 是一个Web 服务器,但它不像传统的Web 服务器有容器的概念,它由两个核心jar包组成,使用API加载一个Web应用可以使用小于10MB的内存.

kernel.org服务器遭入侵

- Lamo - Solidot
kernel.org网站首页发布公告,声称多台服务器在本月初(8月12日前)遭黑客攻击,他们在8月28日发现了入侵. 入侵者利用一位用户凭证获得了服务器根访问权限,他们正在调查黑客是如何提升权限的;系统启动脚本被加入了一个木马启动文件;ssh相关文件被修改. kernel.org声称,他们相信Linux kernel源代码库未受影响,因为git分布式版本控制系统的特性决定了它可以很容易注意到代码变化.

Ubuntu下赌ARM服务器

- Tim - Solidot
今日无数手机平板使用的低能耗处理器能否撑起未来的服务器市场. Canonical计划推出支持ARM架构的Ubuntu服务器版本. Ubuntu Linux并不是x86服务器市场的重量级选手,Red Hat才是. 但通过与ARM合作打造ARM服务器,Canonical正努力赢得更多市场份额. 计划于2011年10月发布的Ubuntu Server 11.10,将同步推出支持x86、x86-64和ARM架构的版本.

Windows 搭建VPN服务器

- 洋白菜 - iGFW
Windows XP搭建PPTP VPN. 普通用户,在家里也可以搭建自己的VPN. 需要将服务器端的电脑直接放置于外网访问下,若是ADSL拨号的话,可以用此电脑直接拨号,中间不接路由器. 若是接路由器的话,可以启用NAT(网络地址转换)中的DMZ,将该服务器IP地址填入此处,那么外网访问到本路由Wan口时,就会直接转到该服务器上.

浅谈web服务器—Nginx

- - CSDN博客推荐文章
常见的web服务器有apache,Nginx,lighttpd等. 但Nginx作为一款高性能的Http和反向代理服务器,由于其高效率、简配置等优势在业内被广泛使用. 目前Taobao、新浪、赶集网、金山、豆瓣网、网易新闻等众多知名互联网企业的服务器都是采用Nginx. 根据url的不同,将HTTP请求转发到后端的应用服务器集群.

centos linux 服务器安全

- - 操作系统 - ITeye博客
我们必须明白:最小的权限+最少的服务=最大的安全. 所以,无论是配置任何服务器,我们都必须把不用的服务关闭、把系统权限设置到最小话,这样才能保证服务器最大的安全. 下面是CentOS服务器安全设置,供大家参考. 一、注释掉系统不需要的用户和用户组. 注意:不建议直接删除,当你需要某个用户时,自己重新添加会很麻烦.

Java NIO服务器实例

- - ImportNew
我一直想学习如何用Java写一个 非阻塞IO服务器,但无法从网上找到一个满足要求的服务器. 我找到了 这个示例,但仍然没能解决我的问题. 还可以选择 Apache MINA框架. 但我的要求相对简单,MINA对我来说还稍微有点复杂. 所以在MINA和一些教程(参见 这篇和 这篇)的帮助下,我自己写了一个非阻塞IO服务器.

angularjs与服务器交互

- - CSDN博客Web前端推荐文章
真正的应用需要和真实的服务器进行交互,移动应用和新兴的Chrome桌面应用可能是个例外,但是对于此外的所有应用来说,无论你是想把数据持久化到云端,还是需要与其他用户进行实时交互,都需要让应用与服务器进行交互. 为了实现这一点,Angular提供了一个叫做$http的服务. 它提供了一个可扩展的抽象方法列表,使得与服务器的交互更加容易.