You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
35 lines
626 B
35 lines
626 B
2 weeks ago
|
package testUnit
|
||
|
|
|
||
|
|
import (
|
||
|
|
"goUpload/dbHelper"
|
||
|
|
"log"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestMqttRecv(t *testing.T) {
|
||
|
|
mqHelpers := dbHelper.MqttHelper{
|
||
|
|
Host: "10.8.30.160",
|
||
|
|
Port: 30883,
|
||
|
|
ClientId: "lzwjdq500101-lk",
|
||
|
|
UserName: "lzwjdq500101",
|
||
|
|
Password: "lzwjdq500101p",
|
||
|
|
}
|
||
|
|
mqHelpers.Initial()
|
||
|
|
topic := "udasUpload/#" //荔枝乌江大桥
|
||
|
|
//topic = "t/500103" //龙河桥
|
||
|
|
time.Sleep(time.Second * 1)
|
||
|
|
mqHelpers.Subscribe(topic, myHandle)
|
||
|
|
|
||
|
|
log.Println("=====开始订阅=====")
|
||
|
|
|
||
|
|
for {
|
||
|
|
time.Sleep(1 * time.Minute)
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
func myHandle(Topic string, Msg string) {
|
||
|
|
log.Printf("mqtt-recv:[%s]:%s", Topic, Msg)
|
||
|
|
}
|