SW 개발/Kotlin
Kotlin, Okio를 이용하여 TCP 소켓 클라이언트 구현하기
지단로보트
2018. 12. 11. 03:47
개요
- 스퀘어 사는
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()