NIO TCP blocking channel 소켓서버 & 클라이언트

NIO TCP blocking channel 소켓서버 & 클라이언트

서버 소켓 생성

ServerSocketChannel sock = ServerSocketChannel.open();

sock.configureBlocking(true);

sock.bind(new InetSocketAddress(9190));

요청기다림

SocketChannel socketChannel = sock.accept();

클라이언트 소켓 생성

SocketChannel socketChannel = SocketChannel.open();

socketChannel.configureBlocking(true);

socketChannel.connect(new InetSocketAddress(9190));

서버 or 클라이언트로부터 정보 받기

socketChannel.read();

서버 or 클라이언트로부터 정보 보내기

socketChannel.write();

ex) 소켓 서버

ServerSocketChannel sock = ServerSocketChannel.open();

sock.configureBlocking(true);

sock.bind(new InetSocketAddress(9190));

ExecutorService executorService = Executors.newCachedThreadPool();

while (true) {

System.out.println("연결기다리기");

SocketChannel socketChannel = sock.accept();

InetSocketAddress addr = (InetSocketAddress) socketChannel.getRemoteAddress();

System.out.println("연결수락 : " + addr.getHostName());

String data = null;

Charset charset = Charset.forName("UTF-8");

ByteBuffer byteBuffer = ByteBuffer.allocate(100);

int len = socketChannel.read(byteBuffer);

byteBuffer.flip();

data += charset.decode(byteBuffer).toString();

System.out.println("request msg : " + data);

byteBuffer = charset.encode("hello world Client");

socketChannel.write(byteBuffer);

System.out.println("데이터 보내기 성공");

if (sock.isOpen()) {

sock.close();

break;

}

}

ex) 클라이언트

SocketChannel socketChannel = SocketChannel.open();

socketChannel.configureBlocking(true);

socketChannel.connect(new InetSocketAddress(9190));

System.out.println("연결성공");

Charset charset = Charset.forName("UTF-8");

ByteBuffer buffer = charset.encode("hello world");

socketChannel.write(buffer);

System.out.println("보내기성공");

buffer = ByteBuffer.allocate(100);

int len = socketChannel.read(buffer);

buffer.flip();

String data = charset.decode(buffer).toString();

System.out.println("받은 데이터 : "+ data);

if(socketChannel.isOpen()) {

socketChannel.close();

}