一个简单的web服务器-阿里云开发者社区

一个简单的web服务器

2016-04-10 1722

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介：

https://github.com/javahongxi

https://coding.net/u/javahongxi/p/whatsmars-mars001/git

https://code.csdn.net/javahongxi/whatsmars-mars001/tree/master

HttpServer, Request, Response

    Java代码  
    
  
package com.iteye.wely.server;  
  
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;  
  
/** 
 * Created by shenhongxi on 16/3/21. 
 */  
public class HttpServer {  
  
    public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "ixhong-tomcat-web/src/main/webapp";  
  
    private static final String SHUTDOWN_COMMAND = "SHUTDOWN";  
  
    private boolean shutdown = false;  
  
    public static void main(String[] args) {  
        HttpServer server = new HttpServer();  
        System.out.println(WEB_ROOT);  
        server.await();  
    }  
  
    private void await() {  
        ServerSocket serverSocket = null;  
        int port = 8080;  
        try {  
            serverSocket = new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));  
            System.out.println("Server started!");  
        } catch (IOException e) {  
            e.printStackTrace();  
            System.exit(1);  
        }  
  
        while (!shutdown) {  
            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();  
  
                shutdown = request.getUri().equals(SHUTDOWN_COMMAND);  
            } catch (Exception e) {  
                e.printStackTrace();  
                continue;  
            }  
        }  
    }  
}  

    Java代码  
    
  
package com.iteye.wely.server;  
  
import java.io.IOException;  
import java.io.InputStream;  
  
/** 
 * Created by shenhongxi on 16/3/21. 
 */  
public class Request {  
  
    private InputStream input;  
  
    private String uri; // 性能考虑，用byte[]  
  
    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 (IOException e) {  
            e.printStackTrace();  
            i = -1;  
        }  
        for (int j = 0; j < i; j++) {  
            request.append((char) buffer[j]);  
        }  
        System.out.println(request.toString());  
        uri = parseUri(request.toString());  
    }  
  
    private String parseUri(String requestStr) {  
        // GET /index.html HTTP/1.1  
        // Accept: text/plain; text/html  
        // ...  
        int index1 = requestStr.indexOf(' ');  
        int index2;  
        if (index1 != -1) {  
            index2 = requestStr.indexOf(' ', index1 + 1);  
            if (index2 > index1) {  
                return requestStr.substring(index1 + 1, index2);  
            }  
        }  
        return null;  
    }  
  
    public String getUri() {  
        return uri;  
    }  
}  

    Java代码  
    
  
package com.iteye.wely.server;  
  
import java.io.File;  
import java.io.FileInputStream;  
import java.io.IOException;  
import java.io.OutputStream;  
  
/** 
 * Created by shenhongxi on 16/3/21. 
 */  
public class Response {  
  
    private static final int BUFFER_SIZE = 1024;  
  
    Request request;  
  
    OutputStream output;  
  
    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 errorMsg = "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(errorMsg.getBytes());  
            }  
        } catch (Exception e) {  
            e.printStackTrace();  
        } finally {  
            if (fis != null) {  
                fis.close();  
            }  
        }  
    }  
  
    public Response(OutputStream output) {  
        this.output = output;  
    }  
  
    public void setRequest(Request request) {  
        this.request = request;  
    }  
}  

一个简单的web服务器

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

一个简单的web服务器

热门文章

最新文章

相关课程

相关电子书

相关实验场景