高并发C/S的TCP版本golang实现
生活随笔
收集整理的這篇文章主要介紹了
高并发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实现的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 用golang完成tcp协议传输
- 下一篇: golang基于UDP完成