Chatting dengan Menampilkan Foto Menggunakan Program Java

Sama dengan program chatting sebelumnya, hanya saja pada program chatting ini pada saat menjalankan chatting maka akan ada tampilan fotonya.

Program pada server :
import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {

    private static int uniqueId;
    private ArrayList<ChatServer.ClientThread> clients;
    private int port;
    private boolean keepGoing;

    public ChatServer() {
        this.port = 9999;
        clients = new ArrayList();
    }

    public void start() {
        keepGoing = true;
        try {
            ServerSocket serverSocket = new ServerSocket(port);
            while (keepGoing) {
                System.out.println("ChatServer waiting for Clients on port " + port + ".");
                Socket socket = serverSocket.accept();
                if (!keepGoing) {
                    break;
                }
                ChatServer.ClientThread t = new ChatServer.ClientThread(socket);
                clients.add(t);
                t.start();
                send("login~" + t.username + "~" + t.username + " sedang login...~Server~\n");
            }
            try {
                serverSocket.close();
                for (int i = 0; i < clients.size(); ++i) {
                    ChatServer.ClientThread tc = clients.get(i);
                    try {
                        tc.sInput.close();
                        tc.sOutput.close();
                        tc.socket.close();
                    } catch (IOException ioE) {
                    }
                }
            } catch (Exception e) {
                System.out.println("Exception closing the server and clients: " + e);
            }
        } catch (IOException e) {
            String msg = "Exception on new ServerSocket: " + e + "\n";
            System.out.println(msg);
        }
    }

    private synchronized void send(String message) {
        for (int i = clients.size(); --i >= 0;) {
            ChatServer.ClientThread ct = clients.get(i);
            if (!ct.writeMsg(message)) {
                clients.remove(i);
                System.out.println("Disconnected Client " + ct.username + " removed from list.");
            }
        }
    }

    private String getClients() {
        String s = "";
        for (ClientThread clientThread : clients) {
            s += clientThread.username + ":";
        }
        s += "---";
        System.out.println(s);
        return s;
    }

    private synchronized void remove(int id) {
        for (int i = 0; i < clients.size(); ++i) {
            ChatServer.ClientThread ct = clients.get(i);
            if (ct.id == id) {
                clients.remove(i);
                return;
            }
        }
    }

    public static void main(String[] args) {
        ChatServer server = new ChatServer();
        server.start();
    }

    private class ClientThread extends Thread {

        private Socket socket;
        private ObjectInputStream sInput;
        private ObjectOutputStream sOutput;
        private int id;
        private String username;

        public ClientThread(Socket socket) {
            id = ++uniqueId;
            this.socket = socket;
            System.out.println("Menciptakan Object Input/Output Streams");
            try {
                sOutput = new ObjectOutputStream(socket.getOutputStream());
                sInput = new ObjectInputStream(socket.getInputStream());
                String message = (String) sInput.readObject();
                username = message.split("~")[1];
                System.out.println(username + " masuk.");
            } catch (IOException e) {
                System.out.println("Exception creating new Input/output Streams: " + e);
            } catch (ClassNotFoundException e) {
            }
        }

        @Override
        public void run() {
            boolean keepGoing = true;
            while (keepGoing) {

                String message;
                try {
                    message = sInput.readObject().toString();
                } catch (IOException e) {
                    System.out.println(username + " Exception reading Streams: " + e);
                    break;
                } catch (ClassNotFoundException e2) {
                    break;
                }

                String type = message.split("~")[0];
                String pengirim = message.split("~")[1];
                String text = message.split("~")[2];
                String kepada = message.split("~")[3];
                String response;

                switch (type) {
                    case "postText":
                        response = "recieveText~" + pengirim + "~" + text + "~" + kepada + "~\n";
                        send(response);
                        break;
                    case "postPrivateText":
                        response = "recievePrivateText~" + pengirim + "~" + text + "~" + kepada + "~\n";
                        send(response);
                        break;
                    case "login":
                        response = "login~" + pengirim + "~" + text + "~" + kepada + "~\n";
                        send(response);
                        break;
                    case "logout":
                        response = "logout~" + pengirim + "~" + text + "~" + kepada + "~\n";
                        send(response);
                        break;
                    case "list":
                        response = "list~server~" + getClients() + "~ ~ ~ ~ ~\n";
                        send(response);
                        break;
                }
            }

            remove(id);
            close();
        }

        private void close() {
            try {
                if (sOutput != null) {
                    sOutput.close();
                }
            } catch (Exception e) {
            }
            try {
                if (sInput != null) {
                    sInput.close();
                }
            } catch (Exception e) {
            }
            try {
                if (socket != null) {
                    socket.close();
                }
            } catch (Exception e) {
            }
        }

        private boolean writeMsg(String msg) {
            if (!socket.isConnected()) {
                close();
                return false;
            }
            try {
                sOutput.writeObject(msg);
            } catch (IOException e) {
                System.out.println("Error sending message to " + username);
                System.out.println(e.toString());
            }
            return true;
        }
    }
}

