Téléchargement CookIM - Téléchargement du code source CookIM

Cookim - est une application de chat WebSocket distribuée basée sur AKKA

Prise en charge du message privé et du message de groupe
Soutien des serveurs de chat Communication en cluster
Maintenant, nous prenons en charge le message texte, le message de fichier et le message vocal. Merci pour le PR de FT115637850 pour le message vocal.

Logo Cookim

中文文档
Document anglais

Projet GitHub
Projet Oschina

Catégorie

Démo
1. Demo sur PC
2. Démo sur mobile
3. Lien de démonstration
Démarrer plusieurs nœuds Cookim dans Docker Compose
1. Démarrer Docker Compose
2. Ajouter des nœuds dans Docker Compose
3. Débogue dans le conteneur docker
4. Arrêter Docker Compose
Comment courir
1. Condition préalable
2. Code source de clone
3. Configuration et assemblage
4. Démarrer le serveur Cookim
5. Open Browser et Access Web Port 8080
6. Démarrer un autre serveur Cookim
7. Open Browser et Access Web Port 8081
Architecture
1. Image d'architecture
2. Graphique WebSocket Akka Stream
3. Spécification des tables mongoDB
4. Type de message WebSocket
Changelog
1. 0,1,0 snapshot
2. 0.2.0 snapshot
3. 0.2.4-napshot

Catégorie

### démo

Demo sur PC

instantané

Démo sur mobile

instantané

Lien de démonstration

https://im.cookeem.com

Démarrer plusieurs nœuds Cookim dans Docker Compose

Démarrer Docker Compose

Changez en répertoire CookIm, exécutez la commande ci-dessous, démarrez plusieurs nœuds Cookim Serveurs en mode Docker Compose. Cette façon commencera 3 conteneurs: Mongo, Cookim1 et Cookim2

$ git clone https://github.com/cookeem/CookIM.git

$ cd CookIM

$ sudo docker-compose up -d
Creating mongo
Creating cookim1
Creating cookim2

Après l'exécution de Docker Compose, utilisez différents navigateurs pour accéder aux URL ci-dessous pour vous connecter à CookIm1 et CookIm2

http: // localhost: 8080 http: // localhost: 8081

Catégorie

Ajouter des nœuds dans Docker Compose

Vous pouvez ajouter une configuration dans docker-compose.yml (dans le répertoire Cookim) pour ajouter des nœuds de serveur Cookim, cet exemple montre comment ajouter CookIm3 dans Docker Compose:

      cookim3 :
        image : cookeem/cookim
        container_name : cookim3
        hostname : cookim3
        environment :
          HOST_NAME : cookim3
          WEB_PORT : 8080
          AKKA_PORT : 2551
          SEED_NODES : cookim1:2551
          MONGO_URI : mongodb://mongo:27017/local
        ports :
        - " 8082:8080 "
        depends_on :
        - mongo
        - cookim1

Catégorie

Débogue dans le conteneur docker

Afficher la sortie des journaux cookim1

$ sudo docker logs -f cookim1

Exec dans Container cookim1 pour déboguer

$ sudo docker exec -ti cookim1 bash

Catégorie

Arrêter Docker Compose

$ sudo docker-compose stop
$ sudo docker-compose rm

Catégorie

Comment courir

Condition préalable

JDK 8+
Scala 2.11+
SBT 0.13.15
MongoDB 2.6 - 3.4

Catégorie

Code source de clone

git clone https://github.com/cookeem/CookIM.git

cd CookIM

Catégorie

Configuration et assemblage

Le fichier de configuration se localise sur conf/application.conf , veuillez vous assurer que votre configuration URI MongoDB.

mongodb {
  dbname = " cookim "
  uri = " mongodb://mongo:27017/local "
}

Assemblage du projet Cookim vers un pot de Fatjar, Jar Target Localisez à target/scala-2.11/CookIM-assembly-0.2.0-SNAPSHOT.jar

sbt clean assembly

Catégorie

Démarrer le serveur Cookim

Cookim utilise MongoDB pour stocker les messages de chat et les données des utilisateurs, assurez-vous de démarrer MongoDB avant de démarrer Cookim.

Il existe deux façons de démarrer Cookim Server: SBT et Java

un. SBT Debug Way:

$ cd # CookIM directory#

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

né Pack et compiler un pot de graisse:

$ sbt assembly

c. Java Production Way:

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

