PCAP-Parser

slgobinath · slgobinath · commit 10ce3f1a749c · 2017-08-11T15:25:48.000-04:00
diff --git a/library/PCAP-Parser/pom.xml b/library/PCAP-Parser/pom.xml
@@ -0,0 +1,28 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<groupId>com.javahelps</groupId>
+	<artifactId>PCAP-Parser</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+
+	<properties>
+		<maven.compiler.source>1.8</maven.compiler.source>
+		<maven.compiler.target>1.8</maven.compiler.target>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>io.pkts</groupId>
+			<artifactId>pkts-core</artifactId>
+			<version>3.0.0</version>
+			<type>jar</type>
+		</dependency>
+
+		<dependency>
+			<groupId>io.pkts</groupId>
+			<artifactId>pkts-streams</artifactId>
+			<version>3.0.0</version>
+			<type>jar</type>
+		</dependency>
+	</dependencies>
+</project>
diff --git a/library/PCAP-Parser/src/main/java/com/javahelps/pcapparser/Main.java b/library/PCAP-Parser/src/main/java/com/javahelps/pcapparser/Main.java
@@ -0,0 +1,42 @@
+package com.javahelps.pcapparser;
+
+import io.pkts.PacketHandler;
+import io.pkts.Pcap;
+import io.pkts.buffer.Buffer;
+import io.pkts.packet.Packet;
+import io.pkts.packet.TCPPacket;
+import io.pkts.packet.UDPPacket;
+import io.pkts.protocol.Protocol;
+
+import java.io.IOException;
+
+public class Main {
+
+	public static void main(String[] args) throws IOException {
+
+		final Pcap pcap = Pcap.openStream("tcpdump.pcap");
+
+		pcap.loop(new PacketHandler() {
+			@Override
+			public boolean nextPacket(Packet packet) throws IOException {
+
+				if (packet.hasProtocol(Protocol.TCP)) {
+
+					TCPPacket tcpPacket = (TCPPacket) packet.getPacket(Protocol.TCP);
+					Buffer buffer = tcpPacket.getPayload();
+					if (buffer != null) {
+						System.out.println("TCP: " + buffer);
+					}
+				} else if (packet.hasProtocol(Protocol.UDP)) {
+
+					UDPPacket udpPacket = (UDPPacket) packet.getPacket(Protocol.UDP);
+					Buffer buffer = udpPacket.getPayload();
+					if (buffer != null) {
+						System.out.println("UDP: " + buffer);
+					}
+				}
+				return true;
+			}
+		});
+	}
+}
