main.go 1.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. package main
  2. import (
  3. "flag"
  4. "fmt"
  5. "github.com/gogf/gf/frame/g"
  6. "github.com/gogf/gf/net/ghttp"
  7. )
  8. var (
  9. testURL = flag.String("url", "http://192.168.0.224:18100", "login url")
  10. testProductKey = flag.String("productkey", "958daf8b3a533f0d9516ac8fd17ef0cb06b439e664787a2a89608a10eeee8eb3c35c82c505d19f8a4417e530de0678fd", "product key")
  11. testProtocol = flag.String("protocol", "mqtt", "access protocol")
  12. )
  13. func main() {
  14. flag.Parse()
  15. if *testProductKey == "" {
  16. fmt.Println("product key not provided. use -productkey flag")
  17. return
  18. }
  19. dev := NewDevice(*testURL, *testProductKey, "5566", "1.2.5", *testProtocol)
  20. err := dev.DoRegister()
  21. if err != nil {
  22. fmt.Printf("device register error %s", err)
  23. return
  24. }
  25. err = dev.DoLogin()
  26. if err != nil {
  27. fmt.Printf("device login error %s", err)
  28. return
  29. }
  30. err = dev.DoAccess()
  31. if err != nil {
  32. fmt.Printf("device access error %s", err)
  33. return
  34. }
  35. go func() {
  36. s := g.Server()
  37. s.BindHandler("/", func(r *ghttp.Request) {
  38. r.Response.Write("哈喽世界!")
  39. })
  40. s.Run()
  41. }()
  42. }