日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

高并发C/S的TCP版本golang实现

發布時間:2024/4/18 编程问答 30 豆豆
生活随笔 收集整理的這篇文章主要介紹了 高并发C/S的TCP版本golang实现 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

前面一篇文章寫到的實現服務器只能連接一個客戶端,沒有發揮出go語言的協程特性,所以又可用如下方法實現高并發,多個客戶端連接來完成:

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

總結

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

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。