NIO Socket은 서버 파트만 변경을 하고 클라이언트는 이전 ServerSocket 과 Socket을 이용한 Echo 테스트 의 Client 소스를 그대로 이용하면 됩니다.

package coozplz.example.nio.echo;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.*;
import java.nio.charset.Charset;
import java.nio.charset.CharsetEncoder;
import java.util.Iterator;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;

public class NIOEchoServer implements Runnable {
	Selector selector; // 어떤 채널이 어떤 IO 를 할 수 있는지 알려주는 클래스
	int port = 9999;
	// 한글 전송 ENCODING 설정
	Charset charset = Charset.forName("EUC-KR");
	CharsetEncoder encoder = charset.newEncoder();

	public NIOEchoServer() throws IOException {
		// 1. Selector 생성
		selector = Selector.open();
		// SeverSocket 에 대응하는 ServerSocketChannel 생성
		ServerSocketChannel channel = ServerSocketChannel.open();
		// 서버 소켓 생성
		ServerSocket socket = channel.socket();
		SocketAddress addr = new InetSocketAddress(port);
		socket.bind(addr);
		// Non-Blocking 상태로 만듬
		channel.configureBlocking(false);
		// 바인딩된 ServerSocketChannel 을 Selector에 등록한다.
		channel.register(selector, SelectionKey.OP_ACCEPT);
		System.out.println("wait for connecting client");
	}

	public void run() {
		try {
			int socketOps = SelectionKey.OP_CONNECT | SelectionKey.OP_READ | SelectionKey.OP_WRITE;
			ByteBuffer buffer = null;
			// 생성된 소켓채널에 대해 accept 상태 일때 알려달라고 selector에 등록 시킨 후
			// 이벤트가 일어날 때 까지 기다린다.
			// 클라이언트가 접속하면 Selector는 미리 등록 했던 SeverSocketChannel에 이벤트가
			// 발생했으므로 Select 메소드에서 1을 돌려준다.
			while (selector.select() > 0) {
				// 현재 Selector에 등록된 채널에 동작이 아니라도 실행 되는 경우 그 채널들을 SelectionKey의
				// Set 에 추가한다. 아래에서는 선택된 채널들의 키를 얻는다. 즉 해당 IO 에 대해 등록해
				// 놓은 채널의 키를 얻는다.
				Set keys = selector.selectedKeys();
				Iterator iter = keys.iterator();
				while (iter.hasNext()) {
					SelectionKey selected = (SelectionKey) iter.next();
					iter.remove();
					// channel() 의 현재 하고 있는 동작(읽기, 쓰기)에 대한 파악
					SelectableChannel channel = selected.channel();
					if (channel instanceof ServerSocketChannel) {
						// ServerSocketChannel이라면 Accept() 를 호출
						// 접속 요청을 해온 상대방 소켓과 연결 될 수 있는 SocketChannel 을 얻는다.
						ServerSocketChannel serverSocketChannel = (ServerSocketChannel) channel;
						SocketChannel socketChannel = serverSocketChannel.accept();
						
						// 현 시점의 ServerSocketChannel은 Non-Blocking IO로 설정 되어 있음
						// 이것은 당장 접속이 없어도 블로킹 되지 않고 바로 NULL 을 던지므로 체크 필요
						if (socketChannel == null) {
							System.out.println("Socket channel is null");
							continue;
						}
						System.out.println("Client is conntected " + socketChannel);
						// 얻은 socketChannel 은 블로킹 소켓이므로 Non-Blocking IO 상태로 설정
						socketChannel.configureBlocking(false);
						// 소켓 채널을 Selector에 등록
						socketChannel.register(selector, socketOps);
					} else {
						// 일반 소켓 채널이 경우 해당 채널을 얻어 낸다.
						SocketChannel socketChannel = (SocketChannel) channel;
						try {
							buffer = ByteBuffer.allocate(100);

							// 소켓 채널의 행동을 검사해서 그에 대응하는 작업을 함
							if (selected.isConnectable()) {
								System.out.println("Client 와의 연결 설정 OK");
								if (socketChannel.isConnectionPending()) {
									System.out.println("Client 와의 연결 설정을 마무리 중입니다.");
									socketChannel.finishConnect();
								}
							} else if (selected.isReadable()) {
								// 읽기 요청 이라면
								socketChannel.read(buffer);
								if (buffer.position() != 0) {
									buffer.clear();
									System.out.println("클라이언트로 전달된 내용:");

									// Non-BLocking Mode 이므로 데이터가 모두 전달될때 까지 기다림
									while (buffer.hasRemaining()) {
										System.out.print((char) buffer.get());
									}
									buffer.clear();
									System.out.println();

									// 쓰기가 간으하다면
									if (selected.isWritable()) {
										String str = "이건 서버에서 보낸 데이터…";
										// 한글 인코딩
										CharBuffer charBuf = CharBuffer.wrap(str);

										socketChannel.write(encoder.encode(CharBuffer.wrap(str+ "\r\n")));
										// socketChannel.write(byteBuffer);
										System.out.println("Send:" + str);
									}
								}

							}

						} catch (Exception ex) {
							Logger.getLogger(NIOEchoServer.class.getName()).log(Level.SEVERE, null, ex);
						}
					}
				}
			}
		} catch (IOException ex) {
			Logger.getLogger(NIOEchoServer.class.getName()).log(Level.SEVERE,null, ex);
		}
	}

