Java 8及以后版本中，与InputStream配合使用的CharsetDecoder未遵循CodingErrorAction.Replace规则的疑问

我理解你遇到的这个问题确实容易让人困惑——明明给CharsetDecoder明确配置了CodingErrorAction.REPLACE策略，预期遇到畸形输入时会生成替换字符\uFFFD（即�），但通过InputStreamReader（底层依赖StreamDecoder）处理末尾带有畸形字节序列的输入流时，这个替换字符却没有出现；而直接使用解码器的decode方法或者new String构造器却能正常生成预期的替换符。

先把你的测试代码整理成可运行的完整版本，方便后续分析：

import java.io.ByteArrayInputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CodingErrorAction;

public class CharsetDecoderTest {
    public static void main(String[] args) throws Exception {
        Charset charset = Charset.forName("x-windows-iso2022jp");
        
        // 配置两个解码器，都启用REPLACE错误处理策略
        CharsetDecoder charsetDecoderForStr = charset.newDecoder()
                .onMalformedInput(CodingErrorAction.REPLACE)
                .onUnmappableCharacter(CodingErrorAction.REPLACE);
        CharsetDecoder charsetDecoderForStrm = charset.newDecoder()
                .onMalformedInput(CodingErrorAction.REPLACE)
                .onUnmappableCharacter(CodingErrorAction.REPLACE);
        
        // 构造测试字节流：末尾的单个27（ESC字符）属于不完整的ISO-2022-JP控制序列
        byte[] bytes = {27, 36, 66, 124, 98, 27, 40, 66, 27};
        ByteBuffer buffer = ByteBuffer.wrap(bytes);
        
        // 三种方式测试输出
        System.out.println("Using new String without Decoder: " + new String(bytes, charset).trim());
        System.out.println("Using Decoder: " + charsetDecoderForStr.decode(buffer.asReadOnlyBuffer()).toString().trim());
        
        Reader reader = new InputStreamReader(new ByteArrayInputStream(bytes), charsetDecoderForStrm);
        char[] chars = new char[10];
        reader.read(chars);
        System.out.println("Using StreamDecoder: " + new String(chars).trim());
    }
}

你的测试输出结果：

Using new String without Decoder: 髙�
Using Decoder: 髙�
Using StreamDecoder: 髙

问题的核心原因：StreamDecoder的流式缓冲特性 #

两种处理方式的差异源于StreamDecoder的设计目标：它是为持续流式输入场景优化的，和直接处理完整ByteBuffer的逻辑有本质区别：

1. 直接解码（decode方法/new String）：解码器接收的是完整的ByteBuffer，明确知道这是全部输入数据。当遇到末尾的畸形/不完整字节序列（比如测试数据最后单独的ESC字符），会立即判定为错误，触发REPLACE策略，生成\uFFFD替换符。
2. StreamDecoder处理流式输入：它会内部缓冲不完整的字节序列，默认认为后续还有更多数据会输入进来。在你的测试中，只调用了一次reader.read(chars)，此时StreamDecoder读取到了完整的“髙”对应的字节序列，而末尾的单个ESC被缓冲起来等待后续数据。因为没有继续读取直到流结束，StreamDecoder不会将这个缓冲的不完整序列判定为错误，自然不会生成替换符。

解决方案：读取流直到结束 #

要让StreamDecoder处理末尾的畸形序列，你需要持续读取流直到read()方法返回-1（表示流已结束）。此时StreamDecoder会确认没有更多数据，将缓冲的不完整字节序列当作错误处理，触发REPLACE策略。

修改你的读取逻辑如下：

Reader reader = new InputStreamReader(new ByteArrayInputStream(bytes), charsetDecoderForStrm);
char[] chars = new char[10];
int totalRead = 0;
int readCount;
// 循环读取直到流结束
while ((readCount = reader.read(chars, totalRead, chars.length - totalRead)) != -1) {
    totalRead += readCount;
}
System.out.println("Using StreamDecoder (read to end): " + new String(chars, 0, totalRead).trim());

此时的输出会和另外两种方式一致：

Using StreamDecoder (read to end): 髙�

关键总结 #

• StreamDecoder的缓冲机制是为了支持流式输入，避免误判“后续还有数据”的情况，不会轻易将不完整的字节序列判定为错误。
• 只有当流明确结束（read()返回-1）时，StreamDecoder才会处理缓冲的不完整字节序列，触发配置的错误处理策略。
• 直接使用CharsetDecoder.decode()或new String(bytes, charset)时，因为输入是完整的，所以会立即处理所有错误。

内容来源于stack exchange