TCP Channel (Blocking)

NIO의 tcp는 blocking, non-blocking, asyncronized은 서로 구현방식이 전혀 다릅니다.

Blocking Socket

SocketChannel

ServerSocketChannel : buffer X blocking 방식

SocketChannel : buffer O, blocking, non-blocking 방식

Connection

Server

ServerSocket을 생성한 뒤 blocking으로 설정해줍니다.

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(INET);
serverSocketChannel.configureBlocking(true);
serverSocketChannel.bind(new InetSocketAddress(8877));

클라이언트의 연결을 승인하기 위한 accept()를 실행합니다.

SocketChannel accept = serverSocketChannel.accept();

(InetSocketAddress) socketChannel.getRemoteAddress(); 를사용하면 클라이언트의 정보를 볼 수 있습니다.

연결을 종료하고 싶은 경우 close를 실행해 줍니다.

serverSocketChannel.close();

Client

Socket을 생성한 뒤 blocking으로 설정해줍니다.

SocketChannel socketChannel = SocketChannel.open(INET);
socketChannel.configureBlocking(true);

서버에 연결 요청을 보내기 위해 connet()를 실행합니다.

socketChannel.connect(new InetSocketAddress("localhost", 8877));

연결 종료는 close를 실행해 줍니다.

if (socketChannel.isConnected()) {
    socketChannel.close();
}

how do code?

Server

public class Main {
    public static void main(String[] args) throws IOException{
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(INET);
        serverSocketChannel.configureBlocking(true);
        serverSocketChannel.bind(new InetSocketAddress(8877));

        while (true) {
            SocketChannel socketChannel = serverSocketChannel.accept();
            InetSocketAddress inetSocketAddress = (InetSocketAddress) socketChannel.getRemoteAddress();

            System.out.println("CONNECTED !!! " + inetSocketAddress.getHostName());
        }
    }
}

Client

public class Main {
    public static void main(String[] args) throws IOException {
        SocketChannel socketChannel = SocketChannel.open(INET);
        socketChannel.configureBlocking(true);

        socketChannel.connect(new InetSocketAddress("localhost", 8877));
        System.out.println("COMPLETE CONNECT");
        if (socketChannel.isConnected()) {
            socketChannel.close();
            System.out.println("COMPLETE CLOSE");
        }
    }
}

Data Communication

Client의 연결 요청이 Server에서 수락되었다면, read(), write()를 이용해 통신할 수 있습니다.

모두 버퍼를 가지고 있기 때문에 버퍼를 사용하여 데이터를 교환합니다.

Write

데이터 전송은 write를 사용하여 전송한다.

바이트코드로 전송하면된다.

socketChannel.write(Charset.defaultCharset().encode("This is junny land"));

Read

전송된 데이터를 읽어오는 것은 Read를 사용한다.

바이트 코드로 들어온 값을 읽으면 된다.

ByteBuffer buffer = ByteBuffer.allocate(1024);

socketChannel.read(buffer);
buffer.flip();
String result = Charset.defaultCharset().decode(buffer).toString();

read를 호출한 시점부터 상대방이 데이터를 보내주기전 까지는 항상 Blocking상태가 되는데,

블로킹이 해제되고 응답이 오는 경우는 세가지 입니다.

reason	response
데이터 전송받음	바이트 수
상대측 close()	-1
비정상적 종료	IOException

Thread Pool?

동기 방식의 서버 채널의 read는 응답을 기다리는 동안 blocking되기 때문에 작업이 뎌디다.

이런 문제는병렬 프로그래밍 방식 중 Tread pool을 이용하여 해결할 수 있다.

this.executorService = newFixedThreadPool(getRuntime().availableProcessors());

executorService에 스레드풀 의 크기를 지정해 준뒤

Runnable runnable = () -> {
    CharBuffer answer = Charset.defaultCharset().decode(BUFFER);
    System.out.println("READ ="+ answer);
};
executorService.submit(runnable);

Runnable에 실행할 작업을 작성한 뒤, executorService에 등록해준다