2017-03-30

Java Socket Programming (Java Networking Tutorial)

Java Socket Programming using swing. instant messaging program.

Server



  2. import java.io.*;
  3. import java.net.ServerSocket;
  4. import java.net.Socket;

  6. import javax.swing.*;

  8. import java.awt.*;
  9. import java.awt.event.*;
  10. public class server extends JFrame
  11. {
  12. private JTextField userText;
  13. private JTextArea chatWindow;
  14. private ObjectOutputStream output;
  15. private ObjectInputStream input;
  16. private ServerSocket servers;
  17. private Socket connection;

  19. public server()
  20. {
  21. super("Chat Messenger");
  22. userText=new JTextField();
  23. userText.setEditable(false);
  24. userText.addActionListener(
  25. new ActionListener(){
  26. public void actionPerformed(ActionEvent event){
  27. sendMessage(event.getActionCommand());
  28. userText.setText("");
  29. }
  30. }
  31. );
  32. add(userText,BorderLayout.NORTH);
  33. chatWindow=new JTextArea();
  34. chatWindow.setEditable(false);
  35. add(new JScrollPane(chatWindow));
  36. setSize(300,150);
  37. setVisible(true);
  38. }


  41. public void startRunning()
  42. {
  43. try{
  44. servers=new ServerSocket(6789,100);
  45. while(true)
  46. {
  47. try{
  48. waitForConnection();
  49. setupStreams();
  50. whileChatting();
  51. }catch(EOFException eofException)
  52. {
  53. showMessage("\n Server Ended the connection! ");
  54. }
  55. finally
  56. {
  57. closeCrap();
  58. }

  60. }
  61. }catch(IOException ioException)
  62. {
  63. ioException.printStackTrace();
  64. }
  65. }
  66. private void waitForConnection() throws IOException
  67. {
  68. showMessage("wating for someone for connect ....\n");
  69. connection=servers.accept();
  70. showMessage("Now Connected to "+connection.getInetAddress().getHostName());
  71. }
  72. private void setupStreams()throws IOException
  73. {
  74. output=new ObjectOutputStream(connection.getOutputStream());
  75. output.flush();
  76. input=new ObjectInputStream(connection.getInputStream());
  77. showMessage("\n Streams are now setup !!\n");
  78. }

  80. private void whileChatting()throws IOException
  81. {
  82. String message="Your are Connected!!!";
  83. sendMessage(message);
  84. ableToType(true);

  86. do
  87. {
  88.        try
  89.         {
  90. message=(String)input.readObject();
  91. showMessage("\n"+message);
  92.             }
  93.        catch(ClassNotFoundException classNotFoundException)
  94.        {

  96.        }

  98. }
  99. while(!message.equals("CLIENT - END"));
  100. }

  102. private void closeCrap()
  103. {
  104. showMessage("\n Clossing Connection!!!!!!!! \n");
  105. ableToType(false);
  106. try{
  107. output.close();
  108. input.close();
  109. connection.close();
  110. }catch(IOException ioException)

  112. {
  113. ioException.printStackTrace();
  114. }
  115. }

  117. private void sendMessage(String message)
  118. {
  119. try{
  120. output.writeObject("SERVER - "+ message);
  121. output.flush();
  122. showMessage("\n SERVER - " + message);
  123. }catch(IOException ioException)
  124. {
  125. chatWindow.append("\n your can't send Message");
  126. }
  127. }

  129. private void showMessage(final String text)
  130. {
  131. SwingUtilities.invokeLater(
  132.    new Runnable()
  133. {
  134.          public void run()
  135.           {
  136.     chatWindow.append(text);
  137.           }
  138. }
  139. );
  140. }


  143. private void ableToType(final boolean tof)
  144. {
  145. SwingUtilities.invokeLater(
  146.    new Runnable()
  147. {
  148.          public void run()
  149.           {
  150.    userText.setEditable(tof);
  151.           }
  152. }
  153. );
  154. }


  157. }

