Блог

Я пытался отправить непрерывные изображения с веб-камеры (используя Webcam-api) от клиента через ObjectOutStream на сервер и показать его на ярлыке кадра и нашел код на youtube, но через некоторое время программа выдает ошибку «из памяти». Кто-нибудь может объяснить ее причину? Может быть, InputStream на стороне сервера хранит все изображения, которые не требуются. Если это так, предложите какие-либо методы очистки InputStream на сервере.

TestClient :

 import java.io.IOException;

import java.awt.image.BufferedImage;
import java.io.*;
import java.net.*;

import javax.imageio.ImageIO;
import javax.swing.Icon;
import javax.swing.ImageIcon;
import javax.swing.JFrame;
import javax.swing.JLabel;

import com.github.sarxos.webcam.Webcam;
import com.github.sarxos.webcam.WebcamResolution;

public class TestClient {


    static Socket socket;
    public static void main(String[] args) throws IOException,ClassNotFoundException{
        Webcam webcam = Webcam.getDefault();
        webcam.setViewSize(WebcamResolution.VGA.getSize());
        System.out.println(WebcamResolution.VGA.getSize());
        webcam.open();

        socket = new Socket("localhost",5001);
        
        ObjectOutputStream dout = new ObjectOutputStream(socket.getOutputStream());
        JLabel label = new JLabel();
        JFrame frame = new JFrame("Client");

        frame.setSize(WebcamResolution.VGA.getSize());
        frame.setDefaultCloseOperation(frame.EXIT_ON_CLOSE);
        label.setSize(WebcamResolution.VGA.getSize());
        label.setVisible(true);

        frame.add(label);
        frame.setVisible(true);


        while(true) {
            BufferedImage wc = webcam.getImage();
            ImageIcon ic = new ImageIcon(wc);
            label.setIcon(ic);
            dout.writeObject(ic);
            dout.flush();
        }

    }
}
  

Тестовый сервер:

 import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.*;

public class TestServer {
    public static void main(String[] args) throws IOException,ClassNotFoundException{
        ServerSocket server = new ServerSocket(5001);
        System.out.println("Waiting...");
        Socket socket = server.accept();
        System.out.println("Connected ..");
        ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
        JLabel label = new JLabel();
        JFrame frame = new JFrame("ServerSide");
        
        frame.setSize(640,480);
        frame.setDefaultCloseOperation(frame.EXIT_ON_CLOSE);
        label.setSize(640,480);
        label.setVisible(true);
        
        frame.add(label);
        frame.setVisible(true);
        
        while(true) {
            label.setIcon((ImageIcon)in.readObject());
        }
            
    }
    

}
  

Ошибка через некоторое время::

 Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
    at java.base/java.lang.reflect.Array.newArray(Native Method)
    at java.base/java.lang.reflect.Array.newInstance(Array.java:78)
    at java.base/java.io.ObjectInputStream.readArray(ObjectInputStream.java:2036)
    at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1656)
    at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:482)
    at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:440)
    at java.desktop/javax.swing.ImageIcon.readObject(ImageIcon.java:501)
    at java.base/jdk.internal.reflect.GeneratedMethodAccessor1.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1175)
    at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2295)
    at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166)
    at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668)
    at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:482)
    at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:440)
    at TestServer.main(TestServer.java:29)
  

Редактировать::
Я пробовал это, но сервер получает изображение только в первый раз, после чего возникает исключение нулевой точки. Я не могу понять, почему?

Клиент:

 DataOutputStream out = new DataOutputStream(socket.getOutputStream());
    
ByteArrayOutputStream bos = new ByteArrayOutputStream();
while(true) {
   BufferedImage wc = webcam.getImage();
   ImageIO.write(wc, "jpg", bos); 
   byte imgBytes[] = bos.toByteArray();
   out.write(imgBytes,0,imgBytes.length);
   bos.flush();
}
  

Сервер ::

 DataInputStream in=new DataInputStream(socket.getInputStream());
ImageInputStream imgin = ImageIO.createImageInputStream(in);

while(true){
    BufferedImage img=ImageIO.read(imgin);
    ImageIcon ic = new ImageIcon(img);
    label.setIcon(ic);
}
  

Ни InputStream, ни ObjectInputStream не могут быть «очищены», и они не «сохраняют» какие-либо предыдущие результаты. Скорее всего, биты на проводе повреждены, и отправляемые данные заставляют операцию чтения пытаться выделить гигантский массив «случайно».

Обратите внимание, что отправка ImageIcons через ObjectOutputStream невероятно неэффективна; протокол тратит тонны пропускной способности и тратит много циклов процессора, пытаясь сериализовать этот объект, который не был предназначен для этого. Лучше сохранить ваше изображение в какой-нибудь быстрый формат изображения (возможно, не PNG) и отправить его, что попутно также значительно упростит отладку поврежденных отправлений.

То, что вы здесь делаете, постоянно устанавливает значок метки:

 while(true) {
            label.setIcon((ImageIcon)in.readObject());
        }
  

То, что делает этот код, создает новые экземпляры ImageIcon , ссылку label на этот экземпляр, а затем, когда приходит новое изображение, ссылка на исходный объект теряется, и сборщик мусора не может очистить его или не получает возможности очистить его, поскольку это происходит в цикле без каких-либо пауз.

Таким образом, если камера непрерывно генерирует 60 кадров в секунду, у сборщика мусора не будет возможности очистить память, поскольку (гипотетически) в памяти будет создаваться 60 объектов в секунду.

Вы можете отслеживать свое приложение с помощью jvisualvm и видеть, что это так.