Go语言核心编程（TCP）

根儿

第18章TCP编程

18.1网络编程基础介绍

Golang的主要设计目标之一就是面向大规模后端服务程序，网络通讯这一块是服务端程序必不可少也是至关重要的一部分。

• 网络编程有两种
  

• TCP socket编程，底层是基于Tcp/ip协议的。
  
• b/s结构的http编程，我们使用http协议访问服务器。而http的底层依旧是tcp socket的实现。
  

18.1.1协议tcp/ip

TCP/IP（Transmission Control Protocol/Internet Protocol)的简写,中文译名为传输控制协议/因特网互联协议，又叫网络通讯协议，这个协议是 Internet 最基本的协议、Internet 国际互联网络的基础，简单地说，就是由网络层的 IP 协议和传输层的 TCP 协议组成的。
18.1.2 OSI与Tcp/ip参考模型（推荐tcp/ip协议3卷内容）



18.1.3 ip地址

概述：每个internet上的主机和路由器都有一个ip地址，它包括网络号和主机号，ip地址有ipv4(32位)或者ipv6（128位），可以通过ipconfig查看。
18.1.4 端口（port）介绍

端口不是物理意义上的端口：特指tcp/ip协议中的端口，是逻辑意义上的端口。
注意：Ip地址的端口可以 有65536（256X256）个之多，端口是通过端口号来标记的，端口号只有整数，范围是0到65535 （256 X 256 -1）
18.1.5 端口（port）分类

• 0号是保留端口
  
• 1-024是固定端口
  22：SSH远程登录协议
  23：telnet 使用
  25：smtp服务使用
  21：ftp
  80：iis
  7：echo服务
  
• 动态端口：（1025-65535）
  18.1.4 端口的使用注意事项
  1）在计算机要尽量少的开端口
  2）一个端口只能被一个程序监听
  3）如果使用netstat -an 可以查看本机有哪些端口在监听
  4）可以使用netstat -anb来查看监听端口的pid在结合任务管理器关闭不安全的端口
  18.1.5 tcp socket 编程的客户端和服务端
  Golang socket 编程中客户端和服务端
  服务器代码：
  

18.2 tcp socket 编程
18.2.1 服务端处理流程
1）监听端口8888
2）接收客户端tcp链接，建立客户端和服务端的链接
3）创建goroutine,处理该链接的请求（通常客户端会通过链接发送请求包）
18.2.2 客户端处理流程
1）建立与服务端的链接
2）发送请求数据到终端，接收服务器返回的结果数据
3）关闭链接




18.2.3 代码实现
服务端：

• 编写一个服务端程序，在8888端口监听，可以和多个客户端创建链接，链接成功后，可，客户端可以发送数据，服务器可以接收到数据，并显示在终端上。
  服务端代码：
  

package main
import (
"fmt"
"net" //做网络 socket 开发时,net 包含有我们需要所有的方法和函数
_"io"
)
func process(conn net.Conn) {
//这里我们循环的接收客户端发送的数据
defer conn.Close() //关闭 conn
for {
//创建一个新的切片
buf := make([]byte, 1024)
//conn.Read(buf)
//1. 等待客户端通过 conn 发送信息
//2. 如果客户端没有 wrtie[发送]，那么协程就阻塞在这里
fmt.Printf("服务器在等待客户端%s 发送信息\n", conn.RemoteAddr().String())
n , err := conn.Read(buf) //从 conn 读取
if err != nil {
fmt.Printf("客户端退出 err=%v", err)
return //!!!
}
//3. 显示客户端发送的内容到服务器的终端
fmt.Print(string(buf[:n]))
}
}
func main() {
fmt.Println("服务器开始监听....")
//net.Listen("tcp", "0.0.0.0:8888")
//1. tcp 表示使用网络协议是 tcp
//2. 0.0.0.0:8888 表示在本地监听 8888 端口
listen, err := net.Listen("tcp", "0.0.0.0:8888")
if err != nil {
fmt.Println("listen err=", err)
return
}
defer listen.Close() //延时关闭 listen
//循环等待客户端来链接我
for {
//等待客户端链接
fmt.Println("等待客户端来链接....")
conn, err := listen.Accept()
if err != nil {
fmt.Println("Accept() err=", err)

} else {
fmt.Printf("Accept() suc con=%v 客户端 ip=%v\n", conn, conn.RemoteAddr().String())
}
//这里准备其一个协程，为客户端服务
go process(conn)
}
//fmt.Printf("listen suc=%v\n", listen)
}

• 客户端功能
  1）编写一个程序，链接到服务端的8888端口
  2）客户端可以发送单行数据，然后退出
  3）能通过终端输入数据（输入一行发送一行），并发送给服务器[]
  4）在终端输入exit,表示程序退出。
  客户端代码
  

package main
import (
"fmt"
"net"
"bufio"
"os"
)
func main() {
       
conn, err := net.Dial("tcp", "192.168.1.104:8888")
if err != nil {
   fmt.Println("client dial err=", err)
   return
}
//功能一：客户端可以发送单行数据，然后就退出
reader := bufio.NewReader(os.Stdin) //os.Stdin 代表标准输入[终端]
//从终端读取一行用户输入，并准备发送给服务器
line, err := reader.ReadString('\n')
if err != nil {
    fmt.Println("readString err=", err)
}
//再将 line 发送给 服务器
n, err := conn.Write([]byte(line))
if err != nil {
    fmt.Println("conn.Write err=", err)
}
fmt.Printf("客户端发送了 %d 字节的数据，并退出", n)

}

• 客户端代码改进
  在终端输入一行，发送一行，输入exit退出会话
  

for{
   //从终端读取一行用户输入，并准备发送给服务器
   line, err := reader.ReadString('\n')
   if err != nil {
        fmt.Println("readString err=", err)
   }

   line = strings.Trim(line," \r\n")
   //如果用户输入的内容是exit就退出程序
   if line == "exit"{
        fmt.Println("客户端退出。..")
        break
   }

• 两个客户端访问一个服务并产生会话
  

18.1经典项目-实战

18.1.1需求分析

1）用户注册

2）用户登录

3）显示在线用户列表

4）群聊

5）点对点聊天

6）离线留言

18.2界面设计



项目保存需要使用用户信息和消息数据，因此我们需要学习Redis。