本文详解java socket编程中使用原始inputstream/outputstream传输整数时因字节截断导致加减乘运算结果异常的问题，并提供基于datainputstream/dataoutputstream的健壮解决方案。
本文详解
java
socket编程中使用原始inputstream/outputstream传输整数时因字节截断导致加减乘运算结果异常的问题，并提供基于datainputstream/dataoutputstream的健壮解决方案。
在Java Socket网络编程中，初学者常误用InputStream.read()和OutputStream.write()直接读写整数（int），从而引发隐蔽而严重的逻辑错误——如题所述：
加法看似“工作”，但减法和乘法结果完全错误（例如输入5、10、20执行减法却得231）
。根本原因在于：InputStream.read()每次仅读取
1个字节（8位）
，返回值为0–255范围内的int，而Java int是
4字节（32位）有符号整数
。当客户端调用output.write(5)时，实际只发送字节0x05；但若发送-5，则write(int)会自动截断为0xFB（即251），服务端read()收到251后无法还原原意——这直接导致数值语义丢失。
更关键的是，原始流不具备数据类型边界感知能力。例如客户端连续调用：
服务端用input.read()依次读取4次，得到[2, 5, 10, 20]——表面无误。但问题在于：
read()返回的是int，其高24位恒为0
，因此num1=5实际被存为0x00000005，而计算num1 - num2 - num3时，5 - 10 - 20 = -25，但output.write(-25)会将-25（补码0xFFFFFFE7）
仅写入最低字节0xE7（即231）
。客户端input.read()收到231，误以为结果就是231——这正是“减法得231”的真相。
✅ 正确解法：使用DataInputStream和DataOutputStream
它们专为跨网络传输Java基本类型设计，能完整、无损地序列化/反序列化int（4字节）、short、double等，自动处理字节序（默认大端序）和符号扩展：
服务端（Server.java）核心修正：
立即学习
“
Java免费学习笔记（深入）
”；
Eclipse导入Android或其他的JAVA项目的正确方法 WORD版
本文档主要讲述的是Eclipse导入Android或其他的JAVA项目的正确方法；希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看
下载
客户端（Client.java）同步修正：
⚠️ 关键注意事项：
永远不要对int使用InputStream.read()/OutputStream.write()
：它们仅操作单字节，无法表示负数或大于255的值；
显式关闭资源
：使用try-with-resources确保Socket、InputStream、OutputStream及时释放；
协议一致性
：客户端与服务端必须严格按相同顺序、相同类型读写数据（如先写操作符，再写三个操作数）；
异常处理
：网络I/O易受中断影响，需捕获IOException并记录日志；
端口选择
：避免使用1024以下特权端口（如原文的10端口），推荐8080、9000等非特权端口。
通过采用DataInputStream/DataOutputStream，不仅解决了减法、乘法的数值错误问题，更构建了可扩展的二进制协议基础——后续可轻松支持浮点数、字符串（writeUTF()）甚至自定义对象（配合ObjectInputStream）。这是Java网络编程中保障数据完整性的基石实践。
output.write(2); // 操作符：减法（case 1）
output.write(5); // num1 = 5
output.write(10); // num2 = 10
output.write(20); // num3 = 20import java.net.*;
import java.io.*;
public class Server {
private final ServerSocket server;
public Server() throws IOException {
this.server = new ServerSocket(8080);
System.out.println("Server started on port 8080");
}
public void run() throws IOException {
while (true) {
try (Socket client = server.accept();
DataInputStream input = new DataInputStream(
new BufferedInputStream(client.getInputStream()));
DataOutputStream output = new DataOutputStream(
new BufferedOutputStream(client.getOutputStream()))) {
int op = input.readInt(); // 安全读取4字节int
int num1 = input.readInt();
int num2 = input.readInt();
int num3 = input.readInt();
int result;
switch (op) {
case 0: result = num1 + num2 + num3; break;
case 1: result = num1 - num2 - num3; break; // 5-10-20 = -25
case 2: result = num1 * num2 * num3; break;
default: result = 0;
}
output.writeInt(result); // 安全写入4字节int
output.flush();
}
}
}
public static void main(String[] args) {
try {
new Server().run();
} catch (IOException e) {
e.printStackTrace();
}
}
}import java.net.*;
import java.io.*;
public class Client {
public Client() throws IOException {
try (Socket socket = new Socket("localhost", 8080);
DataInputStream input = new DataInputStream(
new BufferedInputStream(socket.getInputStream()));
DataOutputStream output = new DataOutputStream(
new BufferedOutputStream(socket.getOutputStream()))) {
output.writeInt(1); // 减法操作符
output.writeInt(5);
output.writeInt(10);
output.writeInt(20);
output.flush();
int response = input.readInt(); // 安全读取4字节结果
System.out.println("Result: " + response); // 输出: Result: -25
}
}
public static void main(String[] args) {
try {
new Client();
} catch (IOException e) {
e.printStackTrace();
}
}
}