I/O 상호 운용성

Ktor는 기본 I/O 프리미티브를 제공하는 멀티플랫폼 코틀린 라이브러리인 kotlinx-io를 기반으로 구축된 논블로킹(non-blocking), 비동기 I/O를 지원합니다. 이를 통해 HTTP 요청 및 응답 본문을 스트리밍하고, 파일을 읽거나 쓸 수 있으며, 모든 데이터를 메모리에 로드하지 않고 점진적으로 처리할 수 있습니다.

다른 I/O 모델을 사용하는 외부 라이브러리 또는 플랫폼과 작업하는 경우, 다음과 상호 운용하기 위한 어댑터 세트를 사용할 수 있습니다.

• RawSource 및 RawSink와 같은 kotlinx-io 타입
• OutputStream과 같은 Java I/O 타입

이 페이지에서는 Ktor의 I/O 프리미티브( ByteReadChannel, ByteWriteChannel)와 이러한 외부 타입 간에 변환하는 방법을 설명합니다.

ByteReadChannel을 RawSource로 변환

ByteReadChannel을 RawSource로 변환하려면 .asSource() 확장 함수를 사용하세요.

val channel: ByteReadChannel = response.bodyAsChannel()
val source: RawSource = channel.asSource()

ByteWriteChannel을 RawSink로 변환

suspending ByteWriteChannel을 RawSink로 변환하려면 .asSink() 확장 함수를 사용하세요.

val channel: ByteWriteChannel = ...
val sink: RawSink = channel.asSink()

이 어댑터가 생성하는 RawSink는 데이터를 플러시할 때 내부적으로 runBlocking을 사용하므로, 플러시 작업이 호출 스레드를 블록(block)할 수 있습니다.

RawSink를 ByteWriteChannel로 변환

RawSink를 suspending ByteWriteChannel로 래핑(wrap)하려면 .asByteWriteChannel() 확장 함수를 사용하세요.

val sink: RawSink = ...
val channel: ByteWriteChannel = sink.asByteWriteChannel()

channel.writeByte(42)
channel.flushAndClose()

이를 통해 suspending 함수에서 싱크(sink)로 비동기적으로 쓸 수 있습니다. 반환된 채널은 버퍼링됩니다. 모든 데이터가 작성되도록 하려면 .flush() 또는 .flushAndClose()를 사용하세요.

OutputStream을 ByteWriteChannel로 변환

Java OutputStream을 ByteWriteChannel로 변환하려면 .asByteWriteChannel() 확장 함수를 사용하세요.

val outputStream: OutputStream = FileOutputStream("output.txt")
val channel: ByteWriteChannel = outputStream.asByteWriteChannel()

channel.writeFully("Hello, World!".toByteArray())
channel.flushAndClose()

ByteWriteChannel의 모든 작업은 버퍼링됩니다. 기본 OutputStream은 ByteWriteChannel에서 .flush()가 호출될 때만 데이터를 받습니다.