【Golang】✔️走进 Go 语言✔️ 第二十四课 TCP 高阶操作
【摘要】
【Golang】✔️走进 Go 语言✔️ 第二十四课 TCP 高阶操作
概述基础知识Conn 接口net.Listen()listener.Accept()conn.Read()conn.Writ...
概述
Golang 是一个跨平台的新生编程语言. 今天小白就带大家一起携手走进 Golang 的世界. (第 24 课)
基础知识
Conn 接口
Conn 是一种通用的面向流的网络连接. 多个 Goroutine 可以同时调用 Conn 上的方法.
net.Listen()
监听本地网络的广播.
格式:
net.Listen(network, address string)
- 1
参数:
- network: 网络模式, “tcp”, “tcp4”, “tcp6”, “unix”, “unixpacket” 六选一
- address: 网络地址
例子:
listen_socket, err := net.Listen("tcp", "127.0.0.1:8888")
- 1
返回值:
- listen_socket: 监听接口
- err: 错误
listener.Accept()
连接客户端.
格式:
listener.Accept()
- 1
例子:
conn, err := listen_socket.Accept()
- 1
返回值:
- conn: 网络接口
- err: 错误
conn.Read()
读取信息.
格式:
conn.Read(b []byte)
- 1
例子:
nums, err := conn.Read(buffer)
- 1
返回值:
- nums: 读取的字节数
- err: 错误
conn.Write()
传输信息.
格式:
conn.Write(b []byte)
- 1
例子:
conn.Write([]byte("Hi, Server"))
- 1
交互式通信
服务器
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)
}
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
客户端
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
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
输出结果:
服务端:
服务端正在启动...
服务端启动完毕, 等待连接...
收到消息: 洞1洞1, 我是洞2 来自: 127.0.0.1:62831
发送消息: Message received
收到消息: 洞1洞1, 我是洞3 来自: 127.0.0.1:55002
发送消息: Message received
- 1
- 2
- 3
- 4
- 5
- 6
客户端:
客服端正在建立连接...
客户端成功连接到服务器, 服务器地址: 127.0.0.1:8888
洞1洞1, 我是洞3
收到消息: Message received
- 1
- 2
- 3
- 4
文章来源: iamarookie.blog.csdn.net，作者：我是小白呀，版权归原作者所有，如需转载，请联系作者。
原文链接：iamarookie.blog.csdn.net/article/details/119834557
【版权声明】本文为华为云社区用户转载文章，如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）