模拟服务器2.0——HttpRequest 、HttpResponse

创建HttpRequest类
-声明三个请求参数
-在构造函数中初始化请求参数
-改造run方法
HttpRequest1.0版本-私有化变量，提高程序安全性，代码复用性，开发效率。

package http;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

/**
 * 这个类用来封装请求信息
 */
public class HttpRequest {
    // 声明三个请求参数 GET /index.html HTTP/1.1
    private String method;// 请求方式
    private String uri;// 请求资源的路径
    private String protocol;// 请求遵循的协议名,版本号

    public String getMethod() {
        return method;
    }

    public void setMethod(String method) {
        this.method = method;
    }

    public String getUri() {
        return uri;
    }

    public void setUri(String uri) {
        this.uri = uri;
    }

    public String getProtocol() {
        return protocol;
    }

    public void setProtocol(String protocol) {
        this.protocol = protocol;
    }

    // 在构造函数中初始化请求参数
    public HttpRequest(InputStream in) {
        // 获取请求流
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
        // 获取请求行
        try {
            String line = reader.readLine();
            // GET /index.html HTTP/1.1
            if (line != null && line.length() >= 0) {
                // 按空格切分字符串
                String[] datas = line.split(" ");
                method = datas[0];
                uri = datas[1];
                // 设置网站的默认主页
                if (uri.equals("/")) {
                    uri = "/index.html";
                }
                protocol = datas[2];
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 改造run方法
}

ClientHandler1.0

package core;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;

import http.HttpRequest;

/**
 * 这个类用来完成WebServer类的优化，提取代码
 *
 */
public class ClientHandler implements Runnable {

    // 创建代表客户端的Socket对象
    private Socket socket;

    // 在构造函数中传入Socket对象并保存在类中
    public ClientHandler(Socket socket) {
        this.socket = socket;// this.socket获取等号左边的成员变量
    }

    // 重写run方法
    @Override
    public void run() {
        // 创建PrintStream对象
        try {
               //利用请求对象完成请求过程
                HttpRequest request=new HttpRequest(socket.getInputStream());
            
                PrintStream ps = new PrintStream(socket.getOutputStream());
                // 拼接响应头
                // 状态行
                // 响应头只能发送一次
                ps.println("HTTP/1.1 200 OK");// 协议名/版本号 状态码 状态码对应的状态描述信息
                ps.println("Content-Type:text/html");// 响应头

                // 向浏览器输出响应文件
                File file = new File("WebContent" + request.getUri());// 读取指定位置的文件
                ps.println("Content-Length:" + file.length());

                // 空白行
                ps.println();
                // 数据响应:响应网页文件 带缓存的读入流
                BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file));
                byte[] bs = new byte[(int) file.length()];
                bis.read(bs);
                // 响应
                ps.write(bs);
                bis.close();
                ps.flush();
                socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

WebServer

package core;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 这个类用来代表服务器端的程序
 */
public class WebServer {
    // 1.声明ServerSocket,代表服务器
    private ServerSocket server;
    
    //声明线程池对象
    private ExecutorService pool;
    

    // 2.在构造函数初始化ServerSocket对象
    public WebServer() {
        try {
            server = new ServerSocket(8082);
            //在构造函数中初始化线程池
            pool=Executors.newFixedThreadPool(100);//固定大小的线程池
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 3.创建start方法，用来接收请求，处理业务，响应
    public void start() {
        // 用来接收请求
        try {
            while (true) {
                // 返回客户端
                Socket socket = server.accept();
                //改造start方法
                pool.execute(new ClientHandler(socket));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 创建mian方法启动服务器
    public static void main(String[] args) {
        WebServer server = new WebServer();
        server.start();
    }
}

创建HttpResponse
--声明4个响应参数，get set
--在构造函数中传入OutputStream对象
--改造getOut方法，并给参数赋值
--改造run方法

package http;

import java.io.OutputStream;
import java.io.PrintStream;

/**
 * 这个类用来封装响应信息
 */
public class HttpResponse {
    // 声明4个响应参数，get set
    // HTTP/1.1200 OK
    // Content-Type
    // Content-Length
    private String protocol;// 协议名版本号
    private int status;// 状态码 404 500 403 400
    private String contentType;// 响应类型
    private int contentLength;// 响应长度

    public String getProtocol() {
        return protocol;
    }

    public void setProtocol(String protocol) {
        this.protocol = protocol;
    }

    public int getStatus() {
        return status;
    }

    public void setStatus(int status) {
        this.status = status;
    }

    public String getContentType() {
        return contentType;
    }

    public void setContentType(String contentType) {
        this.contentType = contentType;
    }

    public int getContentLength() {
        return contentLength;
    }

    public void setContentLength(int contentLength) {
        this.contentLength = contentLength;
    }

    // 在构造函数中传入OutputStream对象
    private OutputStream out;

    public HttpResponse(OutputStream out) {
        this.out = out;
    }

    // 改造getOut方法，并给参数赋值
    // 保证响应头只被发送一次
    boolean isSend;// 默认是false

    public OutputStream getOut() {
        if (!isSend) {// 拼接响应头的过程
            PrintStream ps = new PrintStream(out);// ps有换行的功能
            // 拼接状态行
            ps.println(protocol + " " + status + " OK");
            // 响应类型
            ps.println("Content-Type:" + contentType);
            // 响应长度
            ps.println("Content-Length:" + contentLength);
            // 空白行
            ps.println();
            isSend=true;//改变发送状态
        }
        return out;
    }

    public void setOut(OutputStream out) {
        this.out = out;
    }

    // 改造run方法
}

改造ClinetHandler

package core;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;

import http.HttpRequest;
import http.HttpResponse;

/**
 * 这个类用来完成WebServer类的优化，提取代码
 *
 */
public class ClientHandler implements Runnable {

    // 创建代表客户端的Socket对象
    private Socket socket;

    // 在构造函数中传入Socket对象并保存在类中
    public ClientHandler(Socket socket) {
        this.socket = socket;// this.socket获取等号左边的成员变量
    }

    // 重写run方法
    @Override
    public void run() {
        // 创建PrintStream对象
        try {
               //利用请求对象完成请求过程
                HttpRequest request=new HttpRequest(socket.getInputStream());
            
                PrintStream ps = new PrintStream(socket.getOutputStream());
                // 拼接响应头
                // 状态行
                // 响应头只能发送一次
                ps.println("HTTP/1.1 200 OK");// 协议名/版本号 状态码 状态码对应的状态描述信息
                ps.println("Content-Type:text/html");// 响应头

                //利用响应对象完成响应过程
                HttpResponse response=new HttpResponse(socket.getOutputStream());
                response.setProtocol("HTTP/1.1");
                response.setStatus(200);
                response.setContentType("text/html");
                File file=new File("WebContent"+request.getUri());
                response.setContentLength((int)file.length());
                // 数据响应:响应网页文件 带缓存的读入流
                BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file));
                byte[] bs = new byte[(int) file.length()];
                bis.read(bs);
                // 响应
                response.getOut().write(bs);
                bis.close();
                response.getOut().flush();
                socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

相关阅读更多精彩内容

  • 2016年5月Swift 2 学习 --- 117个注意事项与要点
    这是16年5月份编辑的一份比较杂乱适合自己观看的学习记录文档，今天18年5月份再次想写文章，发现简书还为我保存起的...
    Jenaral阅读 3,247评论 2赞 9
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 137,140评论 19赞 139
  • RN模拟器报错中文翻译
    { "Unterminated string literal.": "未终止的字符串文本。", "Identifi...
    一粒沙随风飘摇阅读 11,435评论 0赞 3
  • 咖啡在等一个人（结）
    林旭去了意大利参加比赛，这一次他获得了亚洲区冠军，成为了中国最有名气的咖啡大师。 比赛结束的一年里，他要奔走在各大...
    拉小姐阅读 512评论 6赞 3
  • …
    生活里没有暂停键 只有好好过和将就过 不管你又有准备好，有没有心情 一天终究会过去
    qu溜达溜达阅读 111评论 0赞 0

友情链接更多精彩内容