Coolpy7技术手册
Search…
开始使用
OAuth2用户中心应用
MQTT协议基础知识
程序安装
CP7 消息服务器可跨平台运行在 Linux、FreeBSD、Mac OS X 或 Windows(Docker) 服务器上。
备注：
Coolpy7所有发行版没有特别说明的情况下只支持64bit系统，因为32bit操作系统最大只支持4G内存，作为高性能的消息服务系统，CP7需要大于4G的内存运行。
Coolpy7会出现可运行于简易设备的版本，例如MIPS框架基本上使用于OpenWrt操作系统。还有基于ARM的相关微型设备等等。
CP7运行终端概要
7.3.5.5版本开始ws-proxy服务已整合到cp7内核
基础功能服务器端
- 1.CP7核心服务器
- 2.CP7 TLS TCP 代理服务器
- 3.CP7 WebSocket 代理服务器
- 4.CP7 WebSocket TLS 代理服务器
- 5.CP7 数据库代理服务器
Coolpy7 应用程序说明
应用程序
默认端口
协议
说明
防火墙根据使用的 MQTT 接入方式，开启上述端口的访问权限。
扩展功能服务器端
扩展功能
开源地址
状态
说明
完整部署整套CP7消息系统(IOT)
硬件环境机器准备
服务名称
IP
协议
端口
备注
CP7核心服务
192.168.200.201
TCP
1883
CP7核心服务 TLS代理
192.168.200.202
TCP
8883
CP7 WS-TLS代理服务器
192.168.200.204
TCP
8084
CP7数据库代理
192.168.200.205
TCP
无
Mongodb数据库
192.168.200.206
TCP
27017
Gridfs->OSS
运行CP7核心服务
CP7核心服务是一个最原始最单纯功能完备的MQTT消息服务器端，包括功能有：QoS:0,QoS1,QoS2消息质量支持。Will消息支持等等。深入了解 https://mcxiaoke.gitbooks.io/mqtt-cn/content/
- 1.防止暴力连接攻击，对已连接客户端进行优先保护
- 2.防止空连接攻击，当用户连接建立后两秒钟内没有进行身份验证即主动关闭客户端连接
通过ssh进入服务器192.168.200.201，并确保你已经按照 https://coolpy7.gitbook.io/coolpy7book/kai-shi-shi-yong/start 配置服务器操作系统的网络优化配置。
CP7核心服务运行后会自行构当前目录下的data文件夹，此文件夹存放MQTT运行期所需求持久化的数据信息，使用的是开源项目 https://github.com/jacoblai/yiyidb，支持10亿级秒op的高性能数据库，数据库内核使用的是Leveldb技术。
1
# 下载服务器端
2
wget https://github.com/Coolpy7/Coolpy7/raw/master/go_build_Coolpy7_go_linux.zip
3
# 解压文件
4
unzip go_build_Coolpy7_go_linux.zip
5
# 提权
6
chmod -R 777 go_build_Coolpy7_go_linux
7
# 启动Coolpy7 启动参数
8
# l 当前服务Host地址 (默认为:1883即本地1883端口,此参数一般默认即可，无需配置)
9
# a 连接接入调度器最大线程，此值可防止暴力连接攻击，对已连接客户端进行优先保护 (默认值128)
10
./go_build_Coolpy7_go_linux
11
12
# 启动成功后会打印如下信息，即说明服务端已正常启动，host于1883端口，请确保相关防火墙配置可用
13
2018/10/29 12:59:55 Coolpy7 tcp is listening on [::]:1883
Copied!
一般需为程序提权才可以运行Linux服务，指令：chmod -R 777 go_build_Coolpy7_go_linux
CP7核心服务 TLS代理
此功能即为CP7核心服务提供TLS接入功能。通过ssh进入服务器192.168.200.202，并确保你已经按照 https://coolpy7.gitbook.io/coolpy7book/kai-shi-shi-yong/start 配置服务器操作系统的网络优化配置。
TLS服务需要对应域名的数字证书
以阿里云为例可以进入对应域名的管理后台下载证书，把key和pem文件复制到data文件夹下，并命名为server.key和server.pem
1
# 下载CP7 TLS代理 服务器端
2
git clone https://github.com/Coolpy7/Coolpy7-TLS-Poxy.git && cd Coolpy7-TLS-Poxy/bin
3
# 提权
4
chmod -R 777 go_build_Coolpy7_tls_go_linux_linux
5
# 启动Coolpy7 tls poxy
6
# r启动参数 CP7核心服务器所在ip或域名 (例：core.coolpy.net:1883 or 192.168.200.201:1883)
7
# l启动参数 当前服务Host地址 (默认为:8883即本地8883端口,此参数一般默认即可，无需配置)
8
./go_build_Coolpy7_tls_go_linux_linux -r=192.168.200.201:1883
9
10
# 启动成功后会打印如下信息，即说明服务端已正常启动，host于8883端口，请确保相关防火墙配置可用
11
2018/10/29 12:59:55 upstream 192.168.200.201:1883 ok
12
2018/10/29 12:59:55 Coolpy7 TLS proxy is listening on [::]:8883
Copied!
CP7核心服务 WS代理（此功能已整合到CP7内核）
此功能即为CP7核心服务提供WebSocket接入功能。默认端口为8083
- 1.千万级WebSocket代理服务器
- 2.支持防爆力攻击
CP7 WS服务 TLS代理
此功能即为CP7 WebSocket代理服务提供TLS接入功能。通过ssh进入服务器192.168.200.204，并确保你已经按照 https://coolpy7.gitbook.io/coolpy7book/kai-shi-shi-yong/start 配置服务器操作系统的网络优化配置。
1
# 下载CP7 WS TLS代理 服务器端
2
git clone https://github.com/Coolpy7/Coolpy7-WS-TLS-Poxy.git && cd Coolpy7-WS-TLS-Poxy/bin
3
# 提权
4
chmod -R 777 go_build_Coolpy7_ws_tls_go_linux_linux
5
# 启动Coolpy7 ws tls poxy
6
# r启动参数 CP7 WebSocket 代理服务器所在ip或域名 (例：core.coolpy.net:8083 or 192.168.200.201:8083)
7
# l启动参数 当前服务Host地址 (默认为:8084即本地8084端口,此参数一般默认即可，无需配置)
8
./go_build_Coolpy7_tls_go_linux_linux -r=192.168.200.203:8083
9
10
# 启动成功后会打印如下信息，即说明服务端已正常启动，host于8084端口，请确保相关防火墙配置可用
11
2018/10/29 12:59:55 upstream 192.168.200.203:8083 ok
12
2018/10/29 12:59:55 Coolpy7 TLS proxy is listening on [::]:8084
Copied!
CP7 DbPoxy数据库代理
CP7 DbPoxy数据库代理服务器支持 MongoDB、Mysql、Mssql、Pgsql等主流数据库。当使用mongodb作为数据库即可使用Gridfs特性支持文件存储功能，即可实现对象存储（Object Storage Service，简称OSS）功能。
单个DbPoyx数据库代理运行实例只允许连接一种数据库。支持多实例连接多种数据库提供服务器。
1
# 下载服务器端
2
git clone https://github.com/Coolpy7/DbPoxy.git && cd DbPoxy/bin
3
# 提权
4
chmod -R 777 go_build_Coolpy7_db_poxy_go_linux_linux
5
# 启动Coolpy7 DbPoxy
6
# c启动参数 当前服务配置文件路径 (默认为/data/dbpoxy.yml 此参数一般默认即可，无需配置)
7
./go_build_Coolpy7_db_poxy_go_linux_linux
8
9
# 启动成功后会打印如下信息，即说明服务端已正常启动，host于8083端口，请确保相关防火墙配置可用
10
2018/11/03 16:55:14 dbpoxy/mongodb/get OK, token: password
11
2018/11/03 16:55:14 mongodb ping ok
Copied!
本例使用mongodb演示并假设网络环境中在192.168.200.206中已运行一个未开户身份验证的mongod服务，并Host端口于27017
配置文件说明
1
#使用mongodb作为普通数据服务
2
DatabaseType: mongodb
3
#mongodb数据库连接字符串,即当前环境已经在运行的何意一个mongodb数据库实例
4
DatabaseConnectionString: mongodb://192.168.200.206:27017
5
6
#使用postgres作为普通数据服务
7
#更多sql数据库的连接字符串请参阅：https://github.com/go-xorm/xorm
8
#DatabaseType: postgres #mssql mysql postgres mongodb oss-gridfs
9
#DatabaseConnectionString: host=192.168.100.187 port=13246 user=postgres dbname=ldh sslmode=disable password=123456
10
11
#使用mongodb作为OSS服务
12
#DatabaseType: oss-gridfs
13
#mongodb数据库连接字符串,即当前环境已经在运行的何意一个mongodb数据库实例
14
#DatabaseConnectionString: mongodb://192.168.200.206:27017
15
16
#Coolpy7 Core服务地址信息
17
BrokerHost: 192.168.200.201
18
BrokerPort: 1883
19
20
#MQTT连接信息
21
BrokerClientId: dbpoxy
22
BrokerUser: dypoxy
23
BrokerPassword: dypoxy
24
BrokerClearSession: true
25
26
#日志文件
27
LogFilePath: dbpoxy.log
28
29
#端访问相关配置信息
30
#操作token，通过此定义可进行安全校验，在指令发出端需把此token填写一致指令才会被接受
31
#如果填写空即不进入任何安全校验
32
AccessToken: password
33
#本实例的操作topic，指令发出端对应的发布地址，及qos消息质量控制
34
OpTopics:
35
Topic: dbpoxy/mongodb/get
36
Qos: 0
Copied!
配置文件默认所有路径：/data/dbpoxy.yml
通过以上操作，我们已经得出一套完整的千万级MQTT消息系统。下一章介绍如何用客户端工具验证系统功能。
用户账户指南
当需要对接任何用户账号数据库时，请参阅 《Coolpy7(IOT)通用控制协议》一书，里边祥尽介绍如果通过协议实现对数据库的CURD操作。
Last modified 8mo ago