pangum / mqtt Public

Notifications You must be signed in to change notification settings
Fork 1
Star 1

盘古MQTT集成，在原来MQTT框架的基础上增加了如下功能：1、深度与盘古框架集成（可以最大限度的加速业务系统的开发）；2、友好的API（在原来的API基础上，增加更易使用的API接口）；3、高度可配置（可以通过配置文件和Option来定制运行时功能）；4、动态Clientid；5、可定制序列化器（已集成JSON、Msgpack、Protobuf、XML以及各种内置类型）

mqtt.pangum.tech

Apache-2.0 license

1 star 1 fork Branches Tags Activity

Star

Notifications

Branches Tags

Name		Name	Last commit message	Last commit date
Latest commit History 126 Commits
.github		.github
core		core
doc		doc
example		example
http		http
verify		verify
webhook		webhook
.drone.yml		.drone.yml
.editorconfig		.editorconfig
.gitignore		.gitignore
.mergify.yml		.mergify.yml
LICENSE		LICENSE
README.md		README.md
broker.go		broker.go
brokers_option.go		brokers_option.go
client.go		client.go
client_http_subscription.go		client_http_subscription.go
client_mqtt.go		client_mqtt.go
config.go		config.go
connection.go		connection.go
const.go		const.go
go.mod		go.mod
handler.go		handler.go
http.go		http.go
labeled_server.go		labeled_server.go
logo.png		logo.png
message.go		message.go
message_option.go		message_option.go
mqtt.go		mqtt.go
mqtt_options.go		mqtt_options.go
option.go		option.go
option_defaults.go		option_defaults.go
option_delay.go		option_delay.go
option_label.go		option_label.go
option_qos.go		option_qos.go
option_retained.go		option_retained.go
option_save.go		option_save.go
option_serializer.go		option_serializer.go
option_validates.go		option_validates.go
pangu.go		pangu.go
pangu_config.go		pangu_config.go
protocol.go		protocol.go
publish_option.go		publish_option.go
reconnect.go		reconnect.go
retry.go		retry.go
serializer.go		serializer.go
session.go		session.go
setter.go		setter.go
subscribe_option.go		subscribe_option.go
subscription.go		subscription.go
timeout.go		timeout.go
will.go		will.go

Repository files navigation

mqtt

盘古框架Mqtt集成，方便用户在盘古框架中接入Mqtt功能

本框架对Mqtt做了一定的封装，使用参看使用文档

快速开始

Mqtt使用非常简单，只需要定义配置和依赖项

配置有很多，但是大部分都有默认值，可以参考配置文档

配置代码如下

mqtt: broker: - tcp://192.168.95.102:31883 - ws://192.168.95.102:38083 options: username: test_username password: test_password clientid: ${HOSTNAME}

依赖项的代码如下

package main import ( `github.com/pangum/mqtt` ) type agent struct { client *mqtt.Client } func newAgent(client *mqtt.Client) *agent { return &agent{ client: client, } } func (a *agent) subscribe() error { return a.client.Subscribe(`topic`, opts...) }