Hasil dari program server di atas adalah :

Program pada client :
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.ImageIcon;
import javax.swing.JLabel;
import javax.swing.table.DefaultTableModel;

public class ChatClient extends javax.swing.JFrame {

    /**
     * Creates new form ChatClient
     */
    private ObjectInputStream input;
    private ObjectOutputStream output;
    private Socket socket;
    private String server, username;
    private int port;
    private List<String> clients;

    public ChatClient() {
        clients = new ArrayList();
        initComponents();

    }

    public boolean start() {
        try {
            socket = new Socket(server, port);
        } catch (Exception ec) {
            System.out.println("Error connectiong to server:" + ec);
            return false;
        }

        String msg = "Connection accepted " + socket.getInetAddress() + ":" + socket.getPort();
        System.out.println(msg);

        try {
            input = new ObjectInputStream(socket.getInputStream());
            output = new ObjectOutputStream(socket.getOutputStream());
        } catch (IOException eIO) {
            System.out.println("Exception creating new Input/output Streams: " + eIO);
            return false;
        }

        new ChatClient.ListenFromServer().start();

        try {
            output.writeObject("login~" + username + "~" + username + " sedang login...~server~\n");
            output.writeObject("list~" + username + "~" + username + " sedang login...~server~\n");

        } catch (IOException eIO) {
            System.out.println("Exception doing login : " + eIO);
            disconnect();
            return false;
        }

        return true;
    }

    private void disconnect() {
        try {
            // TODO add your handling code here:
            output.writeObject("logout~" + username + "~" + username + " sudah logout...~Server~\n");
        } catch (IOException ex) {
            //Logger.getLogger(ChatClient.class.getName()).log(Level.SEVERE, null, ex);
        }

        try {
            if (input != null) {
                input.close();
            }
        } catch (Exception e) {
        }
        try {
            if (output != null) {
                output.close();
            }
        } catch (Exception e) {
        }
        try {
            if (socket != null) {
                socket.close();
            }
        } catch (Exception e) {
        }
    }

    /**
     * This method is called from within the constructor to initialize the form.
     * WARNING: Do NOT modify this code. The content of this method is always
     * regenerated by the Form Editor.
     */
    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">
    private void initComponents() {

        jScrollPane1 = new javax.swing.JScrollPane();
        viewTextArea = new javax.swing.JTextArea();
        jScrollPane2 = new javax.swing.JScrollPane();
        clientTable = new javax.swing.JTable();
        postTextField = new javax.swing.JTextField();
        kirimButton = new javax.swing.JButton();
        lbljpg   = new javax.swing.JLabel(new ImageIcon("E:/esa.jpg"));
        jLabel2 = new javax.swing.JLabel();
        serverTextField = new javax.swing.JTextField();
        jLabel3 = new javax.swing.JLabel();
        portTextField = new javax.swing.JTextField();
        masukButton = new javax.swing.JButton();
        jLabel4 = new javax.swing.JLabel();
        usernameTextField = new javax.swing.JTextField();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);

        viewTextArea.setEditable(false);
        viewTextArea.setColumns(20);
        viewTextArea.setLineWrap(true);
        viewTextArea.setRows(5);
        viewTextArea.setFocusable(false);
        jScrollPane1.setViewportView(viewTextArea);

        jScrollPane2.setViewportView(clientTable);

