基于spring reactor3构建的即时通讯api。
2024-09-04 21:03:14
欢迎阅读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
最新文章
- 验证管理员权限(C#)
- DNG格式解析
- hibernate复合主键
- [ruby]Windows Ruby安装步骤
- 001 今天开始系统学习C#
- iOS - OC RunTime		运行时
- 5.2 i++
- 设置webconfig 解决asp.net上传文件过大问题
- oracle PL/SQL(procedure language/SQL)程序设计之异常(exception)
- ruby的命名约定
- HNOI2015滚粗记
- git入门超详细(转载)
- LINQ实现行列转换
- linux 的 ping 原理
- DATA VISUALIZATION – PART 1
- EF基于方法的查询语法
- Xshell 使用数字小键盘进行vim 写入操作.
- 第19章:MongoDB-聚合操作--聚合管道--$limit+$skip
- 利用for循环如何判定是水仙花数
- windows server 2003中用系统自带工具调整磁盘分区大小