Compare commits
No commits in common. "d4572677f5b34b8b3bfa384fcc5cd0301a78cf56" and "19f9cd84de753810a1e6df080121a7a6331ba76e" have entirely different histories.
d4572677f5
...
19f9cd84de
BIN
Client.class
BIN
Client.class
Binary file not shown.
47
Client.java
47
Client.java
|
@ -1,47 +0,0 @@
|
|||
|
||||
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.
BIN
Server.class
BIN
Server.class
Binary file not shown.
72
Server.java
72
Server.java
|
@ -1,72 +0,0 @@
|
|||
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