        postTextField.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                postTextFieldActionPerformed(evt);
            }
        });

        kirimButton.setText("Kirim");
        kirimButton.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                kirimButtonActionPerformed(evt);
            }
        });

        jLabel2.setText("Server");

        serverTextField.setText("10.17.0.0");

        jLabel3.setText("Port");

        portTextField.setText("9999");

        masukButton.setText("Masuk");
        masukButton.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                masukButtonActionPerformed(evt);
            }
        });

        jLabel4.setText("Username");

        usernameTextField.setText("Esa");

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addGroup(layout.createSequentialGroup()
                        .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                                .addComponent(postTextField)
                                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                                .addComponent(kirimButton))
                            .addComponent(jScrollPane1))
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addComponent(jScrollPane2, javax.swing.GroupLayout.PREFERRED_SIZE, 259, javax.swing.GroupLayout.PREFERRED_SIZE))
                    .addGroup(layout.createSequentialGroup()
                        .addComponent(lbljpg)
                        .addComponent(jLabel2)
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addComponent(serverTextField, javax.swing.GroupLayout.PREFERRED_SIZE, 167, javax.swing.GroupLayout.PREFERRED_SIZE)
                        .addGap(18, 18, 18)
                        .addComponent(jLabel3)
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addComponent(portTextField, javax.swing.GroupLayout.PREFERRED_SIZE, 46, javax.swing.GroupLayout.PREFERRED_SIZE)
                        .addGap(18, 18, 18)
                        .addComponent(jLabel4)
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addComponent(usernameTextField, javax.swing.GroupLayout.DEFAULT_SIZE, 194, Short.MAX_VALUE)
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addComponent(masukButton)))
                .addContainerGap())
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.BASELINE)
                    .addComponent(lbljpg)
                    .addComponent(jLabel2)
                    .addComponent(serverTextField, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                    .addComponent(jLabel3)
                    .addComponent(portTextField, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                    .addComponent(masukButton)
                    .addComponent(jLabel4)
                    .addComponent(usernameTextField, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(jScrollPane2, javax.swing.GroupLayout.Alignment.TRAILING, javax.swing.GroupLayout.DEFAULT_SIZE, 427, Short.MAX_VALUE)
                    .addGroup(layout.createSequentialGroup()
                        .addComponent(jScrollPane1)
                        .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.RELATED)
                        .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.BASELINE)
                            .addComponent(postTextField, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                            .addComponent(kirimButton))))
                .addContainerGap())
        );

        pack();
    }// </editor-fold>

    private void masukButtonActionPerformed(java.awt.event.ActionEvent evt) {
        // TODO add your handling code here:
        this.server = serverTextField.getText();
        this.port = new Integer(portTextField.getText());
        this.username = usernameTextField.getText();
        start();
    }

    private void kirimButtonActionPerformed(java.awt.event.ActionEvent evt) {
        // TODO add your handling code here:
        try {
            String message = "postText~" + username + "~" + postTextField.getText() + "~all~\n";
            output.writeObject(message);
            postTextField.setText("");
        } catch (IOException ex) {
            Logger.getLogger(ChatClient.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    private void postTextFieldActionPerformed(java.awt.event.ActionEvent evt) {
        // TODO add your handling code here:
        kirimButtonActionPerformed(evt);
    }

    /**
     * @param args the command line arguments
     */
    public static void main(String args[]) {
                /* Set the Nimbus look and feel */
        //<editor-fold defaultstate="collapsed" desc=" Look and feel setting code (optional) ">
        /* If Nimbus (introduced in Java SE 6) is not available, stay with the default look and feel.
         * For details see http://download.oracle.com/javase/tutorial/uiswing/lookandfeel/plaf.html
         */
        try {
            for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
                if ("Nimbus".equals(info.getName())) {
                    javax.swing.UIManager.setLookAndFeel(info.getClassName());
                    break;
                }
            }
        } catch (ClassNotFoundException ex) {
            java.util.logging.Logger.getLogger(ChatClient.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (InstantiationException ex) {
            java.util.logging.Logger.getLogger(ChatClient.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (IllegalAccessException ex) {
            java.util.logging.Logger.getLogger(ChatClient.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(ChatClient.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }
        //</editor-fold>

        /* Create and display the form */
        java.awt.EventQueue.invokeLater(new Runnable() {
            @Override
            public void run() {

                new ChatClient().setVisible(true);
            }
        });
    }
    // Variables declaration - do not modify
    private javax.swing.JTable clientTable;
    private javax.swing.JLabel jLabel2;
    private javax.swing.JLabel jLabel3;
    private javax.swing.JLabel jLabel4;
    private javax.swing.JScrollPane jScrollPane1;
    private javax.swing.JScrollPane jScrollPane2;
    private javax.swing.JButton kirimButton;
    private javax.swing.JButton masukButton;
    private javax.swing.JTextField portTextField;
    private javax.swing.JTextField postTextField;
    private javax.swing.JTextField serverTextField;
    private javax.swing.JTextField usernameTextField;
    private javax.swing.JTextArea viewTextArea;
    private JLabel lbljpg ;
    // End of variables declaration

    class ListenFromServer extends Thread {

        @Override
        public void run() {
            while (true) {
                try {
                    String msg = (String) input.readObject();
                    String res;
                    String type = msg.split("~")[0];
                    String pengirim = msg.split("~")[1];
                    String text = msg.split("~")[2];
                    String kepada = msg.split("~")[3];
                    switch (type) {
                        case "recieveText":
                            res = pengirim + ": " + text;
                            viewTextArea.setText(viewTextArea.getText() + res + "\n");
                            break;
                        case "recievePrivateText":
                            res = pengirim + ": " + text;
                            if (kepada.equals(username)) {
                                viewTextArea.setText(viewTextArea.getText() + res + "\n");
                            }
                            break;
                        case "login":
                            viewTextArea.setText(viewTextArea.getText() + pengirim + " sudah login..." + "\n");
                            clients.add(pengirim);
                            break;
                        case "logout":
                            viewTextArea.setText(viewTextArea.getText() + pengirim + " telah logout..." + "\n");
                            clients.remove(pengirim);
                            break;
                        case "list":
                            setTable(text);
                            break;
                    }
                } catch (IOException e) {
                    System.out.println("Server has close the connection: " + e);
                    break;
                } catch (ClassNotFoundException e2) {
                }
            }
        }

        private void setTable(String text) {
            int rows = text.split(":").length - 1;
            Object[][] data = new Object[rows][1];
            for (int i = 0; i < rows; i++) {
                String t = text.split(":")[i];
                data[i][0] = t;
            }

            String[] header = {"Clients"};

            clientTable.setModel(new DefaultTableModel(data, header));

        }
    }
}

Hasil dari program client di atas seperti gambar di bawah ini :

Program ini sedikit berbeda dengan program chatting sebelumnya, untuk memperjelas silahkan 

Download di sini

Multi Thread Chat Server dan Client

Multi thread chat server dan client ialah  program yang dapat melakukan chatting lebih dari satu komputer. Dalam pelajaran ini akan melakukan percobaan multi thread chat server dan client menggunakan bahasa java. Pertama jalankan telebih dahulu program server jika sudah berhasil maka jalankan program client, pada program client samakan terlebih dahulu IP dengan server. Jika sudah sama maka kita dapat terhubung dengan semua komputer yang terhubung dengan server.

Program Multi Thread Chat Server :

import java.io.DataInputStream;

import java.io.PrintStream;

import java.io.IOException;

import java.net.Socket;

import java.net.ServerSocket;

/*

 * chat server yang mengantar pesan publik dan private.

 */

public class MultiThreadChatServer {

  // server socket.

  private static ServerSocket serverSocket = null;

  // client socket.

  private static Socket clientSocket = null;

  // chat server dapat menerima sampai maxClientsCount pada koneksi client.

  private static final int maxClientsCount = 10;

  private static final clientThread[] threads = new clientThread[maxClientsCount];

  public static void main(String args[]) {

    // default port number.

    int portNumber = 2222;

    if (args.length < 1) {

      System.out

          .println("Usage: java MultiThreadChatServer <portNumber>\n"

              + "Now using port number=" + portNumber);

    } else {

      portNumber = Integer.valueOf(args[0]).intValue();

    }

    /*

     * buka server socket pada portNumber (default 2222). catatan:kita tidak da

     * pat memilih port dibawah 1023 jika kita bukan administrator (root).

     */

    try {

      serverSocket = new ServerSocket(portNumber);

    } catch (IOException e) {

      System.out.println(e);

    }

    /*

     * buat client socket untuk setiap koneksi dan sesuaikan dengan thread 

     * client baru.

     */

    while (true) {

      try {

        clientSocket = serverSocket.accept();

        int i = 0;

        for (i = 0; i < maxClientsCount; i++) {

          if (threads[i] == null) {

            (threads[i] = new clientThread(clientSocket, threads)).start();

            break;

          }

        }

        if (i == maxClientsCount) {

          PrintStream os = new PrintStream(clientSocket.getOutputStream());

          os.println("Server too busy. Try later.");

          os.close();

          clientSocket.close();

        }

      } catch (IOException e) {

        System.out.println(e);

      }

    }

  }

}

/*

 * Thread chat client . thread client ini membuka input dan output

 * streams untuk hubungan client, menanyakan nama client,menginformasikan semua

 * client yang terhubung ke server bahwa ada client baru yang terhubung ke da-

 * lam chatroom, selama data diterima, data di kembalikan ke semua

 * client. saat client meninggalkan chatroom thread ini juga menginformasikan

 * pada client lainnya.

 */

class clientThread extends Thread {

  private DataInputStream is = null;

  private PrintStream os = null;

  private Socket clientSocket = null;

  private final clientThread[] threads;

  private int maxClientsCount;

  public clientThread(Socket clientSocket, clientThread[] threads) {

    this.clientSocket = clientSocket;

    this.threads = threads;

    maxClientsCount = threads.length;

  }

  public void run() {

    int maxClientsCount = this.maxClientsCount;

    clientThread[] threads = this.threads;

    try {

      /*

       * membuat input dan output streams  untuk client.

       */

      is = new DataInputStream(clientSocket.getInputStream());

      os = new PrintStream(clientSocket.getOutputStream());

      os.println("Enter your name.");

      String name = is.readLine().trim();

      os.println("Hello " + name

          + " to our chat room.\nTo leave enter /quit in a new line");

      for (int i = 0; i < maxClientsCount; i++) {

        if (threads[i] != null && threads[i] != this) {

          threads[i].os.println("*** A new user " + name

              + " entered the chat room !!! ***");

        }

      }

      while (true) {

        String line = is.readLine();

        if (line.startsWith("/quit")) {

          break;

        }

        for (int i = 0; i < maxClientsCount; i++) {

          if (threads[i] != null) {

            threads[i].os.println("<" + name + "&gr; " + line);

          }

        }

      }

      for (int i = 0; i < maxClientsCount; i++) {

        if (threads[i] != null && threads[i] != this) {

          threads[i].os.println("*** The user " + name

              + " is leaving the chat room !!! ***");

        }

      }

      os.println("*** Bye " + name + " ***");

      /*

       * buat variabel thread terakhir menjadi null agar client baru

       * dapat diterima oleh server.

       */

      for (int i = 0; i < maxClientsCount; i++) {

        if (threads[i] == this) {

          threads[i] = null;

        }

      }

      /*

       * tutup output stream, tutup input stream, tutup socket.

       */

      is.close();

      os.close();

      clientSocket.close();

    } catch (IOException e) {

    }

  }

}

Hasil dari program sever di atas adalah :

Program Multi Thread Chat Client :

import java.io.DataInputStream;

import java.io.PrintStream;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

public class MultiThreadChatClient implements Runnable {

  //  client socket

  private static Socket clientSocket = null;

  //  output stream

  private static PrintStream os = null;

  //  input stream

  private static DataInputStream is = null;

  private static BufferedReader inputLine = null;

  private static boolean closed = false;

  public static void main(String[] args) {

    //  default port.

    int portNumber = 2222;

    //  default host.

    String host = "192.168.1.1";

    if (args.length < 2) {

      System.out

          .println("Usage: java MultiThreadChatClient <host> <portNumber>\n"

              + "Now using host=" + host + ", portNumber=" + portNumber);

    } else {

      host = args[0];

      portNumber = Integer.valueOf(args[1]).intValue();

    }

    /*

     * Buka sebuah socket pada host dan port. Buka input dan output streams.

     */

    try {

      clientSocket = new Socket(host, portNumber);

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

      os = new PrintStream(clientSocket.getOutputStream());

      is = new DataInputStream(clientSocket.getInputStream());

    } catch (UnknownHostException e) {

      System.err.println("Don't know about host " + host);

    } catch (IOException e) {

      System.err.println("Couldn't get I/O for the connection to the host "

          + host);

    }

    /*

     * Jika semua telah diinisialisasi lalu kita ingin menulis data pada socket yang kita buka pada koneksi port number.

     */

    if (clientSocket != null && os != null && is != null) {

      try {

        /* Buat sebuah thread untuk membaca dari server. */

        new Thread(new MultiThreadChatClient()).start();

        while (!closed) {

          os.println(inputLine.readLine().trim());

        }

        /*

         * tutup output stream, tutup input stream, tutup socket.

         */

        os.close();

        is.close();

        clientSocket.close();

      } catch (IOException e) {

        System.err.println("IOException:  " + e);

      }

    }

  }

  /*

   * buat sebuah thread untuk membaca dari server.

   */

  public void run() {

    /*

     * tetap membaca dari socket sampai kita menerima "Bye" dari

     * server. setelah diterima maka break.

     */

    String responseLine;

    try {

      while ((responseLine = is.readLine()) != null) {

        System.out.println(responseLine);

        if (responseLine.indexOf("*** Bye") != -1)

          break;

      }

      closed = true;

    } catch (IOException e) {

      System.err.println("IOException:  " + e);

    }

  }

}

Hasil dari program client di atas seperti gambar di bawah ini :

                                    
Silahkan download materi di bawah ini agar lebih memudahkan untuk mempraktekkan dan memahami materi multi thread chat server dan client.

Download Di Sini

Browser

Kali ini kita akan mempraktekkan program tentang membuat program browser dari bahasa pemrograman java. Program ini akan menghubungkan langsung ke koneksi internet. 

Program Browser :

import java.io.*;

import java.awt.*;

import java.awt.event.*;

import java.net.*;

import java.util.Scanner;

public class browseresa{

public static void main

(

String[] args

)

{

try {

BufferedReader input= new BufferedReader

(

new InputStreamReader

(

System.in

)

)

;

int menu=0;

int pil;

Scanner masuk = new Scanner

(

System.in

)

; while

(

menu==0

)

{

System.out.println

("==================================")

;

System.out.println

("1.Membuka URL web *")

;

System.out.println

("2.Pencarian Google *")

;

System.out.println

("3.Pencarian Gambar di Google *")

;

System.out.println

("4.Google Translate *")

;

System.out.println

("5.Pencarian video di Youtube *")

;

System.out.println

("6.Cari Aplikasi Playstore *")

;

System.out.println

("7.Cari berita di Sriwijaya Post *")

;

System.out.println

("8.EXIT *")

;

System.out.println

("==================================")

;

System.out.println

("")

;

System.out.println

("Masukkan Pilihan :")

;

pil = masuk.nextInt

(

)

;

if

(pil < 1 || pil > 8)

{

System.out.print

("")

;

System.out.print

("")

;

System.out.println

("Input Salah!!")

;

} else if

(pil==8)

{

System.exit

(0)

;}

switch

(pil)

{

case 1:

String URL = null;

System.out.print

("Masukkan URL :")

; URL = input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

(

URL

)

)

;

break;

case 2:

String src2 = null;

System.out.print

("Masukkan Kata Pencarian :")

;

src2 = input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("https://www.google.com/search?q="+ src2)

)

;

break;

case 3:

String gmbr3 = null;

System.out.print

("Masukkan Nama Gambar :")

;

gmbr3 = input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("https://www.google.co.id/search?site=imghp&tbm=isch&source=hp&biw=1360&bih=642&q="+gmbr3)

)

;

break;

case 4:

String kata4 = null;

System.out.print

("Masukkan Kata Yang akan di terjemah : ")

;

kata4 = input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("https://translate.google.co.id/?hl=id&tab=wT#en/id/"+kata4)

)

;

break;

case 5:

String kata5 = null;

System.out.print

("Masukkan video yang dicari : ")

;

kata5 = input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("http://www.youtube.com/results?search_query="+kata5)

)

;

break;

case 6:

String kata7 = null;

System.out.print

("Masukkan aplikasi yang dicari : ")

;

kata7= input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("https://play.google.com/store/search?q="+kata7)

)

;

break;

case 7:

String kata8 = null;

System.out.print

("Masukkan berita yang dicari : ")

;

kata8= input.readLine

(

)

;

java.awt.Desktop.getDesktop

(

)

.browse

(

java.net.URI.create

("http://palembang.tribunnews.com/search/?q="+kata8)

)

;

break;

}

}

}

catch

(

Exception ex

)

{System.out.println

("Error")

;}

}}

Tampilan dari program di atas :

                           


Dari tampilan di atas kita harus memilih ini menjalankan pilihan nomor berapa. Contohnya seperti dibawah ini:
                             
Dan akan menampilkan perintah yang diinginkan, langsung terkoneksi dengan internet.
                                  
 Praktekkanlah program di bawah ini untuk lebih memahami materinya.

Baca Selengkapnya

Info Server dan Client

Pada materi kali ini kita akan mempraktekkan program server dan client. Pada program ini program server dan client harus di jalankan dan akan ada tampilan pada program client. Jika pada program server sudah dijalankan, maka hasil dari program akan mencul.

Program Sever :
import java.io.*;
import java.net.*;
import java.util.*;

public class InfoServer {
private final int INFO_PORT=50000;
private String datafromClient;

public InfoServer() {
BufferedReader inFromClient;
DataOutputStream outToClient;
Socket serverSocket;
try {

ServerSocket infoServer =
new ServerSocket(INFO_PORT);
System.out.println("Server telah siap...");

while (true){

serverSocket = infoServer.accept();
System.out.println("Ada client" +
"yang terkoneksi!");

inFromClient =
new BufferedReader(
new InputStreamReader(
serverSocket.getInputStream()));
outToClient =
new DataOutputStream(
serverSocket.getOutputStream());
outToClient.writeBytes("InfoServer versi 0.1\n"+
"hanya untuk testing..\n"+
"Silahkan berikan perintah TIME|NET|QUIT\n");

boolean isQUIT = false;
while (!isQUIT) {
datafromClient = inFromClient.readLine();
if (datafromClient.startsWith("TIME")){
outToClient.writeBytes(new
Date().toString() + "\n");
} else if (datafromClient.startsWith("NET")){
outToClient.writeBytes(
InetAddress.getByName("localhost").toString()+
"\n");
} else if (datafromClient.startsWith("QUIT"))
{
isQUIT = true;
}
}
outToClient.close();
inFromClient.close();
serverSocket.close();
System.out.println("Koneksi client tertutup..");
}
}
catch (IOException ioe) {
System.out.print("error:" + ioe);
}
catch (Exception e) {
System.out.print("error:" + e);
}
}

public static void main(String[]args) {
new InfoServer();
}
}

Hasil dari program server adalah :

Program Info Client :

import java.net.*;
import java.io.*;
import java.util.*;

public class InfoClient {
private final int INFO_PORT=50000;
private final String TargetHost = "localhost";
private final String QUIT = "QUIT";

public InfoClient() {
try {

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

Socket clientSocket = new
Socket(TargetHost, INFO_PORT);

DataOutputStream outToServer =
new DataOutputStream(
clientSocket.getOutputStream());

BufferedReader inFromServer =
new BufferedReader(
new InputStreamReader(
clientSocket.getInputStream()));

System.out.println(inFromServer.readLine());
System.out.println(inFromServer.readLine());
System.out.println(inFromServer.readLine());
System.out.println("");
boolean isQuit = false;
while (!isQuit) {

System.out.print("Perintah Anda : ");
String cmd = inFromUser.readLine();
cmd = cmd.toUpperCase();
if (cmd.equals(QUIT)) {
isQuit = true;
}
outToServer.writeBytes(cmd + "\n");
String result = inFromServer.readLine();
System.out.println("Dari Server: " + result);
}

outToServer.close();
inFromServer.close();
clientSocket.close();
}

catch (IOException ioe) {
System.out.println("Error:" + ioe);
}

catch (Exception e) {
System.out.println("Error:" + e);
}
}
public static void main(String[]args) {
new InfoClient();
}
}

Maka jalankan Client dan akan muncul tampilan seprti gambar di bawah ini.

                             

 Agar lebih memudah untuk memahami silahkan praktekkan program di bawah ini.

Baca Selengkapnya