Compare commits
3 Commits
19f9cd84de
...
d4572677f5
Author | SHA1 | Date |
---|---|---|
|
d4572677f5 | |
|
53c846a386 | |
|
b0fcb7c79c |
Binary file not shown.
|
@ -0,0 +1,47 @@
|
|||
|
||||
import java.io.*;
|
||||
import java.net.*;
|
||||
import java.util.*;
|
||||
|
||||
// Client class
|
||||
class Client {
|
||||
|
||||
// driver code
|
||||
public static void main(String[] args) {
|
||||
// establish a connection by providing host and port
|
||||
// number
|
||||
try (Socket socket = new Socket("localhost", 8080)) {
|
||||
|
||||
// writing to server
|
||||
PrintWriter out = new PrintWriter(
|
||||
socket.getOutputStream(), true);
|
||||
|
||||
// reading from server
|
||||
BufferedReader in = new BufferedReader(new InputStreamReader(
|
||||
socket.getInputStream()));
|
||||
|
||||
// object of scanner class
|
||||
Scanner sc = new Scanner(System.in);
|
||||
String line = null;
|
||||
|
||||
while (!"exit".equalsIgnoreCase(line)) {
|
||||
|
||||
// reading from user
|
||||
line = sc.nextLine();
|
||||
|
||||
// sending the user input to server
|
||||
out.println(line);
|
||||
out.flush();
|
||||
|
||||
// displaying server reply
|
||||
System.out.println("Server replied "
|
||||
+ in.readLine());
|
||||
}
|
||||
|
||||
// closing the scanner object
|
||||
sc.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
Binary file not shown.
Binary file not shown.
|
@ -0,0 +1,72 @@
|
|||
import java.io.*;
|
||||
import java.net.*;
|
||||
|
||||
class Server {
|
||||
public static void main(String[] args) {
|
||||
ServerSocket server = null;
|
||||
try {
|
||||
// start server
|
||||
server = new ServerSocket(8080);
|
||||
server.setReuseAddress(true);
|
||||
|
||||
while (true) {
|
||||
Socket client = server.accept();
|
||||
System.out.println("New client: " + client.getInetAddress().getHostAddress());
|
||||
|
||||
ClientHandler clientSock = new ClientHandler(client);
|
||||
new Thread(clientSock).start();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
if (server != null) {
|
||||
try {
|
||||
server.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private static class ClientHandler implements Runnable {
|
||||
|
||||
private Socket clientSocket;
|
||||
|
||||
public ClientHandler(Socket socket) {
|
||||
this.clientSocket = socket;
|
||||
}
|
||||
|
||||
public void run() {
|
||||
PrintWriter out = null;
|
||||
BufferedReader in = null;
|
||||
try {
|
||||
out = new PrintWriter(clientSocket.getOutputStream(), true);
|
||||
in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
|
||||
|
||||
String line;
|
||||
while ((line = in.readLine()) != null) {
|
||||
System.out.printf("From the client: %s\n", line);
|
||||
out.println(line);
|
||||
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
try {
|
||||
if (out != null) {
|
||||
out.close();
|
||||
}
|
||||
if (in != null) {
|
||||
in.close();
|
||||
System.out.println("closing socket " + clientSocket.getInetAddress().getHostAddress());
|
||||
clientSocket.close();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
Loading…
Reference in New Issue