예제

package manual.tcp;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;

public class TCPClient {
    BufferedReader br;
    BufferedWriter bw;
    InputStream is;
    OutputStream os;
    int headerLength = 4;

    String ip;
    int port;
    String message;

    public TCPClient(String ip, int port, String message, int headerLength) {
        this.ip = ip;
        this.port = port;
        this.message = message;
        this.headerLength = headerLength;
    }

    public void run() {
        try {
            System.out.println("Start Client ip:" + ip + " port:" + port);
            long startTime = System.currentTimeMillis();

            Socket socket = new Socket(ip, port);
            socket.setSoTimeout(10000);
            is = socket.getInputStream();
            os = socket.getOutputStream();

            br = new BufferedReader(new InputStreamReader(is));
            bw = new BufferedWriter(new OutputStreamWriter(os));

            System.out.println("TCPSimpleClient:Connected to " + socket.getRemoteSocketAddress());
            bw.write(message);
            bw.flush();
            System.out.println("TCPSimpleClient:Send message : " + message);

            char[] headerbuf = new char[headerLength];
            br.read(headerbuf, 0, headerLength);
            System.out.println("recv length: " + new String(headerbuf));
            int bodybufLength = Integer.parseInt(new String(headerbuf));

            char[] bodybuf = new char[bodybufLength];
            br.read(bodybuf);
            System.out.println("TCPSimpleClient:recv data: " + new String(bodybuf));

            bw.flush();
            br.close();
            bw.close();

            is.close();
            os.close();

            socket.close();

            long endTime = System.currentTimeMillis();
            long lTime = endTime - startTime;
            System.out.println("TCPSimpleClient:TIME : " + lTime + "(ms)");

        } catch (Throwable t) {
            t.printStackTrace();
        }
    }

    public static void main(String[] args) {
        String sendMessage = "0106AAAAA00120160701KIMCHEOLSUB01P1034LEEYEONGSUKNIGHT      THISISSAMPLEDATA                                  ";
        TCPClient client = new TCPClient("192.168.14.106", 30000, sendMessage, 4);
        client.run();
    }
}

package manual.tcp;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;


public class TCPServer extends Thread {

    BufferedReader br;
    BufferedWriter bw;
    InputStream is;
    OutputStream os;
    int port;
    int headerLength = 4;

    public TCPServer(int port, int headerLength) {
        this.port = port;
        this.headerLength = headerLength;
    }

    @Override
    public void run() {
        ServerSocket serverSocket = null;
        try {
            System.out.println("Start TCP Server");
            serverSocket = new ServerSocket(port);
            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("Accept from client:" + port);

                is = socket.getInputStream();
                os = socket.getOutputStream();
                br = new BufferedReader(new InputStreamReader(is));
                bw = new BufferedWriter(new OutputStreamWriter(os));

                System.out.println("read...");

                char[] headerbuf = new char[headerLength];
                br.read(headerbuf, 0, headerLength);
                System.out.println("recv length: " + new String(headerbuf));

                int bodybufLength = Integer.parseInt(new String(headerbuf));
                char[] bodybuf = new char[bodybufLength];

                br.read(bodybuf, 0, bodybufLength);

                System.out.println("recv data: " + new String(bodybuf));

                System.out.println("write...");
                String retMessage = "00261000KIMCHEOLSU20160720SP01";
                System.out.println("send message: " + retMessage);
                bw.write(retMessage);
                System.out.println("write done");

                bw.flush();
                br.close();
                bw.close();
            }

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (Throwable t) {
            }
        }
    }

    public static void main(String[] args) {
        TCPServer server = new TCPServer(38000, 4);
        server.start();

        try {
            Thread.sleep(600000);
        } catch (InterruptedException e) {
        }
    }
}