一、回顾聊天室应用
拥有一个服务器端用来收到客户端的消息并实现业务逻辑、一个客户端发送消息
注意,这里并没有使用任何应用层面的协议,只简单的发送转发等,没有添加额外内容。
不过,显示上在发送消息过程中只是这么简单的转发发送消息是远远不够的,如果BUFFER尺寸不够大,消息残缺也不会报错,我们需要能确保消息发送完整等等特别的应用层协议。
二、网络应用
除了聊天室应用我们还需要知道一些其他应用广泛的应用——网络应用
同样,网络应用也是只是需要一个客户端和一个服务器端进行收发消息的操作。
其中请求及分为两大类:静态资源和动态资源。
静态资源
它拥有如下几个特点:
- 不因请求的次数或顺序而变化
- HTML、CSS、GIF、PNG
-
请求静态资源
客户端请求资源,服务器在获取请求以后会根据相应路径获取资源然后响应给客户端。
动态资源
如果只有静态资源网络会变得无趣,网络中需要一些比如随时间等变量变化变化的资源
它有如下几个特点:
随着请求方/发起时间/请求内容等因素而变化
- 目前的商品库存量
-
请求动态资源
客户端请求资源,服务器会请求容器,容器又会通过Servlet来获取动态资源,然后逐步返回最后响应客户端。
三、Tomcat结构
Tomcat是一个开源的网络服务器,它支持开发人员编译自己的Servlet发送到服务器中,概要结构如图:
接下来解析一下基本结构。
由图注意到在最里面才包裹着Servlet,在外面一层一层的包裹有什么用呢?+
Server:
拥有以下几个特点:
Tomcat服务器最顶层的组件
- 负责运行Tomcat服务器
-
Service:
拥有如下几个特点:
集合Connector和Engine的抽象组件(盒子)
- 一个Server可以包含多个Service
一个Service可以包含多个Connector和Engine
Connector和Processor:
它主要负责提供给服务器的客户一个可以和服务器创建连接的端点,它负责接收请求,负责把相应递交给服务器,它也可以根据请求做出基本的解析来判断下一步如何操作,但它不做具体操作,它会把请求传递给Processor,Processor再把资源传递给Engine。
概括一下:
Connector负责和外界链接建立和请求和响应发送。
Processor负责从Connector接收到请求。总结:
Connector提供基于不同特定协议的实现
- Connector接受解析请求,返回响应
-
Engine:
拥有特点如下:
容器时Tomcat用来处理请求的组件
- 容器内部的组件按照层级排列
-
Host:
拥有特点如下:
Host代表一个虚拟主机
- 一个Engine可以支持对多个虚拟主机的请求
-
Context:
拥有特点如下:
Context代表一个Web Application
- Tomcat最复杂的组件之一
-
Wrapper:
拥有特点如下:
Wrapper是容器最底层的组件
- 包裹住Servlet实例
- 负责管理Servlet实例的生命周期
四、精简版的服务器设计
省略掉Engine、Host、Context、Wrapper五、实现Request
抽象出需要操作的请求 ```java package connector;
import java.io.IOException; import java.io.InputStream;
public class Request { private static final int BUFFER_SIZE = 1024;
/**
* 和Socket对应的InputStream,通过这里真正的读到quest
*/
private InputStream input;
/**
* 具体的资源名字
*/
private String uri;
public Request(InputStream input) {
this.input = input;
}
public String getRequestUri() {
return uri;
}
/**
* 解析请求
*/
public void parse() {
int length = 0;
byte[] buffer = new byte[BUFFER_SIZE];
try {
length = input.read(buffer);
} catch (IOException e) {
e.printStackTrace();
}
StringBuilder request = new StringBuilder();
for (int j = 0; j < length; j++) {
request.append((char) buffer[j]);
}
//进一步解析
uri = parseUri(request.toString());
}
private String parseUri(String request) {
int index1, index2;
index1 = request.indexOf(" ");
if (index1 != -1) {
index2 = request.indexOf(" ", index1 + 1);
if (index2 != -1) {
return request.substring(index1 + 1, index2);
}
}
return "";
}
}
<a name="7k8Hw"></a>
# 六、测试Request
```java
package test.connector;
import connector.Request;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import java.io.ByteArrayInputStream;
import java.io.InputStream;
public class RequestTest {
private static final String VALID_REQUEST="GET /index.html HTTP/1.1";
@Test
public void givenValidRequestThenExtrackUri(){
InputStream input=new ByteArrayInputStream(VALID_REQUEST.getBytes());
Request request=new Request(input);
request.parse();
Assertions.assertEquals("/index.html",request.getRequestUri());
}
}
通过: