Rmessage

Bienvenido a la documentación de Rmessage

pila de tecnología

Rmessage es una API de envío de mensajes en tiempo real construida en el proyecto reactor-netty utilizando Reactor3.

• ¿Qué es Reactor3?

  Reactor es un marco de programación reactiva completamente sin bloqueo para JVM, con capacidades eficientes de gestión de la demanda (es decir, control de "contrapresión"). Se integra directamente con las API funcionales de Java 8, como CompletableFuture, Stream y Duration. Proporciona la secuencia asincrónica API Flux (para [N] elementos) y Mono (para [0|1] elementos), y sigue e implementa completamente la "Especificación de extensiones reactivas".

• ¿Cuáles son los beneficios de utilizar Reactor?

  Es muy fácil crear código asincrónico puro de alto rendimiento y puede integrar perfectamente proyectos spring5 [webflux].

Introducción del proyecto

Para usar Rmessage, debe administrar externamente las relaciones de usuarios del grupo y el almacenamiento de mensajes sin conexión. Rmessage no proporciona persistencia. Las pruebas pueden usar la memoria del controlador predeterminada para retener mensajes sin conexión. Todo el proyecto se desarrolla utilizando ideas de programación puramente asíncrona, con el objetivo de aprender programación reactiva.

• dirección de nube de código
• dirección de github

Funciones actualmente admitidas

1. charla privada
2. chat grupal
3. Aterrizaje y extracción de mensajes sin conexión
4. Gestión de notificaciones en línea y fuera de línea
5. Latido del corazón, mecanismo de autenticación de conexión.
6. Gestión de relaciones grupales.
7. Soporte multiterminal en línea
8. Actualmente, se admite el protocolo TCP y se considera la expansión multiprotocolo al diseñar el proyecto.
9. Admite la interceptación de mensajes personalizados del lado del servidor
10. Mecanismo QOS de mensajes (aún no implementado)

inicio rápido

• Servidor

Rmessage no gestiona la relación entre grupos de usuarios y expone el exterior a través de la interfaz. Solo necesita implementar la inyección de interfaz.

 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 ());
  });

Para obtener definiciones de métodos de interfaz específicos, consulte los comentarios de la interfaz.

1. La interfaz UserHandler maneja la verificación de inicio de sesión del usuario, etc.
2. OfflineHandler es una interfaz para procesar el almacenamiento de mensajes sin conexión y extraer mensajes sin conexión.
3. GroupHandler es la interfaz para obtener todos los usuarios del grupo.

• cliente

 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 -> {
    }); // 接受所有消息
  });

Diseño de protocolo

• Chatea solo y chatea más

FixHeader【1 byte】

tipo_cliente	tipo_mensaje
alto 4 bits	bajo 4 bits

Tema 【n bytes】

de longitud	a la longitud	de	a
1 byte	1 byte	n bytes	n bytes

Cuerpo [n bytes]

longitud del cuerpo	cuerpo
2 bytes	n bytes

sello de tiempo
8 bytes

• mensaje en línea

FixHeader【1 byte】

tipo_cliente	tipo_mensaje
alto 4 bits	bajo 4 bits

Estado de conexión [n bytes]

longitud del usuario	longitud de la contraseña	usuario	contraseña
1 byte	1 byte	n bytes	n bytes

• Mensaje sin conexión

FixHeader【1 byte】

tipo_cliente	tipo_mensaje
alto 4 bits	bajo 4 bits

Estado de conexión [n bytes]

longitud del usuario	usuario
1 byte	n bytes

• Mensaje ping/mensaje Pong

FixHeader【1 byte】

tipo_cliente	tipo_mensaje
alto 4 bits	bajo 4 bits