package main

import (
? ?"net"
? ?"fmt"
)

func main() {
? ?//創建TCPAddress變量,指定協議tcp4,監聽本機8899端口
? ?addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")

? ?//監聽TCPAddress設定的地址
? ?lis, _ := net.ListenTCP("tcp4", addr)

? ?fmt.Println("服務器已啟動")

? ?//阻塞式等待客戶端消息,返回連接對象,用于接收客戶端消息或向客戶端發送消息
? ?conn, _ := lis.Accept()

? ?//把數據讀取到切片中
? ?b := make([]byte, 256)
? ?fmt.Println("read之前")
? ?//客戶端沒有發送數據且客戶端對象沒有關閉,Read()將會阻塞,一旦接收到數據就不阻塞
? ?count, _ := conn.Read(b)
? ?fmt.Println("接收到的數據:", string(b[:count]))

? ?/*
? ?向客戶端發送數據
? ? */
? ?conn.Write([]byte("這是服務器傳遞的數據"))

? ?//關閉連接
? ?conn.Close()
? ?fmt.Println("服務器結束")
}

package main

import (
? ?"net"
? ?"fmt"
)

func main() {
? ?//服務器端ip和端口
? ?addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
? ?//申請連接客戶端
? ?conn, _ := net.DialTCP("tcp4", nil, addr)
? ?//向服務端發送數據
? ?count, _ := conn.Write([]byte("客戶端傳遞的數據"))
? ?fmt.Println("客戶端向服務端發送的數據量為:", count)

? ?/*
? ?接收服務器傳遞回來的數據
? ? */
? ?b := make([]byte, 256)
? ?c, _ := conn.Read(b)
? ?fmt.Println(string(b[:c]))

? ?關閉連接
? ?conn.Close()
? ?fmt.Println("客戶端結束")

}

package main

import (
? ?"net"
? ?"fmt"
)

func main() {
? ?addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
? ?lis, _ := net.ListenTCP("tcp4", addr)
? ?fmt.Println("服務器已啟動")

? ?/*
? ?服務器端添加死循環,不停的接收客戶端對象
? ? */
? ?for {
? ? ? conn, _ := lis.Accept()
? ? ? b := make([]byte, 256)
? ? ? count, _ := conn.Read(b)
? ? ? nc := string(b[:count])
? ? ? fmt.Println("接收到的數據:", nc)
? ? ? conn.Write([]byte("服務器:" + nc))
? ? ? conn.Close()
? ?}
? ?fmt.Println("服務器結束")
}

package main

import (
? ?"net"
? ?"fmt"
? ?"strconv"
)

func main() {
? ?//服務器端ip和端口
? ?addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")

? ?//通過循環,模擬發送五次客戶端請求
? ?for i := 1; i <= 5; i++ {
? ? ? conn, _ := net.DialTCP("tcp4", nil, addr)
? ? ? conn.Write([]byte("客戶端數據" + strconv.Itoa(i)))
? ? ? b := make([]byte, 256)
? ? ? c, _ := conn.Read(b)
? ? ? fmt.Println("第", i, "次服務器返回的數據:", string(b[:c]))
? ? ? conn.Close()
? ?}

? ?fmt.Println("客戶端結束")

}

package main

import (
? ?"net"
? ?"fmt"
)

func main() {
? ?addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
? ?lis, _ := net.ListenTCP("tcp4", addr)
? ?fmt.Println("服務器已啟動")

? ?/*
? ?服務器端添加死循環,不停的接收客戶端對象
? ? */
? ?for {
? ? ? conn, _ := lis.Accept()
? ? ? go func() { //在此處添加創建go func()即可
? ? ? ? ?b := make([]byte, 256)
? ? ? ? ?count, _ := conn.Read(b)
? ? ? ? ?nc := string(b[:count])
? ? ? ? ?fmt.Println("接收到的數據:", nc)
? ? ? ? ?conn.Write([]byte("服務器:" + nc))
? ? ? ? ?conn.Close()
? ? ? }()
? ?}
? ?fmt.Println("服務器結束")
}