51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记
时间:2022-05-04
本文章向大家介绍51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
Socket服务器是网络服务中常用的服务器。使用 go 语言实现这个业务场景是很容易的。
这样的网络通讯,需要一个服务端和至少一个客户端。
我们计划构建一个这样的通讯过程。服务端启动后等待客户端的访问。客户端发送一段信息给服务端。服务端接收信息后,再回馈给客户端一段信息。
首先要建立服务端。 服务端最先要做的事情就是“建立Socket端口监听”
netListen, err := net.Listen("tcp", "localhost:1024")
这样代码,表明监听的本机端口是 1024,而使用的通讯协议是 TCP。
当监听结束,模块任务完成时,最后要close这个netListen
defer netListen.Close()
使用日志功能,让服务端窗口能看到服务已经运行了。
Log("Waiting for clients ...")
之后使用一个 for 循环,无尽的等待那些不知何时来访问的客户端信息。
for 循环体内,要监听 netListen 的信息接收情况
conn, err := netListen.Accept()
当有来自客户端的访问时,接收访问。并且在服务端的日志记录已经有客户端连接成功了。
Log(conn.RemoteAddr().String(), "tcp connect success")
conn.RemoteAddr().String()
表示的就是远程客户端。
然后,我们开启一个 goroutine 处理连接任务。
go handleConnection(conn)
处理过程就是接收客户端信息和反馈给客户端信息
n, err := conn.Read(buffer)
conn.Write([]byte(strTemp))
服务端代码示例:
package main
import (
"net"
"fmt"
"os"
"log"
"time"
)
func main() {
//建立socket端口监听
netListen, err := net.Listen("tcp", "localhost:1024")
CheckError(err)
defer netListen.Close()
Log("Waiting for clients ...")
//等待客户端访问
for{
conn, err := netListen.Accept() //监听接收
if err != nil{
continue //如果发生错误,继续下一个循环。
}
Log(conn.RemoteAddr().String(), "tcp connect success") //tcp连接成功
go handleConnection(conn)
}
}
//处理连接
func handleConnection(conn net.Conn) {
buffer := make([]byte, 2048) //建立一个slice
for{
n, err := conn.Read(buffer) //读取客户端传来的内容
if err != nil{
Log(conn.RemoteAddr().String(), "connection error: ", err)
return //当远程客户端连接发生错误(断开)后,终止此协程。
}
Log(conn.RemoteAddr().String(), "receive data string:n", string(buffer[:n]))
//返回给客户端的信息
strTemp := "CofoxServer got msg ""+string(buffer[:n])+"" at "+time.Now().String()
conn.Write([]byte(strTemp))
}
}
//日志处理
func Log(v ...interface{}) {
log.Println(v...)
}
//错误处理
func CheckError(err error) {
if err != nil{
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
}
}
客户端的业务逻辑是,发送信息给服务端,然后接收服务端的反馈。
conn, err := net.DialTCP("tcp", nil, tcpAddr)
用 TCP 协议拨号(Dial)到服务端。如果没有发生错误,就说明拨通了。于是在客户端日志记录连接成功
fmt.Println("connection success")
然后在这个已经通畅的连接里,进行发送和接收信息的任务。
conn.Write([]byte(words))
是发送信息
conn.Read(buffer)
是接收信息
如果接收发生错误,就记录错误
Log(conn.RemoteAddr().String(), "waiting server back msg error: ", err)
并且中断进程。
如果没有发生错误,就把接收到的信息在日志中记录。
Log(conn.RemoteAddr().String(), "receive server back msg: ", string(buffer[:n]))
客户端代码示例:
package main
import (
"net"
"fmt"
"log"
"os"
)
//发送信息
func sender(conn net.Conn) {
words := "Hello Server!"
conn.Write([]byte(words))
fmt.Println("send over")
//接收服务端反馈
buffer := make([]byte, 2048)
n, err := conn.Read(buffer)
if err != nil {
Log(conn.RemoteAddr().String(), "waiting server back msg error: ", err)
return
}
Log(conn.RemoteAddr().String(), "receive server back msg: ", string(buffer[:n]))
}
//日志
func Log(v ...interface{}) {
log.Println(v...)
}
func main() {
server := "127.0.0.1:1024"
tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
if err != nil {
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
os.Exit(1)
}
conn, err := net.DialTCP("tcp", nil, tcpAddr)
if err != nil {
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
os.Exit(1)
}
fmt.Println("connection success")
sender(conn)
}
服务端运行效果
客户端运行效果
- 行业数据重要性不用多说,呕心整理分享(2)
- 云计算如何在银行业务发挥作用?
- SNH48 要推出定制 AI 形象,和初音未来有什么不同?
- 字节对齐
- 微信更新为小程序引入游戏功能,朋友圈又刷屏了
- WCF技术剖析之二十七: 如何将一个服务发布成WSDL[基于WS-MEX的实现](提供模拟程序)
- Linux同步机制(二) - 条件变量,信号量,文件锁,栅栏
- WCF技术剖析之二十七: 如何将一个服务发布成WSDL[基于HTTP-GET的实现](提供模拟程序)
- zookeeper集群搭建
- WCF技术剖析之二十七: 如何将一个服务发布成WSDL[编程篇]
- 浅谈反馈式按钮的设计与实现
- 对比手游和PC游戏的发展,小程序会成为手游开发的热点?
- 雷军旗下金山云再获融资2.2亿美元
- WCF技术剖析之二十五: 元数据(Metadata)架构体系全景展现[WS标准篇]
- 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 数组属性和方法
- 浅谈vue+element全局loading加载
- LeetCode59|重复N次的元素
- 谈Vue组件的is特性
- 基于日志的回放对比系统设计
- 【收藏向】常用Java排错工具单
- MYSQL数据同步之基于GTID事务数据同步
- 【风险通告】XXL-JOB远程命令执行漏洞
- MySQL8.0特性之redo logging动态开关
- 3分钟短文:Laravel模型集合跟基类真不一样,别混为一谈
- 3分钟短文:Laravel模型一对一一对多关系真的乱吗?
- 3分钟短文:Laravel请求对象方法极多,可不是花拳绣腿
- 3分钟短文:Laravel验证用户输入,不要把啥都存到系统里
- 3分钟短文:Laravel用户自定义命令行简明教程
- 3分钟短文:Laravel命令行参数和可选项分不清?怎么可能!
- 《Offer一箩筐》求职之前你必须知道的 4 件事!!