前面一篇文章寫到的實(shí)現(xiàn)服務(wù)器只能連接一個(gè)客戶端，沒有發(fā)揮出go語言的協(xié)程特性，所以又可用如下方法實(shí)現(xiàn)高并發(fā)，多個(gè)客戶端連接來完成：

package mainimport ("fmt""net""strings" )// 服務(wù)器Read讀客戶端，返回0 說明對(duì)端關(guān)閉 func main() {// 創(chuàng)建監(jiān)聽套接字listener, err := net.Listen("tcp", "127.0.0.1:8001")if err != nil {fmt.Println("listen err", err)return}defer listener.Close()for {// 監(jiān)聽客戶端連接請(qǐng)求fmt.Println("服務(wù)器等待客戶端連接")conn, err := listener.Accept()if err != nil {fmt.Println("listener.Accept err", err)return}// 具體完成服務(wù)器和客戶端的數(shù)據(jù)通信go HandlerConnect(conn)}}func HandlerConnect(conn net.Conn) {defer conn.Close()// 獲取連接的客戶端Addraddr := conn.RemoteAddr()fmt.Println(addr, "客戶端成功連接---")// 循環(huán)讀取客戶端發(fā)送數(shù)據(jù)buf := make([]byte, 4096)for {n, err := conn.Read(buf)if n == 0 {fmt.Println("服務(wù)器檢測(cè)到客戶端已關(guān)閉，斷開連接")// 這里關(guān)閉的只是go線程，main線程還是在for循環(huán)的return}if err != nil {fmt.Println("conn Read err", err)return}fmt.Println("服務(wù)器讀到數(shù)據(jù)：", string(buf[:n]))// 小寫轉(zhuǎn)大寫回發(fā)conn.Write([]byte(strings.ToUpper(string(buf[:n]))))}}

總結(jié)

以上是生活随笔為你收集整理的高并发C/S的TCP版本golang实现的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。