Kali ini kita akan coba membuat aplikasi dari java untuk membuat java socket server.
Pertama kita buat file dengan nama TCPServer.java, lalu kita copy coding dibawah ini ke file yang dibuat tadi:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; public class TCPServer extends Thread { final static int TCP_SERVER_PORT = 6789; private Socket socket; public TCPServer(Socket sock) { socket = sock; } public void run() { System.out.println(this.socket.getPort() + " working or sleeping for 5 seconds"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } DataInputStream clientinp; DataOutputStream clientout; try { clientinp = new DataInputStream(socket.getInputStream()); clientout = new DataOutputStream(socket.getOutputStream()); while (true) { System.out.println("reading..."); String sentence = clientinp.readUTF(); System.out.printf("read from socket %s: %s\n", this.socket.getPort(), sentence); if (sentence.equalsIgnoreCase("exit")) { System.out.printf("socket %s: to be down\n", this.socket.getPort()); clientout.writeUTF("bye"); break; } else { clientout.writeUTF(String.format("answer: %s", sentence)); } } } catch (IOException e) { e.printStackTrace(); } finally { try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } public static void main(String args[]) throws IOException { ServerSocket serversocket; serversocket = new ServerSocket(TCP_SERVER_PORT); while (true) { Socket clientsocket = serversocket.accept(); new TCPServer(clientsocket).start(); } } } |
