Switch

main.go

@@ -12,6 +12,9 @@ import (
 	"time"
 )
 
+type Switch struct {
+}
+
 // 协议基础信息
 
 var SwitchName string     // 连接地址
@@ -46,6 +49,30 @@ func AiotSwitchInit(name, nats string, funPH func(T_topic string, T_data []byte)
 
 }
 
+// 初始化 NATS 服务
+func (s *Switch) initNats(url string) {
+	var err error
+	// 连接Nats服务器
+	ns, err = nats.Connect(url, nats.MaxReconnects(10), nats.ReconnectWait(10*time.Second),
+		nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
+			// handle disconnect error event
+			fmt.Println("natsS.DisconnectErrHandler 断开 ", err)
+		}),
+		nats.ReconnectHandler(func(nc *nats.Conn) {
+			// handle reconnect event
+			fmt.Println("natsS.ReconnectHandler, 已经重新连接 ", err)
+		}))
+	if err != nil {
+		fmt.Println("natsS 连接失败！", err)
+		panic(any("natsS 连接失败！" + url))
+	}
+
+	if err != nil {
+		fmt.Println("nats 连接失败！", err)
+		panic(any(err))
+	}
+	fmt.Println("nats OK！")
+}
 func initNats(url string) {
 	var err error
 	// 连接Nats服务器