Rmessage

Willkommen bei der Rmessage-Dokumentation

Technologie-Stack

Rmessage ist eine Echtzeit-Nachrichten-Push-API, die auf dem Reactor-Netty-Projekt mit Reactor3 basiert.

• Was ist Reactor3?

  Reactor ist ein völlig blockierungsfreies reaktives Programmierframework für die JVM mit effizienten Nachfragemanagementfunktionen (d. h. Kontrolle des „Gegendrucks“). Es lässt sich direkt in Java 8-Funktions-APIs wie CompletableFuture, Stream und Duration integrieren. Es bietet die asynchrone Sequenz API Flux (für [N] Elemente) und Mono (für [0|1] Elemente) und folgt vollständig der „Reactive Extensions Specification“ und implementiert diese.

• Welche Vorteile bietet die Verwendung von Reactor?

  Es ist sehr einfach, reinen asynchronen Code mit hohem Durchsatz zu erstellen und Spring5-Projekte [Webflux] nahtlos zu integrieren.

Projekteinführung

Um Rmessage zu verwenden, müssen Sie Gruppenbenutzerbeziehungen extern verwalten und Rmessage bietet keine Persistenz. Tests können den Standard-Handler-Speicher verwenden, um Offline-Nachrichten aufzubewahren. Das gesamte Projekt wird unter Verwendung rein asynchroner Programmierideen entwickelt, mit dem Ziel, reaktives Programmieren zu erlernen.

• Code-Cloud-Adresse
• Github-Adresse

Derzeit unterstützte Funktionen

1. Privater Chat
2. Gruppenchat
3. Offline-Nachrichtenlandung und -Abruf
4. Offline- und Online-Benachrichtigungsverwaltung
5. Heartbeat, Verbindungsauthentifizierungsmechanismus
6. Gruppenbeziehungsmanagement
7. Unterstützen Sie Multi-Terminal online
8. Derzeit wird das TCP-Protokoll unterstützt und die Erweiterung um mehrere Protokolle wird beim Entwurf des Projekts berücksichtigt.
9. Unterstützt serverseitiges Abfangen benutzerdefinierter Nachrichten
10. Nachrichten-QOS-Mechanismus (noch nicht implementiert)

Schnellstart

• Server

Rmessage verwaltet nicht die Beziehung zwischen Benutzergruppen und macht es über die Schnittstelle nach außen sichtbar. Es muss lediglich die Schnittstelleninjektion implementiert werden.

 ServerStart
   . builder ()
   . tcp ()
   . ip ( "127.0.0.1" )
   . port ( 1888 )
   . onReadIdle ( 10000l ) //设置读心跳时间
   . onWriteIdle ( 10000l ) //设置写心跳时间
   . option ( ChannelOption . SO_RCVBUF , 1023 )
   . interceptor ( frame -> frame , frame -> frame ) // 拦截所有message
   . setAfterChannelInit ( channel -> { //  channel设置
      })
   . connect ()
   . cast ( TcpServerSession . class )
   . subscribe ( session ->{
                    session . addGroupHandler ( groupId -> null ). subscribe ();
                    session . addOfflineHandler ( new DefaultOffMessageHandler ()). subscribe ();
                    session . addUserHandler ( new DefaultUserTransportHandler ());
  });

Spezifische Schnittstellenmethodendefinitionen finden Sie in den Schnittstellenkommentaren.

1. Die UserHandler-Schnittstelle übernimmt die Überprüfung der Benutzeranmeldung usw.
2. OfflineHandler ist eine Schnittstelle zum Verarbeiten der Offline-Nachrichtenspeicherung und zum Abrufen von Offline-Nachrichten.
3. GroupHandler ist die Schnittstelle zum Abrufen aller Benutzer unter der Gruppe

• Kunde

 ClientStart
     . builder ()
     . tcp ()
     . ip ( "127.0.0.1" )
     . port ( 1888 )
     . userId ( "21344" )  //设置用户名
     . password ( "12312" ) //设置密码
     . onReadIdle ( 10000l ,()->()-> System . out . println ( "心跳了" )) //设置读心跳,以及设置回调runner
     . setClientType ( ClientType . Ios ) //设置客户端类型
     . setAfterChannelInit ( channel -> {
                    //  channel设置
      })
     . connect ()
     . cast ( TcpClientSession . class )
     . subscribe ( session ->{
      session . sendPoint ( "123" , "测试一下哦" ). subscribe (); //发送单聊消息
                    session . sendGroup ( "group1" , "123" ). subscribe ();  // 发送群聊消息
                    session . accept ( message -> {
    }); // 接受所有消息
  });

Protokolldesign

• Chatten Sie alleine und chatten Sie mehr

FixHeader【1 Byte】

client_type	Nachrichtentyp
hohe 4bit	niedrige 4bit

Thema 【n Bytes】

von der Länge	auf Länge	aus	Zu
1 Byte	1 Byte	n Bytes	n Bytes

Körper [n Bytes]

Körperlänge	Körper
2 Bytes	n Bytes

Zeitstempel
8 Byte

• Online-Nachricht

FixHeader【1 Byte】

client_type	Nachrichtentyp
hohe 4bit	niedrige 4bit

ConnectionState [n Byte]

Benutzerlänge	Passwortlänge	Benutzer	Passwort
1 Byte	1 Byte	n Bytes	n Bytes

• Offline-Nachricht

FixHeader【1 Byte】

client_type	Nachrichtentyp
hohe 4bit	niedrige 4bit

ConnectionState [n Byte]

Benutzerlänge	Benutzer
1 Byte	n Bytes

• Ping-Nachricht/Pong-Nachricht

FixHeader【1 Byte】

client_type	Nachrichtentyp
hohe 4bit	niedrige 4bit