go语言TCP编程入门
时间:2022-07-24
本文章向大家介绍go语言TCP编程入门,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
服务端
服务端的处理流程
- 监听端口8888
- 接收客户端的tcp连接
- 创建gorountine,处理该链接的请求(通常客户端会通过链接发送请求包)
客户端
客户端的处理流程
- 建立与服务端的链接
- 发送请求数据 (终端),接收服务器端返回的结果数据
- 关闭链接
简单的程序示意图
服务端与客户端的关系
服务端功能
- 编写一个服务端程序,在8888端口监听
- 可以和多个客户端创建链接
- 链接成功后,客户端可以发送数据,服务端接收数据,并且显示在终端上
- 先可以使用talnet来测试,然后编写客户端程序来测试
package main
import (
"fmt"
"io"
"net"
)
func process(conn net.Conn) {
defer conn.Close()
for {
buf := make([]byte, 1024)
//等待客户端通过conn发送信息
//如果客户端没有Write[发送],那么协程就阻塞在这里
//fmt.Printf("服务器在等待客户端%s, 发送信息n", conn.RemoteAddr().String())
n, err := conn.Read(buf)
if err == io.EOF {
fmt.Println("客户端退出")
return
}
if err != nil {
fmt.Println("服务器Read err", err)
return
}
//显示客户端发送的内容到服务器的终端
fmt.Println(string(buf[:n]))
}
}
func Server() {
//Listen函数创建的服务器
//头层皮:网络协议
//127.0.0.1:8888 8888本机ip和端口
l, err := net.Listen("tcp", "127.0.0.1:8888")
if err != nil {
fmt.Println("error:", err)
return
}
defer l.Close()
//循环等待客户端访问
for {
conn, err := l.Accept()
if err != nil {
fmt.Println("accept error", err)
}
fmt.Printf("访问客户端信息:con = %v 客户端ip=%vn", conn, conn.RemoteAddr())
go process(conn)
}
}
func main() {
Server()
}
客户端功能
- 编写一个客户端程序,能链接到服务端的8888窗口
- 客户端可以发送单行数据,然后就退出
- 能通过终端输入数据( 输入一行发送一行),并发送给服务器端
- 在终端输入exit,表示退出程序
import (
"bufio"
"fmt"
"net"
"os"
"strings"
)
func main() {
con, err := net.Dial("tcp", "0.0.0.0:8888")
if err != nil {
fmt.Println("connect err", err)
return
}
fmt.Println("con 成功=", con)
for {
//客户端可以发送单行数据,然后就退出
reader := bufio.NewReader(os.Stdin) //os.Stdin代表标准输入[终端]
//从终端读取一行用户输入,并准备发送给服务端
line, err := reader.ReadString('n')
if err != nil {
fmt.Println("readstring err = ", err)
}
line = strings.Trim(line, " rn")
if line == "exit" {
break
}
//再将line发送给服务器
n, err := con.Write([]byte(line))
if err != nil {
fmt.Println("con.write err = ", err)
}
fmt.Printf("发送了%d字节到服务器n", n)
}
fmt.Println("程序退出")
}
- SpringCloud配置中心高可用搭建
- hadoop压缩与解压
- cordova插件- Media
- JDK8之新特性扩展篇
- Java管理Cookie增删改查操作。
- Intellij Idea乱码解决方案都在这里了
- 神奇,教你用随机数打印hello world
- Mapreduce任务实现邮件监控
- Eclipse中Maven打包程序并在Linux中运行
- SDN开发笔记(七):L2switch源码分析(上)
- spark使用zipWithIndex和zipWithUniqueId为rdd中每条数据添加索引数据
- Spring Boot Server容器配置
- Spring Boot读取配置的几种方式
- 如何用TensorFlow构建RNN?这里有一份极简的教程
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Python 技术篇-文件操控:文件的移动和复制
- Python发邮件脚本,Python调用163邮箱SMTP服务实现邮件群发
- 为PXC集群引入Mycat并构建完整的高可用集群架构
- Python3 字典
- 安装Percona Server数据库(in CentOS 8)
- Python 基础篇-正斜杠("/")和反斜杠("")的用法
- 在CentOS8下搭建PXC集群
- Python 基础篇-相对路径、绝对路径的写法
- Python3 元组
- 关于MySQL的基准测试
- Python 技术篇-操作excel,对excel进行读取和写入
- Mycat 整合 MySQL 8.x 踩坑实践
- Python 技术篇-xlwt库不新建,直接读取已存在的excel并写入
- Python3 列表
- Mycat 核心配置详解