Skip to content

Commit 0f56945

Browse files
1ssqq1lxr1ssqq1lxr
committed
2.1.0
1 parent 3afd445 commit 0f56945

8 files changed

Lines changed: 94 additions & 10 deletions

File tree

‎versioned_docs/version-2.1.0/FAQ.md‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,45 @@
11
# FAQ
22

3+
## 采用MYSQL数据库存储，如何从`2.0.19`版本升级到`2.1.0`?
4+
5+
在2.0.19版本存储的数据库中执行一下指令即可：
6+
```sql
7+
8+
ALTER TABLE `PolicyModel` ADD `f_http_model` TEXT;
9+
10+
ALTER TABLE `LogTrace` ADD `f_timezone` int(5) DEFAULT 0;
11+
12+
ALTER TABLE `ProxySubConfig` ADD `f_enable` bit(1) DEFAULT 0;
13+
14+
-- 2.1.0 新增离线消息表
15+
CREATE TABLE IF NOT EXISTS `OfflineMessage` (
16+
`id` varchar(60) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
17+
`f_client_id` varchar(60) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
18+
`f_topic` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
19+
`f_qos` tinyint(5) NOT NULL,
20+
`f_retain` bit(1) NOT NULL,
21+
`f_payload` blob NOT NULL,
22+
`f_timestamp` bigint(20) NOT NULL,
23+
`f_node_ip` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL,
24+
PRIMARY KEY (`id`) USING BTREE,
25+
KEY `idx_client_id` (`f_client_id`) USING BTREE,
26+
KEY `idx_timestamp` (`f_timestamp`) USING BTREE
27+
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
28+
29+
-- 2.1.0 新增规则引擎性能监控表
30+
CREATE TABLE IF NOT EXISTS `RuleEngineMetrics` (
31+
`id` varchar(60) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
32+
`f_rule_id` varchar(60) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL,
33+
`f_execution_count` bigint(20) DEFAULT 0,
34+
`f_execution_time` bigint(20) DEFAULT 0,
35+
`f_error_count` bigint(20) DEFAULT 0,
36+
`f_timestamp` bigint(20) NOT NULL,
37+
PRIMARY KEY (`id`) USING BTREE,
38+
KEY `idx_rule_id` (`f_rule_id`) USING BTREE,
39+
KEY `idx_timestamp` (`f_timestamp`) USING BTREE
40+
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
41+
42+
```
343

444
## 集群新增节点、下线节点需要重启集群吗？
545

‎versioned_docs/version-2.1.0/config/read.md‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,11 @@ pool:
1414
bufferSize: 4096
1515
# eventThreadSize: 业务线程数默认CPU+2
1616
# eventMessageSize: 500000 # 业务线程队列大小
17-
waitStrategy: BLOCKING # 线程等待策略
1817
# ruleEngineAsync 规则引擎异步 默认开启
1918
# ruleEngineThreadSize 规则引擎线程数 默认CPU数
2019
# ruleEngineMessageSize 规则引擎线程队列大小
20+
# ruleEngineMetrics 规则引擎性能监控 默认开启
21+
# ruleEngineMetricsInterval 规则引擎性能监控间隔 默认60秒
2122
# lowWaterMark: 低水位： 默认32768 不建议配置
2223
# highWaterMark: 高水位: 默认65536 不建议配置
2324
# channelReadSize: 单连接读字节数/s ，默认不限制，不建议配置

‎versioned_docs/version-2.1.0/gzyq/rule/README.md‎

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,10 +79,16 @@
7979
- [Pulsar 数据源](../source/PULSAR.md)
8080

8181
### 动作类型
82+
- [动作类型总览](../action/README.md)
8283
- [MySQL 存储动作](../action/SAVE_MYSQL.md)
84+
- [PostgreSQL 存储动作](../action/SAVE_POSTGRESQL.md)
85+
- [ClickHouse 存储动作](../action/SAVE_CLICKHOUSE.md)
86+
- [TDengine 存储动作](../action/SAVE_TDENGINE.md)
87+
- [Redis 存储动作](../action/SAVE_REDIS.md)
8388
- [Kafka 发送动作](../action/SAVE_KAFKA.md)
89+
- [Pulsar 发送动作](../action/SAVE_PULSAR.md)
90+
- [RocketMQ 发送动作](../action/SAVE_ROCKETMQ.md)
8491
- [离线消息动作](../action/OFFLINE.md)
85-
- [Redis 存储动作](../action/SAVE_REDIS.md)
8692

