Golang实现UDP Server

Server端

1、net.ListenUDP() 监听UDP服务

2、net.UDPConn.ReadFromUDP() 循环读取数据

3、net.UDPConn.WriteToUDP() 写数据

package main
import (
  "fmt"
  "log"
  "net"
)
func main() {
  // 监听UDP服务
  udpConn,err := net.ListenUDP("udp",&net.UDPAddr{
   IP: net.IPv4(0,0,0,0),
   Port: 9090,
  })
  if err != nil{
   log.Fatal("Listen failed,",err)
   return
  }
  // 循环读取消息
  for {
   var data [1024]byte
   n,addr,err := udpConn.ReadFromUDP(data[:])
   if err != nil{
     log.Printf("Read from udp server:%s failed,err:%s",addr,err)
     break
   }
   go func() {
     // 返回数据
     fmt.Printf("Addr:%s,data:%v count:%d \n",addr,string(data[:n]),n)
     _,err := udpConn.WriteToUDP([]byte("msg recived."),addr)
     if err != nil{
      fmt.Println("write to udp server failed,err:",err)
     }
   }()
  }
}

Client端

1、net.Dial() 建立连接

2、net.UDPConn.Write() 写数据

3、net.UDPConn.ReadFromUDP() 回复数据

package main
import (
  "fmt"
  "log"
  "net"
)
func main() {
  // 连接服务器
  conn,err := net.DialUDP("udp",nil,&net.UDPAddr{
   IP: net.IPv4(127,0,0,1),
   Port: 9090,
  })
  if err != nil {
   log.Println("Connect to udp server failed,err:",err)
   return
  }
  for i:=0;i<10;i++{
   // 发送数据
   _,err := conn.Write([]byte(fmt.Sprintf("udp testing:%v",i)))
   if err != nil {
     fmt.Printf("Send data failed,err:",err)
     return
   }
   //接收数据
   result := make([]byte,1024)
   n,remoteAddr,err := conn.ReadFromUDP(result)
   if err != nil{
     fmt.Printf("Read from udp server failed ,err:",err)
     return
   }
   fmt.Printf("Recived msg from %s, data:%s \n",remoteAddr,string(result[:n]))
  }
}

本文来自:51CTO博客

感谢作者:筑梦攻城狮

查看原文:Golang实现UDP Server

• 编辑
• 预览