Simple Chat Project Java

Pratyu2003 · web-flow · commit 2c7a596d1664 · 2022-10-14T18:54:03.000+05:30
diff --git a/Chat Project/Client.java b/Chat Project/Client.java
@@ -0,0 +1,90 @@
+import java.net.Socket;
+
+import java.net.*;
+import java.io.*;
+
+public class Client {
+
+Socket socket;
+
+BufferedReader br;
+PrintWriter out;
+
+
+public Client(){
+
+
+    try{
+        System.out.println("Sending request to server");
+        socket=new Socket("127.0.0.1",7777);
+    System.out.println("Connection done!!");
+
+    br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+
+    out = new PrintWriter(socket.getOutputStream());
+
+    startReading();
+    startWriting();
+
+}
+    catch(Exception e){}
+}
+
+public void startReading(){
+    Runnable r1=()->{
+      System.out.println("reader started...");
+  
+      try{ 
+      while(true){
+         
+          String msg = br.readLine();
+          if(msg.equals("EXIT")){System.out.println("Server terminated the chatting!!");
+          socket.close();
+           break;}
+  
+           System.out.println("Server : "+msg);
+      
+      
+          }
+        }catch(Exception e){System.out.print("----Connection is Closed----");}
+    };
+  
+    new Thread(r1).start();
+  }
+  
+  
+  
+  public void startWriting(){
+    Runnable r2=()->{
+      System.out.println("Writer started...");
+      
+      try{
+      while(!socket.isClosed()){
+  
+         BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));
+  
+               String content=br1.readLine();
+               out.println(content);
+               out.flush();
+
+               if(content.equals("EXIT")){
+                socket.close();
+                break;
+            }
+  
+  System.out.print("----Connection is Closed----");
+      }
+    }catch(Exception e){};
+    };
+  
+    new Thread(r2).start();
+  }
+  
+
+
+    public static void main(String[] args){
+
+        System.out.println("this is client...");
+        new Client();
+    }
+}
diff --git a/Chat Project/mclient.java b/Chat Project/mclient.java
@@ -0,0 +1,43 @@
+import java.util.*;
+import java.net.*;
+import java.io.*;
+
+public class mclient {
+
+    public static void main(String s[]) throws Exception {
+        Socket s1 = null;
+        String line = null;
+        DataInputStream br = null;
+        DataInputStream is = null;
+        PrintWriter os = null;
+        try {
+            s1 = new Socket("localhost", 9999);
+            br = new DataInputStream(System.in);
+            is = new DataInputStream(s1.getInputStream());
+            os = new PrintWriter(s1.getOutputStream());
+
+        } catch (IOException e) {
+            System.err.print("IO Exception");
+
+        }
+        System.out.println("Enter data to server (enter QUIT to end) :-> "+s1.getRemoteSocketAddress().toString());
+        String res = null;
+        try {
+            line = br.readLine();
+            while (line.compareTo("QUIT") != 0) {
+                os.println(line);
+                os.flush();
+                res = is.readLine();
+                System.out.println("server response :-> " + res);
+                line = br.readLine();
+            }
+            is.close();
+            os.close();
+            br.close();
+            s1.close();
+            System.out.println("close connection ");
+        } catch (IOException e) {
+            System.out.println("socket read error");
+        }
+    }
+}
diff --git a/Chat Project/mserver.java b/Chat Project/mserver.java
@@ -0,0 +1,63 @@
+import java.util.*;
+import java.net.*;
+import java.io.*;
+
+public class mserver {
+
+    public static void main(String s[]) throws Exception {
+        Socket sa = null;
+        ServerSocket ss2 = null;
+        System.out.println("Host starts accepting response ");
+        try {
+            ss2 = new ServerSocket(9999);
+        } catch (IOException e) {
+            System.out.println("server error");
+        }
+        while (true) {
+            try {
+                sa = ss2.accept();
+                System.out.println("connetion established by"+ ss2.getInetAddress());
+                ServerThread st = new ServerThread(sa);
+                st.start();
+            } catch (Exception e) {
+                System.out.println("connetion error");
+            }
+        }
+    }
+}
+
+class ServerThread extends Thread {
+    String line = null;
+    DataInputStream is = null;
+    PrintWriter od = null;
+    Socket s1 = null;
+
+    public ServerThread(Socket s) {
+        s1 = s;
+    }
++
+    public void run() {
+        try {
+
+            is = new DataInputStream(s1.getInputStream());
+            od = new PrintWriter(s1.getOutputStream());
+
+            line = is.readLine();
+
+            while (!line.equals("QUIT")) {
+                od.println(line);
+                od.flush();
+
+                System.out.println("response to client " + line);
+                line = is.readLine();
+
+            }
+            is.close();
+            od.close();
+            s1.close();
+
+        } catch (IOException ie) {
+            System.out.println("socket close error");
+        }
+    }
+}
