使用 ImageIO 发送图像流？

我设置了一个 ServerSocket 和一个 Socket，因此 ServerSocket 使用 ImageIO.write(....) 发送图像流，并且 Socket 尝试读取它们并用它们更新 JFrame。所以我想知道 ImageIO 是否可以检测图像的结尾。 （我对JPEG格式完全不了解，所以我测试了一下）

显然不是。

在服务器端，我通过使用 ImageIO.write(...) 循环发送图像，并在中间进行一些睡眠。在客户端，ImageIO 读取第一个图像没有问题，但在下一个图像上它返回 null。这很令人困惑。我期望它要么阻止读取第一张图像（因为它认为下一张图像仍然是同一图像的一部分），要么成功读取所有图像（因为它有效）。到底是怎么回事？看起来 ImageIO 检测到第一个图像的结尾，但没有检测到第二个图像的结尾。 （顺便说一下，这些图像彼此大致相似）是否有一种简单的方法来流式传输这样的图像，或者我是否必须制定自己的机制，将字节读入缓冲区，直到达到指定的字节或序列字节，此时它从缓冲区中读取图像？

这是我的服务器代码的有用部分：

        while(true){
            Socket sock=s.accept();
            System.out.println("Connection");
            OutputStream out=sock.getOutputStream();
            while(!socket.isClosed()){
                BufferedImage img=//get image
                ImageIO.write(img, "jpg", out);
                Thread.sleep(100);
            }
            System.out.println("Closed");
        }

我的客户代码：

        Socket s=new Socket(InetAddress.getByName("localhost"), 1998);
        InputStream in=s.getInputStream();
        while(!s.isClosed()){
            BufferedImage img=ImageIO.read(in);
            if(img==null)//this is what happens on the SECOND image
            else // do something useful with the image
        }

ImageIO.read(InputStream)创建一个ImageInputStream并打电话read(ImageInputStream)内部。后一种方法被记录为在读取图像完成后关闭流。

所以，理论上，你可以得到ImageReader，创建一个ImageInputStream自己，并拥有ImageReader读自ImageInputStream反复。

除此之外，它似乎是一个ImageInputStream旨在处理一张且仅一张图像（可能包含也可能不包含多个帧）。如果你打电话ImageReader.read(0)不止一次，它每次都会倒回到（缓存的）流数据的开头，一遍又一遍地为您提供相同的图像。ImageReader.read(1)会在多帧图像中寻找第二帧，这对于 JPEG 来说当然没有意义。

那么，也许我们可以创建一个 ImageInputStream，让 ImageReader 从中读取，然后创建一个新的 ImageInputStream 来处理流中的后续图像数据，对吗？除外，看来ImageInputStream进行各种缓存、预读和推回，这使得很难知道包装后的 InputStream 的读取位置。下一个 ImageInputStream 将开始从某处读取数据，但它并不像我们期望的那样位于第一个图像数据的末尾。

确定底层流位置的唯一方法是mark and reset。由于图像可能很大，您可能需要BufferedInputStream以允许大readLimit.

这对我有用：

private static final int MAX_IMAGE_SIZE = 50 * 1024 * 1024;

static void readImages(InputStream stream)
throws IOException {
    stream = new BufferedInputStream(stream);

    while (true) {
        stream.mark(MAX_IMAGE_SIZE);

        ImageInputStream imgStream =
            ImageIO.createImageInputStream(stream);

        Iterator<ImageReader> i = 
            ImageIO.getImageReaders(imgStream);
        if (!i.hasNext()) {
            logger.log(Level.FINE, "No ImageReaders found, exiting.");
            break;
        }

        ImageReader reader = i.next();
        reader.setInput(imgStream);

        BufferedImage image = reader.read(0);
        if (image == null) {
            logger.log(Level.FINE, "No more images to read, exiting.");
            break;
        }

        logger.log(Level.INFO,
            "Read {0,number}\u00d7{1,number} image",
            new Object[] { image.getWidth(), image.getHeight() });

        long bytesRead = imgStream.getStreamPosition();

        stream.reset();
        stream.skip(bytesRead);
    }
}