Golang如何实现异步Udp Server接入数据
<pre><code>package main
import (
"net"
"log"
"os"
"fmt"
)
type Data struct{
C string
D *net.UDPAddr
}
const MAX_MTU int = 1024 * 64
var path string = "/data/flume-agent/log/go_xg_udp.log"
func main() {
// 创建监听
log.SetFlags(0)
file, err := os.OpenFile(path, os.O_CREATE|os.O_RDWR|os.O_APPEND, 0666)
if err != nil {
log.Fatalln("fail to create go_udp.log file!")
}
logger := log.New(file, "", log.LstdFlags|log.Llongfile)
logger.Println("started udp server")
socket, err := net.ListenUDP("udp4", &net.UDPAddr{
IP: net.IPv4(0, 0, 0, 0),
Port: 5141,
})
if err != nil {
logger.Println("监听失败!", err)
return
}
defer socket.Close()
c := make(chan Data, 1024) // 带缓冲的通道
for {
// 读取数据
data := make([]byte, MAX_MTU)
read, remoteAddr, err := socket.ReadFromUDP(data)
if err != nil {
logger.Println("读取数据失败!", err)
continue
}
go sets(string(data[:read]), remoteAddr, c)
select {
case k:=<-c:
fmt.Println(k.D.IP,k.C)
}
}
}
func sets(k string, remoteAddr *net.UDPAddr, c chan Data){
c<-Data{k, remoteAddr}
}
</code></pre>
折腾这样吧,发现之前发的没有用markdown标注，不好意思
原来udp启动之后，后面的并发不并发自己随便写就可以了，还是可以走到的
[参考:](https://tonychyi.wetofu.top/2015/11/25/async-udp-server-using-go/)https://tonychyi.wetofu.top/2015/11/25/async-udp-server-using-go/