java | My Life Note

Hai Sobat Blogger Sekalian. AKFive kali ini akan share program client-server sederhana menggunakan Socket pada JAVA.

Berikut ini source code programnya :

1. Source Code untuk server.java

/*
 * SERVER
 */
package SocketExample;
 
/**
 *
 * @author aida
 */
import java.net.Socket;
import java.net.ServerSocket;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.IOException;
 
 
public class VerySimpleServer {
    private int serverPort = 0;
    private ServerSocket serverSock = null;
 
    public VerySimpleServer(int serverPort) {
        this.serverPort = serverPort;
 
        try {
            serverSock = new ServerSocket(serverPort);
        }
        catch (IOException e){
            e.printStackTrace(System.err);
        }
    }

public void handleConnection(InputStream sockInput, OutputStream sockOutput) {
        while(true) {
            byte[] buf=new byte[1024];
            int bytes_read = 0;
            try {
              
                bytes_read = sockInput.read(buf, 0, buf.length);
           
                if(bytes_read < 0) {
                    System.err.println("Tried to read from socket, read() returned < 0,  Closing socket.");
                    return;
                }
                System.err.println("Received "+bytes_read
                                   +" bytes, sending them back to client, data="
                                   +(new String(buf, 0, bytes_read))+" World");
                sockOutput.write(buf, 0, bytes_read);
                sockOutput.flush();
            }
            catch (Exception e){
                System.err.println("Exception reading from/writing to socket, e="+e);
                e.printStackTrace(System.err);
                return;
            }
        }
 
    }
 
    public void waitForConnections() {
        Socket sock = null;
        InputStream sockInput = null;
        OutputStream sockOutput = null;
        while (true) {
            try {
              
                sock = serverSock.accept();
                System.err.println("Have accepted new socket.");
 
                sockInput = sock.getInputStream();
                sockOutput = sock.getOutputStream();
               
            }
            catch (IOException e){
                e.printStackTrace(System.err);
            }
 
            handleConnection(sockInput, sockOutput);
 
            try {
                System.err.println("Closing socket.");
                sock.close();
            }
            catch (Exception e){
                System.err.println("Exception while closing socket.");
                e.printStackTrace(System.err);
            }
 
            System.err.println("Finished with socket, waiting for next connection.");
        }
    }
   
    public static void main(String argv[]) {
        int port = 54321;
        VerySimpleServer server = new VerySimpleServer(port);
        server.waitForConnections();
    }
}

2. Source Code untuk client.java

/*
 * CLIENT
 */
package SocketExample;
 
/**
 *
 * @author aida
 */
import java.net.Socket;
import java.net.ServerSocket;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.IOException;
 
public class VerySimpleClient {
    private String serverHostname = null;
    private int serverPort = 0;
    private byte[] data = null;
 
    public VerySimpleClient(String serverHostname, int serverPort, byte[] data){
        this.serverHostname =  serverHostname;
 
    private Socket sock = null;
    private InputStream sockInput = null;
    private OutputStream sockOutput = null;
        this.serverPort = serverPort;
        this.data = data;
    }
   
    public void sendSomeMessages(int iterations) {
        System.err.println("Opening connection to "+serverHostname+" port "+serverPort);
        try {
            sock = new Socket(serverHostname, serverPort);
            sockInput = sock.getInputStream();
            sockOutput = sock.getOutputStream();
        }
        catch (IOException e){
            e.printStackTrace(System.err);
            return;
        }
 
        System.err.println("About to start reading/writing to/from socket.");
 
        byte[] buf = new byte[data.length];
        int bytes_read = 0;
        for(int loopi = 1; loopi <= iterations; loopi++) {
            try {
                sockOutput.write(data, 0, data.length);
                bytes_read = sockInput.read(buf, 0, buf.length);
            }
            catch (IOException e){
                e.printStackTrace(System.err);
            }
            if(bytes_read < data.length) {
                System.err.println("run: Sent "+data.length+" bytes, server should have sent them back, read "+bytes_read+" bytes, not the same number of bytes.");
            }
            else {
                System.err.println("Sent "+bytes_read+" bytes to server and received them back again, msg = "+(new String(data)));
            }
            // Sleep for a bit so the action doesn't happen to fast - this is purely for reasons of demonstration, and not required technically.
            try { Thread.sleep(50);} catch (Exception e) {};
        }
        System.err.println("Done reading/writing to/from socket, closing socket.");
 
        try {
            sock.close();
        }
        catch (IOException e){
            System.err.println("Exception closing socket.");
            e.printStackTrace(System.err);
        }
        System.err.println("Exiting.");
    }
 
    public static void main(String argv[]) {
        String hostname = "localhost";
        int port = 54321;
        byte[] data = "Hello".getBytes();
       
        VerySimpleClient client = new VerySimpleClient(hostname, port, data);
        client.sendSomeMessages(1);
    }
}

Screenshot Running dari program di atas :

Fiuh, cukup sekian dulu ya :D

Silahkan dicoba-coba modif program di atas sendiri ya...

Thanks for Visiting !!!

My Life Note | AK-Five

Membuat Program Client-Server Sederhana dengan Socket pada JAVA

Entry Populer

Arsip Blog

Tentang Saya