Отладка и запуск сервиса:

$ sbt "run-main com.cookeem.chat.CookIM -h localhost -w 8081 -a 2552 -s localhost:2551"

Запуск сервиса в рабочем режиме:

$ java -classpath "target/scala-2.11/CookIM-assembly-0.2.0-SNAPSHOT.jar" com.cookeem.chat.CookIM -h localhost -w 8081 -a 2552 -s localhost:2551

Эти команды запускают веб-сервис, который слушает порт 8081. Система Akka также слушает порт 2552.

Вернуться к содержанию

Запуск браузера и посещение веб-адреса 8081:

http://localhost:8081

Демонстрация запускает два сервиса CookIM, доступ к которым осуществляется через порты 8080 и 8081 соответственно. Пользователи могут получить доступ к разным сервисам CookIM через разные браузеры. В браузере пользователи отправляют сообщения через WebSocket в кластер Akka, где сообщения распределяются между соответствующими узлами. Это обеспечивает обмен сообщениями между различными сервисами.

Вернуться к содержанию

Архитектура

Общая архитектура сервиса CookIM:

Сервис CookIM состоит из трёх частей:

• Akka HTTP используется для предоставления веб-сервиса, к которому браузер подключается через WebSocket.
• Akka Stream обрабатывает сообщения, полученные через WebSocket после их отправки браузером. Когда сообщение получено, оно помещается в поток chatService для обработки. Если сообщение содержит JWT (Javascript web token), то поток проверяет его. Если проверка проходит успешно, сообщение отправляется в ChatSessionActor.
• Кластер Akka используется для распределения сообщений между узлами кластера. CookIM использует DistributedPubSub от Akka Cluster. Когда пользователь присоединяется к сеансу, он подписывается на соответствующий сеанс. Когда пользователь отправляет сообщение в сеанс, сообщение публикуется в Actor, связанном с сеансом. Другие участники сеанса могут получать эти сообщения.

Вернуться к содержанию

Граф потока WebSocket:

После получения сообщения через WebSocket, Akka HTTP помещает его в поток chatService, где происходит обработка. Поток chatService использует следующие шаги:

1. flowFromWS принимает сообщения через WebSocket и декодирует JWT, содержащийся в сообщении.
2. Сообщения, которые не проходят проверку JWT, фильтруются через filterFailure. Сообщения, прошедшие проверку, фильтруются через filterSuccess.
3. builder.materializedValue представляет материализованное значение потока Akka. При создании потока автоматически отправляется сообщение connectedWs. connectedWs преобразует сообщение в UserOnline и отправляет его через ChatSinkActor в ChatSessionActor.
4. ChatActorSink отправляет сообщения в ChatSessionActor и, когда поток завершается, отправляет сообщение UserOffline в downstream.
5. ChatSource получает сообщения от ChatSessionActor и отправляет их в flowAcceptBack.
6. flowAcceptBack обеспечивает поддержку соединения.
7. flowReject и flowAcceptBack объединяют сообщения и отправляют их обратно через WebSocket как Message.

Вернуться к содержанию

Описание базы данных MongoDB:

Таблица users содержит информацию о пользователях:

Таблица sessions содержит информацию о сеансах (групповых или личных чатах):

Таблица messages содержит сообщения, отправленные в сеансе:

Таблица onlines содержит информацию об онлайн-пользователях:

Таблица notifications содержит уведомления, отправленные пользователям:

Вернуться к содержанию

Типы сообщений:

Существует два канала WebSocket: ws-push и ws-chat.

ws-push отправляет уведомления пользователям, когда они не находятся в сеансе.

/ws-push channel:

Вверх: подписка на push-уведомления: {userToken: «xxx»}.

Вниз: acceptMsg: {uid: «xxx», nickname: «xxx», avatar: «xxx», sessionid: «xxx», sessionName: «xxx», sessionIcon: «xxx», msgType: «accept», content: «xxx», dateline: «xxx»}, rejectMsg: {uid: "", nickname: "", avatar: "", sessionid: "", sessionName: "", sessionIcon: "", msgType: "reject", content: "xxx", dateline: "xxx"}, keepAlive: {uid: "", nickname: "", avatar: "", sessionid: "", sessionName: "", sessionIcon: "", msgType: "keepalive", content: "", dateline: "xxx"} и textMsg: {uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "text", content: "xxx", dateline: "xxx"}.