我们可以将Tomcat 简单理解成一个Web 服务器。这一节主要是讲解Web 服务器是如何工作的。

Web 服务器也可以看作是Http 服务器&＃xff0c;主要是因为它是使用Http 来与客户端进行通信的。一个基于Java 的Web 服务器&＃xff0c;最重要的两个类是java.net.Socket 和 java.net.ServerSocket &＃xff0c; 并通过Http 消息进行通信。其中前者是Socket 客户端&＃xff0c;后者是Socket 服务端。

套接字&＃xff08;Socket&＃xff09;指的就是网络连接的一个端点。可以从网络中读取和写入数据。

Java 中创建一个Socket 有很多构造方法。可以通过主机名/IP地址、端口创建一个Socket 对象

new Socket("127.0.0.1",80);

Socket 创建以后&＃xff0c;就可以使用它来发送和接收数据。

// 1.创建一个Socket 客户端对象
Socket socket &＃61; new Socket("127.0.0.1", 80);
// 2.关闭Socket
socket.close();

为了从Web 服务器获取适当的响应&＃xff0c;需要发送一个遵守Http 协议的 Http 请求。

2.ServerSocket 类

上面Socket 类表示的是客户端的套接字&＃xff0c;在你需要远程连接到一个服务器的时候&＃xff0c;你需要创建的套接字。但是如果&＃xff0c;你是创建的服务器应用&＃xff0c;那么显然这里的逻辑会有所不同&＃xff0c;应为作为服务端&＃xff0c;你需要监听客户端的行为。

这里我们采用ServerSocket 类&＃xff0c;ServerSocket 会等待客户端发来的请求&＃xff0c;一旦ServerSocket 获得一个连接请求&＃xff0c;它会创建一个Socket 实例来与客户端进行通信。

创建ServerSocket 也有多个构造方法&＃xff0c;构造方法中有一个重要的属性&＃xff1a;backlog&＃xff0c;表示服务端开始拒绝传入的请求前&＃xff0c;可传入的连接请求的最大值。

new ServerSocket(80,3);

在实际工作中&＃xff0c;可以通过ServerSocket 的accept 方法监听客户端是否有连接请求&＃xff0c;当接收到连接的请求时&＃xff0c;accept 方法会返回一个Socket 对象&＃xff0c;用来与客户端进行交互。

ServerSocket serverSocket &＃61; new ServerSocket(80,10);
int count &＃61; 0;
while(true){System.out.println(count&＃43;&＃43;);Socket socket &＃61; serverSocket.accept();System.out.println("New connection accepted "&＃43;socket.getInetAddress()&＃43;":"&＃43;socket.getPort());socket.close();
}
3.模拟简单的Web 服务器

三个核心的类&＃xff1a;HttpServer、Request、Response。

下面的示例就是这三个核心类的具体代码。

其中主方法main 在HttpServer 中&＃xff0c;它初始化了一个ServerSocket 然后一直await 等待监听到客户端的程序。监听到了之后&＃xff0c;将输入作为Request &＃xff0c;然后输出Response &＃xff0c;整个过程一直这样监听者直到接收到一个SHUTDOWN 的指令&＃xff0c;退出程序。

public class HttpServer {// 这里定义的目录是用来存放一些静态的html 文件或者txt 文件或者jpg 等静态文件public static final String WEB_ROOT &＃61; System.getProperty("user.dir") &＃43; File.separator &＃43; "webroot";// 关闭命令private static final String SHUTDOWN_COMMAND &＃61; "/SHUTDOWN";private boolean shutdown &＃61; false;public static void main(String[] args) {HttpServer server &＃61; new HttpServer();server.await();}public void await() {ServerSocket serverSocket &＃61; null;int port &＃61; 8080;try {serverSocket &＃61; new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));} catch (IOException e) {e.printStackTrace();System.exit(1);}// 循环等待请求的到来while (!shutdown) {Socket socket &＃61; null;InputStream input &＃61; null;OutputStream output &＃61; null;try {socket &＃61; serverSocket.accept();input &＃61; socket.getInputStream();output &＃61; socket.getOutputStream();// 创建请求对象然后解析Request request &＃61; new Request(input);request.parse();// 创建响应对象Response response &＃61; new Response(output);response.setRequest(request);response.sendStaticResource();// 关闭socketsocket.close();// 判断是否有SHUTDOWN 指令shutdown &＃61; request.getUri().equals(SHUTDOWN_COMMAND);} catch (Exception e) {e.printStackTrace();continue;}}}
}

一个HttpServer 相当于一个ServerSocket 服务端的套接字&＃xff0c;等待Socket 客户端的请求。

再收到客户端的请求后&＃xff08;我们这里是浏览器访问 http://localhost:8080/index.html&＃xff09;&＃xff0c;创建Request对象&＃xff0c;并返回Response对象。

public class Request {private InputStream input;private String uri;public Request(InputStream input) {this.input &＃61; input;}public void parse() {// 从Socket 中读取字符集合StringBuffer request &＃61; new StringBuffer(2048);int i;byte[] buffer &＃61; new byte[2048];try {i &＃61; input.read(buffer);} catch (IOException e) {e.printStackTrace();i &＃61; -1;}for (int j &＃61; 0; j index1)return requestString.substring(index1 &＃43; 1, index2);}return null;}public String getUri() {return uri;}}

目前这里的请求Request 对象主要是用来解析浏览器的请求uri 。

public class Response {private static final int BUFFER_SIZE &＃61; 1024;Request request;OutputStream output;public Response(OutputStream output) {this.output &＃61; output;}public void setRequest(Request request) {this.request &＃61; request;}public void sendStaticResource() throws IOException {byte[] bytes &＃61; new byte[BUFFER_SIZE];FileInputStream fis &＃61; null;try {File file &＃61; new File(HttpServer.WEB_ROOT, request.getUri());if (file.exists()) {fis &＃61; new FileInputStream(file);int ch &＃61; fis.read(bytes, 0, BUFFER_SIZE);while (ch !&＃61; -1) {output.write(bytes, 0, ch);ch &＃61; fis.read(bytes, 0, BUFFER_SIZE);}} else {// file not foundString errorMessage &＃61; "HTTP/1.1 404 File Not Found\r\n" &＃43; "Content-Type: text/html\r\n"&＃43; "Content-Length: 23\r\n" &＃43; "\r\n" &＃43; "

File Not Found

Response 对象主要是用来向浏览器发送静态资源。我们这里可以发送一个静态文本&＃xff0c;图片或者html 文件。

演示&＃xff1a;

但是到目前为止&＃xff0c;测试 在IE下能够成功&＃xff0c;在Google 浏览器下不能成功加载。不知道是不是Google 浏览器做了什么限制。