README
¶
使用方法
go get -v -u github.com/worldflyingct/mqttserver
产品说明
GO语言版本并非完整的运行程序，仅仅是一个运行库，方便给自己开发的应用添加mqtt功能。
C语言版本的是完整的运行程序，所有的io操作都是异步非阻塞io，使用了epoll技术实现高并发。
Documentation
¶
Index ¶
- func CloseServer(ms *MqttServer)
- func GetMqttDataLength(data []byte, num uint32) (uint32, uint32)
- func HandleMqttClientRequest(ms *MqttServer, mqttclient *MqttClient)
- func HasSliceValue(arr []*string, d string) bool
- func ListenFastHttpWebSocket(ms *MqttServer, ctx *fasthttp.RequestCtx, params *WebSocketParam) error
- func ListenNetHttpWebSocket(ms *MqttServer, w http.ResponseWriter, r *http.Request, params *WebSocketParam) error
- func PublishData(ms *MqttServer, topic string, msg []byte)
- func RemoveClientFromMqttClients(ms *MqttServer, mqttclient *MqttClient)
- func RemoveSliceByValue(arrs []*string, d string) []*string
- func StartTcpServer(ms *MqttServer, tcpListen *net.TCPListener)
- type Callback
- type MqttClient
- type MqttServer
- type WebSocketParam
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseServer ¶
func CloseServer(ms *MqttServer)
func HandleMqttClientRequest ¶
func HandleMqttClientRequest(ms *MqttServer, mqttclient *MqttClient)
func HasSliceValue ¶
func ListenFastHttpWebSocket ¶
func ListenFastHttpWebSocket(ms *MqttServer, ctx *fasthttp.RequestCtx, params *WebSocketParam) error
func ListenNetHttpWebSocket ¶
func ListenNetHttpWebSocket(ms *MqttServer, w http.ResponseWriter, r *http.Request, params *WebSocketParam) error
func PublishData ¶
func PublishData(ms *MqttServer, topic string, msg []byte)
func RemoveClientFromMqttClients ¶
func RemoveClientFromMqttClients(ms *MqttServer, mqttclient *MqttClient)
func RemoveSliceByValue ¶
func StartTcpServer ¶
func StartTcpServer(ms *MqttServer, tcpListen *net.TCPListener)
Types ¶
type MqttClient ¶
type MqttClient struct {
// contains filtered or unexported fields
}
func (MqttClient) Close ¶
func (c MqttClient) Close() error
type MqttServer ¶
type MqttServer struct {
// contains filtered or unexported fields
}
func StartServer ¶
type WebSocketParam ¶
type WebSocketParam struct {
// contains filtered or unexported fields
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.