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服务器的资料请关注脚本之家其它相关文章!

相关文章

  • 在Java中将double转换为int的操作方法

    在Java中将double转换为int的操作方法

    这篇文章主要介绍了在Java中将double转换为int的操作方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03
  • Java实现桥接方法isBridge()和合成方法isSynthetic()

    Java实现桥接方法isBridge()和合成方法isSynthetic()

    本文主要介绍了Java实现桥接方法isBridge()和合成方法isSynthetic(),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-06-06
  • SpringBoot权限认证-Sa-Token的使用详解

    SpringBoot权限认证-Sa-Token的使用详解

    Sa-Token是一款轻量级Java权限认证框架,它简化了权限管理,提高了开发效率,本文通过实例介绍了Sa-Token的基本概念、与其他框架的比较、基本语法和高级用法,并探讨了其核心原理和实际应用场景,感兴趣的朋友一起看看吧
    2024-09-09
  • Lombok的@Data等注解无效的解决

    Lombok的@Data等注解无效的解决

    这篇文章主要介绍了Lombok的@Data等注解无效的解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • 浅谈Spring @Async异步线程池用法总结

    浅谈Spring @Async异步线程池用法总结

    本篇文章主要介绍了浅谈Spring @Async异步线程池用法总结,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-07-07
  • JPA-JpaRepository方法命名语法说明

    JPA-JpaRepository方法命名语法说明

    这篇文章主要介绍了JPA-JpaRepository方法命名语法说明,具有很好的参考价值。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11
  • Java 面试题和答案 -(上)

    Java 面试题和答案 -(上)

    本文主要介绍Java 面试题和答案,这里整理了Java面试中出现的各种题型,和相应知识点,有需要的小伙伴可以好好参考下,帮助大家面试成功
    2016-09-09
  • springCloud config本地配置操作

    springCloud config本地配置操作

    这篇文章主要介绍了springCloud config本地配置操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-10-10
  • MyBatis延迟加载的处理方案

    MyBatis延迟加载的处理方案

    MyBatis 支持 延迟加载(Lazy Loading),允许在需要数据时才从数据库加载,而不是在查询结果第一次返回时就立即加载所有数据,延迟加载的核心思想是,将关联对象或集合的加载推迟到真正需要时才进行加载,本文给大家介绍了MyBatis延迟加载的处理方案
    2024-12-12
  • Java动态代理机制详解_动力节点Java学院整理

    Java动态代理机制详解_动力节点Java学院整理

    这篇文章主要为大家详细介绍了Java动态代理机制,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-06-06

最新评论