private void handle(InputStream input, OutputStream output) throws IOException { System.out.println("Process new http request..."); var reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8)); var writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8)); // 读取HTTP请求: boolean requestOk = false; String first = reader.readLine(); if (first.startsWith("GET / HTTP/1.")) { requestOk = true; } for (;;) { String header = reader.readLine(); if (header.isEmpty()) { // 读取到空行时, HTTP Header读取完毕 break; } System.out.println(header); } System.out.println(requestOk ? "Response OK" : "Response Error"); if (!requestOk) { // 发送错误响应: writer.write("HTTP/1.0 404 Not Found\r\n"); writer.write("Content-Length: 0\r\n"); writer.write("\r\n"); writer.flush(); } else { // 发送成功响应: String data = "<html><body><h1>Hello, world!</h1></body></html>"; int length = data.getBytes(StandardCharsets.UTF_8).length; writer.write("HTTP/1.0 200 OK\r\n"); writer.write("Connection: close\r\n"); writer.write("Content-Type: text/html\r\n"); writer.write("Content-Length: " + length + "\r\n"); writer.write("\r\n"); // 空行标识Header和Body的分隔 writer.write(data); writer.flush(); } }
时间: 2024-02-07 12:03:22 浏览: 180
这段代码是一个简单的 HTTP 服务器的处理方法。它通过输入流和输出流处理 HTTP 请求和响应。首先,它从输入流中读取 HTTP 请求的第一行,然后通过循环读取 HTTP 头部信息,直到读取到空行。如果请求的路径是根路径,则设置请求为有效。如果请求无效,它将发送一个 404 错误响应,否则将发送一个包含“Hello, world!”的 HTML 响应。此代码使用 UTF-8 编码。
相关问题
在这里面,为什么第三次握手成功后,控制台打印的是客户端第一次发送的消息,应该是“已经收到第三次握手!你说:我是客户端,这是第三次握手‘ package com.pro0530.Serve; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class fuwuqi { public static void main(String[] args) throws IOException { ServerSocket serve = new ServerSocket(6666); //收到第一次握手 Socket server = serve.accept(); InputStream inputStream = server.getInputStream(); byte[] b = new byte[1024]; int len = inputStream.read(b); String msg = new String(b,0,len); System.out.println("已经收到第一次握手!你说:"+msg); //发送第二次握手 OutputStream outputStream = server.getOutputStream(); outputStream.write("这是第二次握手".getBytes()); outputStream.flush(); System.out.println("已经发送第二次握手"); outputStream.flush(); //收到第三次握手 Socket server1 = serve.accept(); InputStream inputStream1 = server1.getInputStream(); byte[] b1 = new byte[1024]; int len1 = inputStream1.read(b1); String msga = new String(b,0,len1); System.out.println("已经收到第三次握手!你说:"+msga); inputStream1.close(); outputStream.close(); inputStream.close(); } } 怎么修改
第三次握手成功后,控制台打印的应该是客户端第二次发送的消息,而不是第一次发送的消息。这是因为在第二次握手时,服务器端已经发送了一条消息,因此在第三次握手时,客户端会再次发送一条消息。
要修改代码,需要修改以下两个地方:
1. 在第三次握手时,读取客户端发送的消息应该使用b1数组,而不是b数组:
```
byte[] b1 = new byte[1024];
int len1 = inputStream1.read(b1);
String msga = new String(b1, 0, len1);
System.out.println("已经收到第三次握手!你说:" + msga);
```
2. 在第二次握手时,不需要调用两次outputStream.flush()方法:
```
OutputStream outputStream = server.getOutputStream();
outputStream.write("这是第二次握手".getBytes());
outputStream.flush();
System.out.println("已经发送第二次握手");
```
修改后的代码如下:
```
package com.pro0530.Serve;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class fuwuqi {
public static void main(String[] args) throws IOException {
ServerSocket serve = new ServerSocket(6666);
// 收到第一次握手
Socket server = serve.accept();
InputStream inputStream = server.getInputStream();
byte[] b = new byte[1024];
int len = inputStream.read(b);
String msg = new String(b, 0, len);
System.out.println("已经收到第一次握手!你说:" + msg);
// 发送第二次握手
OutputStream outputStream = server.getOutputStream();
outputStream.write("这是第二次握手".getBytes());
outputStream.flush();
System.out.println("已经发送第二次握手");
// 收到第三次握手
Socket server1 = serve.accept();
InputStream inputStream1 = server1.getInputStream();
byte[] b1 = new byte[1024];
int len1 = inputStream1.read(b1);
String msga = new String(b1, 0, len1);
System.out.println("已经收到第三次握手!你说:" + msga);
inputStream1.close();
outputStream.close();
inputStream.close();
}
}
```
package com.test; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.Scanner; public class ChatServer { public static void main(String[] args) throws Exception { // 创建一个服务器 ServerSocket ss = new ServerSocket(9090); System.out.println("服务器已上线,等待客户端连接..."); Socket sk = ss.accept(); System.out.println("客户端已经连接"); Scanner mys = new Scanner(System.in); System.out.println("请输入您要发送的信息:"); String str = mys.next(); // 打开客户端字节流 OutputStream os = sk.getOutputStream(); OutputStreamWriter osw = new OutputStreamWriter(os); BufferedWriter bw = new BufferedWriter(osw); bw.write(str); bw.newLine(); bw.flush(); // 打开读取的字节流 InputStream is = sk.getInputStream(); // 字节流转换为字符流量 InputStreamReader isr = new InputStreamReader(is); // 添加buffered BufferedReader br = new BufferedReader(isr); String sa = br.readLine(); System.out.println("客户端:"+sa); } }
这是一个简单的 Java 程序,实现了一个基本的聊天服务器。程序首先创建了一个 ServerSocket 对象,并将其绑定到端口 9090。然后程序等待客户端的连接,一旦有客户端连接,程序就会打印出相应的信息。接着程序会让用户输入要发送的信息,并将其发送到客户端。程序也会从客户端读取信息,并打印出来。其中使用了 Java 的输入输出流和网络编程相关类。
阅读全文