ServerTest


  1. import javax.swing.JFrame;
  2. public class ServerTest {
  3. public static void main(String[] args) {
  4. server sally=new server();
  5.          sally.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  6.          sally.startRunning();
  7. }

  9. }

Client


  1. import java.io.*;
  2. import java.net.*;
  3. import java.awt.*;
  4. import java.awt.event.*;
  5. import javax.swing.*;
  6. public class Client extends JFrame{

  8. private JTextField userText;
  9. private JTextArea chatWindow;
  10. private ObjectOutputStream output;
  11. private ObjectInputStream input;
  12. private String message="";
  13. private String serverIP;
  14. private Socket connection;

  16. public Client(String host)
  17. {
  18. super("Client ");
  19. serverIP=host;
  20. userText= new JTextField();
  21. userText.setEditable(false);
  22. userText.addActionListener(new ActionListener(){
  23. public void actionPerformed(ActionEvent event)
  24. {
  25. sendMessage(event.getActionCommand());
  26. userText.setText("");
  27. }
  28. });
  29. add(userText,BorderLayout.NORTH);
  30. chatWindow=new JTextArea();
  31. chatWindow.setEditable(false);
  32. add(new JScrollPane(chatWindow),BorderLayout.CENTER);
  33. setSize(300,150);
  34. setVisible(true);
  35. }

  37. public void startRunning()
  38. {
  39. try{
  40. connectToServer();
  41. setupStreams();
  42. whileChatting();
  43. }catch(EOFException eofException)
  44. {
  45. showMessage("\n Client Treminated connection !!!!!!");
  46. }catch(IOException ioException)
  47. {
  48. ioException.printStackTrace();
  49. }finally{
  50. closeCrap();
  51. }
  52. }

  54. private void connectToServer() throws IOException
  55. {
  56. showMessage(" Attempting Connection........\n");
  57. connection=new Socket(InetAddress.getByName(serverIP),6789);
  58. showMessage("Connected to : " +  connection.getInetAddress().getHostName());
  59. }


  62. private void setupStreams() throws IOException
  63. {
  64. output=new ObjectOutputStream(connection.getOutputStream());
  65. output.flush();
  66. input=new ObjectInputStream(connection.getInputStream());
  67. showMessage("\n your Message are Now good to go !!!!!!!!! \n");
  68. }

  70. private void whileChatting() throws IOException
  71. {
  72. ableToType(true);
  73. do{
  74. try{
  75. message=(String)input.readObject();
  76. showMessage("\n " + message);
  77. }catch(ClassNotFoundException classNotFoundException)
  78. {
  79. showMessage("\n Dont know the Object type ");
  80. }

  82. }while(!message.equals("SERVER - END"));

  84. }

  86. private void closeCrap()
  87. {
  88. showMessage("\n Closing crop down");
  89. ableToType(false);
  90. try{
  91. output.close();
  92. input.close();
  93. connection.close();
  94. }catch(IOException ioException)
  95. {
  96. ioException.printStackTrace();
  97. }
  98. }


  101. private void sendMessage(String message)
  102. {
  103. try{
  104. output.writeObject("CLIENT - " + message);
  105. output.flush();
  106. showMessage("\n CLIENT - " + message);
  107. }catch(IOException ioException)
  108. {
  109. chatWindow.append("\n Something messed up sending message Host !!!!!!");
  110. }
  111. }


  114. private void showMessage(final String m)
  115. {
  116. SwingUtilities.invokeLater(
  117. new Runnable(){
  118. public void run()
  119. {
  120. chatWindow.append(m);
  121. }
  122. });
  123. }
  124. private void ableToType(final boolean tof)
  125. {
  126. SwingUtilities.invokeLater(
  127. new Runnable(){
  128. public void run()
  129. {
  130. userText.setEditable(tof);
  131. }
  132. });
  133. }





  139. }

ClientTest


  1. import javax.swing.JFrame;
  2. public class ClientTest {
  3. public static void main(String[] args) {
  4. Client charlie;
  5. charlie=new Client("192.168.1.6");
  6. charlie.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  7. charlie.startRunning();

  9. }

  11. }


Posted by on
Labels: ,

