溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

怎么用Go語言實(shí)現(xiàn)UDP版聊天小工具

發(fā)布時間:2023-03-29 15:35:29 來源:億速云 閱讀:68 作者:iii 欄目:開發(fā)技術(shù)

這篇文章主要介紹“怎么用Go語言實(shí)現(xiàn)UDP版聊天小工具”的相關(guān)知識,小編通過實(shí)際案例向大家展示操作過程,操作方法簡單快捷,實(shí)用性強(qiáng),希望這篇“怎么用Go語言實(shí)現(xiàn)UDP版聊天小工具”文章能幫助大家解決問題。

代碼實(shí)現(xiàn)

server.go

package main
 
import (
	"bufio"
	"fmt"
	"io"
	"net"
	"os"
	"strings"
)
 
// 監(jiān)聽UDP協(xié)議進(jìn)行通信
 
func main() {
	// 建通udp端口, 傳入?yún)f(xié)議名稱與,UDPAddr類型的地址與端口
	listen, err := net.ListenUDP("udp", &net.UDPAddr{
		IP:   net.IPv4(127, 0, 0, 1),
		Port: 10000,
	})
	if err != nil {
		fmt.Println("listen udp port failed err:", err)
		return
	}
	// 函數(shù)結(jié)束關(guān)閉連接
	defer listen.Close()
	// 發(fā)送與接受數(shù)據(jù)
	for {
		var baby [1024]byte
		reader := bufio.NewReader(os.Stdin)
		// 接受數(shù)據(jù),傳入切片類型對象,baby[:]表示切片類型嗎,返回字節(jié)數(shù)與發(fā)送端地址與錯誤信息
		n, addr, err := listen.ReadFromUDP(baby[:])
		if err == io.EOF {
			fmt.Println("read ok, ", err)
			continue
		}
		if err != nil {
			fmt.Println("read data failed, err:", err)
			continue
		}
		fmt.Printf("Client:%v, remoteaddr:%v bytes:%v\n", string(baby[:n]), addr, n)
		// 發(fā)送數(shù)據(jù)
		fmt.Print("Server:")
		// 對輸入對內(nèi)容進(jìn)行格式輸出,對特殊字符進(jìn)行轉(zhuǎn)義,傳入的字節(jié)返回的字符串
		text, _ := reader.ReadString('\n')
		// 去掉開頭或結(jié)尾的空格
		msg := strings.TrimSpace(text)
		_, err = listen.WriteToUDP([]byte(msg), addr)
		if err != nil {
			fmt.Println("write to udp failed, err:", err)
			continue
		}
	}
}

client.go

package main
 
import (
	"bufio"
	"fmt"
	"net"
	"os"
	"strings"
)
 
func main() {
	// 與遠(yuǎn)端udp進(jìn)行通信, 傳入?yún)f(xié)議名稱與,UDPAddr類型的地址與端口
	listen, err := net.DialUDP("udp", nil, &net.UDPAddr{
		IP:   net.IPv4(127, 0, 0, 1),
		Port: 10000,
	})
	if err != nil {
		fmt.Println("connection udp port failed,err:", err)
		return
	}
	// 函數(shù)結(jié)束關(guān)閉連接
	defer listen.Close()
	// 發(fā)送與接受數(shù)據(jù)
	var baby [1024]byte
	for {
		// 發(fā)送數(shù)據(jù)
		fmt.Print("Client:")
		reader := bufio.NewReader(os.Stdin)
		text, _ := reader.ReadString('\n')
		// 去掉開頭或結(jié)尾的空格
		msg := strings.TrimSpace(text)
		if msg == "exit" {
			return
		}
		_, err = listen.Write([]byte(msg))
		if err != nil {
			fmt.Println("發(fā)送數(shù)據(jù)失敗,err:", err)
			return
		}
		// 接受數(shù)據(jù)
		n, desaddr, err := listen.ReadFromUDP(baby[:])
		if err != nil {
			fmt.Println("接收數(shù)據(jù)失敗,err:", err)
			return
		}
		fmt.Printf("Server:%v remoteaddr:%v bytes:%v\n", string(baby[:n]), desaddr, n)
	}
}

運(yùn)行效果

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

關(guān)于“怎么用Go語言實(shí)現(xiàn)UDP版聊天小工具”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識,可以關(guān)注億速云行業(yè)資訊頻道,小編每天都會為大家更新不同的知識點(diǎn)。

向AI問一下細(xì)節(jié)
AI