Raspberry Piにて初回画像取得でタイムアウトが発生する場合があり、タイムアウトした場合でもエラーとならないように修正。

shared-camera-client/src/main/java/com/enjoyxstudy/sharedcamera/client/SpringBootCaptureClientApplication.java

@@ -3,6 +3,7 @@
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 import lombok.RequiredArgsConstructor;
@@ -17,7 +18,8 @@ public class SpringBootCaptureClientApplication implements CommandLineRunner {
     public static void main(String[] args) {
         SpringApplication application = new SpringApplication(SpringBootCaptureClientApplication.class);
         application.setWebEnvironment(false);
-        application.run(args);
+        ConfigurableApplicationContext context = application.run(args);
+        context.close();
     }
 
     @Override

shared-camera-client/src/main/java/com/enjoyxstudy/sharedcamera/client/WebcamCapture.java

@@ -42,14 +42,23 @@ public void startCapture() throws IOException, InterruptedException {
         while (true) {
 
             if (webSocketHandler.isConnected()) {
-                BufferedImage image = webcam.getImage();
 
-                try (ByteArrayOutputStream outputStream = new ByteArrayOutputStream()) {
-                    ImageIO.write(image, "jpeg", outputStream);
-                    webSocketHandler.sendMessage(outputStream.toByteArray());
+                BufferedImage image = webcam.getImage();
+
+                // Occasionally time out when the load is high. At that time it becomes null.
+                if (image != null) {
+
+                    try (ByteArrayOutputStream outputStream = new ByteArrayOutputStream()) {
+                        ImageIO.write(image, "jpeg", outputStream);
+                        webSocketHandler.sendMessage(outputStream.toByteArray());
+                    }
                 }
             }
 
+            if (!webcam.isOpen()) {
+                throw new IOException("Camera closed.");
+            }
+
             Thread.sleep(intervalMillis);
         }
     }