From 3c62b863509131e78c18ed13c6b83e4fc508848f Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Sat, 23 Nov 2024 13:51:12 -0500 Subject: import replica code from assignment --- .../java/derms/replica/replica1/ObjectPacket.java | 38 ++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 src/main/java/derms/replica/replica1/ObjectPacket.java (limited to 'src/main/java/derms/replica/replica1/ObjectPacket.java') diff --git a/src/main/java/derms/replica/replica1/ObjectPacket.java b/src/main/java/derms/replica/replica1/ObjectPacket.java new file mode 100644 index 0000000..28010c0 --- /dev/null +++ b/src/main/java/derms/replica/replica1/ObjectPacket.java @@ -0,0 +1,38 @@ +package derms.replica.replica1; + +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.io.Serializable; +import java.net.DatagramPacket; +import java.net.SocketAddress; + +public class ObjectPacket { + public static DatagramPacket create(Serializable obj, SocketAddress remoteAddr) throws IOException { + ByteArrayOutputStream byteStream = new ByteArrayOutputStream(); + ObjectOutputStream objStream = new ObjectOutputStream(byteStream); + objStream.writeObject(obj); + objStream.flush(); + byte[] buf = byteStream.toByteArray(); + objStream.close(); + return new DatagramPacket(buf, buf.length, remoteAddr); + } + + public static E deserialize(DatagramPacket pkt, Class clazz) throws IOException { + ObjectInputStream objectStream; + try { + objectStream = new ObjectInputStream( + new ByteArrayInputStream(pkt.getData())); + } catch (Exception e) { + throw new IOException("failed to create input stream: "+e.getMessage()); + } + + try { + return clazz.cast(objectStream.readObject()); + } catch (Exception e) { + throw new IOException(e.getMessage()); + } + } +} \ No newline at end of file -- cgit v1.2.3