欢迎阅读Rmessage文档

技术栈

Rmessage是采用Reactor3,基于reactor-netty项目构建的实时消息推送api。

什么是Reactor3?

Reactor 是一个用于JVM的完全非阻塞的响应式编程框架，具备高效的需求管理（即对 “背压（backpressure）”的控制）能力。它与 Java 8 函数式 API 直接集成，比如 CompletableFuture， Stream，以及 Duration。它提供了异步序列 API Flux（用于[N]个元素）和 Mono（用于 [0|1]个元素），并完全遵循和实现了“响应式扩展规范”（Reactive Extensions Specification）。
使用Reactor好处?

非常容易构建高吞吐量纯异步的代码,还有就是能够无缝整合spring5[webflux]项目。

项目简介

使用Rmessage你需要外部管理群组用户关系,以及离线消息存储，Rmessage不提供持久化，测试可以使用默认Handler内存保留离线消息。
整个项目采用纯异步的编程思想去开发，旨在学习reactive programming。

目前支持的功能

单聊
群聊
离线消息落地以及拉取
离线在线通知管理
心跳,连接鉴权机制
群组关系管理
支持多端在线
目前支持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 -> {

    }); // 接受所有消息

  });

Github地址https://github.com/1ssqq1lxr/Rmessage

基于spring reactor3构建的即时通讯api。的更多相关文章

TCP UDP Socket 即时通讯 API 示例 MD
Markdown版本笔记我的GitHub首页我的博客我的微信我的邮箱 MyAndroidBlogs baiqiantao baiqiantao bqt20094 baiqiantao@sina ...
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯（三）
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯(三) 后台服务用户与认证新建一个空的.net core web项目Demo.Chat,端口配置为 ...
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯（二）
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯(二) IdentityServer4 用户中心生成数据库上文已经创建了所有的数据库上下文迁移代码 ...
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯（一）
IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯前言 .net core 2.1已经正式发布了,signalr core1.0随之发布,是时候写个 ...
基于SignalR的web端即时通讯 - ChatJS
先看下效果. ChatJS 是基于SignalR实现的Web端IM,界面风格模仿的是“脸书”,可以很方便的集成到已有的产品中. 项目官网:http://chatjs.net/ github地址:htt ...
基于Spring Boot构建的Spring MVC快速入门
原文地址:http://tianmaying.com/tutorial/spring-mvc-quickstart 环境准备一个称手的文本编辑器(例如Vim.Emacs.Sublime Text)或 ...
websocket(三)——基于node sockit.io的即时通讯
通过前面的学习发现,常见的websocket虽然可以很好地实现服务端和客户端的信息传递,但二者之间传递的数据只是简单的字符串,这对事物的描述,信息的传递是非常不友好的,下面将引入socket.io,来 ...
Spring Security构建Rest服务-0300-Restful API异常处理
SpringBoot默认的错误处理机制: 一.测试需要的部分代码 (完整代码放在了github https://github.com/lhy1234/spring-security): UserCon ...
基于Android 平台简易即时通讯的研究与设计[转]
摘要:论文简单介绍Android 平台的特性,主要阐述了基于Android 平台简易即时通讯(IM)的作用和功能以及实现方法.(复杂的通讯如引入视频音频等可以考虑AnyChat SDK~)关键词:An ...

随机推荐

Surface Shader简单向导
Surface Shader 表面着色器描述当你的Material要处理光照,则一般使用Surface Shader.Surface Shader隐藏了光照的计算,你只需要在surf函数里设置好反 ...
android源码环境下用mmm/mm编译模块，输出编译log到文件的方法
android源码环境下用mmm/mm编译模块,输出编译log到文件的方法 1,在android目录下直接用mmm命令编译, log信息保存在android目录下 mmm packages/apps/ ...
jquery mobile的事件
有个问题困扰了我两天,知道今天才解决. 那就是page的pagecreate事件,只调用一次如果想随时更新,就要调用pageshow事件,每次都会调用, 这个事情再次告诉我,基础要扎实啊,不然会浪费 ...
batch_size 和 fetch_size作用
hibernate抓取策略,,batch-szie在<class>上的应用 batch-size属性,可以批量加载实体类, hbm.xml classes.hbm.xml <?xml ...
WPF多线程演示
WPF中的几种处理线程的工作方式: 1.简单的DispatcherTimer类似Timer控件 2.需要处理UI同步时,Dispatcher DispatcherOpertion 3.增强的Threa ...
HTML5初学者福利！11个在线学习网站推荐
HTML5初学者福利!11个在线学习网站推荐 HTML5的强大及流行趋势,让更多的人想要系统的对它进行学习.而大多数人获取HTML5知识的重要途径都是网络,不过面对五花八门的搜索结果,是不是觉得摸不着 ...
2、粘包现象（struct模块）
昨天我们所做的套接字是有漏洞的,它会出现粘包现象,没有发现这个问题的我们今天会进行演示.今天也会稍微讲解一下基于udp的套接字. 一.基于udp的套接字 udp是无链接的,先启动哪一端都不会报错 ud ...
C#无限级分类递归显示示例
<%@ Page Language="C#" AutoEventWireup="true" CodeFile="RoleDemo20150305 ...
使用cmd查看电脑连接过的wifi密码并将密码发送至指定邮箱(三)
之前,我写了使用cmd查看电脑连接过的wifi密码(二)和使用cmd查看电脑连接过的wifi密码(一)但其中的功能不完善,在本次的更新中新增了更多的功能,其实2018/10/24 就更新完成了,一直拖 ...
实验1 C语言开发环境使用和数据类型，运算符，表达式
part :验证性内容 .输出学号. #include<stdio.h> int main(void){ printf("); ; } .输入两个整数,求它们的乘积. #incl ...

基于spring reactor3构建的即时通讯api。

欢迎阅读Rmessage文档

技术栈

项目简介

目前支持的功能

快速开始

Rmessage不管理用户群组之间关系,通过接口暴漏外部，只要实现接口注入即可。

具体接口方法定义请参照接口注释

基于spring reactor3构建的即时通讯api。的更多相关文章

随机推荐

热门专题