Java 如何实现一个http服务器

更新时间：2020年11月20日 12:02:16 作者：自律给我自由

这篇文章主要介绍了Java 如何实现一个http服务器，帮助大家更好的理解和学习Java，感兴趣的朋友可以了解下

在Java中可以使用HttpServer类来实现Http服务器，该类位于com.sun.net包下(rt.jar)。实现代码如下：

主程序类

package bg.httpserver;

import com.sun.net.httpserver.HttpServer;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.concurrent.Executors;

public class HttpServerStarter {
  public static void main(String[] args) throws IOException {
    //创建一个HttpServer实例，并绑定到指定的IP地址和端口号
    HttpServer httpServer = HttpServer.create(new InetSocketAddress(8080), 0);

    //创建一个HttpContext，将路径为/myserver请求映射到MyHttpHandler处理器
    httpServer.createContext("/myserver", new MyHttpHandler());

    //设置服务器的线程池对象
    httpServer.setExecutor(Executors.newFixedThreadPool(10));

    //启动服务器
    httpServer.start();
  }
}

HttpServer：HttpServer主要是通过带参的create方法来创建，第一个参数InetSocketAddress表示绑定的ip地址和端口号。第二个参数为int类型，表示允许排队的最大TCP连接数，如果该值小于或等于零，则使用系统默认值。

createContext：可以调用多次，表示将指定的url路径绑定到指定的HttpHandler处理器对象上，服务器接收到的所有路径请求都将通过调用给定的处理程序对象来处理。

setExecutor：设置服务器的线程池对象，不设置或者设为null则表示使用start方法创建的线程。

HttpHandler实现

package bg.httpserver;

import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 处理/myserver路径请求的处理器类
 */
public class MyHttpHandler implements HttpHandler {
  @Override
  public void handle(HttpExchange httpExchange) {
    try {
      StringBuilder responseText = new StringBuilder();
      responseText.append("请求方法：").append(httpExchange.getRequestMethod()).append("<br/>");
      responseText.append("请求参数：").append(getRequestParam(httpExchange)).append("<br/>");
      responseText.append("请求头：<br/>").append(getRequestHeader(httpExchange));
      handleResponse(httpExchange, responseText.toString());
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }

  /**
   * 获取请求头
   * @param httpExchange
   * @return
   */
  private String getRequestHeader(HttpExchange httpExchange) {
    Headers headers = httpExchange.getRequestHeaders();
    return headers.entrySet().stream()
                .map((Map.Entry<String, List<String>> entry) -> entry.getKey() + ":" + entry.getValue().toString())
                .collect(Collectors.joining("<br/>"));
  }

  /**
   * 获取请求参数
   * @param httpExchange
   * @return
   * @throws Exception
   */
  private String getRequestParam(HttpExchange httpExchange) throws Exception {
    String paramStr = "";

    if (httpExchange.getRequestMethod().equals("GET")) {
      //GET请求读queryString
      paramStr = httpExchange.getRequestURI().getQuery();
    } else {
      //非GET请求读请求体
      BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(httpExchange.getRequestBody(), "utf-8"));
      StringBuilder requestBodyContent = new StringBuilder();
      String line = null;
      while ((line = bufferedReader.readLine()) != null) {
        requestBodyContent.append(line);
      }
      paramStr = requestBodyContent.toString();
    }

    return paramStr;
  }

  /**
   * 处理响应
   * @param httpExchange
   * @param responsetext
   * @throws Exception
   */
  private void handleResponse(HttpExchange httpExchange, String responsetext) throws Exception {
    //生成html
    StringBuilder responseContent = new StringBuilder();
    responseContent.append("<html>")
        .append("<body>")
        .append(responsetext)
        .append("</body>")
        .append("</html>");
    String responseContentStr = responseContent.toString();
    byte[] responseContentByte = responseContentStr.getBytes("utf-8");

    //设置响应头，必须在sendResponseHeaders方法之前设置！
    httpExchange.getResponseHeaders().add("Content-Type:", "text/html;charset=utf-8");

    //设置响应码和响应体长度，必须在getResponseBody方法之前调用！
    httpExchange.sendResponseHeaders(200, responseContentByte.length);

    OutputStream out = httpExchange.getResponseBody();
    out.write(responseContentByte);
    out.flush();
    out.close();
  }
}

运行HttpServerStarter，在浏览器中访问如下：

以上就是Java 如何实现一个http服务器的详细内容，更多关于Java 实现http服务器的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Spring在SingleTon模式下的线程安全详解
这篇文章主要介绍了Spring在SingleTon模式下的线程安全详解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-01-01
Android中Socket通信的实现方法概述
这篇文章主要介绍了Android中Socket通信的实现方法,很有实用价值,需要的朋友可以参考下
2014-08-08
JAVA Iterator 转成 List 的操作
这篇文章主要介绍了JAVA Iterator 转成 List 的操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-12-12
RxJava中map和flatMap的用法区别源码解析
这篇文章主要为大家介绍了RxJava中map和flatMap的用法区别源码解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-09-09
Java中的OkHttp使用教程
OkHttp是目前非常火的网络库，OKHttp与HttpClient类似，也是一个Http客户端，提供了对 HTTP/2 和 SPDY 的支持，并提供了连接池，GZIP 压缩和 HTTP 响应缓存功能，本文重点给大家介绍Java OkHttp使用，感兴趣的朋友一起看看吧
2022-04-04
Java LinkedHashMap深入分析源码
大多数情况下，只要不涉及线程安全问题，Map基本都可以使用HashMap，不过HashMap有一个问题，就是迭代HashMap的顺序并不是HashMap放置的顺序，也就是无序。HashMap的这一缺点往往会带来困扰，所以LinkedHashMap就闪亮登场了，这篇文章通过源码解析带你了解LinkedHashMap
2022-11-11
Spring事务的失效场景你知道多少
这篇文章主要为大家详细介绍了Spring事务的失效场景，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
Java实现网络数据提取所需知识点
这篇文章主要介绍了Java实现网络数据提取所需知识点，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-07-07
Java用for循环Map详细解析
本篇文章主要介绍了Java用for循环Map，需要的朋友可以过来参考下，希望对大家有所帮助
2013-12-12
搜索一文入门ElasticSearch(节点分片 CRUD 倒排索引分词)
这篇文章主要为大家介绍了搜索一文入门ElasticSearch(节点分片 CRUD 倒排索引分词)的基础详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03

Java 如何实现一个http服务器

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具