網路通訊3：TCP互動通訊
摘要：
版權宣告：本文為博主尹成聯絡QQ77025077,微信18510341407原創文章，歡迎轉載侵權不究。 https://blog.csdn.net/yincheng01/article/details/84135860
服務端實現
import (
"fmt...
版權宣告：本文為博主尹成聯絡QQ77025077,微信18510341407原創文章，歡迎轉載侵權不究。 https://blog.csdn.net/yincheng01/article/details/84135860
服務端實現
import (
"fmt"
"net"
"os"
"strings"
)
func CheckErrorS(err error) {
if err != nil {
fmt.Println("網路錯誤", err.Error())
os.Exit(1)
}
}
func Processinfo(conn net.Conn) {
buffer := make([]byte, 1024) //開創緩衝區
defer conn.Close()//關閉連線
for {
n, err := conn.Read(buffer) //讀取資料
CheckErrorS(err)
if n != 0 {
//拿到客戶端地址
remoteAddr := conn.RemoteAddr()
msg := string(buffer[:n])
fmt.Println("收到訊息",msg, "來自", remoteAddr)
if strings.Contains(msg,"錢") {
conn.Write([]byte("fuckoff"))
break
}
conn.Write([]byte("已閱："+msg))
}
}
}
func main() {
//建立TCP伺服器
listener, err := net.Listen("tcp", "127.0.0.1:8898")
CheckErrorS(err)
defer listener.Close() //關閉網路
fmt.Println("伺服器正在等待")
for {
conn, err := listener.Accept() //新的客戶端連線
CheckErrorS(err)
//處理每一個客戶端
go Processinfo(conn)
}
}
客戶端實現
import (
"fmt"
"net"
"bufio"
"os"
)
func CheckErrorC(err error) {
if err != nil {
fmt.Println("網路錯誤", err.Error())
os.Exit(1)
}
}
func MessageSend(conn net.Conn) {
var msg string
reader := bufio.NewReader(os.Stdin) //讀取鍵盤輸入
for {
lineBytes, _, _ := reader.ReadLine() //讀取一行
msg = string(lineBytes)//鍵盤輸入轉化為字串
if msg == "exit" {
conn.Close()
fmt.Println("客戶端關閉")
break
}
_, err := conn.Write([]byte(msg)) //輸入寫入字串
if err != nil {
conn.Close()
fmt.Println("客戶端關閉")
break
}
}
}
func main() {
conn, err := net.Dial("tcp", "127.0.0.1:8898") //建立TCP伺服器
CheckErrorC(err)//檢查錯誤
defer conn.Close()
//傳送訊息中有阻塞讀取標準輸入的程式碼
//為了避免阻塞住訊息的接收，所以把它獨立的協程中
go MessageSend(conn)
buffer := make([]byte, 1024)
for {
n, err := conn.Read(buffer)
CheckErrorC(err)
msg := string(buffer[:n])
fmt.Println("收到伺服器訊息", msg)
if msg=="fuckoff"{
break
}
}
fmt.Println("連線已斷開")
}
學院Go語言視訊主頁
ofollow,noindex" target="_blank">https://edu.csdn.net/lecturer/1928