Golang✔️走进 Go 语言✔️ 第二十三课 UDP & TCP

Posted 2021-10-22 我是小白呀

【Golang】✔️走进 Go 语言✔️ 第二十三课 UDP & TCP

• 概述
• UDP 通信
• • 服务端
  • 客户端
  • 输出结果
• TCP
• • 服务端
  • 客户端
  • 输出结果

概述

Golang 是一个跨平台的新生编程语言. 今天小白就带大家一起携手走进 Golang 的世界. (第 23 课)

UDP 通信

UDP (User Datagram Protocal) 是一个简单的面向对象数据报的通信协议. 位于 OSI 模型的传输层. UDP 只提供数据不可靠传递, 一旦把应用程序的数据发送出去, 就不保留备份.

服务端

package main

import (
	"fmt"
	"net"
	"os"
)

func main() {

	// 创建UDP服务器
	udp_address, err := net.ResolveUDPAddr("udp", ":8848")
	if err != nil {
		fmt.Println("Error", err.Error())
		os.Exit(1)
	}

	// 开始监听
	conn, err := net.ListenUDP("udp", udp_address)
	if err != nil {
		fmt.Println("Error", err.Error())
		os.Exit(1)
	}

	// 关闭连接
	defer conn.Close()

	// 接收消息
	var buffer [30]byte // 缓冲
	n, address, err := conn.ReadFromUDP(buffer[:])

	if err != nil {
		fmt.Println("Error:", err.Error())
	}

	fmt.Println("收到消息:", string(buffer[:n]))

	// 发送消息, 根据地址
	_, err = conn.WriteToUDP([]byte("Hi, Client"), address)
	fmt.Println("发送消息: Hi, Client")

}

客户端

package main

import (
	"fmt"
	"net"
	"os"
)

func main() {

	// 建立网络连接
	conn, err := net.Dial("udp", "127.0.0.1:8848")

	if err != nil {
		fmt.Println("网络连接错误")
		os.Exit(1)
	}

	// 关闭网络
	defer conn.Close()

	// 发送消息
	conn.Write([]byte("Hi, Server"))
	fmt.Println("发送消息: Hi, Server")

	// 接收消息
	var msg[30] byte
	n, err := conn.Read(msg[0:])
	if err != nil {
		fmt.Println("网络连接错误")
		os.Exit(1)
	}

	fmt.Println("收到消息:", string(msg[0:n]))

}

输出结果

服务端:

收到消息: Hi, Server
发送消息: Hi, Client

客户端:

发送消息: Hi, Server
收到消息: Hi, Client

TCP

TCP (Transmission Control Protocol) 即传输控制协议. TCP 是一种面向连接的, 可靠的, 基于字节流的传输层通信协议.

三次握手:

• 三次握手是指建立一个 TCP 连接时需要客户端和服务端总共发送三个包确认连接的建立

四次挥手:

• 四次挥手即终止 TCP 连接. 就是指断开一个 TCP 连接时, 需要客户端和服务端总共发送 4 个包以确认连接的断开

服务端

package main

import (
	"fmt"
	"net"
)

func process_info(conn net.Conn) {

	// 缓冲区
	buffer := make([]byte, 1024)

	// 关闭连接
	for {
		// 读取数据
		nums, err := conn.Read(buffer)
		if err != nil {
			break
		}

		if nums != 0 {
			fmt.Println("收到消息:", string(buffer[:nums]))
		}
	}
}

func main() {

	// 创建TCP服务器
	listen_socket, err := net.Listen("tcp", "127.0.0.1:8898")
	if err != nil {
		fmt.Println("Error:", err.Error())
	}

	// 关闭
	defer listen_socket.Close()

	for {
		// 连接新客户端
		conn, err := listen_socket.Accept()
		if err != nil {
			fmt.Println("Error:", err.Error())
		}

		// 处理每一个客户端
		go process_info(conn)

	}

}

客户端

package main

import (
	"fmt"
	"net"
	"os"
)

func main() {

	// 建立网络连接
	conn, err := net.Dial("tcp", "127.0.0.1:8898")

	if err != nil {
		fmt.Println("网络连接错误")
		os.Exit(1)
	}

	// 关闭
	defer conn.Close()

	// 发送消息
	conn.Write([]byte("Hi, Server"))
	fmt.Println("发送消息: Hi, Server")

}

输出结果

服务端:

收到消息: Hi, Server
收到消息: Hi, Server
收到消息: Hi, Server

客户端:

发送消息: Hi, Server