2 Fragen zu Virusscan

Hier ist ein vollständiges Java-Beispiel, das einen beliebigen `InputStream` (mit unbekannter Länge und ohne bekannten Namen) via Socket im ICAP-RESMOD-Modus an einen ICAP-Server sendet. Es werden Chunks und ein Preview-Mechanismus gemäß ICAP-Spezifikation verwendet, um z.B. einen Virenscan durchzuführen. **Hinweise:** - Das Beispiel ist auf Verständlichkeit und Nachvollziehbarkeit ausgelegt, nicht auf maximale Performance oder Fehlerbehandlung. - Die ICAP-Kommunikation ist nicht trivial. Das Beispiel orientiert sich an RFC 3507 und typischen ICAP-Virenscannern wie Kaspersky, Symantec, etc. - Die ICAP-Server-Adresse, Port und Service müssen ggf. angepasst werden. - Die HTTP-Response, die im RESPMOD gescannt wird, ist ein Dummy und kann nach Bedarf angepasst werden. **Java-Beispiel:** ```java import java.io.*; import java.net.Socket; public class IcapRespmodClient { private static final String ICAP_SERVER = "icap.example.com"; private static final int ICAP_PORT = 1344; private static final String ICAP_SERVICE = "avscan"; private static final int PREVIEW_SIZE = 1024; // z.B. 1024 Bytes Preview public static void main(String[] args) throws IOException { // Beispiel-InputStream (kann beliebig ersetzt werden) InputStream dataStream = new FileInputStream("testfile.dat"); try (Socket socket = new Socket(ICAP_SERVER, ICAP_PORT)) { OutputStream out = socket.getOutputStream(); InputStream in = socket.getInputStream(); // Dummy HTTP-Response-Header (kann angepasst werden) String httpResponseHeader = "HTTP/1.1 200 OK\r\n" + "Content-Type: application/octet-stream\r\n" + "\r\n"; // ICAP-Request-Header String icapHeader = "RESPMOD icap://" + ICAP_SERVER + "/" + ICAP_SERVICE + " ICAP/1.0\r\n" + "Host: " + ICAP_SERVER + "\r\n" + "Allow: 204\r\n" + "Preview: " + PREVIEW_SIZE + "\r\n" + "Encapsulated: res-hdr=0, res-body=" + httpResponseHeader.length() + "\r\n" + "\r\n"; // Sende ICAP-Header und HTTP-Response-Header out.write(icapHeader.getBytes()); out.write(httpResponseHeader.getBytes()); // Sende Preview (ersten PREVIEW_SIZE Bytes als Chunk) byte[] previewBuffer = new byte[PREVIEW_SIZE]; int previewRead = dataStream.read(previewBuffer); if (previewRead > 0) { out.write((Integer.toHexString(previewRead) + "\r\n").getBytes()); out.write(previewBuffer, 0, previewRead); out.write("\r\n".getBytes()); } // Preview-Ende markieren out.write("0; ieof\r\n\r\n".getBytes()); out.flush(); // Lese ICAP-Antwort (Header) BufferedReader reader = new BufferedReader(new InputStreamReader(in)); String line; boolean continueExpected = false; while ((line = reader.readLine()) != null) { if (line.startsWith("ICAP/1.0 100")) { continueExpected = true; } if (line.isEmpty()) break; // Header-Ende } // Wenn 100 Continue, dann restliche Daten als Chunks senden if (continueExpected) { byte[] buffer = new byte[8192]; int read; while ((read = dataStream.read(buffer)) != -1) { out.write((Integer.toHexString(read) + "\r\n").getBytes()); out.write(buffer, 0, read); out.write("\r\n".getBytes()); } // Letzter Chunk out.write("0\r\n\r\n".getBytes()); out.flush(); } // ICAP-Server-Antwort lesen (z.B. Virenscan-Ergebnis) System.out.println("ICAP-Server-Antwort:"); while ((line = reader.readLine()) != null) { System.out.println(line); if (line.isEmpty()) break; // Header-Ende } } } } ``` **Wichtige Punkte:** - Die Vorschau (`Preview`) wird mit `ieof` markiert, wenn der Stream kleiner als die Preview-Größe ist. - Nach

