修改qos

mqtt_binding/mqtt_client/mqtt_client.go

@@ -220,7 +220,7 @@ func (c *MqttClient) rangeRouters(rangeFunc func(router *router.Router) error) e
 }
 
 func (c *MqttClient) subscribe(item *router.Item) error {
-	token := c.client.Subscribe(item.Topic, 0, func(client mqtt.Client, message mqtt.Message) {
+	token := c.client.Subscribe(item.Topic, 2, func(client mqtt.Client, message mqtt.Message) {
 		item.CallHandlers(message.Payload())
 	})
 	if token.Wait(); token.Error() != nil {