	public static void main(String[] args) throws IOException {
		NIOEchoServer s = new NIOEchoServer();
		new Thread(s).start();
	}
}

EchoServer

package coozplz.example;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

public class MultiThreadEchoServerMain extends Thread {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(9999);
        System.out.println("서버 소켓 생성 완료");

        while (true) {
            Socket sock = ss.accept();
            System.out.println(sock.getInetAddress().toString() + " // is connted");
            MultiThreadEchoServer client = new MultiThreadEchoServer(sock);
            client.start();


        }

    }
}

class MultiThreadEchoServer extends Thread {
    Socket socket;
    InputStream in;
    OutputStream os;

    public MultiThreadEchoServer(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        System.out.println("MultiThreadEchoServer is Running");
        try {
            in = socket.getInputStream();
            os = socket.getOutputStream();


            byte[] buf = new byte[1024];
            int count;
            while ((count = in.read(buf)) > 0) {

                System.out.println("received: " + new String(buf, 0, count));
                os.write(buf, 0, count);
                System.out.println("write:" + new String(buf, 0, count));
            }
            os.close();
            System.out.println("연결종료");
        } catch (IOException ex) {
            Logger.getLogger(MultiThreadEchoServerMain.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            if (socket != null) {
                try {
                    socket.close();
                } catch (IOException ex) {
                    Logger.getLogger(MultiThreadEchoServerMain.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
    }


}

Echo Client

package coozplz.example;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;

public class EchoClientThread {
    public static void main(String[] ar) throws IOException {
        EchoClientThread client = new EchoClientThread();
        client.process();
    }

    public void process() throws IOException {
        Socket socket = new Socket();
        socket.connect(new InetSocketAddress("127.0.0.1", 9999));
        OutputStream os = socket.getOutputStream();
        InputStream in = socket.getInputStream();


        byte[] buf = new byte[1024];
        int count = 0;
        while ((count = System.in.read(buf)) > 0) {
            os.write(buf, 0, count);
            System.out.println("Client -> Svr: " + new String(buf, 0, count));
            count = in.read(buf);
            System.out.println("Svr -> Client: " + new String(buf, 0, count));
        }
        os.close();
        while ((count = in.read(buf)) > 0) {
            System.out.write(buf, 0, count);
        }
        System.out.close();
        System.out.println("연결종료");
        if (socket != null) {
            socket.close();
        }
    }
}

이제 조금 있으면 대용량 서버를 만들어야 하는 경우가 발생 할 수도 있을 것 같아 미리 준비를 해야겠습니다. (해본 것과 할 수 있는 것은 분명한 차이가 있다고 생각이 되기에…)

대략 일정

1. 자료 검색 (4/23 ~ 5/4)
– Java NIO  Example 검색( 2D )

– Java NIO 자료 분석 ( 2D )
– Java NIO 채팅 서버 분석 ( 2D )
– Apache MINA ( 2D )
– 대용량 메신저 서버 분석 ( 2D )

2. 간단한 메신저 서버 구현  (5/6~5/11)
– 메신저 접속 및 전문 교환

3. SAPP 서버 NIO 로 변경 ( 5/12~5/18 )
– 이벤트 처리 부분 수정
– XML 파싱 부분 수정

1. 자료 검색

• J2SDK1.4에 추가된 nio로 비동기식 고가용성 서버 만들기
• java.nio 강좌
• java.nio 강좌 두번째
• java.nio 강좌 첫번째
• 아파치 미나(Apache MINA) 이해하기
• Apache Mina를 활용한 Sample TCP Server
• Apache MINA Example Source
• Nettry 사용자 가이드 

라이선스 적용을 위해 랜카드 정보를 찾는데 기존 방식은
Runtime.getRuntime().exec(“ipconfig /all”);
을 사용하여 InputStream 으로 추출 했습니다.  이렇게 하는 방법 외에 다른 방법을 해보니 예전에 특정아이피로 바인딩 하는 방법에서 찾을 수 있을 것 같아. 아래와 같이 해봤습니다.

간단하게 맥어드레스와 이름 만 출력 합니다.

// 설치된 모든 랜카드 정보를 얻는다.
 Enumeration netEnumeration =  NetworkInterface.getNetworkInterfaces();

 while (netEnumeration.hasMoreElements()) {

    // 랜카드 목록에서 랜카드 하나의 정보를 추출한다.
    NetworkInterface networkInterface = (NetworkInterface) netEnumeration.nextElement();

    // 맥어드레스를 추출
    byte[] data = networkInterface.getHardwareAddress();
    if(data == null || data.length != 6) {
        continue;
    }


    StringBuilder macAddress = new StringBuilder();

    // 맥어드레스를 읽기 쉬운 타입 => 00:00:00:00:00:00 형식으로 변환한다.
    for (int i = 0; i < data.length; i++) {
        macAddress.append(Integer.toHexString(0x10000 | (0xff & (int)data[ 0 + i])).substring(3, 5).toUpperCase())
        if (i != 5)
            macAddress.append(":");
    }


    // 출력한다.
    System.out.println("NAME:" + networkInterface.getDisplayName());
    System.out.println("MAC: " + macAddress.toString());
 }

Socket

   1: Socket socket = new Socket();

   2:  

   3: // If set the port zero, the port will set any available port in you system

   4: SocketAddress localAddress = new InetSocketAddress(addr, 0);

   5:  

   6: socket.bind(localAddress);

   7:  

   8: SocketAddress remoteAddress = new InetSocketAddress(user.getIpAddress(), 8000);

   9:  

  10: // set Connection Timeout 

  11: socket.connect(remoteAddress, 2000);

URLConnection

   1: URL url = new URL(pushURL);

   2:             

   3: // set up specify local IP Address

   4: SocketAddress localAddress = new InetSocketAddress(addr, 0);

   5: Proxy proxy = new Proxy(Proxy.Type.DIRECT, localAddress);

   6: URLConnection urlConnection = url.openConnection(proxy);

   7:  

   8: // set the timeout

   9: urlConnection.setConnectTimeout(2000);

  10: urlConnection.setReadTimeout(2000);

HttpClient

   1: HttpClient client = new DefaultHttpClient();

   2: client.getParams().setParameter("http.connection.timeout", 1000);

   3: client.getParams().setParameter("http.socket.timeout", 1000);

   4: client.getParams().setParameter("http.protocol.version", HttpVersion.HTTP_1_1);

   5: client.getConnectionManager().closeIdleConnections(2000, TimeUnit.MILLISECONDS);

   6:  

   7: // Set specify local ip address

   8: client.getParams().setParameter(ConnRouteParams.LOCAL_ADDRESS, addr); 

   9: post.getParams().setParameter(ConnRouteParams.LOCAL_ADDRESS, addr);