ServerSocket ss = new ServerSocket(10086); Socket server = ss.accept(); // BufferedReader r_server = new BufferedReader(new InputStreamReader(server.getInputStream())); InputStreamReader r = new InputStreamReader(server.getInputStream()); BufferedWriter w_server = new BufferedWriter(new OutputStreamWriter(server.getOutputStream())); System.out.println("开始接收"); String message; int len; char[] buf = new char[1024]; while (true) { // message = r_server.readLine(); len = r.read(buf); message = new String(buf, 0, len); System.out.println(message); w_server.write("接收到客户端：" + message); w_server.flush(); if (message.equals("886")) { System.out.println("关闭服务器端"); break; } } // r_server.close(); w_server.close(); ss.close();为什么用BufferedReader接收不到数据，用InputStreamReader可以

这可能是因为 BufferedReader 会缓存数据，只有当缓存区满了或者遇到换行符时才会读取数据，而 InputStreamReader 则是直接读取数据流。因此，如果发送的数据没有换行符或者缓存区还没有满，使用 BufferedReader 可能会接收不到数据。

相关问题

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); } }分析此代码

这是一个简单的聊天服务器的代码实现。下面是代码的分析：

1. 创建一个服务器

ServerSocket ss = new ServerSocket(9090);

使用ServerSocket类创建一个服务器，并指定端口号为9090。

2. 等待客户端连接

Socket sk = ss.accept();

使用ServerSocket的accept()方法，等待客户端连接。当客户端连接成功，accept()方法会返回一个Socket对象，该对象表示与客户端的连接。

3. 获取用户输入

Scanner mys = new Scanner(System.in);
System.out.println("请输入您要发送的信息：");
String str = mys.next();

使用Scanner类获取用户输入的信息，可以通过控制台输入。这里只是简单地演示了如何获取用户输入。

4. 发送消息到客户端

OutputStream os = sk.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os);
BufferedWriter bw = new BufferedWriter(osw);
bw.write(str);
bw.newLine();
bw.flush();

获取客户端的输出流，使用BufferedWriter类将消息写入输出流中，并使用flush()方法刷新流。

5. 接收客户端的消息

InputStream is = sk.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
String sa = br.readLine();
System.out.println("客户端："+sa);

获取客户端的输入流，使用BufferedReader类读取输入流中的消息，并输出到控制台上。注意，这里使用了readLine()方法，它会一直阻塞等待客户端的输入，直到客户端输入了一行字符串并通过回车键结束输入。

逐行分析解释下面代码：import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { try { ServerSocket server = new ServerSocket(8888); // 监听指定端口号 System.out.println("等待客户端连接..."); Socket socket = server.accept(); // 等待客户端连接 System.out.println("客户端已连接，IP地址为：" + socket.getInetAddress().getHostAddress()); // 为客户端创建读取器和写入器 BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); PrintWriter writer = new PrintWriter(socket.getOutputStream(), true); // 启动一个线程来接收客户端发送的消息 Thread receiveThread = new Thread(() -> { try { while (true) { String message = reader.readLine(); if (message == null) { break; } System.out.println("客户端说：" + message); } } catch (IOException e) { e.printStackTrace(); } finally { try { reader.close(); writer.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } }); receiveThread.start(); // 主线程用于发送消息 BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in)); while (true) { String message = consoleReader.readLine(); writer.println(message); writer.flush(); } } catch (IOException e) { e.printStackTrace(); } } }

这段代码实现了一个简单的Socket服务器，接收客户端发送的消息并将其输出到控制台，同时也可以通过控制台向客户端发送消息。

1. 导入必要的包：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

2. 在主函数中，创建一个ServerSocket对象并指定端口号为8888，然后等待客户端连接：

ServerSocket server = new ServerSocket(8888); // 监听指定端口号
System.out.println("等待客户端连接...");
Socket socket = server.accept(); // 等待客户端连接
System.out.println("客户端已连接，IP地址为：" + socket.getInetAddress().getHostAddress());

3. 创建一个BufferedReader对象和一个PrintWriter对象，用于读取和写入数据：

BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);

4. 创建一个线程用于接收客户端发送的消息，该线程通过while循环不断地读取客户端发送的消息，并将其输出到控制台：

Thread receiveThread = new Thread(() -> {
    try {
        while (true) {
            String message = reader.readLine();
            if (message == null) {
                break;
            }
            System.out.println("客户端说：" + message);
        }
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            reader.close();
            writer.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
});
receiveThread.start();

5. 在主线程中，通过BufferedReader对象从控制台读入消息，并通过PrintWriter对象将其发送给客户端：

BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in));
while (true) {
    String message = consoleReader.readLine();
    writer.println(message);
    writer.flush();
}

6. 若有异常，则打印异常信息：

} catch (IOException e) {
    e.printStackTrace();
}