Skip to content

Commit 38ee531

Browse files
committed
java client and server basic
1 parent 7d53634 commit 38ee531

File tree

5 files changed

+160
-0
lines changed

5 files changed

+160
-0
lines changed

Client.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
import java.io.ObjectOutputStream;
2+
import java.io.IOException;
3+
import java.io.ObjectInputStream;
4+
import java.net.Socket;
5+
import java.util.Scanner;
6+
7+
public class Client{
8+
public static void main(String[] args) throws IOException{
9+
Socket socket = new Socket("localhost", 5000);
10+
System.out.println("client Started");
11+
12+
//must first create the output stream before the input stream
13+
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
14+
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
15+
16+
Scanner sc =new Scanner(System.in);
17+
String messsag= sc.nextLine();
18+
19+
20+
try {
21+
//send to server
22+
oos.writeObject(messsag);
23+
//receive from server
24+
String fromServer = (String) ois.readObject();
25+
System.out.println("Server: " + fromServer);
26+
} catch (Exception e) {
27+
// TODO: handle exception
28+
}
29+
30+
}
31+
}

Server.class

1.62 KB
Binary file not shown.

Server.java

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
import java.io.ObjectInputStream;
2+
import java.io.ObjectOutputStream;
3+
import java.net.ServerSocket;
4+
import java.net.Socket;
5+
6+
public class Server {
7+
public static void main(String[] args) throws Exception{
8+
ServerSocket serverSocket = new ServerSocket(5000);
9+
10+
while(true){
11+
Socket clientSocket = serverSocket.accept();
12+
System.out.println("Server connected");
13+
14+
ObjectInputStream ois= new ObjectInputStream(clientSocket.getInputStream());
15+
ObjectOutputStream oos = new ObjectOutputStream(clientSocket.getOutputStream());
16+
17+
try{
18+
String message = (String) ois.readObject();
19+
System.out.println("Client: " + message);
20+
oos.writeObject("Server: " + message);
21+
}catch(Exception e){
22+
System.out.println("An error occurred");
23+
}
24+
}
25+
}
26+
}

TwoWayClient.java

Lines changed: 54 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
import java.io.BufferedReader;
2+
import java.io.DataInputStream;
3+
import java.io.DataOutputStream;
4+
import java.io.IOException;
5+
import java.io.InputStreamReader;
6+
import java.net.*;
7+
8+
public class TwoWayClient
9+
{
10+
public static void main(String[] args) throws IOException {
11+
Socket s = new Socket("localhost", 5000);
12+
13+
System.out.println("Client Connected at server Handshaking port "
14+
+s.getPort());
15+
System.out.println("Client's communication port " +
16+
s.getLocalPort());
17+
System.out.println("Client is Connected");
18+
19+
20+
DataOutputStream output = new
21+
DataOutputStream(s.getOutputStream());
22+
DataInputStream input = new DataInputStream(s.getInputStream());
23+
BufferedReader read = new BufferedReader(new
24+
InputStreamReader(System.in));
25+
26+
String str = "";
27+
String serverResponse;
28+
29+
30+
while (!str.equals("stop"))
31+
{
32+
System.out.println("Enter message to send (or 'stop' to close): ");
33+
System.out.print("Client: ");
34+
35+
str = read.readLine();
36+
37+
38+
output.writeUTF(str);
39+
40+
if (!str.equals("stop")) {
41+
serverResponse = input.readUTF();
42+
System.out.println("Server: " + serverResponse);
43+
}
44+
}
45+
46+
output.close();
47+
input.close();
48+
read.close();
49+
s.close();
50+
}}
51+
52+
53+
//TwoWayServer.java
54+

TwoWayServer.java

Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
2+
import java.io.DataInputStream;
3+
import java.io.DataOutputStream;
4+
import java.io.IOException;
5+
import java.net.ServerSocket;
6+
import java.net.Socket;
7+
import java.util.Scanner;
8+
9+
public class TwoWayServer {
10+
11+
public static void main(String[] args) throws IOException {
12+
ServerSocket serverSocket = new ServerSocket(5000);
13+
System.out.println("Server started on port " +
14+
serverSocket.getLocalPort());
15+
16+
Socket clientSocket = serverSocket.accept();
17+
System.out.println("Client connected: " +
18+
clientSocket.getRemoteSocketAddress());
19+
20+
DataOutputStream outputToClient = new
21+
DataOutputStream(clientSocket.getOutputStream());
22+
DataInputStream inputFromClient = new
23+
DataInputStream(clientSocket.getInputStream());
24+
25+
String clientMessage;
26+
String serverResponse;
27+
Scanner scanner = new Scanner(System.in);
28+
29+
while (true) {
30+
clientMessage = inputFromClient.readUTF();
31+
32+
if (clientMessage.equals("stop")) {
33+
break;
34+
}
35+
36+
System.out.println("Client: " + clientMessage);
37+
38+
System.out.print("Server reply: ");
39+
serverResponse = scanner.nextLine();
40+
41+
outputToClient.writeUTF(serverResponse);
42+
}
43+
44+
outputToClient.close();
45+
inputFromClient.close();
46+
scanner.close();
47+
clientSocket.close();
48+
serverSocket.close();
49+
}}

0 commit comments

Comments
 (0)