package acc import ( "encoding/json" "fmt" "joylink.club/bj-rtsts-server/third_party/message" "joylink.club/bj-rtsts-server/third_party/udp" "testing" ) func TestAccUdp(t *testing.T) { fmt.Println("准备启动服务...") addr := fmt.Sprintf("%v:%v", "127.0.0.1", "8899") server := udp.NewServer(addr, handle) server.Listen() for { } } func handle(d []byte) { ri := message.RadarInfo{} err := ri.Decode(d) if err == nil { jsonD, _ := json.Marshal(ri) fmt.Println(string(jsonD)) } }