In java write a simple 1-room chat server that is compatible with the given client code.

Question

In java write a simple 1-room chat server that is compatible with the given client code.  9 public class Client private static String addr; private static int port; private static String username; 14 private static iter> currenthriter new AtomicReference>(null); public static void main(String[] args) throws Exception [ addr -args[]; port Integer.parseInt (args[1]); username-args[21 Thread keyboardHandler new Thread(Main: handlekeyboardInput); 18 19 while (true) [ try (Socket socket -new Socket (addr, port) println(&#34; CONNECTED!; Printwriter writer new Printwriter(socket.getoutputStreamO); writer.println(username); writer.flush); currenthriter.set(writer); BufferedReader reader new BufferedReader(new InputStreamReader (socket.getinputStreamO); String line; while ((line-reader . readLine()) != null) { 31 receiveMsg(line); catch (Exception ex) [ ex.printStackTrace); Thread.sLeep(1_88); 35 36 private static void receiveMsg(String line) String[] partsline.split(&#34;:&#34;, 2); String content parts[1], String usernameparts[e]; System . out . printf(&#34;%s: %s
&#34;, username, content); 5 private static void sendMsg (String line) [ try while (true) [ try Printwriter writer currentiiriter.get(); writer println(line); writer.flush); catch (Exception ex) [ Thread.sLeep (58); 56 57 catch (InterruptedException ex) [ //This should never happern ex.printStackTrace); private static void handleKevboardInput) BufferedReader reader new BufferedReader(new InputStreamReader(System.in)); String line; while (true) [ try while ((line reader . readLine()) != null) { sendsg(line); 68 78 72 catch (Exception ex) [ ex.printStackTrace); 73 75 private static void println(Object o) 1 System.err.println(o);  9 public class Client private static String addr; private static int port; private static String username; 14 private static iter> currenthriter new AtomicReference>(null); public static void main(String[] args) throws Exception [ addr -args[]; port Integer.parseInt (args[1]); username-args[21 Thread keyboardHandler new Thread(Main: handlekeyboardInput); 18 19 while (true) [ try (Socket socket -new Socket (addr, port) println(&#34; CONNECTED!; Printwriter writer new Printwriter(socket.getoutputStreamO); writer.println(username); writer.flush); currenthriter.set(writer); BufferedReader reader new BufferedReader(new InputStreamReader (socket.getinputStreamO); String line; while ((line-reader . readLine()) != null) { 31 receiveMsg(line); catch (Exception ex) [ ex.printStackTrace); Thread.sLeep(1_88); 35 36 private static void receiveMsg(String line) String[] partsline.split(&#34;:&#34;, 2); String content parts[1], String usernameparts[e]; System . out . printf(&#34;%s: %s
&#34;, username, content); 5 private static void sendMsg (String line) [ try while (true) [ try Printwriter writer currentiiriter.get(); writer println(line); writer.flush); catch (Exception ex) [ Thread.sLeep (58); 56 57 catch (InterruptedException ex) [ //This should never happern ex.printStackTrace); private static void handleKevboardInput) BufferedReader reader new BufferedReader(new InputStreamReader(System.in)); String line; while (true) [ try while ((line reader . readLine()) != null) { sendsg(line); 68 78 72 catch (Exception ex) [ ex.printStackTrace); 73 75 private static void println(Object o) 1 System.err.println(o);

 · Answer

i have 5 steps for chat server Step 1: A simple server that will accept a single client connection and display everything the client says on the screen. If the client user types &#34;.bye&#34;, the client and the server will both quit.      Step 2: A server as before, but this time it will remain 'open' for additional connection once a client has quit. The server can handle at most one connection at a time.     Step 3: A server as before, but this time it can handle multiple clients simultaneously. The output from all connected clients will appear on the server's screen. Step 4: A server as before, but this time it sends all text received from any of the connected clients to all clients. This means that the server has to receive and send, and the client has to send as well as receive     Step 5: Wrapping the client from step 4 into a very simple GUI interface but not changing the functionality of either server or client.The client is implemented as an Applet, but a Frame would have worked just as well (for a stand-alone program).    Step 1: Simple, one-time Server import java.net.*; import java.io.*;  public class ChatServer {  private Socket          socket   = null;    private ServerSocket    server   = null;    private DataInputStream streamIn =  null;     public ChatServer(int port)    {  try       {  System.out.println(&#34;Binding to port &#34; + port + &#34;, please wait  ...&#34;);          server = new ServerSocket(port);            System.out.println(&#34;Server started: &#34; + server);          System.out.println(&#34;Waiting for a client ...&#34;);           socket = server.accept();          System.out.println(&#34;Client accepted: &#34; + socket);          open();          boolean done = false;          while (!done)          {  try             {  String line = streamIn.readUTF();                System.out.println(line);                done = line.equals(&#34;.bye&#34;);             }             catch(IOException ioe)             {  done = true;             }          }          close();       }       catch(IOException ioe)       {  System.out.println(ioe);        }    }    public void open() throws IOException    {  streamIn = new DataInputStream(new BufferedInputStream(socket.getInputStream()));    }    public void close() throws IOException    {  if (socket != null)    socket.close();       if (streamIn != null)  streamIn.close();    }    public static void main(String args[])    {  ChatServer server = null;       if (args.length != 1)          System.out.println(&#34;Usage: java ChatServer port&#34;);       else          server = new ChatServer(Integer.parseInt(args[0]));    } } The Simple Client corresponding to the previous server (and to step 2 and step 3 servers as well): import java.net.*; import java.io.*;  public class ChatClient {  private Socket socket              = null;    private DataInputStream  console   = null;    private DataOutputStream streamOut = null;     public ChatClient(String serverName, int serverPort)    {  System.out.println(&#34;Establishing connection. Please wait ...&#34;);       try       {  socket = new Socket(serverName, serverPort);          System.out.println(&#34;Connected: &#34; + socket);          start();       }       catch(UnknownHostException uhe)       {  System.out.println(&#34;Host unknown: &#34; + uhe.getMessage());       }       catch(IOException ioe)       {  System.out.println(&#34;Unexpected exception: &#34; + ioe.getMessage());       }       String line = &#34;&#34;;       while (!line.equals(&#34;.bye&#34;))       {  try          {  line = console.readLine();             streamOut.writeUTF(line);             streamOut.flush();          }          catch(IOException ioe)          {  System.out.println(&#34;Sending error: &#34; + ioe.getMessage());          }       }    }    public void start() throws IOException    {  console   = new DataInputStream(System.in);       streamOut = new DataOutputStream(socket.getOutputStream());    }    public void stop()    {  try       {  if (console   != null)  console.close();          if (streamOut != null)  streamOut.close();          if (socket    != null)  socket.close();       }       catch(IOException ioe)       {  System.out.println(&#34;Error closing ...&#34;);       }    }    public static void main(String args[])    {  ChatClient client = null;       if (args.length != 2)          System.out.println(&#34;Usage: java ChatClient host port&#34;);       else          client = new ChatClient(args[0], Integer.parseInt(args[1]));    } }   Step 2: Many Time Server, One Client (Client is as before) import java.net.*; import java.io.*;  public class ChatServer implements Runnable {  private Socket       socket = null;    private ServerSocket server = null;    private Thread       thread = null;    private DataInputStream  streamIn  =  null;     public ChatServer(int port)    {  try       {  System.out.println(&#34;Binding to port &#34; + port + &#34;, please wait  ...&#34;);          server = new ServerSocket(port);            System.out.println(&#34;Server started: &#34; + server);          start();       }       catch(IOException ioe)       {  System.out.println(ioe);        }    }    public void run()    {  while (thread != null)       {   try          {  System.out.println(&#34;Waiting for a client ...&#34;);              socket = server.accept();             System.out.println(&#34;Client accepted: &#34; + socket);             open();             boolean done = false;             while (!done)             {  try                {  String line = streamIn.readUTF();                   System.out.println(line);                   done = line.equals(&#34;.bye&#34;);                }                catch(IOException ioe)                {  done = true;  }             }             close();          }          catch(IOException ie)          {  System.out.println(&#34;Acceptance Error: &#34; + ie);  }       }    }    public void start()    {  if (thread == null)       {  thread = new Thread(this);           thread.start();       }    }    public void stop()    {  if (thread != null)       {  thread.stop();           thread = null;       }    }    public void open() throws IOException    {  streamIn = new DataInputStream(new                          BufferedInputStream(socket.getInputStream()));    }    public void close() throws IOException    {  if (socket != null)    socket.close();       if (streamIn != null)  streamIn.close();    }    public static void main(String args[])    {  ChatServer server = null;       if (args.length != 1)          System.out.println(&#34;Usage: java ChatServer port&#34;);       else          server = new ChatServer(Integer.parseInt(args[0]));    } }  Step 3: Multi-Server handling Multi-Client (Client as before) import java.net.*; import java.io.*;  public class ChatServer implements Runnable {  private ServerSocket     server = null;    private Thread           thread = null;    private ChatServerThread client = null;     public ChatServer(int port)    {  try       {  System.out.println(&#34;Binding to port &#34; + port + &#34;, please wait  ...&#34;);          server = new ServerSocket(port);            System.out.println(&#34;Server started: &#34; + server);          start();       }       catch(IOException ioe)       {  System.out.println(ioe); }    }    public void run()    {  while (thread != null)       {  try          {  System.out.println(&#34;Waiting for a client ...&#34;);              addThread(server.accept());          }          catch(IOException ie)          {  System.out.println(&#34;Acceptance Error: &#34; + ie); }       }    }    public void addThread(Socket socket)    {  System.out.println(&#34;Client accepted: &#34; + socket);       client = new ChatServerThread(this, socket);       try       {  client.open();          client.start();       }       catch(IOException ioe)       {  System.out.println(&#34;Error opening thread: &#34; + ioe); }    }    public void start()                   { /* no change */ }    public void stop()                    { /* no change */ }    public static void main(String args[]){ /* no change */ } }  import java.net.*; import java.io.*;  public class ChatServerThread extends Thread {  private Socket          socket   = null;    private ChatServer      server   = null;    private int             ID       = -1;    private DataInputStream streamIn =  null;     public ChatServerThread(ChatServer _server, Socket _socket)    {  server = _server;  socket = _socket;  ID = socket.getPort();    }    public void run()    {  System.out.println(&#34;Server Thread &#34; + ID + &#34; running.&#34;);       while (true)       {  try          {  System.out.println(streamIn.readUTF());          }          catch(IOException ioe) {  }       }    }    public void open() throws IOException    {  streamIn = new DataInputStream(new BufferedInputStream(socket.getInputStream()));    }    public void close() throws IOException    {  if (socket != null)    socket.close();       if (streamIn != null)  streamIn.close();    } }    Step 4: A Simple but functional, text based chat server/client import java.net.*; import java.io.*;  public class ChatServer implements Runnable {  private ChatServerThread clients[] = new ChatServerThread[50];    private ServerSocket server = null;    private Thread       thread = null;    private int clientCount = 0;     public ChatServer(int port)    {  try       {  System.out.println(&#34;Binding to port &#34; + port + &#34;, please wait  ...&#34;);          server = new ServerSocket(port);            System.out.println(&#34;Server started: &#34; + server);          start(); }       catch(IOException ioe)       {  System.out.println(&#34;Can not bind to port &#34; + port + &#34;: &#34; + ioe.getMessage()); }    }    public void run()    {  while (thread != null)       {  try          {  System.out.println(&#34;Waiting for a client ...&#34;);              addThread(server.accept()); }          catch(IOException ioe)          {  System.out.println(&#34;Server accept error: &#34; + ioe); stop(); }       }    }    public void start()  { /* as before */ }    public void stop()   { /* as before */ }    private int findClient(int ID)    {  for (int i = 0; i < clientCount; i++)          if (clients[i].getID() == ID)             return i;       return -1;    }    public synchronized void handle(int ID, String input)    {  if (input.equals(&#34;.bye&#34;))       {  clients[findClient(ID)].send(&#34;.bye&#34;);          remove(ID); }       else          for (int i = 0; i < clientCount; i++)             clients[i].send(ID + &#34;: &#34; + input);       }    public synchronized void remove(int ID)    {  int pos = findClient(ID);       if (pos >= 0)       {  ChatServerThread toTerminate = clients[pos];          System.out.println(&#34;Removing client thread &#34; + ID + &#34; at &#34; + pos);          if (pos < clientCount-1)             for (int i = pos+1; i < clientCount; i++)                clients[i-1] = clients[i];          clientCount--;          try          {  toTerminate.close(); }          catch(IOException ioe)          {  System.out.println(&#34;Error closing thread: &#34; + ioe); }          toTerminate.stop(); }    }    private void addThread(Socket socket)    {  if (clientCount < clients.length)       {  System.out.println(&#34;Client accepted: &#34; + socket);          clients[clientCount] = new ChatServerThread(this, socket);          try          {  clients[clientCount].open();              clients[clientCount].start();               clientCount++; }          catch(IOException ioe)          {  System.out.println(&#34;Error opening thread: &#34; + ioe); } }       else          System.out.println(&#34;Client refused: maximum &#34; + clients.length + &#34; reached.&#34;);    }    public static void main(String args[]) { /* as before */ } }  import java.net.*; import java.io.*;  public class ChatServerThread extends Thread {  private ChatServer       server    = null;    private Socket           socket    = null;    private int              ID        = -1;    private DataInputStream  streamIn  =  null;    private DataOutputStream streamOut = null;     public ChatServerThread(ChatServer _server, Socket _socket)    {  super();       server = _server;       socket = _socket;       ID     = socket.getPort();    }    public void send(String msg)    {   try        {  streamOut.writeUTF(msg);           streamOut.flush();        }        catch(IOException ioe)        {  System.out.println(ID + &#34; ERROR sending: &#34; + ioe.getMessage());           server.remove(ID);           stop();        }    }    public int getID()    {  return ID;    }    public void run()    {  System.out.println(&#34;Server Thread &#34; + ID + &#34; running.&#34;);       while (true)       {  try          {  server.handle(ID, streamIn.readUTF());          }          catch(IOException ioe)          {  System.out.println(ID + &#34; ERROR reading: &#34; + ioe.getMessage());             server.remove(ID);             stop();          }       }    }    public void open() throws IOException    {  streamIn = new DataInputStream(new                          BufferedInputStream(socket.getInputStream()));       streamOut = new DataOutputStream(new                         BufferedOutputStream(socket.getOutputStream()));    }    public void close() throws IOException    {  if (socket != null)    socket.close();       if (streamIn != null)  streamIn.close();       if (streamOut != null) streamOut.close();    } }  import java.net.*; import java.io.*;  public class ChatClient implements Runnable {  private Socket socket              = null;    private Thread thread              = null;    private DataInputStream  console   = null;    private DataOutputStream streamOut = null;    private ChatClientThread client    = null;     public ChatClient(String serverName, int serverPort)    {  System.out.println(&#34;Establishing connection. Please wait ...&#34;);       try       {  socket = new Socket(serverName, serverPort);          System.out.println(&#34;Connected: &#34; + socket);          start();       }       catch(UnknownHostException uhe)       {  System.out.println(&#34;Host unknown: &#34; + uhe.getMessage()); }       catch(IOException ioe)       {  System.out.println(&#34;Unexpected exception: &#34; + ioe.getMessage()); }    }    public void run()    {  while (thread != null)       {  try          {  streamOut.writeUTF(console.readLine());             streamOut.flush();          }          catch(IOException ioe)          {  System.out.println(&#34;Sending error: &#34; + ioe.getMessage());             stop();          }       }    }    public void handle(String msg)    {  if (msg.equals(&#34;.bye&#34;))       {  System.out.println(&#34;Good bye. Press RETURN to exit ...&#34;);          stop();       }       else          System.out.println(msg);    }    public void start() throws IOException    {  console   = new DataInputStream(System.in);       streamOut = new DataOutputStream(socket.getOutputStream());       if (thread == null)       {  client = new ChatClientThread(this, socket);          thread = new Thread(this);                             thread.start();       }    }    public void stop()    {  if (thread != null)       {  thread.stop();            thread = null;       }       try       {  if (console   != null)  console.close();          if (streamOut != null)  streamOut.close();          if (socket    != null)  socket.close();       }       catch(IOException ioe)       {  System.out.println(&#34;Error closing ...&#34;); }       client.close();         client.stop();    }    public static void main(String args[])    {  ChatClient client = null;       if (args.length != 2)          System.out.println(&#34;Usage: java ChatClient host port&#34;);       else          client = new ChatClient(args[0], Integer.parseInt(args[1]));    } }  import java.net.*; import java.io.*;  public class ChatClientThread extends Thread {  private Socket           socket   = null;    private ChatClient       client   = null;    private DataInputStream  streamIn = null;     public ChatClientThread(ChatClient _client, Socket _socket)    {  client   = _client;       socket   = _socket;       open();         start();    }    public void open()    {  try       {  streamIn  = new DataInputStream(socket.getInputStream());       }       catch(IOException ioe)       {  System.out.println(&#34;Error getting input stream: &#34; + ioe);          client.stop();       }    }    public void close()    {  try       {  if (streamIn != null) streamIn.close();       }       catch(IOException ioe)       {  System.out.println(&#34;Error closing input stream: &#34; + ioe);       }    }    public void run()    {  while (true)       {  try          {  client.handle(streamIn.readUTF());          }          catch(IOException ioe)          {  System.out.println(&#34;Listening error: &#34; + ioe.getMessage());             client.stop();          }       }    } }    Stage 5: Chat client moved to very simple GUI interface import java.net.*; import java.io.*; import java.applet.*; import java.awt.*; public class ChatClient extends Applet {  private Socket socket              = null;    private DataInputStream  console   = null;    private DataOutputStream streamOut = null;    private ChatClientThread client    = null;    private TextArea  display = new TextArea();    private TextField input   = new TextField();    private Button    send    = new Button(&#34;Send&#34;), connect = new Button(&#34;Connect&#34;),                      quit    = new Button(&#34;Bye&#34;);    private String    serverName = &#34;localhost&#34;;    private int       serverPort = 4444;     public void init()    {  Panel keys = new Panel(); keys.setLayout(new GridLayout(1,2));       keys.add(quit); keys.add(connect);       Panel south = new Panel(); south.setLayout(new BorderLayout());       south.add(&#34;West&#34;, keys); south.add(&#34;Center&#34;, input);  south.add(&#34;East&#34;, send);       Label title = new Label(&#34;Simple Chat Client Applet&#34;, Label.CENTER);       title.setFont(new Font(&#34;Helvetica&#34;, Font.BOLD, 14));       setLayout(new BorderLayout());       add(&#34;North&#34;, title); add(&#34;Center&#34;, display);  add(&#34;South&#34;,  south);       quit.disable(); send.disable(); getParameters(); }    public boolean action(Event e, Object o)    {  if (e.target == quit)       {  input.setText(&#34;.bye&#34;);          send();  quit.disable(); send.disable(); connect.enable(); }       else if (e.target == connect)       {  connect(serverName, serverPort); }       else if (e.target == send)       {  send(); input.requestFocus(); }       return true; }    public void connect(String serverName, int serverPort)    {  println(&#34;Establishing connection. Please wait ...&#34;);       try       {  socket = new Socket(serverName, serverPort);          println(&#34;Connected: &#34; + socket);          open(); send.enable(); connect.disable(); quit.enable(); }       catch(UnknownHostException uhe)       {  println(&#34;Host unknown: &#34; + uhe.getMessage()); }       catch(IOException ioe)       {  println(&#34;Unexpected exception: &#34; + ioe.getMessage()); } }    private void send()    {  try       {  streamOut.writeUTF(input.getText()); streamOut.flush(); input.setText(&#34;&#34;); }       catch(IOException ioe)       {  println(&#34;Sending error: &#34; + ioe.getMessage()); close(); } }    public void handle(String msg)    {  if (msg.equals(&#34;.bye&#34;))       {  println(&#34;Good bye.Press RETURN to exit ...&#34;);  close(); }       else println(msg); }    public void open()    {  try       {  streamOut = new DataOutputStream(socket.getOutputStream());          client = new ChatClientThread(this, socket); }       catch(IOException ioe)       {  println(&#34;Error opening output stream: &#34; + ioe); } }    public void close()    {  try       {  if (streamOut != null)  streamOut.close();          if (socket    != null)  socket.close(); }       catch(IOException ioe)       {  println(&#34;Error closing ...&#34;); }       client.close();  client.stop(); }    private void println(String msg)    {  display.appendText(msg + &#34;
&#34;); }    public void getParameters()    {  serverName = getParameter(&#34;host&#34;);       serverPort = Integer.parseInt(getParameter(&#34;port&#34;)); } }We were unable to transcribe this imageWe were unable to transcribe this imageWe were unable to transcribe this imageWe were unable to transcribe this image.

In java write a simple 1-room chat server that is compatible with the given client code.

Question:

Answers

Similar Solved Questions

The loading on the bookshelif is distributed as shown. Determine the magnitude of the equivalent resultant...

When placed 1.14 m apart, the force each exerts on the other is 11.8 N and...

田 ntegral Calculator McDonald's t; New d'opbox Robin Cheg a 758) Mr. Raja(2018: D pertect Romeo...

Suppose Stuart Company has the following results related to cash flows for 2018: Net Income of...

Introduction to healthcare management third edition Sharon B Buchbinder Why is it important to develop multiple...

3. Award: 30.00 points “Blast it!” said David Wilson, president of Teledex Company. “We’ve just lost...

Doxazosin is an antihypertensive drug of the alpha-1 adrenergic blocker type. If a patient is taking...

Study the nucleotide sequences of wild type and its mutant gene Wild type: GAACCATG Mutant: GAACATG...

Describe the government’s involvement in EHRs( electronic health record)

John, a 30-year-old male, married and the father of a two-year-old daughter, is diagnosed as brain...

-0.0001211 Use the model (t)-20e for radiocarbon dating to answer the question. A sample from a...

Please let me know the best answer to this Previous Page Next Page Page 10 of...

5.80 is not the answer i dont kmow why, it shows is wrong any help why??...

How do you solve #log_2(x+2) + log_2(x+6)=5#?

You are considering the risk-return profile of two mutual funds for invastment. The relatively risky fund...

"we basically know nothing about how life on Earth originated from 3.5 billion years ago" assume...

2,3, 6, 7 1. Without matrices, solve the following system using the Gaussian elimination method +...