Java 内置Http Server构建web应用案例详解

更新时间：2021年09月06日 10:54:55 作者：陈宏鸿

这篇文章主要介绍了Java 内置Http Server构建web应用案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下

一、概述

使用Java技术构建Web应用时，我们通常离不开tomcat和jetty之类的servlet容器，这些Web服务器功能强大，性能强劲，深受欢迎，是运行大型Web应用的必备神器。

虽然Java的设计初衷就是用来开发大型应用的，然而有时候我们开发的程序只是简单的小型应用，对于功能的需求和性能的要求并不高，可能仅仅就几百行甚至几十行代码，这个时候使用tomcat之类的Web服务器去运行就显得有点大材小用了。比如说只是将数据库中的数据读出来转换成JSON，以Web服务的形式吐给调用方这样的阉割型Web应用。如下图所示

二、最简单的Java Http服务器

其实在jdk中已经内置了用于此类简单Web应用构建需求的类库了，sun公司提供的 com.sun.net.httpserver 包就是用来帮助我们解决这类问题的

import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;

public class Main {

    public static void main(String[] arg) throws Exception {
        HttpServer server = HttpServer.create(new InetSocketAddress(8001), 0);
        server.createContext("/test", new TestHandler());
        server.start();
    }

    static  class TestHandler implements HttpHandler{
        @Override
        public void handle(HttpExchange exchange) throws IOException {
            String response = "hello world";
            exchange.sendResponseHeaders(200, 0);
            OutputStream os = exchange.getResponseBody();
            os.write(response.getBytes());
            os.close();
        }
    }
}

如上代码清单所示，仅仅几行代码就可以构建一个五脏俱全的Web应用了。执行代码，在浏览器地址栏里代开链接

http://localhost:8001/test

就能运行这个段程序，输入的结果为helloworld

三、获得外部数据

那在这个程序中如何获取到外部传递过来的数据呢？比如说URL上的查询字符串，POST提交的数据等，其实也很简单

import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import org.apache.commons.io.IOUtils;

import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.InetSocketAddress;
import java.net.URLDecoder;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class Main {

    public static void main(String[] arg) throws Exception {
        HttpServer server = HttpServer.create(new InetSocketAddress(8001), 0);
        server.createContext("/test", new TestHandler());
        server.start();
    }

    static class TestHandler implements HttpHandler{
        @Override
        public void handle(HttpExchange exchange) {
            String response = "hello world";

            try{
                //获得查询字符串(get)
                String queryString =  exchange.getRequestURI().getQuery();
                Map<String,String> queryStringInfo = formData2Dic(queryString);
                //获得表单提交数据(post)
                String postString = IOUtils.toString(exchange.getRequestBody());
                Map<String,String> postInfo = formData2Dic(postString);

                exchange.sendResponseHeaders(200,0);
                OutputStream os = exchange.getResponseBody();
                os.write(response.getBytes());
                os.close();
            }catch (IOException ie) {

            } catch (Exception e) {

            }
        }
    }

    public static Map<String,String> formData2Dic(String formData ) {
        Map<String,String> result = new HashMap<>();
        if(formData== null || formData.trim().length() == 0) {
            return result;
        }
        final String[] items = formData.split("&");
        Arrays.stream(items).forEach(item ->{
            final String[] keyAndVal = item.split("=");
            if( keyAndVal.length == 2) {
                try{
                    final String key = URLDecoder.decode( keyAndVal[0],"utf8");
                    final String val = URLDecoder.decode( keyAndVal[1],"utf8");
                    result.put(key,val);
                }catch (UnsupportedEncodingException e) {}
            }
        });
        return result;
    }
}

上面的代码清单标识了实现的方法。

注意，要保证上面代码编译通过，需要引入commons-io.jar，此包中提供将InputStream转换成String的方法。

四、并发处理

com.sun.net.httpserver似乎默认不支持同时处理多个请求，一旦有并行的请求涌入，需要排队等待程序处理，导致Web程序响应卡顿。自定义实现的方法也很简单，为每个请求开一个新的线程处理即可，如下代码清单所示

import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import org.apache.commons.io.IOUtils;

