【Golang】??走进 Go 语言?? 第二十四课 TCP 高阶操作
概述
Golang 是一个跨平台的新生编程语言. 今天小白就带大家一起携手走进 Golang 的世界. (第 24 课)
基础知识
Conn 接口
Conn 是一种通用的面向流的网络连接. 多个 Goroutine 可以同时调用 Conn 上的方法.
net.Listen()
监听本地网络的广播.
格式:
net.Listen(network, address string)
参数:
- network: 网络模式, “tcp”, “tcp4”, “tcp6”, “unix”, “unixpacket” 六选一
- address: 网络地址
例子:
listen_socket, err := net.Listen("tcp", "127.0.0.1:8888")
返回值:
- listen_socket: 监听接口
- err: 错误
listener.Accept()
连接客户端.
格式:
listener.Accept()
例子:
conn, err := listen_socket.Accept()
返回值:
- conn: 网络接口
- err: 错误
conn.Read()
读取信息.
格式:
conn.Read(b []byte)
例子:
nums, err := conn.Read(buffer)
返回值:
- nums: 读取的字节数
- err: 错误
conn.Write()
传输信息.
格式:
conn.Write(b []byte)
例子:
conn.Write([]byte("Hi, Server"))
交互式通信
服务器
package main
import (
"fmt"
"net"
)
// 发送消息
func send_info(conn net.Conn) {
// 发送消息
_, err := conn.Write([]byte("Message received"))
error_check(err)
fmt.Println("发送消息: Message received")
}
// 接收消息
func receive_info(conn net.Conn) {
// 缓冲
buffer := make([]byte, 1024)
// 循环读取
for {
// 读取数据
nums, err := conn.Read(buffer)
if err != nil {
break
}
if nums != 0 {
// 获取地址
address := conn.RemoteAddr()
fmt.Println("收到消息:", string(buffer[:nums]), "来自:", address)
}
// 发送消息
send_info(conn)
}
}
// 错误处理
func error_check(err error) {
if err != nil {
fmt.Println("Error:", err)
}
}
func main() {
fmt.Println("服务端正在启动...")
// 创建TCP服务端
listen_socket, err := net.Listen("tcp", "127.0.0.1:8888")
error_check(err)
// 关闭
defer listen_socket.Close()
fmt.Println("服务端启动完毕, 等待连接...")
// 启动连接
for {
// 连接新客户端
conn, err := listen_socket.Accept()
error_check(err)
// 接收每一个客户端
go receive_info(conn)
}
}
客户端
package main
import (
"bufio"
"fmt"
"net"
"os"
)
// 发送消息
func send_msg(conn net.Conn) {
// 循环发送
for {
// 读取键盘输入
reader := bufio.NewReader(os.Stdin)
// 读取一行
data, _, _ := reader.ReadLine()
// 收到exit, 关闭客户端
if string(data) == "exit" {
fmt.Println("客户端关闭")
break
}
// 发送输入的字符串
_, err := conn.Write(data)
if err != nil {
conn.Close()
fmt.Println("Error:", err, "客户端关闭")
break
}
}
}
func main() {
fmt.Println("客服端正在建立连接...")
// 建立网络连接
conn, err := net.Dial("tcp", "127.0.0.1:8888")
if err != nil {
fmt.Println("网络连接错误")
os.Exit(1)
}
fmt.Println("客户端成功连接到服务器, 服务器地址:", conn.RemoteAddr())
// 发送消息
go send_msg(conn)
// 接收消息
buffer := make([]byte, 1024)
// 循环接收
for {
// 读取消息
nums, err := conn.Read(buffer)
if err != nil {
fmt.Println("Error:", err)
}
fmt.Println("收到消息:", string(buffer[:nums]))
}
}
输出结果:
服务端:
服务端正在启动...
服务端启动完毕, 等待连接...
收到消息: 洞1洞1, 我是洞2 来自: 127.0.0.1:62831
发送消息: Message received
收到消息: 洞1洞1, 我是洞3 来自: 127.0.0.1:55002
发送消息: Message received
客户端:
客服端正在建立连接...
客户端成功连接到服务器, 服务器地址: 127.0.0.1:8888
洞1洞1, 我是洞3
收到消息: Message received