Golang 实现Socket服务端和客户端使用TCP协议通讯
作者:冷月醉雪 发布时间:2023-07-21 10:09:38
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)
}
以上为个人经验,希望能给大家一个参考,也希望大家多多支持
来源:https://blog.csdn.net/lengyuezuixue/article/details/79202336
猜你喜欢
- 不废话,直接看代码,需要的根据需求完善。var getKeyCode = function (key) { var key_co
- 我的Python环境:3.7在Python类里声明一个装饰器,并在这个类里调用这个装饰器。代码如下:class Test():
- 特点在 dayjs 之前,还有一个时间处理工具 moment.js,但是它的体积比较大,即使经过压缩压缩之后依然有 80kb 左右。而前者
- html<ul class="header-list"> <li v-cl
- 本文实例讲述了Python集中化管理平台Ansible介绍与YAML。分享给大家供大家参考,具体如下:一 中文社区http://ansibl
- HTML 的空白符处理规则HTML 中的“空白符”包括空格 (space)、制表符 (tab)、换行符 (CR/LF) 三种。我们知道,在默
- 一、背景分析对想要在视觉化环境下制作复杂网页的专业网页制作者来说,Dreamweaver已经渐渐在网页编辑工具中展露头角,成为专业人士编写网
- 1. python中的变量:python中的变量声明不需要像C++、Java那样指定变量数据类型(int、float等),因为python会
- 本文实例讲述了Python简单I/O操作。分享给大家供大家参考,具体如下:文件:poem = '''hellowor
- 首先要用designer设计ui界面打开后就和c#一样拖动控件做ui界面保存后是xxx.ui文件再添加个工具Arguments:-m PyQ
- 结合这个例子分析一下结果:结合以往C语言的基础,画了一张图来解释为什么会有上面这些值的出现。先查看下Go中的这两个运算符是啥吧。①对于所有带
- 今天写了一个java项目连接数据库,之后写了一个执行入库操作的模块。此时暴露出一个问题就是项目的中文插入到数据库时会是乱码:项目输出的中文:
- 让我们面对现实吧,你的模型可能还停留在石器时代。我敢打赌你仍然使用32位精度或GASP甚至只在一个GPU上训练。我明白,网上都是各种神经网络
- 在计算机程序中,算法是灵魂,是程序的精髓所在。程序执行效率的高低直接取决于算法的优劣,所以计算机算法是计算机课程必修课。算法可以快速计算出我
- Django中内置了邮件发送功能,被定义在django.core.mail模块中。发送邮件需要使用SMTP服务器,常用的免费服务器有:163
- 本文实例讲述了Python网络编程之TCP套接字简单用法。分享给大家供大家参考,具体如下:上学期学的计算机网络,因为之前还未学习python
- 本文实例讲述了python单例模式。分享给大家供大家参考。具体分析如下:__new__()在__init__()之前被调用,用于生成实例对象
- python 根据正则表达式提取指定的内容正则表达式是极其强大的,利用正则表达式来提取想要的内容是很方便的事。 下面演
- 现在同类型的网站数不胜数,网站的功能或服务日趋同质化,大的方面看不出什么差别,差别就体现在细节上。“窥斑见豹”,细节成为网站最有力的表现形式
- 背景介绍开发中遇到了一个需求:程序运行到某处时需要用户确认, 但不能一直傻等, 后面的程序不能被一直阻塞, 需要有个超时限制, 也就是这个程