6 comments:

  1. Ritesh3/30/2017 04:08:00 pm

    package server.app;

    import java.io.*;
    import java.net.*;
    import java.awt.*;
    import java.awt.event.*;
    import javax.swing.*;
    public class Client extends JFrame{


    private static final long serialVersionUID = 1L;
    private JTextField userText;
    private JTextArea chatWindow;
    private ObjectOutputStream output;
    private ObjectInputStream input;
    private String message="";
    private String serverIP;
    private Socket connection;

    public Client(String host) throws Exception
    {
    super("Client ");
    serverIP=host;

    String userid = (String)JOptionPane.showInputDialog("Enter ID");
    connectToServer();
    setupStreams();
    output.writeObject(userid);
    message=(String)input.readObject();
    if(message=="reject" || message.equalsIgnoreCase("reject")){
    closeCrap();
    }

    userText= new JTextField();
    userText.setEditable(false);
    userText.addActionListener(new ActionListener(){
    public void actionPerformed(ActionEvent event)
    {
    sendMessage(event.getActionCommand());
    userText.setText("");
    }
    });
    add(userText,BorderLayout.NORTH);
    chatWindow=new JTextArea();
    chatWindow.setEditable(false);
    add(new JScrollPane(chatWindow),BorderLayout.CENTER);
    setSize(300,150);
    setVisible(true);
    }

    public void startRunning()
    {
    try{
    //connectToServer();
    //setupStreams();
    whileChatting();
    }catch(EOFException eofException)
    {
    showMessage("\n Client Treminated connection !!!!!!");
    }catch(IOException ioException)
    {
    ioException.printStackTrace();
    }finally{
    closeCrap();
    }
    }

    private void connectToServer() throws IOException
    {
    showMessage(" Attempting Connection........\n");
    connection=new Socket(InetAddress.getByName(serverIP),8001);
    showMessage("Connected to : " + connection.getInetAddress().getHostName());
    }


    private void setupStreams() throws IOException
    {
    output=new ObjectOutputStream(connection.getOutputStream());
    output.flush();
    input=new ObjectInputStream(connection.getInputStream());
    showMessage("\n your Message are Now good to go !!!!!!!!! \n");
    }

    private void whileChatting() throws IOException
    {
    ableToType(true);
    do{
    try{
    message=(String)input.readObject();
    showMessage("\n " + message);
    }catch(ClassNotFoundException classNotFoundException)
    {
    showMessage("\n Dont know the Object type ");
    }

    }while(!message.equals("SERVER - END"));

    }

    private void closeCrap()
    {
    showMessage("\n Closing crop down");
    ableToType(false);
    try{
    output.close();
    input.close();
    connection.close();
    }catch(IOException ioException)
    {
    ioException.printStackTrace();
    }
    }


    private void sendMessage(String message)
    {
    try{
    output.writeObject("CLIENT - " + message);
    output.flush();
    showMessage("\n CLIENT - " + message);
    }catch(IOException ioException)
    {
    chatWindow.append("\n Something messed up sending message Host !!!!!!");
    }
    }


    private void showMessage(final String m)
    {
    SwingUtilities.invokeLater(
    new Runnable(){
    public void run()
    {
    chatWindow.append(m);
    }
    });
    }
    private void ableToType(final boolean tof)
    {
    SwingUtilities.invokeLater(
    new Runnable(){
    public void run()
    {
    userText.setEditable(tof);
    }
    });
    }





    }


    package server.app;

    import javax.swing.JFrame;
    public class ClientTest {
    public static void main(String[] args) throws Exception {
    Client charlie;
    charlie=new Client("localhost");
    charlie.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    charlie.startRunning();

    }

    }

    ReplyDelete
  2. Anonymous4/03/2017 01:00:00 am

    import java.awt.BorderLayout;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;

    import javax.swing.JFrame;
    import javax.swing.JOptionPane;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;

    public class Client {

    public static Socket socket;
    public static String ip = "192.168.137.71";
    public static int port = 8005;
    public static ObjectOutputStream oos;

    public static void main(String[] args) {
    String username = JOptionPane.showInputDialog(null, "IP: " + ip + ":" + port);
    System.out.println(username);
    JTextArea chatWindow;
    JTextField userText;
    try {
    socket = new Socket(ip, port);
    oos = new ObjectOutputStream(socket.getOutputStream());
    oos.writeObject(username);

    ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
    String response = (String) ois.readObject();
    JFrame frame = new JFrame("Client");
    frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    frame.setVisible(true);
    userText = new JTextField();
    userText.setEditable(false);
    userText.addActionListener(new ActionListener() {
    public void actionPerformed(ActionEvent event) {
    sendMessage(event.getActionCommand());
    userText.setText("");
    }
    });
    ;

    frame.add(userText, BorderLayout.NORTH);
    chatWindow = new JTextArea();
    chatWindow.setEditable(false);
    frame.add(new JScrollPane(chatWindow));
    frame.setSize(300, 150);
    if (response.equalsIgnoreCase("1")) {
    chatWindow.append("connected......");
    userText.setEditable(true);
    do {
    try {
    response = (String) ois.readObject();
    chatWindow.append("\n " + response);
    } catch (ClassNotFoundException classNotFoundException) {
    chatWindow.append("\n Dont know the Object type ");
    chatWindow.append("\n connection close.. ");
    }

    } while (!response.equals(" END"));
    }
    if (response.equalsIgnoreCase("0")) {
    chatWindow.append("\n refused , not authorised....");
    }
    if (response.equalsIgnoreCase("2")) {
    JOptionPane.showMessageDialog(null, "already connected");
    }


    } catch (UnknownHostException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    } catch (IOException e) {
    // TODO Auto-generated catch block
    System.out.println("dis");
    //chatWindow.append("Diss");
    //userText.setEditable(false);
    //e.printStackTrace();
    } catch (ClassNotFoundException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    }

    public static void sendMessage(String message) {
    try {
    oos.writeObject(message);
    } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    }

    }

    ReplyDelete
  3. Anonymous4/03/2017 01:03:00 am

    import java.awt.BorderLayout;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.net.InetAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.net.UnknownHostException;
    import java.util.ArrayList;

    import javax.swing.DefaultListModel;
    import javax.swing.JFrame;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;

    public class Server {
    public static ServerSocket server;
    public static ArrayList list_sockets = new ArrayList();
    public static ArrayList list_client_status = new ArrayList();
    public static ArrayList list_data = new ArrayList();
    public static DefaultListModel list_client_model;
    public static ArrayList list_user = new ArrayList();
    public static ArrayList list_verify = new ArrayList();
    public static String ip = "";
    public static int port = 8005;
    public static ObjectOutputStream oos ;

    public static void main(String[] args) {
    list_verify.add("101");
    list_verify.add("102");
    list_verify.add("103");
    list_verify.add("104");
    list_verify.add("105");

    try {
    ip = InetAddress.getLocalHost().getHostAddress() + ":" + port;
    try {
    server = new ServerSocket(port, 0, InetAddress.getLocalHost());
    System.out.println("Server running in :"+ InetAddress.getLocalHost() +":"+port);
    new Thread(accept).start();
    } catch (IOException e) {
    e.printStackTrace();
    }

    } catch (UnknownHostException e) {
    e.printStackTrace();
    }
    }
    private static Runnable accept = new Runnable() {
    @Override
    public void run() {
    new Thread(send).start();
    new Thread(receive).start();

    while (true) {
    JTextArea chatWindow ;
    JTextField userText ;
    try {

    Socket socket = server.accept();
    ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
    String username = (String) ois.readObject();
    oos = new ObjectOutputStream(socket.getOutputStream());

    ReplyDelete
  4. Anonymous4/03/2017 01:04:00 am


    if(list_verify.contains(username)){
    if(!list_user.contains(username)){
    list_user.add(username);
    oos.writeObject("1");
    System.out.println("connected to : "+username);
    JFrame frame = new JFrame("Server");
    frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    frame.setVisible(true);
    userText = new JTextField();
    userText.setEditable(false);
    userText.addActionListener(new ActionListener() {
    public void actionPerformed(ActionEvent event) {
    sendMessage(event.getActionCommand());
    userText.setText("");
    }
    });
    ;

    frame.add(userText, BorderLayout.NORTH);
    chatWindow = new JTextArea();
    chatWindow.setEditable(false);
    frame.add(new JScrollPane(chatWindow));
    frame.setSize(300, 150);
    chatWindow.append("connected to : "+ username);
    userText.setEditable(true);

    do {
    try {
    username = (String) ois.readObject();
    chatWindow.append("\n " + username);
    } catch (ClassNotFoundException classNotFoundException) {
    chatWindow.append("\n Dont know the Object type ");
    chatWindow.append("\n connection close.. ");
    }

    } while (!username.equals(" END"));

    }else {
    oos.writeObject("2");
    }
    }else {
    oos.writeObject("0");
    }

    } catch (IOException e) {
    System.out.println("Diss");
    //chatWindow.append("Diss");
    //userText.setEditable(false);
    //e.printStackTrace();
    } catch (ClassNotFoundException e) {
    e.printStackTrace();
    }

    }

    }
    };
    private static Runnable send = new Runnable() {
    @Override
    public void run() {

    }
    };
    private static Runnable receive = new Runnable() {
    @Override
    public void run() {

    }
    };
    public static void sendMessage(String message) {
    try {
    oos.writeObject(message);
    } catch (IOException e) {
    e.printStackTrace();
    }
    }
    }

    ReplyDelete
  5. Ritesh4/03/2017 04:58:00 pm

    package Test;

    import java.awt.BorderLayout;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import java.io.IOException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;

    import javax.swing.JFrame;
    import javax.swing.JOptionPane;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;

    public class Client {

    public static Socket socket;
    public static String ip = "58.2.2.231";
    public static int port = 8005;


    public static void main(String[] args) {
    String username = JOptionPane.showInputDialog(null, "IP: " + ip + ":" + port);
    System.out.println(username);
    JFrame frame = new JFrame("Client");

    try {
    socket = new Socket(ip, port);
    ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
    oos.writeObject(username);

    ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
    String response = (String) ois.readObject();
    //JFrame frame = new JFrame("Client");
    frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    frame.setVisible(true);
    JTextField userText = new JTextField();
    userText.setEditable(false);
    userText.addActionListener(new ActionListener() {
    public void actionPerformed(ActionEvent event) {
    sendMessage(oos, event.getActionCommand());
    userText.setText("");
    }
    });
    ;

    frame.add(userText, BorderLayout.NORTH);
    JTextArea chatWindow = new JTextArea();
    chatWindow.setEditable(false);
    frame.add(new JScrollPane(chatWindow));
    frame.setSize(300, 150);
    if (response.equalsIgnoreCase("1")) {
    chatWindow.append("connected......");
    userText.setEditable(true);
    do {
    try {
    response = (String) ois.readObject();
    chatWindow.append("\n " + response);
    } catch (ClassNotFoundException classNotFoundException) {
    chatWindow.append("\n Dont know the Object type ");
    chatWindow.append("\n connection close.. ");
    }

    } while (!response.equals(" END"));
    }
    if (response.equalsIgnoreCase("0")) {
    chatWindow.append("\n refused , not authorised....");
    }
    if (response.equalsIgnoreCase("2")) {
    JOptionPane.showMessageDialog(null, "already connected");
    }

    } catch (UnknownHostException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    } catch (IOException e) {
    // TODO Auto-generated catch block
    System.out.println("disconnected from server");
    frame.dispose();
    // chatWindow.append("Diss");
    // userText.setEditable(false);
    // e.printStackTrace();
    } catch (ClassNotFoundException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    }

    public static void sendMessage(ObjectOutputStream oos, String message) {
    try {
    oos.writeObject(message);
    } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
    }

    }

    ReplyDelete
  6. Ritesh4/03/2017 05:42:00 pm

    58.2.2.231:8005

    ReplyDelete

Subscribe to: Post Comments (Atom)