main.go 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250
  1. package AiotSwitchSDK
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "github.com/nats-io/nats.go"
  7. "github.com/vmihailenco/msgpack/v5"
  8. "io/ioutil"
  9. "os"
  10. "path/filepath"
  11. "time"
  12. )
  13. // 协议基础信息
  14. var SwitchName string // 连接地址
  15. var SwitchConnect string // 连接地址
  16. var SwitchDescribe string // 协议描述
  17. // 参数配置模版
  18. var SwitchConfig = map[string]map[string]string{}
  19. var ns *nats.Conn
  20. var funPullHandleStruct func(T_topic string, T_data []byte) error
  21. /*
  22. name:服务名称 默认 程序名
  23. nats: NATS 地址 默认 nats://127.0.0.1:6503
  24. funPH: 平台-> Switch网关方法
  25. */
  26. func AiotSwitchInit(name, nats string, funPH func(T_topic string, T_data []byte) error) {
  27. funPullHandleStruct = nil
  28. if len(name) == 0 {
  29. name = filepath.Base(os.Args[0]) // 程序名
  30. }
  31. SwitchName = name
  32. if len(nats) == 0 {
  33. nats = "nats://127.0.0.1:6503" // 程序名
  34. }
  35. funPullHandleStruct = funPH
  36. initNats(nats)
  37. initConfig(SwitchName)
  38. funPullHandle(SwitchName)
  39. }
  40. func initNats(url string) {
  41. var err error
  42. // 连接Nats服务器
  43. ns, err = nats.Connect(url, nats.MaxReconnects(10), nats.ReconnectWait(10*time.Second),
  44. nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
  45. // handle disconnect error event
  46. fmt.Println("natsS.DisconnectErrHandler 断开 ", err)
  47. }),
  48. nats.ReconnectHandler(func(nc *nats.Conn) {
  49. // handle reconnect event
  50. fmt.Println("natsS.ReconnectHandler, 已经重新连接 ", err)
  51. }))
  52. if err != nil {
  53. fmt.Println("natsS 连接失败!", err)
  54. panic(any("natsS 连接失败!" + url))
  55. }
  56. if err != nil {
  57. fmt.Println("nats 连接失败!", err)
  58. panic(any(err))
  59. }
  60. fmt.Println("nats OK!")
  61. }
  62. // 配置文件
  63. func initConfig(name string) {
  64. Configjson := "./" + name + ".json"
  65. _, err := os.Stat(Configjson) // 用你的文件路径替换"/path/to/your/file"
  66. if os.IsNotExist(err) {
  67. fmt.Println("文件不存在")
  68. jsonData, err := json.Marshal(SwitchConfig)
  69. if err != nil {
  70. fmt.Println(err)
  71. }
  72. err = ioutil.WriteFile(Configjson, jsonData, 0644)
  73. if err != nil {
  74. fmt.Println("Error unmarshalling JSON:", err)
  75. }
  76. } else {
  77. fmt.Println("文件存在")
  78. jsonData, err := ioutil.ReadFile(Configjson)
  79. if err != nil {
  80. fmt.Println(err)
  81. }
  82. err = json.Unmarshal(jsonData, &SwitchConfig)
  83. if err != nil {
  84. fmt.Println("Error unmarshalling JSON:", err)
  85. }
  86. }
  87. }
  88. // 设备->平台 激活网关
  89. func AiotSwitchActiva() {
  90. // nats 注册 服务
  91. type Struct struct {
  92. T_SwitchName string
  93. T_SwitchConnect string
  94. T_SwitchDescribe string
  95. T_SwitchConfig map[string]map[string]string
  96. }
  97. b, _ := msgpack.Marshal(&Struct{T_SwitchName: SwitchName, T_SwitchConnect: SwitchConnect, T_SwitchDescribe: SwitchDescribe, T_SwitchConfig: SwitchConfig})
  98. // 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
  99. msg, err := ns.Request("/Switch/Init", b, 3*time.Second)
  100. if err != nil {
  101. fmt.Println(err)
  102. panic(any("nats 注册失败!"))
  103. }
  104. if len(msg.Data) != 0 {
  105. panic(any(string(msg.Data)))
  106. }
  107. }
  108. // 设备->平台 设备状态 1 在线 2 离线
  109. func AiotSwitchState(T_sn, T_password string, T_State int, T_Reason string) error {
  110. type Struct struct {
  111. T_sn string
  112. T_password string
  113. T_State int
  114. T_Reason string
  115. }
  116. b, _ := msgpack.Marshal(&Struct{T_sn: T_sn, T_password: T_password, T_State: T_State, T_Reason: T_Reason})
  117. // 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
  118. msg, err := ns.Request("/Switch/State", b, 3*time.Second)
  119. if err != nil {
  120. fmt.Println(err)
  121. return errors.New("通讯异常")
  122. }
  123. if len(msg.Data) != 0 {
  124. return errors.New(string(msg.Data))
  125. }
  126. return nil
  127. }
  128. // 设备->平台 验证
  129. func AiotSwitchVerify(T_sn, T_password string) error {
  130. type Struct struct {
  131. T_sn string
  132. T_password string
  133. }
  134. b, _ := msgpack.Marshal(&Struct{T_sn: T_sn, T_password: T_password})
  135. // 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
  136. msg, err := ns.Request("/Switch/Verify", b, 3*time.Second)
  137. if err != nil {
  138. fmt.Println(err)
  139. return errors.New("通讯异常")
  140. }
  141. if len(msg.Data) != 0 {
  142. return errors.New(string(msg.Data))
  143. }
  144. return nil
  145. }
  146. // 设备->平台 添加设备
  147. func AiotSwitchAdd(T_ProductID, T_ProductKey, T_sn, T_password string) error {
  148. type Struct struct {
  149. T_ProductID string
  150. T_ProductKey string
  151. T_sn string
  152. T_password string
  153. }
  154. b, _ := msgpack.Marshal(&Struct{T_sn: T_sn, T_password: T_password, T_ProductID: T_ProductID, T_ProductKey: T_ProductKey})
  155. // 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
  156. msg, err := ns.Request("/Switch/Add", b, 3*time.Second)
  157. if err != nil {
  158. fmt.Println(err)
  159. return errors.New("通讯异常")
  160. }
  161. if len(msg.Data) != 0 {
  162. return errors.New(string(msg.Data))
  163. }
  164. return nil
  165. }
  166. // 设备->平台
  167. func AiotSwitchPush(T_sn, T_password, T_topic string, T_data []byte) error {
  168. type Struct struct {
  169. T_sn string
  170. T_password string
  171. T_topic string
  172. T_data []byte
  173. }
  174. b, _ := msgpack.Marshal(&Struct{T_sn: T_sn, T_password: T_password, T_topic: T_topic, T_data: T_data})
  175. // 请求-响应, 向 test3 发布一个 `help me` 请求数据,设置超时间3秒,如果有多个响应,只接收第一个收到的消息
  176. msg, err := ns.Request("/Switch/Pull", b, 3*time.Second)
  177. if err != nil {
  178. fmt.Println(err)
  179. return errors.New("通讯异常")
  180. }
  181. if len(msg.Data) != 0 {
  182. return errors.New(string(msg.Data))
  183. }
  184. return nil
  185. }
  186. // 平台->设备
  187. func funPullHandle(T_name string) {
  188. ns.Subscribe("/Switch/"+T_name, func(m *nats.Msg) {
  189. go func(m *nats.Msg) {
  190. type Struct struct {
  191. T_topic string
  192. T_data []byte
  193. }
  194. var date_r Struct
  195. err := msgpack.Unmarshal(m.Data, &date_r)
  196. if err != nil {
  197. fmt.Println("Nats:", err)
  198. ns.Publish(m.Reply, []byte("Unmarshal 错误!"))
  199. return
  200. }
  201. // 防止 没有给方法报错
  202. if funPullHandleStruct != nil {
  203. err = funPullHandleStruct(date_r.T_topic, date_r.T_data)
  204. if err != nil {
  205. ns.Publish(m.Reply, []byte(err.Error()))
  206. return
  207. }
  208. }
  209. ns.Publish(m.Reply, []byte(""))
  210. }(m)
  211. })
  212. }