diff --git a/pom.xml b/pom.xml index 55be3684410b343b3d8cbc50d0148047434ce389..dfbfda913856f1e058281447421e0a6a54b2c67f 100644 --- a/pom.xml +++ b/pom.xml @@ -7,7 +7,7 @@ es.uvigo.esei.dai sockets - 1.0.0 + 1.0.1 Ejemplos de DAI - Sockets 2014 diff --git a/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageReceiver.java b/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageReceiver.java index 068bb67b2991a1f0fbd39ee080a13da5bc703385..64d10c4f1f0ef853718a3a12d35be5a3a96afdae 100644 --- a/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageReceiver.java +++ b/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageReceiver.java @@ -37,10 +37,10 @@ public class MessageReceiver { socket.receive(packet); - try { + try ( final ByteArrayInputStream input = new ByteArrayInputStream(buffer); - final ObjectInputStream dataInput = new ObjectInputStream(input); - + final ObjectInputStream dataInput = new ObjectInputStream(input) + ) { final Message message = (Message) dataInput.readObject(); System.out.println("SUBJECT: " + message.getSubject()); diff --git a/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageSender.java b/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageSender.java index 52b77032c1a27bedaf0c304335d2134026f31da3..d80574618347184006f7e3a2bc3e97ba59897d8c 100644 --- a/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageSender.java +++ b/src/main/java/es/uvigo/esei/dai/sockets/example4/MessageSender.java @@ -32,19 +32,21 @@ import java.util.Date; public class MessageSender { public static void main(String[] args) { try (DatagramSocket socket = new DatagramSocket()) { - final ByteArrayOutputStream output = new ByteArrayOutputStream(60000); - final ObjectOutputStream dataOutput = new ObjectOutputStream(output); - - final Message message = new Message("Time", "Current time: " + new Date()); - System.out.println("SUBJECT: " + message.getSubject()); - System.out.println("MESSAGE: " + message.getMessage()); - dataOutput.writeObject(message); - - final DatagramPacket packet = new DatagramPacket( - output.toByteArray(), output.size(), InetAddress.getLocalHost(), 1234 - ); - - socket.send(packet); + try ( + final ByteArrayOutputStream output = new ByteArrayOutputStream(1500); + final ObjectOutputStream dataOutput = new ObjectOutputStream(output) + ) { + final Message message = new Message("Time", "Current time: " + new Date()); + System.out.println("SUBJECT: " + message.getSubject()); + System.out.println("MESSAGE: " + message.getMessage()); + dataOutput.writeObject(message); + + final DatagramPacket packet = new DatagramPacket( + output.toByteArray(), output.size(), InetAddress.getLocalHost(), 60000 + ); + + socket.send(packet); + } } catch (final IOException e) { System.out.print("Connection error: "); System.out.println(e.getMessage());