maintest.go 659 B

1234567891011121314151617181920212223242526272829303132333435
  1. package main
  2. import (
  3. "encoding/json"
  4. "log"
  5. "mfw/util"
  6. "net"
  7. )
  8. func main() {
  9. udpclient := util.UdpClient{Local: "127.0.0.1:1482", BufSize: 1024}
  10. udpclient.Listen(processUdpMsg2)
  11. m := map[string]string{
  12. "gtid":"5d19bf2fa5cb26b9b79b1994",
  13. "lteid":"5d19bf2fa5cb26b9b79b1995",
  14. }
  15. b, _ := json.Marshal(m)
  16. //for range time.Tick(time.Second){
  17. err := udpclient.WriteUdp(b, util.OP_TYPE_DATA, &net.UDPAddr{
  18. IP: net.ParseIP("172.17.145.163"),
  19. Port: 1481,
  20. })
  21. if err != nil{
  22. log.Println(err)
  23. return
  24. }
  25. log.Println("发送成功")
  26. //}
  27. select {
  28. }
  29. }
  30. func processUdpMsg2(act byte, data []byte, ra *net.UDPAddr) {
  31. log.Println(string(data))
  32. }