golang学习笔记017--tcp编程

golang学习笔记017--tcp编程,第1张

目录 1.网络基本介绍1.1网络编程有两种1.2 协议tcp/ip1.3OSI与TCP/IP参考模型1.4 IP地址1.5端口port1.6端口分类1.7端口注意事项 2.tcp socket编程快速入门2.1服务端处理流程2.2客户端处理流程2.3示意图2.4代码实现server.goclient.go运行结果

1.网络基本介绍 1.1网络编程有两种

● TCP socket编程,是网络编程的主流,底层是基于Tcp/ip协议。比如QQ
● b/s结构的http编程,使用浏览器访问服务器时,使用的就是http协议,而http协议底层依旧是用tcp socket实现的

1.2 协议tcp/ip

TCP/IP (Transmission Control Protocol/Internet Protocol)的简写,中文译名为传输控制协议/因特网互联协议,又叫网络通讯协议,这个协议是Internet最基本的协议、Internet国际互联网络的基础,简单地说,就是由网络层的IP协议和传输层的TCP协议组成的。

1.3OSI与TCP/IP参考模型


1.4 IP地址

每个internet上的主机和路由器都有一个ip地址,它包括网络号和主机号,IP地址有ipv4(32位)和ipv6(128位)

1.5端口port

● 这里的port不是指物理上的端口,而是特指TCP/IP协议中的端口,是逻辑意义上的端口
● 如果把P地址比作一间房子,端口就是出入这间房子的门。真正的房子只有几个门,但是一个IP地址的端口可以有65536(即:256×256)个之多!端口是通过端口号来标记的,端口号只有整数,范围是从0到65535(256×256-1)

1.6端口分类
● 0号是保留端口.
● 1-1024是固定端口(程序员不要使用),又叫有名端口,即被某些程序固定使用,一般程序员不使用.
  ○ 22:SSH远程登录协议﹑23 : telnet 使用21: ftp使用
  ○ 25: smtp服务使用、80: iis 使用、7: echo 服务
● 1025-65535是动态端口,这些端口,程序员可以使用.
1.7端口注意事项

● 在计算机尤其是服务器要尽可能的少开端口
● 一个端口只能被一个程序监听
● 如果使用netstat - an可以查看本机有哪些端口在监听
● 可以使用netstat - anb来查看监听端口的pid,在结合任务管理器关闭不安全的端口

2.tcp socket编程快速入门 2.1服务端处理流程

1)监听端口8888
2)接收客户端的 tcp链接,建立客户端和服务器端的链接.
3)创建goroutine,处理该链接的请求(通常客户端会通过链接发送请求包)

2.2客户端处理流程

1)建立与服务端的链接
2)发送请求数据[终端],接收服务器端返回的结果数据
3)关闭链接

2.3示意图

2.4代码实现 server.go
package main

import (
	"fmt"
	_ "io"
	"net" //做网络socket开发时,net包含有我们需要所有的方法和函数
)

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)
}
client.go
package main

import (
	"bufio"
	"fmt"
	"net"
	"os"
	"strings"
)

func main() {

	conn, err := net.Dial("tcp", "127.0.0.1:8888")
	if err != nil {
		fmt.Println("client dial err=", err)
		return
	}
	//功能一:客户端可以发送单行数据,然后就退出
	reader := bufio.NewReader(os.Stdin) //os.Stdin 代表标准输入[终端]

	for {

		//从终端读取一行用户输入,并准备发送给服务器
		line, err := reader.ReadString('\n')
		if err != nil {
			fmt.Println("readString err=", err)
		}
		//如果用户输入的是 exit就退出
		line = strings.Trim(line, " \r\n")
		if line == "exit" {
			fmt.Println("客户端退出..")
			break
		}

		//再将line 发送给 服务器
		_, err = conn.Write([]byte(line + "\n"))
		if err != nil {
			fmt.Println("conn.Write err=", err)
		}
	}

}
运行结果

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/langs/994259.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-05-21
下一篇 2022-05-21

发表评论

登录后才能评论

评论列表(0条)

保存