Реализую WS-Discovery на Golang. Отправляю Probe мультикастом. Временами перестает работать. Методом проб и ошибок, опытным путем выяснил, что при процедуре включения/отключения брандмауэра Windows, все начинает работать. Но через какое-то время код снова перестает работать.
Листинг функции отправки UDP:
func sendUDPMulticast (msg* string, locAddr string) []string {
cnl := make(chan string)
var resEnv []string
UDPAddr,err := net.ResolveUDPAddr("udp","239.255.255.250:3702")
if err != nil {
fmt.Println("Error: " , err)
}
Conn, err := net.DialUDP("udp", nil, UDPAddr)
if err != nil {
fmt.Println("Error: " , err)
}
defer Conn.Close()
_, port, _ := net.SplitHostPort(Conn.LocalAddr().String())
address := "["+ locAddr + "]:" + port
go listenUDP(address, cnl)
buf := []byte(*msg)
_, err = Conn.Write(buf)
if err != nil {
fmt.Println(*msg, err)
}
for{
select {
case res, ok := <-cnl:
_ = res
if ok {
resEnv = append(resEnv, res)
} else {
fmt.Println("Channel closed!")
}
case <- time.After(time.Second*5):
fmt.Println("resEnv", resEnv)
return resEnv
}
}
return nil
}
Функция чтения:
func listenUDP( address string, cnl chan string ) {
UDPAddr,err := net.ResolveUDPAddr("udp", address)
if err != nil {
fmt.Println("Error: " , err)
}
ln, err := net.ListenUDP("udp", UDPAddr)
if err != nil {
return
}
defer ln.Close()
for {
buffer := make([]byte, 4096)
n, _, err := ln.ReadFrom(buffer)
if err != nil {
fmt.Println("Error: ", err)
}
cnl <- string(buffer[0:n])
}
}
Выяснил, что программа зависает на следующей строке:
n, _, err := ln.ReadFrom(buffer)
Может кто подсказать, почему программа зависает и для ее ввода в работоспособный режим необходимо включить и выключить брандмауэр?