深入剖析tomcat之一个简单的web服务器

简介:

这个简单的web服务器包含三个类

  • HttpServer
  • Request
  • Response

在应用程序的入口点,也就是静态main函数中,创建一个HttpServer实例,然后调用其await()方法。顾名思义,await方法会在制定的端口上等待http请求,并对其进行处理,然后发送相应的消息回客户端。在接收到命令之前,它会一直保持等待的状态。

  • HttpServer类

package simpleHttpServer;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class HttpServer {
    
    public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator
            + "webroot";
    
    private static final String SHUTDOWN_COMMAND = "/SHUTDOWN";
    
    private boolean shudown = false;
    
    public static void main(String[] args){
        HttpServer server = new HttpServer();
        server.await();
    }
    
    public void await(){
        ServerSocket serverSocket = null;
        int port = 8080;
        
        try{
            serverSocket = new ServerSocket(port,1,InetAddress.getByName("127.0.0.1"));
        }
        catch (IOException e){
            e.printStackTrace();
            System.exit(1);
        }
        
        while(!this.shudown){
            Socket socket = null;
            InputStream input = null;
            OutputStream output = null;
            
            try{
                
                socket = serverSocket.accept();
                input = socket.getInputStream();
                output = socket.getOutputStream();
                
                Request request = new Request(input);
                request.parse();
                
                Response response = new Response(output);
                response.setRequest(request);
                response.sendStaticResource();
                
                socket.close();
                
                this.shudown = request.getUri().equals(SHUTDOWN_COMMAND);
                
            }
            catch (Exception e){
                e.printStackTrace();
                continue;
            }
        }
        
    }
        
}

这个简单的web服务器,可以处理指定目录中的静态资源请求;用WEB_ROOT表示制定的目录

public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "webroot";

这里是指当前目录下的webroot文件夹下面的资源。
我们通过在游览器中输入这样的内容,进行资源的请求:
http://127.0.0.1:8080/index.html

  • Request类
    Request类表示一个Http请求,可以传递InputStream对象来创建Request对象,调用InputStream对象的read进行Http请求数据的读取。

package simpleHttpServer;

import java.io.InputStream;

public class Request {
    private InputStream input;
    private String uri;
    
    public Request(InputStream input){
        this.input = input;
    }
    
    public void parse(){
        StringBuffer request = new StringBuffer(2048);
        
        int i;
        byte[] buffer = new byte[2048];
        try{
            i = input.read(buffer);
        }
        catch (Exception e){
            e.printStackTrace();
            i = -1;
        }
        
        for(int j=0;j<i;j++){
            request.append((char)buffer[j]);
        }
        
        System.out.print(request.toString());
        this.uri = this.parseUri(request.toString());
        
    }
    
    private String parseUri(String requestString){
        int index1,index2;
        index1 = requestString.indexOf(' ');
        if(index1 != -1){
            index2 = requestString.indexOf(' ', index1 + 1);
            if(index2 > index1){
                return requestString.substring(index1 + 1,index2 );
            }
        }
        return null;
    }
    
    public String getUri(){
        return this.uri;
    }
    
}

Request类最重要的两个函数是parse和ParseUri;parse()方法会调用私有方法parseUri来解析HTTP请求的uri,初次之外,并没有做太多的工作。parseuri会将解析的URI存储在变量uri中。

我们以 http://127.0.0.1:8080/index.html 请求为例,HTTP请求的请求行为
GET /index.html HTTP/1.1
parse()方法从传入的Request对象的InputStream对象中读取整个字节流,并且将字节数组存入缓冲区。然后用缓存区的数组初始化StringBuffer对象request。 这样再解析StringBuffer就可以解析到Uri。

*Response类
Response类表示Http相应。其定义如下


package simpleHttpServer;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;

public class Response {
    
    private static final int BUFFER_SIZE = 1024;
    private Request request;
    private OutputStream output;
    
    public Response(OutputStream output){
        this.output = output;
    }
    
    public void setRequest(Request request){
        this.request = request;
    }
    
    public void sendStaticResource()throws IOException{
        
        byte[] bytes = new byte[BUFFER_SIZE];
        FileInputStream fis = null;
        
        try{
            
            File file = new File(HttpServer.WEB_ROOT,request.getUri());
            if(file.exists()){
                fis = new FileInputStream(file);
                int ch = fis.read(bytes, 0, BUFFER_SIZE);
                while(ch != -1){
                    output.write(bytes, 0, ch);
                    ch = fis.read(bytes, 0, BUFFER_SIZE);
                }
            }
            else{
                String errorMessage = "HTTP/1.1 404 File Not Found\r\n" + 
                            "Content-Type: text/html\r\n" +
                            "Content-Length:23\r\n" +
                            "\r\n" + 
                            "<h1>File Not Found</h1>";
                output.write(errorMessage.getBytes());
            }
            
        }
        catch (Exception e){
            e.printStackTrace();
        }
        finally{
            if(fis != null){
                fis.close();
            }
        }
        
    }
    
    
}

