|
@@ -2,13 +2,13 @@ package main
|
|
|
|
|
|
|
|
import (
|
|
import (
|
|
|
"context"
|
|
"context"
|
|
|
|
|
+ "fmt"
|
|
|
"strings"
|
|
"strings"
|
|
|
"sync"
|
|
"sync"
|
|
|
"sync/atomic"
|
|
"sync/atomic"
|
|
|
"time"
|
|
"time"
|
|
|
|
|
|
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
|
|
- "hnyfkj.com.cn/rtu/linux/baseapp"
|
|
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
const (
|
|
const (
|
|
@@ -48,13 +48,13 @@ func (c *MQTTCoupler) init() error {
|
|
|
|
|
|
|
|
opts.OnConnect = func(client mqtt.Client) {
|
|
opts.OnConnect = func(client mqtt.Client) {
|
|
|
if !c.isConnected.Swap(true) {
|
|
if !c.isConnected.Swap(true) {
|
|
|
- baseapp.Logger.Infof("[%s] MQTT Broker连接成功", MODULE_NAME)
|
|
|
|
|
|
|
+ fmt.Printf("[%s] MQTT Broker连接成功", MODULE_NAME)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
opts.OnConnectionLost = func(client mqtt.Client, err error) {
|
|
opts.OnConnectionLost = func(client mqtt.Client, err error) {
|
|
|
if c.isConnected.Swap(false) {
|
|
if c.isConnected.Swap(false) {
|
|
|
- baseapp.Logger.Warnf("[%s] MQTT Broker连接丢失: %v!", MODULE_NAME, err)
|
|
|
|
|
|
|
+ fmt.Printf("[%s] MQTT Broker连接丢失: %v!", MODULE_NAME, err)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -84,7 +84,7 @@ func (c *MQTTCoupler) tick() time.Duration {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if err := c.connect(); err != nil {
|
|
if err := c.connect(); err != nil {
|
|
|
- baseapp.Logger.Errorf("[%s] MQTT Broker连接失败: %v!!", MODULE_NAME, err)
|
|
|
|
|
|
|
+ fmt.Printf("[%s] MQTT Broker连接失败: %v!!", MODULE_NAME, err)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
return SlowInterval
|
|
return SlowInterval
|