Ein vollständiges Java-Programm, das eine Datei als InputStream via ICAP RESPMOD über einen Socket in mehreren Chunks (mit Preview) zum Virenscan sendet, ist recht komplex. Es erfordert ein gutes Verständnis des [ICAP-Protokolls](https://datatracker.ietf.org/doc/html/rfc3507), insbesondere der RESPMOD-Methode, Chunked Transfer Encoding und der Preview-Funktion. **Wichtige Hinweise:** - ICAP ist ein textbasiertes Protokoll, das typischerweise auf Port 1344 läuft. - Die Kommunikation erfolgt über einen TCP-Socket. - Die Datei wird in Chunks gesendet, wobei der erste Chunk als Preview markiert werden kann. - Nach dem Preview kann der Server mit `100 Continue` oder `204 No Content` antworten. **Beispielprogramm:** ```java import java.io.*; import java.net.Socket; public class IcapRespmodClient { private static final String ICAP_SERVER = "icap.example.com"; private static final int ICAP_PORT = 1344; private static final String ICAP_SERVICE = "avscan"; private static final int PREVIEW_SIZE = 1024; // 1 KB Preview public static void main(String[] args) throws IOException { File file = new File("testfile.txt"); try (Socket socket = new Socket(ICAP_SERVER, ICAP_PORT); InputStream fileIn = new FileInputStream(file); OutputStream out = socket.getOutputStream(); InputStream in = socket.getInputStream()) { // ICAP RESPMOD header String icapHeader = "RESPMOD icap://" + ICAP_SERVER + "/" + ICAP_SERVICE + " ICAP/1.0\r\n" + "Host: " + ICAP_SERVER + "\r\n" + "Allow: 204\r\n" + "Preview: " + PREVIEW_SIZE + "\r\n" + "Encapsulated: res-hdr=0, res-body=" + getHttpResponseHeader().length() + "\r\n" + "\r\n" + getHttpResponseHeader(); out.write(icapHeader.getBytes()); // Send preview chunk byte[] previewBuffer = new byte[PREVIEW_SIZE]; int previewRead = fileIn.read(previewBuffer); if (previewRead > 0) { out.write((Integer.toHexString(previewRead) + "\r\n").getBytes()); out.write(previewBuffer, 0, previewRead); out.write("\r\n".getBytes()); out.write("0; ieof\r\n\r\n".getBytes()); // ieof: indicates end of preview } else { out.write("0; ieof\r\n\r\n".getBytes()); } out.flush(); // Read ICAP server response after preview String response = readLine(in); if (response.startsWith("ICAP/1.0 100")) { // Server wants the rest of the file sendRemainingChunks(fileIn, out); } // Read final ICAP response while ((response = readLine(in)) != null) { System.out.println(response); if (response.isEmpty()) break; } } } private static void sendRemainingChunks(InputStream fileIn, OutputStream out) throws IOException { byte[] buffer = new byte[4096]; int read; while ((read = fileIn.read(buffer)) != -1) { out.write((Integer.toHexString(read) + "\r\n").getBytes()); out.write(buffer, 0, read); out.write("\r\n".getBytes()); } out.write("0\r\n\r\n".getBytes()); // End of chunks out.flush(); } private static String getHttpResponseHeader() { // Minimal HTTP response header for encapsulation return "HTTP/1.1 200 OK\r\n" + "Content-Type: application/octet-stream\r\n" + "\r\n"; } private static String readLine(InputStream in) throws IOException { ByteArrayOutputStream baos = new ByteArrayOutputStream(); int c; while ((c = in.read()) != -1) { if (c == '\r') { int next = in.read(); if (next == '\n') break; else baos.write(c); } else { baos.write(c); } } return baos.toString(); } } ``` **Erklärung:** - Das Programm baut eine Verbindung zum ICAP-Server auf. - Es sendet einen RESPMOD-Request mit einem HTTP-Response-Header als Encapsulation