import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.InetSocketAddress;
import java.net.URLDecoder;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class Main {

    public static void main(String[] arg) throws Exception {
        HttpServer server = HttpServer.create(new InetSocketAddress(8001), 0);
        server.createContext("/test", new TestHandler());
        server.start();
    }

    static class TestHandler implements HttpHandler{
        @Override
        public void handle(HttpExchange exchange) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try{
                        String response = "hello world";
                        //获得查询字符串(get)
                        String queryString =  exchange.getRequestURI().getQuery();
                        Map<String,String> queryStringInfo = formData2Dic(queryString);
                        //获得表单提交数据(post)
                        String postString = IOUtils.toString(exchange.getRequestBody());
                        Map<String,String> postInfo = formData2Dic(postString);

                        exchange.sendResponseHeaders(200,0);
                        OutputStream os = exchange.getResponseBody();
                        os.write(response.getBytes());
                        os.close();
                    }catch (IOException ie) {
                        ie.printStackTrace();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    }

    public static Map<String,String> formData2Dic(String formData ) {
        Map<String,String> result = new HashMap<>();
        if(formData== null || formData.trim().length() == 0) {
            return result;
        }
        final String[] items = formData.split("&");
        Arrays.stream(items).forEach(item ->{
            final String[] keyAndVal = item.split("=");
            if( keyAndVal.length == 2) {
                try{
                    final String key = URLDecoder.decode( keyAndVal[0],"utf8");
                    final String val = URLDecoder.decode( keyAndVal[1],"utf8");
                    result.put(key,val);
                }catch (UnsupportedEncodingException e) {}
            }
        });
        return result;
    }
}

五、优点

Java内置Web服务器在功能、性能、稳定等方面是无法和tomcat和jetty之类的专业Web服务器相比的，它的优点主要是开发和部署方便简单，把程序代码编译成jar包后，丢到装有jvm的服务器上，直接运行就可以了，省去了安装相关的软件、依赖，配置复杂的环境等工作量。

但是，在一些各方面要求都比较高的生产环境下，还是建议使用专门的Web服务器，毕竟它们久经考验，能满足所有功能需求，并且出问题的几率低。

到此这篇关于Java 内置Http Server构建web应用案例详解的文章就介绍到这了,更多相关Java 内置Http Server构建web应用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Spring Boot与RabbitMQ结合实现延迟队列的示例
本篇文章主要介绍了Spring Boot与RabbitMQ结合实现延迟队列的示例，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-11-11
Java聊天室之实现聊天室服务端功能
这篇文章主要为大家详细介绍了Java简易聊天室之实现聊天室服务端功能，文中的示例代码讲解详细，具有一定的借鉴价值，需要的可以了解一下
2022-10-10
java中有无参数和返回值的方法详解
这篇文章主要介绍了java中有无参数和返回值的方法详解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-02-02
java 按行读取文件并输出到控制台的方法
今天小编就为大家分享一篇java 按行读取文件并输出到控制台的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-07-07
java并发编程专题（一）----线程基础知识
这篇文章主要介绍了java并发编程线程的基础知识，文中讲解非常详细，帮助大家更好的学习JAVA并发编程，感兴趣想学习JAVA的可以了解下
2020-06-06
IDEA切换JDK版本超详细操作步骤记录
在我们项目开发的过程中可能会遇到JDK版本过高或者过低导致一些程序无法启动,不兼容的问题,所以我们需要切换JDK的版本号,这篇文章主要给大家介绍了关于IDEA切换JDK版本的超详细操作步骤,需要的朋友可以参考下
2024-03-03
Java Spring事务使用及验证过程详解
这篇文章主要介绍了Java Spring事务使用及验证过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-12-12
如何使用Java调用Spark集群
这篇文章主要介绍了如何使用Java调用Spark集群,我搭建的Spark集群的版本是2.4.4,本文结合示例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧
2024-02-02
SpringBoot响应Json数据乱码通过配置的解决
这篇文章主要介绍了SpringBoot响应Json数据乱码通过配置的解决，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-11-11
java文件上传（单文件多文件）与删除
本文主要分享了java文件上传（单文件多文件）与删除的示例代码。具有很好的参考价值，下面跟着小编一起来看下吧
2017-01-01