开源软件名称：Rmessage
开源软件地址：https://gitee.com/lxrv587/Rmessage
开源软件介绍：
欢迎阅读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机制(还未实现)
maven依赖 <dependency> <groupId>com.github.1ssqq1lxr</groupId> <artifactId>rmessage-core</artifactId> <version>1.0.1</version> </dependency> 快速开始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 -> { }); // 接受所有消息 });协议设计FixHeader 【1 byte】 | client_type | message_type |
|---|
| high 4bit | low 4bit |
Topic 【n byte】 | from length | to length | from | to |
|---|
| 1byte | 1byte | n byte | n byte |
Body 【n byte】 | body length | body |
|---|
| 2 byte | n byte |
FixHeader 【1 byte】 | client_type | message_type |
|---|
| high 4bit | low 4bit |
ConnectionState 【n byte】 | user length | password length | user | password |
|---|
| 1byte | 1byte | n byte | n byte |
FixHeader 【1 byte】 | client_type | message_type |
|---|
| high 4bit | low 4bit |
ConnectionState 【n byte】 | user length | user |
|---|
| 1byte | n byte |
FixHeader 【1 byte】 | client_type | message_type |
|---|
| high 4bit | low 4bit |
 |
客服电话
APP下载
官方微信
请发表评论