search

wind-c / comqtt

A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
MIT License
877 stars 50 forks source link

server.Events.OnSubscribe, 加入订阅是没有打印信息 #35

Closed Hayast closed 1 year ago

Hayast commented 1 year ago

在main.go里加了server.Events.OnSubscribe // Add OnSubscribe Event Hook server.Events.OnSubscribe = func(filter string, cl events.Client, qos byte, isFirst bool) { fmt.Printf("<< OnSubscribe client subscribed %s: %s %d %t \n", cl.ID, filter, qos, isFirst) } 客户端订阅主题的时候没有打印出信息?

有例子参考是如何使用subscribe吗? 客户端接收不到订阅的主题.

Hayast commented 1 year ago

1680576693798

Hayast commented 1 year ago

server.Events.OnMessage = func(cl events.Client, pk events.Packet) (pkx events.Packet, err error) 这里有打印信息 如图

wind-c commented 1 year ago

是集群模式接不到消息吗？看你的代码是1.x版本的，建议升级到2.0

Hayast commented 1 year ago

升级到了2版本, 订阅出现 Subscribe Failed Unexpected QoS, SubACK failed, Please check MQTT broker ACL configuration, 要如何设置? image

Hayast commented 1 year ago

auth-mode: 1 # 0 Anonymous, 1 Username, 2 ClientID acl-mode: 0 # 0 Anonymous, 1 Username, 2 ClientID

acl-mode: 设0可以,

Hayast commented 1 year ago

自已先研究一下. 谢谢