Kotlin, Okio를 이용하여 TCP 소켓 클라이언트 구현하기

개요

• 스퀘어 사는 OkHttp를 통해 추상화되고 직관적인 REST 클라이언트를 선보인 바 있다. 이번 글에서 소개할 Okio 또한 같은 철학을 공유하는 라이브러리로 Java IO/NIO의 거추장스러움을 완전히 제거하여 간결하고 직관적인 사용법을 제공한다. 이번 글에서는 Okio를 이용하여 TCP 소켓 클라이언트 기능을 구현해 보고자 한다.

라이브러리 종속성 추가

• 프로젝트의 /build.gradle 파일에 아래 내용을 추가한다.

dependencies {
    compile group: 'com.squareup.okio', name: 'okio', version: '2.1.0'
}

TCP 소켓 통신 예제

• 아래는 Okio를 이용하여 TCP 소켓 클라이언트로 작동하는 간단한 예제이다.

// TCP 서버에 연결
// 연결 불가시 java.net.ConnectException: Connection refused: connect 예외 발생
val socket = Socket("127.0.0.1", 6789)

// TCP 서버에 메시지를 요청하기 위한 Sink 생성 (OutputStream 역할)
val sink = socket.sink().buffer()

// 요청 대기 타임아웃 설정
sink.timeout().timeout(5, TimeUnit.SECONDS)

// TCP 서버로부터 메시지를 응답받기 위한 Source 생성 (InputStream 역할)
val source = socket.source().buffer()

// 응답 대기 타임아웃 설정
source.timeout().timeout(5, TimeUnit.SECONDS)

// TCP 서버에 요청 메지지 송신
sink.writeUtf8("안녕하세요.\n")
sink.flush()

// TCP 서버로부터 응답 메시지 수신
// 앞서 설정한 대기 시간 초과시 java.net.SocketTimeoutException: timeout 예외 발생
println(source.readUtf8Line()) // 반갑습니다.\n

// TCP 서버와의 연결 종료
source.close()
sink.close()
socket.close()

참고 글

• Okio
• Okio > Change Log
• Basic HTTP/1.1 with Okio