coolpy7 / coolpy7_benchmark Goto Github PK

Go 95.53% Shell 4.47%

coolpy7_benchmark's Introduction

Coolpy7

一个高性能、高稳定性的跨平台MQTT服务端

Coolpy7社区版开源地址:https://github.com/Coolpy7/Coolpy7_Community

一个高性能、高稳定性的跨平台MQTT服务端，基于EPOLL之上开发，可以在嵌入式设备（OpenWrt/Arm64）、Linux、Windows、Mac上使用，拥有完善Qos功能和配套开源周边功能库，以极少的资源实现优质的单机百万千万级MQTT服务，并且无缝衔接主流数据库。

优势：

具有极高的稳定性：无论是掉线重连，丢包重发，都是严格遵循MQTT协议标准执行，除此之外对大数据量的测试无论是收是发，都是非常稳定，高频测试也是非常稳定。
完善的技术文档：https://coolpy7.gitbook.io/coolpy7book/
多种技术客户端示例 APP(Android,Flutter);后端(Golang,Java,Nodejs,Python3,C#);前端(Electron,React,Vue,微信小程序,WebSocket);单片机(ESP8266)
性能测试项目，https://github.com/Coolpy7/coolpy7_benchmark
内核功能扩展服务，https://github.com/Coolpy7/coolpy7_extend_service
MQTT-SN项目，MQTT-SN网关，MQTT-SN下位机开发包，MQTT-SN网关
ESP8266下位机(单片机客户端)开发包，https://github.com/Coolpy7/EspSdk
数据库代理服务，https://github.com/Coolpy7/DbPoxy
TLS加密连接代理服务，https://github.com/Coolpy7/Coolpy7-TLS-Poxy
WebSocket-TLS代理服务，https://github.com/Coolpy7/Coolpy7-WS-TLS-Poxy
OATUTH2.0用户中心，Coolpy7用户中心服务器端，用户中心Web前端UI

应用示例

多种技术客户端示例 https://github.com/Coolpy7/mqtt-client-examples
上传图片或文件到DbPoxy代理服务器，https://github.com/Coolpy7/dbpoxyclient
Web浏览器应用示例，https://github.com/Coolpy7/mqtt_web_browser_client
微信小程序聊天室示例，https://github.com/Coolpy7/wxsmallapp
Web浏览器聊天室示例（可与微信小程序示例连同一Coolpy7后互相聊天）：https://github.com/Coolpy7/Cp7Chat
Web浏览器mqtt.js客户端示例， https://github.com/Coolpy7/mqttjs_browser_client_demo

整体框架

拥有非常明确的分层框架。

支持的平台

目前已实现了Linux、Mac、Arm64、Mips平台，除此之外更多框架需要使用，请提交Issues需求！

平台	代码位置
Linux	go_build_Coolpy7_go_linux.zip
Mac	go_build_Coolpy7_go_mac
Windows	docker_windows_coolpy7
Arm64	NanoPi,JetsonNano,树莓派等等...
Mips(le)	OpenWrt(MT7688)等等...

版本

发布版本	描述
[最新版本]	release下载

问题

欢迎以 GitHub Issues 的形式提交问题和bug报告

版权和许可

Coolpy7 遵循 MIT 开源协议。可以自由的使用、修改源代码，也可以将修改后的代码作为开源或闭源软件发布。也可直接用于商业项目。

QQ群

coolpy7_benchmark's People

Contributors

Stargazers

Watchers

Forkers

jaylee89 kangshifu1 skyformat99 abcde0818 zhuge10200 nicholasalx wjwzero zhouchang2017 leafseelight oatuilzz l60008028 rikun th997 yunnet isgasho

coolpy7_benchmark's Issues

为什么测试连接数增长很慢？

您好。

我按照您的这篇博客单机千万级MQTT连接服务器测试报告中使用的测试工具，就是当前这个测试工具进行测试。

我看您的连接数涨得非常快，基本1秒1000多：

而我这边测试订阅，连接数涨的很慢，几次测试都是，从0涨到1W需要1分钟左右，从1W涨到2W需要更长的时间

1、订阅的主题是直接复制的，就改了一下其中的url部分。

./go_build_cp7_bench_sub_go_linux -workers=4000000 -cid=tqy -topic=null -qos=0 -url=tcp://192.168.200.238:1883 -keepalive=60000s -clear=true

2、服务端、客户端相关参数也与博客中的几乎一致，部分数值可能不一样，不过那些数值不会影响到连接的速度。
3、两台服务器之间通过一个独立的千兆交换机（交换机上就接着我的笔记本，服务器A，服务器B）通讯。
4、使用jmeter进行测试过，那个连接增长的速度是正常的，很快能够涨到1W，接着2W。

您知道有可能是什么原因吗？

linxy.

invalid memory address or nil pointer dereference

2021/06/20 17:43:17 callback read tcp 172.18.88.182:10641->47.107.80.67:1883: read: connection reset by peer
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x724b3d]

goroutine 3011 [running]:
main.main.func1(0x0, 0x81b160, 0xc0012f45f0, 0x0, 0x0)
D:/GolandProjects/coolpy7_benchmark/test_bench_sub/cp7_bench_sub.go:39 +0x12d
client.(*Client).die.func1()
D:/GolandProjects/coolpy7_benchmark/src/client/client.go:848 +0xfa
sync.(*Once).Do(0xc001522c18, 0xc001544da8)
C:/Go/src/sync/once.go:44 +0xd1
client.(*Client).die(0xc001522b60, 0x81b160, 0xc0012f45f0, 0x810000, 0x0, 0x0)
D:/GolandProjects/coolpy7_benchmark/src/client/client.go:844 +0xa3
client.(*Client).processor(0xc001522b60, 0x0, 0x0)

同一局域网的两个客户端都使用当前工具对同服务端进行压测

先运行的客户端报错

在centos上无法运行报错信息如下

`2019/04/25 18:17:19 0
2019/04/25 18:17:19 conn no ip cat use
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x7241c9]

goroutine 1 [running]:
main.main()
D:/GolandProjects/coolpy7_benchmark/test_bench_sub/cp7_bench_sub.go:54 +0x4b9`

这个好像是找不到windows系统的路径？