服務端實現

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("連線已斷開")
}