首页 > 脚本中心 > Golang > Go语言实现UDP版聊天小工具的示例详解

Go语言实现UDP版聊天小工具的示例详解

福牛 3月 29, 2023 35 0

要看tcp版的小伙伴请移步：聊天小工具tcp版本

udp版本和tcp版本很像，都是分为server端和client端，具体代码如下

代码实现

server.go

  1. package main
  3. import (
  4.      “bufio”
  5.      “fmt”
  6.      “io”
  7.      “net”
  8.      “os”
  9.      “strings”
  10. )
  12. // 监听UDP协议进行通信
  14. func main() {
  15.      // 建通udp端口, 传入协议名称与，UDPAddr类型的地址与端口
  16.      listen, err := net.ListenUDP(“udp”, &net.UDPAddr{
  17.          IP: net.IPv4(127, 0, 0, 1),
  18.          Port: 10000,
  19.      })
  20.      if err != nil {
  21.          fmt.Println(“listen udp port failed err:”, err)
  22.          return
  23.      }
  24.      // 函数结束关闭连接
  25.      defer listen.Close()
  26.      // 发送与接受数据
  27.      for {
  28.          var baby [1024]byte
  29.          reader := bufio.NewReader(os.Stdin)
  30.          // 接受数据，传入切片类型对象，baby[:]表示切片类型吗，返回字节数与发送端地址与错误信息
  31.          n, addr, err := listen.ReadFromUDP(baby[:])
  32.          if err == io.EOF {
  33.              fmt.Println(“read ok, “, err)
  34.              continue
  35.          }
  36.          if err != nil {
  37.              fmt.Println(“read data failed, err:”, err)
  38.              continue
  39.          }
  40.          fmt.Printf(“Client:%v, remoteaddr:%v bytes:%v\n”, string(baby[:n]), addr, n)
  41.          // 发送数据
  42.          fmt.Print(“Server:”)
  43.          // 对输入对内容进行格式输出，对特殊字符进行转义，传入的字节返回的字符串
  44.          text, _ := reader.ReadString(‘\n’)
  45.          // 去掉开头或结尾的空格
  46.          msg := strings.TrimSpace(text)
  47.          _, err = listen.WriteToUDP([]byte(msg), addr)
  48.          if err != nil {
  49.              fmt.Println(“write to udp failed, err:”, err)
  50.              continue
  51.          }
  52.      }
  53. }

client.go

  1. package main
  3. import (
  4.      “bufio”
  5.      “fmt”
  6.      “net”
  7.      “os”
  8.      “strings”
  9. )
  11. func main() {
  12.      // 与远端udp进行通信, 传入协议名称与，UDPAddr类型的地址与端口
  13.      listen, err := net.DialUDP(“udp”, nil, &net.UDPAddr{
  14.          IP: net.IPv4(127, 0, 0, 1),
  15.          Port: 10000,
  16.      })
  17. if err != nil {
  18.          fmt.Println(“connection udp port failed，err:”, err)
  19.          return
  20.      }
  21.      // 函数结束关闭连接
  22.      defer listen.Close()
  23.      // 发送与接受数据
  24.      var baby [1024]byte
  25.      for {
  26.          // 发送数据
  27.          fmt.Print(“Client:”)
  28.          reader := bufio.NewReader(os.Stdin)
  29.          text, _ := reader.ReadString(‘n’)
  30.          // 去掉开头或结尾的空格
  31.          msg := strings.TrimSpace(text)
  32.          if msg == “exit” {
  33.              return
  34.          }
  35.          _, err = listen.Write([]byte(msg))
  36.          if err != nil {
  37.              fmt.Println(“发送数据失败，err:”, err)
  38.              return
  39.          }
  40.          // 接受数据
  41.          n, desaddr, err := listen.ReadFromUDP(baby[:])
  42.          if err != nil {
  43.              fmt.Println(“接收数据失败，err:”, err)
  44.              return
  45.          }
  46.          fmt.Printf(“Server:%v remoteaddr:%v bytes:%v\n”, string(baby[:n]), desaddr, n)
  47.      }
  48. }

运行效果

D:\Software\godata\src\0115\demo\client>go run main.go
Client:你好
Server:滚 remoteaddr:127.0.0.1:10000 bytes:3
Client:好的
Server:….. remoteaddr:127.0.0.1:10000 bytes:5
Client:exit

到此这篇关于Go语言实现UDP版聊天小工具的示例详解的文章就介绍到这了,更多相关Go语言聊天工具内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

标签

相关推荐

发表评论