-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathServidor.java
68 lines (57 loc) · 1.82 KB
/
Servidor.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
import java.net.ServerSocket; //recibe conexiones
import java.net.Socket; //se conecta a un servidor remoto
import java.io.PrintWriter;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Scanner;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
public class Servidor{
private DataOutputStream salida;
Scanner input=new Scanner(System.in);
private int puerto = 4444;
private boolean opcion=true;
public void recibirConexiones(int puerto){
try{
System.out.println("Recibiendo conexiones en el puerto "+ puerto);
ServerSocket servidor = new ServerSocket(puerto);
while(opcion){
Socket cliente = servidor.accept();
PrintWriter escritor = new PrintWriter(cliente.getOutputStream());
BufferedReader lector= new BufferedReader(new InputStreamReader(cliente.getInputStream()));
escritor.println("Bienvenido!!!");
String linea;
while((linea=lector.readLine()) !=null){
if (linea.equals("/quit")) {
System.out.println("el tipo se fue ");
cliente.close();
escritor.flush();
break;
}
System.out.println("el visitante ha dicho: "+ linea);
}
salida=new DataOutputStream(cliente.getOutputStream());
}
}catch(Exception e){
System.err.println("Error al recibir");
e.printStackTrace();
}
}
public void mostrarTexto( String s){
System.out.print(s);
}
public void enviar(String s ){
try {
salida.writeUTF("server: " + s);
salida.flush();
} catch (IOException ex) {
}
}
public void escribir(){
while(opcion){
enviar(input.nextLine());
}
}
}