Wie sieht ein vollständiges Java-Programm aus, das eine Datei (InputStream) via ICAP REQMOD über Socket in mehreren Chunks und mit Preview zum Virenscan sendet?

Ein vollständiges Java-Programm, das eine Datei (bzw. einen InputStream) via ICAP REQMOD über einen Socket in mehreren Chunks und mit Preview zum Virenscan sendet, ist recht komplex. Es muss das ICAP-Protokoll, Chunked Transfer Encoding, die REQMOD-Anfrage und das Preview-Feature korrekt implementieren. Im Folgenden findest du ein Beispiel, das die wichtigsten Aspekte abdeckt. Für einen produktiven Einsatz sind zusätzliche Fehlerbehandlung, Konfigurierbarkeit und Logging zu empfehlen.

**Hinweis:**
- Das Beispiel ist für Lernzwecke und zeigt die Kernlogik.
- Die ICAP-Server-Adresse, Port und Service-Name müssen ggf. angepasst werden.
- Die Datei wird als HTTP POST im REQMOD-Body gesendet (z.B. wie ein Upload).
- Das Preview-Feature wird genutzt, um dem Server einen Teil der Daten vorab zu schicken.

```java
import java.io.*;
import java.net.Socket;

public class IcapReqmodClient {

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. 1 KB Preview

public static void main(String[] args) throws IOException {
File file = new File("testfile.txt");
try (InputStream fileInput = new FileInputStream(file)) {
sendFileViaIcap(fileInput, file.length());
}
}

private static void sendFileViaIcap(InputStream fileInput, long fileLength) throws IOException {
try (Socket socket = new Socket(ICAP_SERVER, ICAP_PORT);
OutputStream out = socket.getOutputStream();
InputStream in = socket.getInputStream()) {

// 1. ICAP-Header mit Preview ankündigen
String icapHeader =
"REQMOD 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: req-hdr=0, req-body=" + getHttpRequestHeaderLength() + "\r\n" +
"\r\n" +
getHttpRequestHeader();

out.write(icapHeader.getBytes());
out.flush();

// 2. Preview senden (Chunked)
byte[] previewBuffer = new byte[PREVIEW_SIZE];
int previewRead = fileInput.read(previewBuffer);
if (previewRead > 0) {
writeChunk(out, previewBuffer, 0, previewRead);
}
// Preview-Ende markieren
out.write("0; ieof\r\n\r\n".getBytes());
out.flush();

// 3. Antwort des ICAP-Servers auf Preview abwarten
String response = readIcapResponse(in);
if (response.contains("100 Continue")) {
// Server will den Rest der Datei
sendRemainingChunks(out, fileInput);
}
// 4. Komplette ICAP-Antwort lesen
String finalResponse = readIcapResponse(in);
System.out.println("ICAP Response:\n" + finalResponse);
}
}

private static String getHttpRequestHeader() {
// Beispiel: HTTP POST Header für einen Datei-Upload
return "POST /upload HTTP/1.1\r\n" +
"Host: www.example.com\r\n" +
"Content-Length: unknown\r\n" +
"Content-Type: application/octet-stream\r\n" +
"\r\n";
}

private static int getHttpRequestHeaderLength() {
return getHttpRequestHeader().getBytes().length;
}

private static void writeChunk(OutputStream out, byte[] buffer, int offset, int length) throws IOException {
out.write((Integer.toHexString(length) + "\r\n").getBytes());
out.write(buffer, offset, length);
out.write("\r\n".getBytes());
out.flush();
}

private static void sendRemainingChunks(OutputStream out, InputStream in) throws IOException {
byte[] buffer = new byte[4096];
int read;
while ((read = in.read(buffer)) != -1) {
writeChunk(out, buffer, 0, read);
}
// Letzter Chunk (0 Länge) signalisiert das Ende
out.write("0\r\n\r\n".getBytes());
out.flush();
}

private static String readIcapResponse(InputStream in) throws IOException {