서비의 다락방

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

public class TcpTestServer {

    public TcpTestServer() {
    }

    public static void main(String[] args) {
        try {
            ServerSocket socketServer = new ServerSocket(6789);
            while (true) {
                Socket socketClient = socketServer.accept();
                System.out.println("socket connected...");
                if (socketClient != null) {
                    new ClientHandler(socketClient).start();
                }
            }
        } catch (IOException objIOException) {
            objIOException.printStackTrace();
        }
    }
}



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

class ClientHandler extends Thread {

private Socket m_socketClient = null;

    public ClientHandler(Socket socket) {
        m_socketClient = socket;
    }

    public void run() {
        try {
            // receive from client
            // received
            InputStream in = null;
            BufferedInputStream bin = null;
            in = m_socketClient.getInputStream();
            bin = new BufferedInputStream(in);
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            int read;
            while ((read = bin.read()) != -1) {
                baos.write(read);
            }

            System.out.println(baos);
            baos.flush();

            // send to client
            String msg = "Server received...";
            OutputStream out = null;
            BufferedOutputStream bout = null;
            out = m_socketClient.getOutputStream();
            bout = new BufferedOutputStream(out);
            bout.write(msg.getBytes());
            bout.flush();

            out.close();
            in.close();
            m_socketClient.close();
        } catch (IOException objIOException) {
            objIOException.printStackTrace();
        }
    }
}

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

public class TcpTestClient {

    public TcpTestClient() {
    }

    public static void main(String[] args) {
        try {
            Socket socketClient = new Socket(localhost, 6789);
            //socketClient.connect(new InetSocketAddress(InetAddress.getByName("220.95.213.193"), 6789), 1000) ;
            String boundary = "11111";
            String msg = "POST /mmsr30/mm7 HTTP/1.1" + "\r\n";
            msg = msg + "host: vmg.nate.com" + "\r\n";
            msg = msg + "Content-Type: multipart/related; type=\"text/xml\"; boundary=\"" 
            + boundary + "\"" + "\r\n";
            msg = msg + "Connection: Close" + "\r\n";
            msg = msg + "SOAPAction: \"\"" + "\r\n\r\n";

            OutputStream out = null;
            BufferedOutputStream bout = null;

            InputStream in = null;
            BufferedInputStream bin = null;

            out = socketClient.getOutputStream();
            bout = new BufferedOutputStream(out);

            in = socketClient.getInputStream();
            bin = new BufferedInputStream(in);

            bout.write(msg.getBytes());
            bout.flush();

            // 결과 수신
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            int read;
            while ((read = bin.read()) != -1) {
                baos.write(read);
            }

            System.out.println(baos);

            baos.flush();

            socketClient.close();
        } catch (UnknownHostException objUnknownHostException) {
            objUnknownHostException.printStackTrace();
        } catch (SocketTimeoutException objSocketTimeoutException) {
            objSocketTimeoutException.printStackTrace();
        } catch (IOException objIOException) {
            objIOException.printStackTrace();
        } catch (Exception objException) {
            objException.printStackTrace();
        }
    }
}