Switch del

main.go

@@ -12,9 +12,6 @@ import (
 	"time"
 )
 
-type Switch struct {
-}
-
 // 协议基础信息
 
 var SwitchName string     // 连接地址
@@ -49,30 +46,6 @@ 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服务器