La commande ci-dessus a démarré un serveur Web Écouter le port 8080 et Akka System Listen Port 2551

Paramètres:

-a -h [-m] [-n] -s -w -a, - Akka-Port Akka Cluster Node Port -H, - Nom de la connexion Web actuelle du service Web actuel -M, - Mongo-Uri MongoDB Connexion URI, Exemple: MongoDB: // LocalHost: 27017 / Local -N, - Nat est Nat Nata avec virgule, exemple: localhost: 2551, localhost: 2552 -w, - port de service Web de port Web

Catégorie

Open Browser et Access Web Port 8080

http: // localhost: 8080

Catégorie

Démarrer un autre serveur Cookim

Ouvrez un autre terminal, démarrez un autre serveur Cookim pour tester la communication des messages entre les serveurs:

un. SBT Debug Way:

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

né Java Production Way:

$ 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

La commande ci-dessus a démarré un serveur Web Écouter le port 8081 et Akka System Listen Port 2552

Catégorie

Open Browser et Access Web Port 8081

http: // localhost: 8081

Catégorie

Architecture

Image d'architecture

** Cookim Server à partir de 3 parties: **

AKKA HTTP: Fournir un service Web, Browser Connect Distributed Chat serveurs par WebSocket

AKKA Stream: AKKA HTTP reçoit le message WebSocket (le message WebSocket inclut TextMessage et BinaryMessage), puis envoyez le message à ChatService par Akka Stream Way, le message WebSocket inclut JWT (Token Web JavaScript), si JWT Vérifiez l'échec, ChatService Stream renvoie le message Reject; Si JWT vérifie le succès, ChatService Stream enverra un message à ChatSessionActor

CLUSTER AKKA ： Akka Stream Envoyer un message WebSocket à AKKA Cluster ChatSessionActor, ChatSessionActor Utilisez DistributedPubSub pour abonner et publier un message dans Akka Cluster. Lorsque l'utilisateur en ligne, il abonnera la session; Lorsque l'utilisateur envoie un message en session, il publiera un message dans Akka Cluster, les acteurs qui souscrivent la session recevront le message de publication

Catégorie

Graphique WebSocket Akka Stream

Ruisseau Cookim

Lorsque AKKA HTTP reçoit le désordre de WebSocket, il enverra un message à ChatService Flow, nous utilisons ici le graphique Akka Stream:

Le corps de message WebSocket inclut JWT, FlowFromws utilise pour recevoir le message WebSocket et Decode JWT;

Lorsque JWT vérifie la défaillance, il diffusera pour filtrerfailure pour filtrer le message échoué; Lorsque JWT vérifiera le succès, il diffusera pour filtrer le message de filtre à Success;

Lorsque AKKA Stream a créé, Builder.MaterializedValue enverra un message à ConnectedWS, ConnectedWS convertit le message Recevoir dans UserOnline Message, puis envoyez à ChatsInkactor Envoyer enfin à ChatSessionActor;

ChatactorsInk Envoyez un message à ChatSessionActeur, lorsque le flux AKKA fermé si vous enverra un message UserOffline à la baisse;

Chatsource reçoit le message de ChatSessionActor, puis renvoie le message à FlowAcceptBack;

FlowAcceptBack permettra à la connexion WebSocket Keepalive;

Les messages FlowReject et FlowACceptback enfin sont enfin envoyés à FlowbackWS, Flowbackws convertissent les messages au format WebSocket puis renvoie aux utilisateurs;

Catégorie

Spécification des tables mongoDB

Utilisateurs: table des utilisateurs

 *login (login email)
nickname (nickname)
password (password SHA1)
gender (gender: unknow:0, boy:1, girl:2)
avatar (avatar abs path, example: /upload/avatar/201610/26/xxxx.JPG)
lastLogin (last login timestamp)
loginCount (login counts)
sessionsStatus (user joined sessions status)
    [{sessionid: session id, newCount: unread message count in this session}]
