Quiero enviar una lista de números al servidor para que este al leerlos efectúe las operaciones correspondientes y devuelva el resultado de las mismas al cliente. Luego volverá a pedir números al cliente y de nuevo le devolverá el resultado correspondiente, repitiéndose el proceso hasta que el cliente introduzca un *, entonces ahí se cerraría conexión con el servidor. Tengo que hacerlo obligatoriamente utilizando protocolo UDP.
El problema es que al mandar los números por lo visto al servidor no le llegan dichos números y no hace nada. Cuando ejecuto el programa me pide los 4 números, los introduzco y ahí es donde se queda parado, el servidor no devuelve ningún resultado. Para guardar los números he utilizado el ArrayList numeros... el problema es el proceso para empaquetar esa lista de números en bytes, mandarlo al servidor y que este lo decodifique y lea esos números, ahí por lo visto no le llega la información al servidor. Soy un novato en esto de conexiones TCP/UDP, seguro que me habré equivocado pero no sé como solucionarlo, espero podáis orientarme un poco, porque estoy más perdido que un pulpo en un garaje.
El código del servidor es es:
import java.awt.List;
import java.io.ByteArrayInputStream;
import java.io.ObjectInputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.ArrayList;
public class Servidor {
public static void main(String args[]) throws Exception {
DatagramSocket serverSocket = new DatagramSocket(9886);
byte[] infoRecibida = new byte[1024];
byte[] infoEnviada = new byte[1024];
byte[] paquete = new byte[1024];
String cadena;
List list;
int n1,n2,n3,n4;
int res;
String num;
String num1,num2,num3,num4;
String x;
while (true) {
System.out.println("Esperando datagrama...");
infoRecibida = new byte[1024];
DatagramPacket paqRecibido = new DatagramPacket(infoRecibida, infoRecibida.length);
serverSocket.receive(paqRecibido);
// IP y puerto desde donde se manda mensaje
InetAddress IPOrigen = paqRecibido.getAddress();
int puerto = paqRecibido.getPort();
//Estas dos lineas supuestamente serían para poder leer el arraylist enviado desde el cliente, aunque igual estoy equivocado
ObjectInputStream inputStream = new ObjectInputStream(new ByteArrayInputStream(infoRecibida));
ArrayList<Integer> numeros = (ArrayList<Integer>)inputStream.readObject();
n1 = numeros.get(0);
n2 = numeros.get(1);
n3 = numeros.get(2);
n4 = numeros.get(3);
num1= Integer.toString(n1);
num2= Integer.toString(n2);
num3= Integer.toString(n3);
num4= Integer.toString(n4);
// Si alguno de los números introducidos es *
// envío "x" al cliente para que este se cierre, posteriormente sale del bucle y se cierra también el servidor
if (num1=="*"||num2=="*"||num3=="*"||num4=="*") {
x = "x";
paquete = x.getBytes();
DatagramPacket paqueteFinal = new DatagramPacket(paquete, paquete.length, IPOrigen, puerto);
break;
}
//Hago las operaciones, el resultado lo paso a cadena y luego a bytes, para ser enviado al cliente
res=(n1+n2)*n3-n4;
num = Integer.toString(res);
infoEnviada=num.getBytes();
// ENVIO DATAGRAMA AL CLIENTE
DatagramPacket paqEnviado = new DatagramPacket(infoEnviada, infoEnviada.length, IPOrigen, puerto);
serverSocket.send(paqEnviado);
} //Fin While
serverSocket.close();
System.out.println("Socket cerrado...");
}
}
Y el del Cliente este
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.ArrayList;
public class Cliente {
public static void main(String[] args) throws Exception {
String cadena;
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
DatagramSocket clientSocket = new DatagramSocket();
//para recibir y enviar datos
byte[] datosEnviados = new byte[1024];
byte[] datosRecibidos = new byte[1024];
InetAddress IPServidor = InetAddress.getByName(...); //En el paréntesis iría el número de ip del servidor adonde quiero mandarlo
int puerto = 6000;
ArrayList<Integer> numeros = new ArrayList<>();
while(true) {
//Rellenamos ArrayList numeros
for(int i=0; i<4;i++) {
System.out.println("Introduce un mensaje: ");
cadena = in.readLine();
numeros.add(Integer.parseInt(cadena));
}
//Empaquetamos ArrayList en bytes para poder enviarlo al servidor
ByteArrayOutputStream out = new ByteArrayOutputStream();
ObjectOutputStream outputStream = new ObjectOutputStream(out);
outputStream.writeObject(numeros);
byte[] listData = out.toByteArray();
DatagramPacket envio = new DatagramPacket(listData, listData.length, IPServidor, puerto);
clientSocket.send(envio);
outputStream.close();
//recibimos respuesta del servidor
DatagramPacket recibo = new DatagramPacket(datosRecibidos, datosRecibidos.length);
System.out.println("Esperando datagrama...");
clientSocket.receive(recibo);
String numero = new String(recibo.getData());
//Si el dato que devuelve el servidor es "x", salimos del bucle y se cierra el cliente
if (numero.equals("x")) {
break;
}
System.out.println("\t Datos: " + numero);
} //Fin While
clientSocket.close(); //Cerramos cliente
}
}
clientSocket.receive(recibo)
antes de que se cree el objetoenvió
outputStream.close();
el de poner fuera. Como tu dices, lo otro no tiene ningún sentido. Es mas que nada si por no haber cerrado el Stream antes de usarlo, este no se manda correctamente.