使用OutputStream和Request来初始化Reponse,Response比较简单,得到Request的Uri,然后读取对应的file,如果file存在,则将file中的数据读取到缓存中,并且发送给游览器;如果file不存在,那么就发送

"HTTP/1.1 404 File Not Found\r\n" + 
                            "Content-Type: text/html\r\n" +
                            "Content-Length:23\r\n" +
                            "\r\n" + 
                            "<h1>File Not Found</h1>";

错误信息给游览器。

我们在eclipse中将代码跑起来,在游览器中输入
http://127.0.0.1:8080/index.html

http://127.0.0.1:8080/index.php

一个简单的额web服务器就跑起来了!


相关文章
|
8月前
|
移动开发 数据挖掘 开发者
服务器发送事件(SSE)在现代Web开发中的关键作用
服务器发送事件(SSE)是HTML5标准协议,用于服务器主动向客户端推送实时数据,适合单向通信场景。相比WebSocket,SSE更简洁高效,基于HTTP协议,具备自动重连、事件驱动等特性。常见应用场景包括实时通知、新闻推送、数据分析等。通过Apipost等工具可轻松调试SSE,助力开发者构建高效实时Web应用。示例中,电商平台利用SSE实现秒杀活动通知,显著减少延迟并简化架构。掌握SSE技术,能大幅提升用户体验与开发效率。
|
12月前
|
XML 前端开发 JavaScript
PHP与Ajax在Web开发中的交互技术。PHP作为服务器端脚本语言,处理数据和业务逻辑
本文深入探讨了PHP与Ajax在Web开发中的交互技术。PHP作为服务器端脚本语言,处理数据和业务逻辑;Ajax则通过异步请求实现页面无刷新更新。文中详细介绍了两者的工作原理、数据传输格式选择、具体实现方法及实际应用案例,如实时数据更新、表单验证与提交、动态加载内容等。同时,针对跨域问题、数据安全与性能优化提出了建议。总结指出,PHP与Ajax的结合能显著提升Web应用的效率和用户体验。
255 3
|
Java PHP
PHP作为广受青睐的服务器端脚本语言,在Web开发中占据重要地位。理解其垃圾回收机制有助于开发高效稳定的PHP应用。
【10月更文挑战第1天】PHP作为广受青睐的服务器端脚本语言,在Web开发中占据重要地位。其垃圾回收机制包括引用计数与循环垃圾回收,对提升应用性能和稳定性至关重要。本文通过具体案例分析,详细探讨PHP垃圾回收机制的工作原理,特别是如何解决循环引用问题。在PHP 8中,垃圾回收机制得到进一步优化,提高了效率和准确性。理解这些机制有助于开发高效稳定的PHP应用。
149 3
|
Java 应用服务中间件 Windows
windows服务器重装系统之后,Tomcat服务如何恢复?
windows服务器重装系统之后,Tomcat服务如何恢复?
236 11
|
安全 Java 应用服务中间件
【服务器知识】Tomcat简单入门
【服务器知识】Tomcat简单入门
|
Java 应用服务中间件 Apache
浅谈Tomcat和其他WEB容器的区别
Tomcat是一款轻量级的免费开源Web应用服务器,常用于中小型系统及并发访问量适中的场景,尤其适合开发和调试JSP程序。它不仅能处理HTML页面,还充当Servlet和JSP容器。相比之下,物理服务器是指具备处理器、硬盘等硬件设施的服务器,如云服务器,其设计目标是在处理能力、稳定性和安全性等方面提供高标准服务。简言之,Tomcat专注于运行Java应用,而物理服务器则提供基础计算资源。
|
云安全 弹性计算 Java
阿里云ECS配置tomcat
centos7配置tomcat
524 1
|
16天前
|
弹性计算 运维 安全
阿里云轻量应用服务器与云服务器ECS啥区别?新手帮助教程
阿里云轻量应用服务器适合个人开发者搭建博客、测试环境等低流量场景,操作简单、成本低;ECS适用于企业级高负载业务,功能强大、灵活可扩展。二者在性能、网络、镜像及运维管理上差异显著,用户应根据实际需求选择。
147 10
|
14天前
|
运维 安全 Ubuntu
阿里云渠道商:服务器操作系统怎么选?
阿里云提供丰富操作系统镜像,涵盖Windows与主流Linux发行版。选型需综合技术兼容性、运维成本、安全稳定等因素。推荐Alibaba Cloud Linux、Ubuntu等用于Web与容器场景,Windows Server支撑.NET应用。建议优先选用LTS版本并进行测试验证,通过标准化镜像管理提升部署效率与一致性。
|
18天前
|
弹性计算 ice
阿里云4核8g服务器多少钱一年?1个月和1小时价格,省钱购买方法分享
阿里云4核8G服务器价格因实例类型而异,经济型e实例约159元/月,计算型c9i约371元/月,按小时计费最低0.45元。实际购买享折扣,1年最高可省至1578元,附主流ECS实例及CPU型号参考。
239 8

热门文章

最新文章