Я пытаюсь создать простой UDP-сервер для обработки пакетов из приложения Log4j2 Socket, но я получаю "java.io.StreamCorruptedException: недопустимый заголовок потока: 7372003E" из второго полученного пакета.
ПРИЛОЖЕНИЕ:
<Socket name="Socket" host="localhost" port="9500" protocol="UDP" >
<SerializedLayout />
</Socket>
SNIPPET UDP СЕРВЕР:
public void startSerialized() throws Exception {
serverSocket = new DatagramSocket(9500);
LogEvent logEvent = null;
ObjectInputStream obj = null;
ByteArrayInputStream bis = null;
while (true) {
try {
receivePacket = new DatagramPacket(packet, packet.length);
serverSocket.receive(receivePacket);
bis = new ByteArrayInputStream(receivePacket.getData());
obj = new ObjectInputStream(bis);
logEvent = (LogEvent) obj.readObject();
System.out.println(logEvent.toString());
} catch (Exception e) {
e.printStackTrace();
} finally {
bis.close();
obj.close();
}
}
}
Есть какие-нибудь предложения, ребята?