Programación en red
En resumen: La programación en red son dos programas que hablan por la red: el servidor espera en una dirección IP y un puerto, el cliente se conecta, y los sockets envían los datos por TCP o UDP.
Problema
La caja y el almacén
La caja de la tienda tiene que preguntarle al almacén cuánto café queda, y el programa del almacén funciona en otra computadora. Un archivo no sirve: los dos programas no ven el disco del otro. Uno tiene que preguntar y el otro tiene que responder, en el momento, por la red.
Así funciona casi todo lo que te rodea: el navegador le pide una página al servidor, la app del banco le pide al banco tu saldo, un juego envía tus jugadas a los demás jugadores.
La idea
Dirección, puerto y dos formas de enviar
Para que los datos lleguen a un programa en otra computadora, necesitas dos cosas:
- Una dirección IP: el número de la computadora en la red, por ejemplo
192.168.1.20o142.250.185.78. Tu propia computadora es siempre127.0.0.1, con el nombrelocalhost. - Un puerto: un número del 0 al 65 535 para el programa de esa computadora. La dirección es el edificio, el puerto es el apartamento. HTTPS usa el 443, y nosotros usaremos el 5761 y los siguientes.
El programa que espera a que lo busquen es el servidor. El que busca es el cliente. Cómo viajan los datos lo decide el protocolo:
| TCP | UDP | |
|---|---|---|
| Conexión | primero se conectan, después hablan | sin conexión, cada paquete es una carta aparte |
| Entrega | todo llega, en el mismo orden, o te enteras de que no llegó | un paquete puede perderse o llegar en otro orden |
| Velocidad | más lento | más rápido |
| Para qué | la web, el correo, los pagos, los archivos | voz y video en directo, juegos, sensores |
Más precisamente, para curiosos
- La red se describe en capas. El modelo OSI tiene siete: física (bits por el cable o por el aire), de enlace de datos (la conexión con el dispositivo vecino), de red (direcciones IP y rutas), de transporte (TCP, UDP), de sesión, de presentación y de aplicación (HTTP, correo). En la práctica, internet usa el modelo TCP/IP, más sencillo, con cuatro capas. Tu programa trabaja en la de arriba: Java se encarga de todo lo de abajo.
- IP entrega paquetes sueltos a una dirección, pero no promete que lleguen. TCP se apoya en IP y numera los paquetes, para poder ordenarlos y volver a pedir los que se perdieron.
- Protocolos con los que te vas a encontrar: HTTP y HTTPS (la web; HTTPS es HTTP cifrado con TLS, cuyo nombre antiguo es SSL), WebSocket (una conexión en los dos sentidos para chats y notificaciones en el navegador), FTP (archivos), SSH (acceso seguro a una computadora remota).
Míralo
El servidor
El servidor del almacén recibe el nombre de un producto y responde con su precio:
static final Map<String, Double> PRICES = Map.of("café", 7.50, "té", 3.20);
static void serve(ServerSocket server) { try (Socket client = server.accept(); BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out = new PrintWriter(client.getOutputStream(), true)) { String product = in.readLine(); System.out.println("El servidor recibió: " + product); Double price = PRICES.get(product); out.println(price == null ? "no existe ese producto" : product + ": " + price + " €"); } catch (IOException e) { System.out.println("El servidor: " + e.getMessage()); }}ServerSocketescucha en un puerto.server.accept()espera hasta que se conecta un cliente y devuelve unSocketpara la conexión con él.- El socket tiene dos flujos:
getInputStream()para lo que llega, ygetOutputStream()para lo que envías. Los envolvemos, como con los archivos:BufferedReaderlee líneas,PrintWriterescribe líneas. trueenPrintWritersignifica «envía después de cadaprintln». Vas a ver por qué importa.- try-with-resources cierra la conexión y los flujos al final.
Míralo
El cliente
new Socket(dirección, puerto) y usa los mismos dos flujos. Aquí el servidor y el cliente están en un solo programa: el servidor funciona en su propio hilo, y main es el cliente. Así puedes probarlos sin una segunda computadora:ServerSocket server = new ServerSocket(5761);new Thread(() -> serve(server)).start();
try (Socket socket = new Socket("localhost", 5761); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) { out.println("café"); System.out.println("El cliente recibió: " + in.readLine());}server.close();El servidor recibió: caféEl cliente recibió: café: 7.5 €new ServerSocket(5761) en main, antes de que arranque el hilo. Así, cuando el cliente se conecta, el servidor ya está escuchando.Los dos lados se turnan: el cliente escribe una línea y espera una respuesta con readLine(), y el servidor lee la línea y responde. Si cambian de papel y los dos esperan para leer, esperarán para siempre.
ServerSocket server = new ServerSocket(5761);new Thread(() -> serve(server)).start();
try (Socket socket = new Socket("localhost", 5761); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) { out.println("café"); System.out.println("El cliente recibió: " + in.readLine());}server.close();Paso a paso, en palabras
- El servidor abre el puerto 5761 y empieza a escuchar.
- En su propio hilo, el servidor llama a accept() y espera a un cliente.
- El cliente se conecta. accept() devuelve un Socket, y cada lado tiene dos flujos: uno para escribir y otro para leer.
- El cliente escribe una línea: «café». Viaja por la conexión hasta el flujo de entrada del servidor.
- El cliente espera en readLine(). El servidor lee la línea y la imprime.
- El servidor busca el precio y responde: «café: 7.5 €».
- El readLine() del cliente devuelve la respuesta, y el cliente la imprime.
- try cierra el socket, y server.close() cierra el puerto.
Más precisamente, para curiosos
- El programa completo, con los
import:
import java.io.*;import java.net.*;import java.util.Map;
public class Main { static final Map<String, Double> PRICES = Map.of("café", 7.50, "té", 3.20);
static void serve(ServerSocket server) { try (Socket client = server.accept(); BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out = new PrintWriter(client.getOutputStream(), true)) { String product = in.readLine(); System.out.println("El servidor recibió: " + product); Double price = PRICES.get(product); out.println(price == null ? "no existe ese producto" : product + ": " + price + " €"); } catch (IOException e) { System.out.println("El servidor: " + e.getMessage()); } }
public static void main(String[] args) throws IOException { ServerSocket server = new ServerSocket(5761); new Thread(() -> serve(server)).start();
try (Socket socket = new Socket("localhost", 5761); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) { out.println("café"); System.out.println("El cliente recibió: " + in.readLine()); } server.close(); }}- En dos archivos separados y dos terminales es lo mismo: primero arrancas el servidor, después el cliente. Si no hay ningún servidor en el puerto,
new SocketlanzaConnectException: Connection refused. Si otro programa ya ocupa el puerto,new ServerSocketlanzaBindException: Address already in use. - El texto viaja por la red como bytes. Java 18 y las versiones más nuevas convierten el texto a UTF-8 por defecto, así que las tildes, la ñ y el € llegan intactos.
Pruébalo
Espera a un cliente
¿Qué método espera hasta que se conecta un cliente?
ServerSocket server = new ServerSocket(5761);
Socket client = server.();accept() se bloquea hasta que alguien se conecta, y devuelve un socket para la conexión con él. El servidor puede llamarlo muchas veces, para muchos clientes.La idea
Muchos clientes a la vez
accept() y los demás esperan. Por eso un servidor real hace un bucle infinito: acepta un cliente, se lo da a un hilo nuevo y vuelve enseguida a accept():static void acceptAll(ServerSocket server) { int number = 0; while (true) { try { Socket client = server.accept(); number++; int n = number; new Thread(() -> handle(client, n)).start(); } catch (IOException e) { return; } }}
static void handle(Socket client, int number) { try (client; BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out = new PrintWriter(client.getOutputStream(), true)) { String line; while ((line = in.readLine()) != null) { System.out.println("Cliente " + number + ": " + line); out.println("Eco: " + line); } } catch (IOException e) { System.out.println("Cliente " + number + " se desconectó: " + e.getMessage()); }}handle responde a cada línea hasta que el cliente cierra la conexión: entonces readLine() devuelve null. Dos clientes, uno detrás de otro:ServerSocket server = new ServerSocket(5762);Thread acceptor = new Thread(() -> acceptAll(server));acceptor.setDaemon(true);acceptor.start();
for (String order : new String[] { "mesa 4: dos cafés", "mesa 7: la cuenta" }) { try (Socket socket = new Socket("localhost", 5762); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) { out.println(order); System.out.println(in.readLine()); }}server.close();Cliente 1: mesa 4: dos cafésEco: mesa 4: dos cafésCliente 2: mesa 7: la cuentaEco: mesa 7: la cuentaMás precisamente, para curiosos
setDaemon(true)convierte el hilo en un hilo «en segundo plano»: el programa termina cuando terminamain, sin esperar al bucle infinito. Un servidor real no lo pone en segundo plano: tiene que funcionar hasta que lo detengas.try (client; ...)mete el socket que ya existe en el try-with-resources, para que se cierre al final.- Con miles de clientes, un hilo para cada uno sale caro. Entonces el bucle que acepta les da los clientes a un grupo de hilos (thread pool) de la lección anterior:
pool.execute(() -> handle(client, n)).
Pruébalo
Los dos esperan
El cliente envía «café» y espera una respuesta. El servidor es el mismo, pero el programa se queda colgado y no imprime nada. ¿En qué línea está el error?
Elige la línea con el error.
PrintWriter sin true no envía enseguida: guarda el texto en un búfer hasta que se junta más. println("café") se queda en la memoria del cliente, el servidor espera una línea, y el cliente espera una respuesta. La corrección es new PrintWriter(socket.getOutputStream(), true) o out.flush() después de println.La idea
UDP: cartas sin conexión
DatagramPacket (bytes más una dirección y un puerto) a través de un DatagramSocket:DatagramSocket receiver = new DatagramSocket(5763);
try (DatagramSocket sensor = new DatagramSocket()) { InetAddress address = InetAddress.getByName("localhost"); for (String reading : new String[] { "cocina 21.5", "almacén 4.0", "nevera 3.2" }) { byte[] data = reading.getBytes(); sensor.send(new DatagramPacket(data, data.length, address, 5763)); }}
byte[] buffer = new byte[256];for (int i = 0; i < 3; i++) { DatagramPacket packet = new DatagramPacket(buffer, buffer.length); receiver.receive(packet); String text = new String(packet.getData(), 0, packet.getLength()); System.out.println("Temperatura: " + text + " °C");}receiver.close();Temperatura: cocina 21.5 °CTemperatura: almacén 4.0 °CTemperatura: nevera 3.2 °C- El receptor escucha en el puerto 5763 con
new DatagramSocket(5763). El emisor usanew DatagramSocket()sin puerto: el sistema le da uno libre. receiveespera un paquete y lo escribe en el búfer.getLength()te dice cuántos bytes llegaron.- Nadie confirma que el paquete llegó. En
localhostno se pierden, pero en una red real sí puede pasar.
Más precisamente, para curiosos
Si el receptor tiene que responder, toma la dirección y el puerto del emisor del propio paquete, con packet.getAddress() y packet.getPort(), y envía allí un paquete nuevo.
Un paquete tiene un tamaño máximo (menos de 64 KB, y por internet conviene quedarse en unos 1400 bytes), así que UDP no sirve para archivos.
La idea
HTTP: el idioma de la web
Cuando abres una página, el navegador hace una conexión TCP con el servidor y envía una petición HTTP de texto: «dame /». El servidor devuelve una respuesta: un estado, unas cabeceras y un cuerpo (HTML, JSON, una imagen). En Java esto lo hace HttpClient:
import java.net.URI;import java.net.http.*;
HttpClient client = HttpClient.newHttpClient();HttpRequest request = HttpRequest.newBuilder(URI.create("https://example.com")).build();HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
System.out.println("Estado: " + response.statusCode());System.out.println("Tipo: " + response.headers().firstValue("content-type").orElse("?"));String body = response.body();System.out.println("Título: " + body.substring(body.indexOf("<title>") + 7, body.indexOf("</title>")));Estado: 200Tipo: text/html; charset=utf-8Título: Example DomainHttpRequest.newBuilder(URI)describe la petición, que por defecto esGET.sendenvía la petición y espera la respuesta.BodyHandlers.ofString()dice «dame el cuerpo como texto».- El estado te dice cómo fue:
200es éxito,404significa que no existe esa página,500es un error del servidor.
La revisión del código del sitio se hace sin internet, así que este programa se muestra con la salida de una ejecución con red. Sin red, send lanza IOException.
Más precisamente, para curiosos
com.sun.net.httpserver). Así puedes probar HttpClient sin internet, en localhost:HttpServer server = HttpServer.create(new InetSocketAddress("localhost", 5764), 0);server.createContext("/stock", exchange -> { byte[] answer = "café: 12 uds.".getBytes(); exchange.sendResponseHeaders(200, answer.length); exchange.getResponseBody().write(answer); exchange.close();});server.start();
HttpClient client = HttpClient.newHttpClient();for (String path : new String[] { "/stock", "/prices" }) { HttpRequest request = HttpRequest.newBuilder(URI.create("http://localhost:5764" + path)).build(); HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString()); System.out.println(path + " -> " + response.statusCode() + " " + response.body());}server.stop(0);/stock -> 200 café: 12 uds./prices -> 404 <h1>404 Not Found</h1>No context found for request/prices no tiene manejador, así que el servidor devuelve 404 por su cuenta. En proyectos reales, los servidores web se hacen con bibliotecas como Spring Boot. Están construidas sobre los mismos sockets e hilos.Ejercicio
Servidores en localhost
1. Servidor de eco. El servidor devuelve cada línea con «Eco: » delante, hasta que recibe «fin». Entonces responde «Adiós» y cierra la conexión. El cliente envía «hola», «qué tal» y «fin», e imprime las respuestas:
Eco: holaEco: qué talAdiós2. Un servidor con comandos. MAYUS texto devuelve el texto en mayúsculas, HORA devuelve la hora actual como 14:05 (LocalTime.now() y DateTimeFormatter.ofPattern("HH:mm")), y cualquier otra cosa devuelve «Comando desconocido: » y el comando. La hora cambia, así que el cliente solo comprueba su forma con una expresión regular:
PEDIDO 42 ESTÁ LISTOLa hora tiene la forma HH:MM: trueComando desconocido: TIEMPOCarlos recibió: ¡Hola, Carlos! ¿Estás libre a las 18:00?Ana recibió: Sí, allí estaré.Carlos recibió: Genial, hasta pronto.Ana recibió: ¡Hasta luego!Test
Ponte a prueba
Lecciones relacionadas
Sección «Lecciones relacionadas»- Se basa en: Listas · HashMap y HashSet · Lambdas · Hilos
- Continúa en: Entrada no confiable · Sesiones, cookies y CSRF · JWT y sus trampas · Diseño de API: contrato, versiones, solicitudes repetidas
- Ejercicios sobre el tema: Programas en el mundo real