创建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();
}
}
}
