FilesExpand file tree

 main

/

Server.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

74 lines (73 loc) · 2.32 KB

 main

/

Server.java

Copy path

Top

File metadata and controls

• Code
• Blame

74 lines (73 loc) · 2.32 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

69

70

71

72

73

74

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.*;

public class Server {

ServerSocket server;

Socket socket;

BufferedReader br;

PrintWriter out;

public Server(){

try{

server = new ServerSocket(7777);

System.out.println("Server Is Now Accepting Connection...");

socket = server.accept();

System.out.println("Connection Is Now Established");

br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

out = new PrintWriter(socket.getOutputStream());

startReading();

startWriting();

}

catch(Exception e){

e.printStackTrace();

System.exit(0);

}

}

public void startReading(){

Runnable r1 =() ->{

while(true){

try {

String mssg = br.readLine();

if (mssg.equals("-101")) {

System.out.println("Client Terminated The Chat");

socket.close();

br.close();

System.exit(0);

}

System.out.println("Client : " + mssg);

}

catch(Exception e){

e.printStackTrace();

System.exit(1);

}

}

};

new Thread(r1).start();

}

public void startWriting(){

Runnable r2 = () ->{

while(true) {

try {

BufferedReader br2 = new BufferedReader(new InputStreamReader(System.in));

String content = br2.readLine();

out.println(content);

out.flush();

if(content.equals("-101")){

System.out.println("Connection Terminated");

socket.close();

System.exit(0);

}

}

catch(Exception e){

e.printStackTrace();

System.exit(1);

}

}

};

new Thread(r2).start();

}

public static void main(String[] args){

System.out.println("Server Is Now Starting");

new Server();

}

}