Rmessage 다운로드 - Rmessage 소스 코드 다운로드

Rmessage

기타 카테고리

1.0.0

다운로드

Rmessage 문서에 오신 것을 환영합니다.

기술 스택

Rmessage는 Reactor3를 사용하여 Reactor-Netty 프로젝트에 구축된 실시간 메시지 푸시 API입니다.

Reactor3 란 무엇입니까?
Reactor는 효율적인 수요 관리(예: "배압" 제어) 기능을 갖춘 JVM을 위한 완전히 비차단 반응형 프로그래밍 프레임워크입니다. CompletableFuture, Stream 및 Duration과 같은 Java 8 기능 API와 직접 통합됩니다. 비동기 시퀀스 API Flux([N] 요소용) 및 Mono([0|1] 요소용)를 제공하며 "Reactive Extensions 사양"을 완전히 따르고 구현합니다.
Reactor를 사용하면 어떤 이점이 있나요?
처리량이 높은 순수 비동기 코드를 구축하는 것은 매우 쉽고 spring5 [webflux] 프로젝트를 완벽하게 통합할 수 있습니다.

프로젝트 소개

Rmessage를 사용하려면 그룹 사용자 관계와 오프라인 메시지 저장소를 외부에서 관리해야 합니다. Rmessage는 지속성을 제공하지 않습니다. 테스트에서는 오프라인 메시지를 유지하기 위해 기본 처리기 메모리를 사용할 수 있습니다. 전체 프로젝트는 반응형 프로그래밍을 배우는 것을 목표로 순수 비동기 프로그래밍 아이디어를 사용하여 개발되었습니다.

코드 클라우드 주소
깃허브 주소

현재 지원되는 기능

비공개 채팅
그룹 채팅
오프라인 메시지 랜딩 및 풀링
오프라인 및 온라인 알림 관리
하트비트, 연결 인증 메커니즘
그룹 관계 관리
멀티 터미널 온라인 지원
현재는 TCP 프로토콜을 지원하며, 프로젝트 설계 시 멀티 프로토콜 확장을 고려하고 있습니다.
서버 측 사용자 정의 메시지 가로채기 지원
메시지 QOS 메커니즘(아직 구현되지 않음)

빠른 시작

섬기는 사람

Rmessage는 사용자 그룹 간의 관계를 관리하지 않고 인터페이스를 통해 외부에 노출시키기만 하면 됩니다.

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

구체적인 인터페이스 메소드 정의는 인터페이스 주석을 참조하세요.

UserHandler 인터페이스는 사용자 로그인 확인 등을 처리합니다.
OfflineHandler는 오프라인 메시지 저장을 처리하고 오프라인 메시지를 가져오기 위한 인터페이스입니다.
GroupHandler는 그룹에 속한 모든 사용자를 얻기 위한 인터페이스입니다.

고객

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