friends (user's friends list: [friends uid])
dateline (register timestamp)

Sessions: Table des séances

 *createuid (creator uid)
*ouid (receiver uid, when session type is private available)
sessionIcon (session icon, when session type is group available)
sessionType (session type: 0:private, 1:group)
publicType (public type: 0:not public, 1:public)
sessionName (session name)
dateline (created timestamp)
usersStatus (users who joined this session status)
    [{uid: uid, online: (true, false)}]
lastMsgid (last message id)
lastUpdate (last update timestamp)

Messages: Tables de messages

 *uid (send user uid)
*sessionid (relative session id)
msgType (message type)
content (message content)
fileInfo (file information)
    {
        filePath
        fileName
        fileType
        fileSize
        fileThumb
    }
*dateline (created timestamp)

Onlines: Table des utilisateurs en ligne

 *uid (online user id)
dateline (last update timestamp)

Notifications: Recevoir le tableau des notifications

 noticeType (notification type: "joinFriend", "removeFriend", "inviteSession")
senduid (send user id)
*recvuid (receive user id)
sessionid (relative session id)
isRead (notification is read: 0:not read, 1:already read)
dateline (created timestamp)

Catégorie

Type de message WebSocket

Il y a deux canaux WebSocket: WS-push et WS-chat

WS-Push Envoyer des sessions de nouveaux messages aux utilisateurs, lorsque l'utilisateur n'est pas en ligne la session, ils peuvent toujours recevoir les sessions qui ont de nouveaux messages

/ canal WS-push

 up message, use to subscribe push message:
{ userToken: "xxx" }

down message:
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" }
fileMsg:       { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "file", fileName: "xxx", fileType: "xxx", fileid: "xxx", thumbid: "xxx", dateline: "xxx" }
onlineMsg:     { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "online", content: "xxx", dateline: "xxx" }
offlineMsg:    { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "offline", content: "xxx", dateline: "xxx" }
joinSessionMsg: { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "join", content: "xxx", dateline: "xxx" }
leaveSessionMsg:{ uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "leave", content: "xxx", dateline: "xxx" }
noticeMsg:     { uid: "", nickname: "", avatar: "", sessionid: "", sessionName: "xxx", sessionIcon: "xxx", msgType: "system", content: "xxx", dateline: "xxx" }

message push to browser:
pushMsg:       { 
                    uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "xxx", 
                    content: "xxx", fileName: "xxx", fileType: "xxx", fileid: "xxx", thumbid: "xxx",
                    dateline: "xxx" 
               }

Catégorie

WS-chat est la chaîne de chat de session, l'envoi de l'utilisateur et reçoivent des messages de session dans ce canal

 /ws-chat channel
up message: 
onlineMsg:     { userToken: "xxx", sessionToken: "xxx", msgType:"online", content:"" }
textMsg:       { userToken: "xxx", sessionToken: "xxx", msgType:"text", content:"xxx" }
fileMsg:       { userToken: "xxx", sessionToken: "xxx", msgType:"file", fileName:"xxx", fileSize: 999, fileType: "xxx" }<#BinaryInfo#>binary_file_array_buffer

down message:   
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" }
fileMsg:       { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "file", fileName: "xxx", fileType: "xxx", fileid: "xxx", thumbid: "xxx", dateline: "xxx" }
onlineMsg:     { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "online", content: "xxx", dateline: "xxx" }
offlineMsg:    { uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "offline", content: "xxx", dateline: "xxx" }
joinSessionMsg:{ uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "join", content: "xxx", dateline: "xxx" }
leaveSessionMsg:{ uid: "xxx", nickname: "xxx", avatar: "xxx", sessionid: "xxx", sessionName: "xxx", sessionIcon: "xxx", msgType: "leave", content: "xxx", dateline: "xxx" }
noticeMsg:     { uid: "", nickname: "", avatar: "", sessionid: "", sessionName: "xxx", sessionIcon: "xxx", msgType: "system", content: "xxx", dateline: "xxx" }

message push to browser:
chatMsg:       { 
                    uid: "xxx", nickname: "xxx", avatar: "xxx", msgType: "xxx", 
                    content: "xxx", fileName: "xxx", fileType: "xxx", fileid: "xxx", thumbid: "xxx",
                    dateline: "xxx" 
               }

Catégorie

Changelog

0,1,0 snapshot

Catégorie

0.2.0 snapshot

Cookim soutient désormais MongoDB 3.4.4
Mettre à niveau la version Akka vers 2.5.2
Mettre à jour le démarrage Docker-Compose Cookim Cluster Readme

Catégorie

0.2.4-napshot

Désormais, envisagez le message vocal Envoyer, le navigateur de support WebBrTC requis, maintenant Chrome Firefox et le nouveau Safari11 disponible.
Configurer les paramètres de connexion MongoDB par ligne de commande.
Mettre à jour le mode de démarrage Docker.

Catégorie

Développer