使用Go創(chuàng)建一個TCP服務器的操作步驟
一、實戰(zhàn)背景
相比 HTTP 請求響應,TCP 通信更底層、更靈活,適合用在:
- 游戲服務器
- 實時聊天程序
- 長連接服務
- 數(shù)據(jù)同步服務
本案例將實現(xiàn)一個簡單的 TCP 聊天 服務器:
- 支持多個客戶端連接
- 客戶端發(fā)送內(nèi)容,服務器打印并回應
- 演示并發(fā)連接處理
二、實戰(zhàn)目標
構建一個簡單的 TCP 網(wǎng)絡程序,包含兩個組件:
TCP服務器
- 啟動監(jiān)聽指定端口
- 接收多個客戶端連接
- 每條連接獨立處理,讀取數(shù)據(jù)并回復
TCP客戶端
- 連接到服務器
- 從終端輸入消息并發(fā)送
- 接收服務器返回的響應
三、完整代碼實現(xiàn)
1. TCP服務器代碼(server.go)
package main
import (
"bufio"
"fmt"
"net"
"strings"
)
func handleConnection(conn net.Conn) {
defer conn.Close()
addr := conn.RemoteAddr().String()
fmt.Println("客戶端連接:", addr)
reader := bufio.NewReader(conn)
for {
data, err := reader.ReadString('\n')
if err != nil {
fmt.Println("客戶端斷開:", addr)
return
}
msg := strings.TrimSpace(data)
fmt.Printf("收到[%s]: %s\n", addr, msg)
// 回復消息
response := fmt.Sprintf("服務端收到: %s\n", msg)
conn.Write([]byte(response))
}
}
func main() {
listener, err := net.Listen("tcp", ":8888")
if err != nil {
fmt.Println("啟動失敗:", err)
return
}
defer listener.Close()
fmt.Println("TCP服務器已啟動,監(jiān)聽端口 8888...")
for {
conn, err := listener.Accept()
if err != nil {
fmt.Println("連接失敗:", err)
continue
}
go handleConnection(conn)
}
}
2. TCP客戶端代碼(client.go)
package main
import (
"bufio"
"fmt"
"net"
"os"
"strings"
)
func main() {
conn, err := net.Dial("tcp", "127.0.0.1:8888")
if err != nil {
fmt.Println("連接服務器失敗:", err)
return
}
defer conn.Close()
fmt.Println("已連接到服務器。請輸入消息,輸入 exit 退出:")
reader := bufio.NewReader(os.Stdin)
for {
fmt.Print(">> ")
input, _ := reader.ReadString('\n')
input = strings.TrimSpace(input)
if input == "exit" {
fmt.Println("斷開連接")
return
}
// 發(fā)送消息
conn.Write([]byte(input + "\n"))
// 接收服務器響應
response, _ := bufio.NewReader(conn).ReadString('\n')
fmt.Println("服務器響應:", strings.TrimSpace(response))
}
}
四、運行方式
啟動服務器
go run server.go
輸出示例:
TCP服務器已啟動,監(jiān)聽端口 8888...
啟動客戶端(多個終端可同時運行)
go run client.go
輸入消息:
>> hello 服務器響應: 服務端收到: hello
服務器端輸出:
客戶端連接: 127.0.0.1:53458 收到[127.0.0.1:53458]: hello
五、關鍵技術點解析
1. net.Listen("tcp", ":8888")
用于監(jiān)聽本地 8888 端口,協(xié)議為 TCP。支持 IPv4、IPv6。
2. listener.Accept()
阻塞方法,等待客戶端連接。每當有新連接,就返回一個 net.Conn。
3. 并發(fā)處理連接
使用 go handleConnection(conn),每個客戶端獨立處理,避免阻塞。
4. bufio.NewReader(conn).ReadString('\n')
按行讀取客戶端發(fā)送內(nèi)容。注意客戶端必須發(fā)送換行(\n)結束,否則會阻塞。
5. 客戶端 net.Dial
客戶端使用 net.Dial("tcp", addr) 建立連接。注意服務端地址和端口應正確。
六、可擴展方向
| 方向 | 實現(xiàn)建議 |
|---|---|
| 廣播機制 | 使用 map[conn]bool 存儲連接,廣播消息 |
| 客戶端昵稱 | 每個連接輸入昵稱,并用于標識消息來源 |
| 心跳檢測 | 定期向客戶端發(fā)送 ping,判斷是否掉線 |
| JSON 協(xié)議 | 使用結構化數(shù)據(jù)通訊 |
| TLS 加密通信 | 使用 crypto/tls 加密 TCP 通道 |
| 多線程聊天室 | 支持多房間并發(fā)聊天 |
七、小結
通過本案例你掌握了:
- 如何編寫基本的 TCP 服務端和客戶端
- 使用 Goroutine 實現(xiàn)并發(fā)連接處理
- 使用
bufio.Reader/Writer實現(xiàn)按行讀寫 - 終端交互式發(fā)送/接收消息
這是構建分布式系統(tǒng)、即時通訊、遠程控制服務的基礎能力。
到此這篇關于使用Go創(chuàng)建一個TCP服務器的操作步驟的文章就介紹到這了,更多相關Go創(chuàng)建TCP服務器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Golang中interface轉(zhuǎn)string輸出打印方法
這篇文章主要給大家介紹了關于Golang中interface轉(zhuǎn)string輸出打印的相關資料,在go語言中interface轉(zhuǎn)string可以直接使用fmt提供的fmt函數(shù),文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-02-02
Golang時間及時間戳的獲取轉(zhuǎn)換超全面詳細講解
說實話,golang的時間轉(zhuǎn)化還是很麻煩的,最起碼比php麻煩很多,下面這篇文章主要給大家介紹了關于golang時間/時間戳的獲取與轉(zhuǎn)換的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2022-12-12
Go gorilla securecookie庫的安裝使用詳解
這篇文章主要介紹了Go gorilla securecookie庫的安裝使用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-08-08

