parent
8030283a7e
commit
648dac48ca
@ -0,0 +1,47 @@ |
||||
package sig; |
||||
|
||||
import java.io.BufferedReader; |
||||
import java.io.IOException; |
||||
import java.io.InputStreamReader; |
||||
import java.io.PrintWriter; |
||||
import java.net.Socket; |
||||
|
||||
public class Client { |
||||
Socket socket; |
||||
PrintWriter out; |
||||
BufferedReader in; |
||||
|
||||
public void start(String ip,int port) { |
||||
socket = new Socket(); |
||||
try { |
||||
out = new PrintWriter(socket.getOutputStream(),true); |
||||
in = new BufferedReader(new InputStreamReader(socket.getInputStream())); |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
|
||||
public String sendMessage(String msg) { |
||||
out.println(msg); |
||||
String res="ERROR: Empty Response"; |
||||
try { |
||||
res = in.readLine(); |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
return res; |
||||
} |
||||
|
||||
public void stop() { |
||||
try { |
||||
in.close(); |
||||
out.close(); |
||||
socket.close(); |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
@ -0,0 +1,36 @@ |
||||
package sig; |
||||
|
||||
import java.io.BufferedReader; |
||||
import java.io.IOException; |
||||
import java.io.InputStreamReader; |
||||
import java.io.PrintWriter; |
||||
import java.net.Socket; |
||||
|
||||
public class ClientHandler extends Thread{ |
||||
Socket socket; |
||||
PrintWriter out; |
||||
BufferedReader in; |
||||
public ClientHandler(Socket socket) { |
||||
this.socket=socket; |
||||
} |
||||
|
||||
public void run() { |
||||
try { |
||||
out = new PrintWriter(socket.getOutputStream(),true); |
||||
in = new BufferedReader(new InputStreamReader(socket.getInputStream())); |
||||
String line; |
||||
while ((line=in.readLine())!=null) { |
||||
if (line.equals("EOF")) { |
||||
out.println("Goodbye."); |
||||
} |
||||
out.println(line); |
||||
} |
||||
|
||||
in.close(); |
||||
out.close(); |
||||
socket.close(); |
||||
} catch (IOException e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
@ -0,0 +1,19 @@ |
||||
package sig; |
||||
|
||||
import java.io.IOException; |
||||
import java.net.ServerSocket; |
||||
|
||||
public class Server { |
||||
ServerSocket socket; |
||||
public void start(int port) { |
||||
try { |
||||
socket = new ServerSocket(port); |
||||
while (true) { |
||||
new ClientHandler(socket.accept()).start(); |
||||
} |
||||
} catch (IOException e) { |
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
Loading…
Reference in new issue