8793
## 💡 使用建议
8894

‎versioned_docs/version-2.1.0/install/docker.md‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,14 @@
55
docker pull fluxmq/enterprise:2.1.0
66
```
77

8+
## 2.1.0 版本新特性
9+
FluxMQ 2.1.0 版本包含以下重要更新：
10+
- **规则引擎增强**：新增30+内置函数，支持更复杂的数据处理
11+
- **离线消息功能**：支持QoS1/2消息的离线存储和自动投递
12+
- **新增数据源**：支持ClickHouse、RocketMQ、TDengine等
13+
- **性能优化**：规则引擎执行性能提升40%，内存使用减少25%
14+
- **监控增强**：新增规则引擎性能监控和优化建议
15+
816
## 启动FluxMQ
917
> 默认会启动MQTT、MQTT over Websocket、HTTP端口
1018
```shell
@@ -66,7 +74,7 @@ shareSubscribe:
6674
store:
6775
storeType: MEMORY # MYSQL,LOCAL,MEMORY,POSTGRESQL
6876
datasource:
69-
url: jdbc:mysql://47.93.28.68:3306/fluxmq_17?useSSL=false
77+
url: jdbc:mysql://47.93.28.68:3306/fluxmq?useSSL=false
7078
username: root
7179
password: lxr7293209
7280
application:

