Java - Socket Programming (Server)

By -

Coding Socket Programing Dibagi Menjadi 2 bagian Aplikasi ( Program)
Yang pertama Server
Ini Codingnya:


/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

package chatapp;

import java.io.*;
import java.net.*;
import java.util.*;
/**
 *
 * @author Moch. Afif
 */
public class Chatapp {

    private static int uniqueId;
    private ArrayList<Chatapp.ClientThread> clients;
    private int port;
    private boolean keepGoing;
    public Chatapp() {
        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;
                }
                Chatapp.ClientThread t = new Chatapp.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) {
                    Chatapp.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;) {
            Chatapp.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) {
            Chatapp.ClientThread ct = clients.get(i);
            if (ct.id == id) {
                clients.remove(i);
                return;
            }
        }
    }
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        // TODO code application logic here
        
        Chatapp server = new Chatapp();
        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;
        }
    }
}


Comments

Post a Comment

Popular posts from this blog

VB.NET - Membuat Angka Acak

By -
Image
Membuat angka acak dengan Vb.Net, dengan menggunakan rumus random yang ada di visual basic. Khusus untuk XI TKJ SMK Hasyim Asy'ari. Pembuatan anka acak ini bisa diterapkan di beberapa versi VB. berikut langkah langkah membuat sebuah angka acak pada Vb.Net. 1. Buat lah sebuah label dan sebuah button, label untuk menampilkan angka sedangkan butoon untuk mengeksekusi coding. lihat gambar dibawah. 2. Klik dua kali di Button untuk memasukan kode. dan masuka kode seperti dibawah ini. 3. Kemudian jalankan dan hasilnya seerti gambar berikut 4. Kemudian klik acak maka akan muncul angka secara acak tak lebih dari 100 Demikian cara membuat program untuk mengacak angka, dimana nilai 100 merupakan nilai batasan yang berarti program akan mnampilkan angka secara acak mulai 1 sampai 100. Semoga bisa dimengerti dengan jelas. " Jika ada niat, maka tiada yang tidak bisa"
Next »

Kenapa dinamai windows?

By -
Image
Sejarah dari wikipedia - Versi pertama Microsoft Windows, yang disebut dengan Windows 1.0, dirilis pada tanggal  20 November 1985 . Versi ini memiliki banyak kekurangan dalam beberapa fungsionalitas, sehingga kurang populer di pasaran. Pada awalnya Windows versi 1.0 ini hendak dinamakan dengan  Interface Manager , akan tetapi  Rowland Hanson , kepala bagian pemasaran di  Microsoft Corporation , meyakinkan para petinggi Microsoft bahwa nama " Windows " akan lebih "memikat" konsumen. Windows 1.0 bukanlah sebuah sistem operasi yang lengkap, tapi hanya memperluas kemampuan MS-DOS  dengan tambahan antarmuka grafis. Selain itu, Windows 1.0 juga memiliki masalah dan kelemahan yang sama yang dimiliki oleh  MS-DOS . Lebih jauh lagi,  Apple  yang menuntut Microsoft,sehingga Microsoft membatasi feature yang ada di operating systemnya. Sebagai contoh, jendela-jendela di dalam Windows 1.0 hanya dapat ditampilkan di layar secara " tile " saja, sehingga jendela ters
Next »

Konversi Desimal ke Biner Menggunakan Stack - Java

By -
Image
Buatlah New Projrct dengan cara klik file -> new projrct , pilih java application. beri nama project kemudian masukan kode dibawa ini: /*  * To change this template, choose Tools | Templates  * and open the template in the editor.  */ package biner; import java.util.Scanner; /**  *  * @author Moch. Afif  */ public class Biner {     /**      * @param args the command line arguments      */     public static void main(String[] args) {         // TODO code application logic here         System.out.println("Program konversi ke biner dari desimal");         Scanner msk =new Scanner(System.in);         System.out.print("Masukan Nilai Desimal :");         int bil = msk.nextInt();         tumpukan bn=new tumpukan(10);         int n=bil;         while (bil>0){             n=bil%2;                         if (n>0){                 bn.push(1);             }else                 bn.push(0);                         bil=bil/2;    
Next »