[java] Akka를 활용한 실시간 채팅 애플리케이션 구현

30 Nov 2023

java

개요

이번 포스트에서는 Akka를 사용하여 실시간 채팅 애플리케이션을 구현하는 방법에 대해 알아보겠습니다. Akka는 개발자들이 고가용성, 분산 시스템 및 병렬 처리를 구현하는 데 도움이 되는 고성능 액터 기반 프레임워크입니다. 실시간 채팅은 다중 클라이언트 간에 메시지를 교환하고 서버에서 이를 관리하는 것을 의미합니다.

애플리케이션 아키텍처

우리의 실시간 채팅 애플리케이션은 다음과 같은 아키텍처로 구성됩니다:

클라이언트: 웹 브라우저나 모바일 애플리케이션과 같은 클라이언트에서 채팅 메시지를 작성하고 전송합니다.
서버: Akka 액터 시스템으로 구현된 실시간 채팅 서버입니다. 새로운 클라이언트 연결을 관리하고 받은 메시지를 모든 클라이언트에게 전달합니다.
데이터베이스: 채팅 메시지의 저장과 조회를 위해 데이터베이스가 필요합니다. 이 예제에서는 간단하게 메모리에 저장됩니다.

서버 구현하기

Akka 액터 시스템 설정하기:

Config config = ConfigFactory.load();
ActorSystem system = ActorSystem.create("chat-app", config);

액터 생성하기:

ActorRef chatRoom = system.actorOf(ChatRoom.props(), "chat-room");

새로운 클라이언트 연결 처리하기:

// WebSocket 핸들러에서 클라이언트가 연결되었을 때 실행되는 메서드
public void onConnect(Session session) {
    ActorRef client = system.actorOf(ChatClient.props(session, chatRoom));
    chatRoom.tell(new Join(client), ActorRef.noSender());
}

클라이언트로부터 받은 메시지 처리하기:

// ChatClient 액터의 receive 메서드 구현
public void onReceive(Object message) {
    if (message instanceof Message) {
        chatRoom.tell(message, self());
    } else {
        unhandled(message);
    }
}

메시지 전달하기:

// ChatRoom 액터의 receive 메서드 구현
public void onReceive(Object message) {
    if (message instanceof Join) {
        Join join = (Join) message;
        clients.add(join.client);
    } else if (message instanceof Message) {
        Message chatMessage = (Message) message;
        for (ActorRef client : clients) {
            client.tell(chatMessage, self());
        }
    } else {
        unhandled(message);
    }
}

요약

위의 단계를 따라가면 Akka를 사용하여 실시간 채팅 애플리케이션을 구현할 수 있습니다. Akka를 활용하면 액터의 동시성과 고가용성을 쉽게 다룰 수 있고, 클라이언트 간의 메시지 교환을 효율적으로 관리할 수 있습니다. 이를 통해 실시간 채팅 애플리케이션을 개발할 때의 복잡성을 크게 줄일 수 있습니다.

개요

애플리케이션 아키텍처

서버 구현하기

요약

참고 자료