Coolpy7社区版 是基于Epoll为通信核心开发的高性能MQTT服务库，专注于 物联网\即时通信\消息总线等 场景。
- 已经支持
MQTT协议支持支持MQTT3.1/MQTT3.1.1Qos全支持支持Qos0 Qos1 Qos2WebSocket提供高性能Websocket桥接MQTT服务JWT验证提供JWT密钥验证（token于password连接参数）- 支持
Linux（操作系统） - 防空连接攻击
- 防
Self Ddos攻击
这里 下载最新版本的各系统平台编译运行文件。
//Coolpy7 community版配置文件
{
//tcp服务端口号
"host": ":1883",
//tcp的tls服务pem证书路径
//例：/etc/aaa.pem
"tcp_tls_pem": "",
//tcp的tls服务key证书路径
//例：/etc/aaa.key
"tcp_tls_key": "",
//websocket服务端口号
"websocket_host": ":8083",
//websocket的tls服务pem证书路径
//例：/etc/aaa.pem
"websocket_tls_pem": "",
//websocket的tls服务key证书路径
//例：/etc/aaa.key
"websocket_tls_key": "",
//启用jwt验证功能，支持多jwt认证，通过","号分隔多个jwt
//例：jksjdfkjsdf,32234jsdkfj
"jwt_secret_key": "",
//防止ping包风暴影响性能，单位/秒，低于此值客户端ping包到达主动禁用此客户端
"self_ddos_deny": 59,
//离线消息补发触发器时间间隔，单位/秒
"lazy_msg": 30,
//防空连攻击，空接断开限时，单位/秒
"nil_conn_deny": 2,
//密码错误禁连限时，单位/秒
"block_time": 1800,
//密码容错次数，单位/次
"max_attempts": 5
}
参数文件路径:
- 配置文件固定文件名为conf.json并位于与本服务程序相同路径下
参数说明:
- 启动服务前请先确认相关执行权限
$ sudo chmod -x coolpy7_community_xxx
启动成功提示:
$ Coolpy7 Community On Port :1883
$ Coolpy7 Community Websocket On Port :8083
$ Coolpy7 v1.0.2 build golang v1.20.6
- kill -2 pid
./mqtt-stresser-linux-amd64 -broker tcp://172.18.157.151:1883 -num-clients 10 -num-messages 150 -rampup-delay 1s -rampup-size 10 -global-timeout 180s -timeout 20s
# Configuration
Concurrent Clients: 10
Messages / Client: 1500
# Results
Published Messages: 1500 (100%)
Received Messages: 992 (66%)
Completed: 0 (0%)
Errors: 0 (0%)
# Publishing Throughput
Fastest: 84124 msg/sec
Slowest: 19982 msg/sec
Median: 63101 msg/sec
< 26396 msg/sec 20%
< 45639 msg/sec 30%
< 52053 msg/sec 40%
< 58467 msg/sec 50%
< 77710 msg/sec 80%
< 84124 msg/sec 90%
< 90538 msg/sec 100%
# Receiving Througput
Fastest: 109125 msg/sec
Slowest: 18135 msg/sec
Median: 28378 msg/sec
< 27234 msg/sec 50%
< 36333 msg/sec 60%
< 45432 msg/sec 80%
< 90927 msg/sec 90%
< 118224 msg/sec 100%
./mqtt-stresser-linux-amd64 -broker tcp://172.18.157.151:1883 -num-clients 10 -num-messages 150 -rampup-delay 1s -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 1 -subscriber-qos 1
..........
# Configuration
Concurrent Clients: 10
Messages / Client: 1500
# Results
Published Messages: 1500 (100%)
Received Messages: 1500 (100%)
Completed: 10 (100%)
Errors: 0 (0%)
# Publishing Throughput
Fastest: 5699 msg/sec
Slowest: 5046 msg/sec
Median: 5295 msg/sec
< 5111 msg/sec 10%
< 5176 msg/sec 20%
< 5241 msg/sec 30%
< 5307 msg/sec 60%
< 5437 msg/sec 80%
< 5503 msg/sec 90%
< 5764 msg/sec 100%
# Receiving Througput
Fastest: 59043 msg/sec
Slowest: 25028 msg/sec
Median: 31189 msg/sec
< 28429 msg/sec 40%
< 31831 msg/sec 50%
< 35232 msg/sec 70%
< 38634 msg/sec 80%
< 52240 msg/sec 90%
< 62445 msg/sec 100%
./mqtt-stresser-linux-amd64 -broker tcp://172.18.157.151:1883 -num-clients 10 -num-messages 150 -rampup-delay 1s -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 2 -subscriber-qos 2
# Configuration
Concurrent Clients: 10
Messages / Client: 1500
# Results
Published Messages: 1500 (100%)
Received Messages: 1500 (100%)
Completed: 10 (100%)
Errors: 0 (0%)
# Publishing Throughput
Fastest: 3187 msg/sec
Slowest: 2841 msg/sec
Median: 3101 msg/sec
< 2876 msg/sec 10%
< 2910 msg/sec 20%
< 2945 msg/sec 30%
< 3049 msg/sec 40%
< 3083 msg/sec 50%
< 3152 msg/sec 80%
< 3187 msg/sec 90%
< 3221 msg/sec 100%
# Receiving Througput
Fastest: 36544 msg/sec
Slowest: 12518 msg/sec
Median: 22943 msg/sec
< 14921 msg/sec 20%
< 17323 msg/sec 40%
< 22128 msg/sec 50%
< 26934 msg/sec 70%
< 31739 msg/sec 80%
< 34141 msg/sec 90%
< 38946 msg/sec 100%