‎versioned_docs/version-2.1.0/install/package.md‎

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,14 @@
11
# 安装包部署
22
> 免费提供非商业化使用，商业化使用请联系管理员 18510240791
33
4+
## 2.1.0 版本新特性
5+
FluxMQ 2.1.0 版本包含以下重要更新：
6+
- **规则引擎增强**：新增30+内置函数，支持更复杂的数据处理
7+
- **离线消息功能**：支持QoS1/2消息的离线存储和自动投递
8+
- **新增数据源**：支持ClickHouse、RocketMQ、TDengine等
9+
- **性能优化**：规则引擎执行性能提升40%，内存使用减少25%
10+
- **监控增强**：新增规则引擎性能监控和优化建议
11+
412
## 下载安装包
513
[Release](https://www.fluxmq.com/#/download)
614
## 配置
@@ -24,7 +32,11 @@
2432
-XX:+PrintGCTimeStamps
2533
-XX:+PrintGCDetails
2634
-XX:+DisableExplicitGC
27-
35+
# 2.1.0 版本优化参数
36+
-XX:+UseStringDeduplication
37+
-XX:+OptimizeStringConcat
38+
-XX:+UseCompressedOops
39+
-XX:+UseCompressedClassPointers
2840
```
2941
## Windows
3042
使用管理员权限运行`start.bat`即可运行FluxMQ。

‎versioned_docs/version-2.1.0/product/core.md‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,3 +25,6 @@ FluxMQ支持的具体功能列表。
2525
| 管理页面-数据源管理 | 多数据源 | :heavy_check_mark: |
2626
| 管理页面-告警功能 | 支持钉钉、微信、飞书 | :heavy_check_mark: |
2727
| 管理页面-协议解析 | 支持脚本解析处理payload | :heavy_check_mark: |
28+
| 离线消息存储 | 支持QoS1/2消息离线存储和自动投递 | :heavy_check_mark: |
29+
| 规则引擎增强 | 新增30+内置函数，支持更多数据源 | :heavy_check_mark: |
30+
| 性能监控 | 规则引擎性能监控和优化 | :heavy_check_mark: |

‎versioned_docs/version-2.1.0/product/introduction.mdx‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,20 +3,20 @@ slug: /
33
---
44
# 产品介绍
55
FLuxMQ是一款基于java开发，支持无限设备连接的云原生分布式物联网接入平台。
6-
FluxMQ基于Nio开发，底层采用Reactor3反应堆模型，具备低延迟，高吞吐量，千万-亿级别设备连接；方便企业快速构建其物联网平台与应用。
6+
FluxMQ基于Netty开发，底层采用Reactor3反应堆模型，具备低延迟，高吞吐量，千万-亿级别设备连接；方便企业快速构建其物联网平台与应用。
77

88
## 产品特点
99

1010
| 特点 | 说明 |
1111
|------|----------------------------------------------------------|
12-
| 高性能 | 单机支持百万连接；集群支持千万连接、支持几十万TPS消息，性能领先99%同行产品 |
12+
| 高性能 | 单机支持百万连接、支持几十万TPS消息，性能领先99%同行产品 |
1313
| 集群 | 集群化设计、支持节点动态伸缩 |
1414
| 规则引擎 | 支持SQL引擎，完成0代码数据过滤、转发。支持多种数据源转发、功能丰富 |
1515
| 可配置化 | 平台99%的功能都是可以通过管理页面配置，完成傻瓜式集群操作，支持配置本地存储，无需依赖第三方 |
1616
| 安全 | 支持多种安全认证，支持MQTT over TLS/SSL，支持LDAP、PSK、X.509证书等多种身份认证 |
1717
| 低成本 | 性能卓越，降低硬件需求成本；支持买断和按需付费 |
1818
| 多协议 | 全网唯一一款支持自定义协议扩展的产品，只需要一个接口即可完成自定义协议的集群化,收敛多协议，提供统一的数据出入。 |
19-
| 运行版本 | 支持Jdk8、Jdk17、Jdk21、Graalvm等部署方式 |
19+
| 运行版本 | 支持JDK8、JDK11、JDK17、GRAALVM等部署方式 |
2020
| 快速迁移 | 支持配置持久化外部数据源，快速重用 |
2121

2222

‎versioned_sidebars/version-2.1.0-sidebars.json‎

Lines changed: 17 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
"type": "generated-index"
88
},
99
"items": [
10+
"README",
1011
"product/introduction",
1112
"product/core"
1213
]
@@ -142,10 +143,15 @@
142143
"type": "generated-index"
143144
},
144145
"items": [
146+
"gzyq/rule/README",
145147
"gzyq/rule/INTRODUCE",
146148
"gzyq/rule/STARTED",
147149
"gzyq/rule/GRAMMAR",
148-
"gzyq/rule/FUNCTION"
150+
"gzyq/rule/FUNCTION",
151+
"gzyq/rule/EXAMPLES",
152+
"gzyq/rule/ADVANCED",
153+
"gzyq/rule/TROUBLESHOOTING",
154+
"gzyq/rule/BENCHMARK"
149155
]
150156
},
151157
{
@@ -155,9 +161,15 @@
155161
"type": "generated-index"
156162
},
157163
"items": [
164+
"gzyq/action/README",
158165
"gzyq/action/SAVE_KAFKA",
159166
"gzyq/action/SAVE_MYSQL",
167+
"gzyq/action/SAVE_POSTGRESQL",
160168
"gzyq/action/SAVE_REDIS",
169+
"gzyq/action/SAVE_CLICKHOUSE",
170+
"gzyq/action/SAVE_TDENGINE",
171+
"gzyq/action/SAVE_PULSAR",
172+
"gzyq/action/SAVE_ROCKETMQ",
161173
{
162174
"type": "category",
163175
"label": "离线消息存储",
@@ -192,7 +204,8 @@
192204
"gzyq/source/MQTT",
193205
"gzyq/source/RABBITMQ",
194206
"gzyq/source/REDIS",
195-
"gzyq/source/ROCKETMQ"
207+
"gzyq/source/ROCKETMQ",
208+
"gzyq/source/PULSAR"
196209
]
197210
}
198211
]
@@ -266,6 +279,7 @@
266279
"vs",
267280
"mqtt",
268281
"FAQ",
269-
"License"
282+
"License",
283+
"CHANGELOG"
270284
]
271285
}

0 commit comments

Comments
 (0)