Java NIO의 핵심 기능 중 하나인 Scatter/Gather는 대용량 데이터나 구조화된 데이터를 처리할 때 매우 유용한 입출력 방식입니다. 이 기술은 여러 개의 버퍼를 사용하여 단일 채널에서 데이터를 분산하여 읽거나(Scatter), 여러 버퍼의 데이터를 모아서 하나의 채널로 쓰는(Gather) 작업을 수행합니다.

Scatter와 Gather의 개념

• Scatter (분산): 채널로부터 데이터를 읽어 여러 개의 버퍼에 나누어 저장하는 과정입니다. 채널은 첫 번째 버퍼가 가득 찰 때까지 데이터를 채우고, 그 다음 버퍼를 순차적으로 채워 나갑니다.
• Gather (집중): 여러 버퍼에 나뉘어 있는 데이터를 하나의 채널에 순차적으로 쓰는 과정입니다. 각 버퍼의 position과 limit 사이의 데이터들이 모여 채널로 전송됩니다.

주요 인터페이스 정의

Java NIO는 Scatter/Gather를 지원하기 위해 ScatteringByteChannel과 GatheringByteChannel 인터페이스를 제공합니다. 이 인터페이스들은 기본 채널 기능에 버퍼 배열을 다루는 메서드를 추가로 정의하고 있습니다.

public interface ScatteringByteChannel extends ReadableByteChannel {
    public long read(ByteBuffer[] dsts) throws IOException;
    public long read(ByteBuffer[] dsts, int offset, int length) throws IOException;
}

public interface GatheringByteChannel extends WritableByteChannel {
    public long write(ByteBuffer[] srcs) throws IOException;
    public long write(ByteBuffer[] srcs, int offset, int length) throws IOException;
}

위 메서드에서 offset은 버퍼 배열 내에서 시작할 인덱스를 의미하며, length는 사용할 버퍼의 개수를 지정합니다. 예를 들어 channel.read(buffers, 0, 2)는 배열의 0번과 1번 버퍼만을 사용하여 데이터를 읽어옵니다.

Gathering Write (집중 쓰기)

네트워크 프로토콜을 구현할 때 헤더와 바디가 별도의 객체로 관리되는 경우가 많습니다. 이때 Gather를 사용하면 데이터를 하나의 큰 버퍼로 복사할 필요 없이 효율적으로 전송할 수 있습니다.

ByteBuffer protocolHeader = ByteBuffer.allocate(64);
ByteBuffer contentBody = ByteBuffer.allocate(2048);

// 각 버퍼에 데이터가 채워져 있다고 가정
ByteBuffer[] messageContainer = { protocolHeader, contentBody };

// 두 버퍼의 내용을 하나의 채널에 순차적으로 기록
long bytesWritten = channel.write(messageContainer);

여기서 주의할 점은 버퍼의 전체 용량이 아닌, 현재 유효한 데이터 범위(position부터 limit까지)만 채널로 전송된다는 것입니다. 만약 헤더 버퍼의 크기가 64바이트인데 20바이트만 채워져 있다면, 실제로 채널에 써지는 데이터는 20바이트입니다.

Scattering Read (분산 읽기)

채널에서 들어오는 데이터를 구조에 맞게 자동으로 분리하여 저장하고 싶을 때 Scatter를 사용합니다.

ByteBuffer metaHeader = ByteBuffer.allocate(16);
ByteBuffer dataPayload = ByteBuffer.allocate(512);

ByteBuffer[] receiveBuffers = { metaHeader, dataPayload };

// 채널로부터 읽어온 데이터를 순서대로 버퍼에 채움
channel.read(receiveBuffers);

이 과정에서 metaHeader가 완전히 채워져야만 dataPayload 버퍼에 데이터가 쌓이기 시작합니다. 따라서 전송되는 데이터의 크기가 고정되어 있을 때 매우 효율적입니다.

Scatter/Gather의 장점

Scatter/Gather 방식이 성능상 유리한 이유는 현대 운영체제 대부분이 Native Vectored I/O를 지원하기 때문입니다. Java NIO에서 이 기능을 호출하면 운영체제 레벨의 시스템 콜로 직접 연결되어 다음과 같은 이점을 얻을 수 있습니다.

1. 시스템 콜 감소: 여러 번의 read/write 호출을 하나의 호출로 줄여 컨텍스트 스위칭 비용을 절감합니다.
2. 버퍼 복사 최소화: 여러 버퍼의 데이터를 합치기 위해 별도의 중간 버퍼를 생성하고 복사하는 과정을 생략할 수 있습니다.
3. 성능 최적화: 특히 Direct ByteBuffer를 함께 사용할 경우, 운영체제가 유저 메모리와 커널 메모리 사이의 복사 과정을 생략하고 직접 I/O를 수행할 수 있어 성능이 극대화됩니다.