|
19 | 19 | - [4.7 websocket 支持](#47-websocket-支持)
|
20 | 20 | - [4.8 系统主题](#48-系统主题)
|
21 | 21 | - [4.9 消息桥接支持](#49-消息桥接支持)
|
22 |
| -- [5 路线图](#5-路线图) |
| 22 | +- [5 开发者说](#5-开发者说) |
23 | 23 | - [6 附表](#6-附表)
|
24 | 24 | - [6.1 配置项](#61-配置项)
|
25 | 25 | - [6.2 版本说明](#62-版本说明)
|
|
29 | 29 |
|
30 | 30 | ## 1 介绍
|
31 | 31 |
|
32 |
| -`Mqttx` 基于 [mqtt v3.1.1](http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html) 协议开发,旨在提供 ***易于使用*** 且 ***性能优越*** 的 **mqtt broker**。 |
| 32 | +`Mqttx` 基于 [MQTT v3.1.1](http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html) 协议开发,旨在提供 ***易于使用*** 且 ***性能优越*** 的 **mqtt broker**。 |
33 | 33 |
|
34 | 34 | ### 1.1 快速开始
|
35 | 35 |
|
|
279 | 279 |
|
280 | 280 | **仅支持单向桥接:device(client) => mqttx => MQ**
|
281 | 281 |
|
282 |
| -## 5 开发计划 |
| 282 | +## 5 开发者说 |
283 | 283 |
|
284 | 284 | 1. 集群态考虑整合服务注册的功能,便于管理集群状态,可能会使用 `consul`,做不做看我后面的想法吧
|
285 | 285 |
|
|
293 | 293 |
|
294 | 294 | > 本来说要放一部分精力到 `mqttx-admin` 这个衍生项目的,但后来发现 `mqttx` 还有太多事情需要做,只能变更计划了。
|
295 | 295 |
|
296 |
| -5. `netty 4.1.52.Final 支持了 mqtt5`,em... |
| 296 | +4. `netty 4.1.52.Final 支持了 mqtt5`,em... |
297 | 297 |
|
298 | 298 | > `v1.0.5.RELEASE` 后,我会考虑支持 `mqtt5` 协议的,又是一个大工程啊。
|
299 | 299 |
|
300 |
| - |
| 300 | +5. [benchmark](#63-benchmark) 表明 mqttx 性能还有提升的可能,我将在 `v1.0.6.RELEASE` 改造 `pub/sub` 处理逻辑 |
| 301 | + |
| 302 | + > 主要是 `StringRedisTemplate` => `ReactiveStringRedisTemplate`,改**同步**为**异步** |
301 | 303 |
|
302 | 304 | 邮箱:85998282@qq.com,项目相关问题可以联系我。
|
303 | 305 |
|
|
352 | 354 |
|
353 | 355 | ### 6.2 版本说明
|
354 | 356 |
|
355 |
| -- **v1.0.5.RELEASE(开发中)** |
| 357 | +- **v1.0.6.RELEASE(开发中)** |
| 358 | + - [x] `redis` 同步转异步实现,提升性能 |
| 359 | +- **v1.0.5.RELEASE** |
356 | 360 | - [x] 测试模式支持
|
357 | 361 | - [x] `epoll` 支持,见 [https://netty.io/wiki/native-transports.html](https://netty.io/wiki/native-transports.html)
|
358 | 362 | - [x] 优化 `cleanSession` 消息处理机制
|
@@ -432,7 +436,7 @@ Result : broker=tcp://localhost:1883, clients=1000, totalCount=1000000, duration
|
432 | 436 | | ------------ | -------- | ------------ | -------------- | -------- | ---- | -------- | ------- |
|
433 | 437 | | `1000` | 发布消息 | `1024byte` | `1000` | 一百万 | `0` | `39.1s` | `25553` |
|
434 | 438 | | `1000` | 发布消息 | `1024byte` | `1000` | 一百万 | `1` | `67.1s` | `14897` |
|
435 |
| -| `1000` | 发布消息 | `1024byte` | `1000` | 一百万 | `2` | `115.3s` | 8667 | |
| 439 | +| `1000` | 发布消息 | `1024byte` | `1000` | 一百万 | `2` | `115.3s` | `8667` | |
436 | 440 |
|
437 | 441 | **资源消耗:`cpu: 25%`, `mem 440 MB`**
|
438 | 442 |
|
|
0 commit comments