对以下代码进行细致解释:public class HttpRequest implements Runnable{ Socket socket; public HttpRequest(Socket socket) throws Exception { this.socket = socket; } public void run() { try { processRequest(); } catch (Exception e) { System.out.println(e); } } private void processRequest() throws Exception { InputStreamReader is = new InputStreamReader(socket.getInputStream()); DataOutputStream os = new DataOutputStream(socket.getOutputStream()); BufferedReader br = new BufferedReader(is); String requestLine = br.readLine(); System.out.println("请求消息\r\n"); System.out.println(requestLine); String headerLine = null; while ((headerLine = br.readLine()).length() != 0){ System.out.println(headerLine); } StringTokenizer tokens = new StringTokenizer(requestLine); tokens.nextToken(); String fileName = tokens.nextToken(); //获取头部行中的URL字段值 FileInputStream fis = null; boolean fileExists = true; try { fis = new FileInputStream("C:\\Users\\Administrator\\web"+fileName); } catch (FileNotFoundException e) { fileExists = false; } String statusLine = null; String contentTypeLine = null; if (fileExists) { statusLine = "HTTP/1.1 200 0K"; contentTypeLine = "Content-type: "+ contentType(fileName) ; System.out.println(); System.out.println("响应消息\r\n"); os.writeBytes(statusLine); System.out.println(statusLine); os.writeBytes(contentTypeLine); System.out.println(contentTypeLine); sendBytes(fis, os); fis.close(); } else { String errorMessage = "HTTP/1.1 404 File Not Found\r\n" + "Content-Type: text/html\r\n" + "Content-Length: 23\r\n" + "\r\n" + "<h1>File Not Found</h1>"; System.out.println(); System.out.println("响应消息\r\n"); System.out.println(errorMessage); os.writeBytes(errorMessage); } os.close(); br.close(); socket.close(); } private static void sendBytes (FileInputStream fis,OutputStream os) 抛出异常 { byte[]buffer=new byte[1024]; int bytes=0; while ((bytes =fis.read(buffer))!=1){ os.write(buffer,0,bytes); } } private static String contentType(String fileName) { if (fileName.endsWith(".htm") || fileName.endsWith(".html")|| fileName.endsWith(".txt")) { return "text/html"; } if (fileName.endsWith(".jpg")) { return "image/jpeg"; } if (fileName.endsWith(".gif")) { return "image/gif"; } return "application/octet-stream"; } }
时间: 2024-04-16 17:26:16 浏览: 150
Java Socket编程(五) 简单的WEB服务器
这段代码定义了一个名为 `HttpRequest` 的类,实了 `Runnable` 接口,用于处理 HTTP 请求。现在我们来逐行进行解释:
```java
public class HttpRequest implements Runnable {
Socket socket;
public HttpRequest(Socket socket) throws Exception {
this.socket = socket;
}
public void run() {
try {
processRequest();
} catch (Exception e) {
System.out.println(e);
}
}
private void processRequest() throws Exception {
InputStreamReader is = new InputStreamReader(socket.getInputStream());
DataOutputStream os = new DataOutputStream(socket.getOutputStream());
BufferedReader br = new BufferedReader(is);
String requestLine = br.readLine(); // 读取请求行
System.out.println("请求消息\r\n");
System.out.println(requestLine);
String headerLine = null;
while ((headerLine = br.readLine()).length() != 0) { // 读取请求头
System.out.println(headerLine);
}
StringTokenizer tokens = new StringTokenizer(requestLine);
tokens.nextToken();
String fileName = tokens.nextToken(); // 获取 URL 字段值
FileInputStream fis = null;
boolean fileExists = true;
try {
fis = new FileInputStream("C:\\Users\\Administrator\\web" + fileName); // 打开文件输入流
} catch (FileNotFoundException e) {
fileExists = false; // 文件不存在
}
String statusLine = null;
String contentTypeLine = null;
if (fileExists) { // 如果文件存在
statusLine = "HTTP/1.1 200 0K"; // 设置响应状态行
contentTypeLine = "Content-type: " + contentType(fileName); // 设置响应头中的 Content-Type 字段
System.out.println();
System.out.println("响应消息\r\n");
os.writeBytes(statusLine); // 发送响应状态行
System.out.println(statusLine);
os.writeBytes(contentTypeLine); // 发送响应头
System.out.println(contentTypeLine);
sendBytes(fis, os); // 发送文件内容
fis.close();
} else { // 如果文件不存在
String errorMessage = "HTTP/1.1 404 File Not Found\r\n" +
"Content-Type: text/html\r\n" +
"Content-Length: 23\r\n" +
"\r\n" +
"<h1>File Not Found</h1>"; // 设置错误消息的 HTML 响应体
System.out.println();
System.out.println("响应消息\r\n");
System.out.println(errorMessage);
os.writeBytes(errorMessage); // 发送错误消息
}
os.close();
br.close();
socket.close();
}
private static void sendBytes(FileInputStream fis, OutputStream os) throws Exception {
byte[] buffer = new byte[1024];
int bytes = 0;
while ((bytes = fis.read(buffer)) != -1) { // 读取文件内容并发送给客户端
os.write(buffer, 0, bytes);
}
}
private static String contentType(String fileName) {
if (fileName.endsWith(".htm") || fileName.endsWith(".html") || fileName.endsWith(".txt")) {
return "text/html"; // 返回文本类型的 Content-Type
}
if (fileName.endsWith(".jpg")) {
return "image/jpeg"; // 返回 JPEG 图片类型的 Content-Type
}
if (fileName.endsWith(".gif")) {
return "image/gif"; // 返回 GIF 图片类型的 Content-Type
}
return "application/octet-stream"; // 默认返回二进制数据类型的 Content-Type
}
}
```
这段代码是一个简单的 HTTP 服务器的实现,用于处理客户端发送的 HTTP 请求并返回对应的响应。下面是对代码的详细解释:
1. `HttpRequest` 类实现了 `Runnable` 接口,用于在多线程环境下处理 HTTP 请求。
2. 构造函数 `HttpRequest(Socket socket)` 接收一个 `Socket` 参数,用于与客户端建立连接。
3. `run()` 方法是 `Runnable` 接口的实现方法,用于在新线程中执行 `processRequest()` 方法来处理请求。
4. `processRequest()` 方法用于处理 HTTP 请求。它首先从 `socket` 中获取输入流和输出流,然后通过输入流读取请求行和请求头,并输出到控制台。接着,使用 `StringTokenizer` 对请求行进行解析,获取 URL 字段值。然后尝试打开与 URL 对应的文件输入流,如果文件存在,就发送响应状态行、响应头和文件内容给客户端;如果文件不存在,就发送 404 错误消息给客户端。最后关闭输入流、输出流和 socket 连接。
5. `sendBytes(FileInputStream fis, OutputStream os)` 方法用于将文件内容发送给客户端。它使用一个缓冲区(大小为 1024 字节)来读取文件内容,并将其写入到输出流中,直到读取完整个文件。
6. `contentType(String fileName)` 方法根据文件名的后缀来判断文件的 MIME 类型(Content-Type)。如果文件名以 `.htm`、`.html` 或 `.txt` 结尾,返回 `text/html`;如果文件名以 `.jpg` 结尾,返回 `image/jpeg`;如果文件名以 `.gif` 结尾,返回 `image/gif`;否则返回 `application/octet-stream`。
7. 最后,关闭输出流、输入流和 socket 连接。
请注意,这段代码只是一个简单的示例,可能存在一些安全和性能问题,并不适合用于生产环境。
阅读全文