文件名称:baetyl-broker
文件大小:81KB
文件格式:ZIP
更新时间:2024-06-20 06:29:03
Go
baetyl-broker 简介 Baetyl-Broker 基于 Golang 语言开发,是一个单机版地消息订阅和发布中心,采用 MQTT3.1.1 协议,可在低带宽、不可靠网络中提供可靠的消息传输服务。其作为 Baetyl 框架端侧的消息中间件,为所有服务提供消息驱动的互联能力。 目前支持 4 种接入方式:TCP、SSL(TCP + SSL)、WS(Websocket)及 WSS(Websocket + SSL),MQTT 协议支持度如下: 支持 Connect、Disconnect、Subscribe、Publish、Unsubscribe、Ping 等功能 支持 QoS 等级 0 和 1 的消息发布和订阅 支持 Retain、Will、Clean Session 支持订阅含有 +、# 等通配符的主题 支持符合约定的 ClientID 和 Payload 的校验 支持认证鉴权,在传输
【文件预览】:
baetyl-broker-master
----broker()
--------broker.go(974B)
--------broker_test.go(12KB)
----Dockerfile(269B)
----.gitignore(312B)
----README.md(5KB)
----.github()
--------workflows()
----session()
--------mqtt_test.go(59KB)
--------mqtt.go(13KB)
--------session.go(5KB)
--------event.go(552B)
--------map.go(886B)
--------cache.go(599B)
--------manager.go(7KB)
--------config.go(1KB)
--------mock_test.go(7KB)
--------config_test.go(1KB)
--------auth.go(4KB)
--------auth_test.go(21KB)
----LICENSE(11KB)
----listener()
--------manager.go(3KB)
--------manager_test.go(9KB)
----go.mod(381B)
----exchange()
--------exchange.go(2KB)
----program.yml(23B)
----queue()
--------queue.go(319B)
--------persistence.go(8KB)
--------temporary.go(2KB)
--------queue_test.go(8KB)
----common()
--------queue.go(81B)
--------event.go(2KB)
----example()
--------etc()
--------var()
----go.sum(45KB)
----store()
--------utils.go(495B)
--------pebble()
--------utils_test.go(274B)
--------db.go(1KB)
----Makefile(3KB)
----cmd()
--------main.go(1KB)