Knoppia

Esta página es de solo lectura. Puedes ver la fuente pero no puedes cambiarla. Pregunta a tu administrador si crees que esto es incorrecto.
====== Sockets ======
Un Socket es un punto de conexión (Una Tubería o un Canal) entre 2 procesos e identificado por una IP y un Puerto.
En este caso serán 2 procesos ejecutándose simultáneamente conectados por un socket.
{{ :dad:socket.png |}}
Un socket funciona de una forma similar a la de los ficheros. Para leer y escribir utilizaremos un Buffer (PrintWritter y BufferedReader)

===== Cliente =====
{{ :dad:imagen_2023-10-05_110539888.png |}}


===== Servidor =====
{{ :dad:imagen_2023-10-05_110936729.png |}}

===== Implementación Cliente =====
{{ :dad:imagen_2023-10-05_115043040.png |}}
<code java Cliente.java>
package jelouda;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Cliente {
	public void ejecutar() {
		try {
			
			
		System.out.print("Lanzando conexión....");
		
		Socket socket = new Socket ("127.0.0.1", Servidor.PUERTO);//Conectamos al servidor
		
		System.out.println("[OK]");
		
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Bufer de lectura
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer de escritura
		
		String cadenaRecibida = br.readLine();
		System.out.println(cadenaRecibida);
		
		pw.println("cadena recibida" + cadenaRecibida);
		pw.flush();
		
		System.out.println("Fin del Cliente");
		
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	
	
	public static void main(String[] args) {
		Cliente client = new Cliente();
		client.ejecutar();

	}	
}

</code>


===== Implementación Servidor =====
{{ :dad:imagen_2023-10-05_115144753.png |}}


<code java Servidor.java>
package jelouda;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Servidor {
	public static int PUERTO = 5000;//Indicamos el puerto del servidor
	public void ejecutar() {
		try {
			
		System.out.println("Lanzando Servidor...");
		ServerSocket serverSocket = new ServerSocket(Servidor.PUERTO);
		
		Socket socket = serverSocket.accept();
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Buffer entrada
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer salida
		
		String cadenaRecibida = br.readLine();
		
		
		
		pw.print(cadenaRecibida);
		pw.flush();
		System.out.println("Fin del Servidor");
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
		Servidor server = new Servidor();
		server.ejecutar();
	}
}

</code>

===== Implementación Servidor continuo =====
Añadimos un nuevo método al que llamaremos ejecutar infinito:
{{ :dad:imagen_2023-10-05_120946334.png |}}
<code java Servidor.java>
package jelouda;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Servidor {
	public static int PUERTO = 5000;//Indicamos el puerto del servidor
	public void ejecutar() {
		try {
			
		System.out.println("Lanzando Servidor...");
		ServerSocket serverSocket = new ServerSocket(Servidor.PUERTO);
		
		//Lo hacemos contínuo
		//Scanner sc = new Scanner(System.in);
		//sc.nextLine();
		
		
		Socket socket = serverSocket.accept();
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Buffer entrada
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer salida
		
		String cadenaRecibida = br.readLine();
		
		
		
		pw.print(cadenaRecibida);
		pw.flush();
		System.out.println("Fin del Servidor");
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	public void ejecutarInfinito() {
		try {
			
		
		System.out.println("Lanzando Servidor...");
		ServerSocket serverSocket = new ServerSocket(Servidor.PUERTO);
		Socket socket = serverSocket.accept();
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Buffer entrada
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer salida
		
		while(true) {
			System.out.println(br.readLine());
			pw.println(br.readLine());
			pw.flush();
		}
		
		
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
		Servidor server = new Servidor();
		server.ejecutarInfinito();
	}
}

</code>

===== Implementación cliente Continuo =====
Añadimos un nuevo método al que llamaremos ejecutar infinito:
{{ :dad:imagen_2023-10-05_120728806.png |}}
<code java Cliente.java>
package jelouda;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Cliente {
	public void ejecutar() {
		try {
			
			
		System.out.print("Lanzando conexión....");
		
		Socket socket = new Socket ("127.0.0.1", Servidor.PUERTO);//Conectamos al servidor
		
		System.out.println("[OK]");
		
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Bufer de lectura
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer de escritura
		
		String cadenaRecibida = br.readLine();
		System.out.println(cadenaRecibida);
		
		pw.println("cadena recibida" + cadenaRecibida);
		pw.flush();
		
		System.out.println("Fin del Cliente");
		
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	
	public void ejecutarInfinito() {
		try {
			
			
		System.out.print("Lanzando conexión....");
		
		Socket socket = new Socket ("127.0.0.1", Servidor.PUERTO);//Conectamos al servidor
		
		System.out.println("[OK]");
		
		
		BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//Bufer de lectura
		PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//Buffer de escritura
		
		String lineaLeida ="";
		Scanner teclado = new Scanner(System.in);
		
		while(true) {
			lineaLeida = teclado.nextLine();
			pw.println(lineaLeida);
			pw.flush();
		}

		
		}catch(IOException e){
			e.printStackTrace();
		}
	}
	
	
	public static void main(String[] args) {
		Cliente client = new Cliente();
		client.ejecutarInfinito();

	}	
}

</code>
Knoppia

Herramientas de usuario

Herramientas del sitio

Herramientas de la página
