实现01
1.实现任务阶段1
编写mytomcat,该服务器能给浏览器返回“你好,我是服务器!”的简单信息。
根据之前的tomcat框架整体分析,我们将浏览器发送请求,tomcat服务器处理请求,返回资源的整个过程分为三个部分。现在来分析并初步实现第一部分的功能。
1.1基于socket开发服务端流程
1.2需求分析/图解
工作:先打通自定义web服务器和浏览器之间的通道。
如浏览器请求http://localhost:8080/Xxx
,服务器可以接收请求并返回简单数据。
注意:这里的交互是都建立在http协议之上的。服务器获取到的数据是http格式的,返回的数据也要封装成http格式,浏览器才能正常解析。
http格式详见javaweb-day14-HTTP协议
1.3代码实现
MyTomcatV1:
package com.li.MyTomcat;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @author 李
* @version 1.0
* 这是第一个版本的tomcat,可以完成接收浏览器请求,并返回信息功能
*/
public class MyTomcatV1 {
public static void main(String[] args) throws IOException {
//1.创建ServerSocket,在8080端口监听
ServerSocket serverSocket = new ServerSocket(8080);
System.out.println("==========mytomcat在8080端口监听=========");
while (!serverSocket.isClosed()) {
//等待浏览器或客户端的连接
//如果有连接来,就创建socket
//这个socket就是浏览器和服务器之间的连接(通道)
Socket socket = serverSocket.accept();
//先接收浏览器发送的数据
InputStream inputStream = socket.getInputStream();//字节流
//为了方便,将其转成字符流(InputStreamReader==>转换流,将一个字节流转换成字符流)
//BufferedReader==>字符处理流
BufferedReader bufferedReader =
new BufferedReader(new InputStreamReader(inputStream, "utf-8"));
String mes = null;
System.out.println("========接收到浏览器发送的数据=======");
//循环地读取
while ((mes = bufferedReader.readLine()) != null) {//按行读取数据,如果已到达流末尾,则返回 null
//判断mes的长度是否为0
if (mes.length() == 0) {
break;//退出while
}
System.out.println(mes);
}
//我们的tomcat回送数据-按照http格式
//关闭资源
inputStream.close();
socket.close();
}
}
}
运行代码,在浏览器中发送请求http://localhost:8080/cal.html
,后端输出如下:
可以看到,程序成功接收到了浏览器的请求(http格式)
下面以http格式响应浏览器请求:
package com.li.MyTomcat;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @author 李
* @version 1.0
* 这是第一个版本的tomcat,可以完成接收浏览器请求,并返回信息功能
*/
public class MyTomcatV1 {
public static void main(String[] args) throws IOException {
//1.创建ServerSocket,在8080端口监听
/**
* ..........
*/
//mytomcat服务器回送数据-按照http格式
OutputStream outputStream = socket.getOutputStream();
//模仿响应头
//\r\n表示回车换行:因为响应头最后一行和响应体中间要隔一个空行,
// 所以最后一行要写两个\r\n(响应头换行是空行,空行再换行才是响应体)
//即 http响应体前面需要有两个换行\r\n\r\n
String respHeader = "HTTP/1.1 200 OK\r\n" +
"Content-Type: text/html;charset=utf-8\r\n\r\n";
String resp = respHeader + "你好,我是服务器!";
System.out.println("=====MyTomcat给浏览器回送的数据=====");
System.out.println(resp);
//注意:这里返回数据要以字节流方式返回
outputStream.write(resp.getBytes());//将resp字符串以byte[]方式返回
//关闭资源
outputStream.flush();
outputStream.close();
inputStream.close();
socket.close();
}
}
}
1.4测试
运行代码,在浏览器中发送请求http://localhost:8080/
,后台输出如下:
浏览器输出如下:
2.实现任务阶段2-使用BIO线程模型,支持多线程
2.1BIO线程模型介绍
这里为了简单,使用方式一来完成操作,每次请求都会创建一个线程。
2.2需求分析/图解
- 需求分析如图所示,浏览器请求http://localhost:8080/,服务器返回“你好,我是服务器”。
- 后台mytomcat使用BIO线程模型,支持多线程,对数据的返回和处理移至线程里处理。
阶段1存在一个问题:当一个客户端被服务端在等待读取数据的时候,服务端会卡在那里,使得别的客户端无法与服务端连接以及收发数据。
解决方案是让等待接收数据的那块让子线程去做,主线程只需要一直监听是否有客户端连接即可,这样每个客户端就相互不影响了。
2.3代码实现
RequestHandler:
package com.li.MyTomcat.hander;
import java.io.*;
import java.net.Socket;
/**
* @author 李
* @version 1.0
* RequestHandler是一个线程对象
* 用来处理一个http请求
*/
public class RequestHandler imple