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
猜你喜欢
- 关于书写习惯,遵循曾经总结过的风格标准,现在一点都没有变。并且近来翻看高手作品,横向连排似乎在大产品项目中逐渐成为主流,个人认为如此维护效率
- 先不说直接改后缀,直接可以用网快等工具直接下载,其实这样你已经是为入侵者打开了大门。入侵者可以利用asp/asa为后缀的数据库直接得到web
- 内容摘要:当讨论Request对象内容时,要研究的集合之一就是ServerVariables集合。这个集合包含了两种值的结合体,一种是随同页
- ASP+Access数据库的18条安全法则:1.首先,我们需要过滤所有客户端提交的内容,其中包括?id=N一类,另外还有提交的html代码中
- 原文作者:青女 附注及色样添加:Quester西式的色名及色样表,可以参见以下链接 (Java 类色彩兼容):http
- 物质世界客观存在,而人的“视觉成像”是对当前世界的“唯心”重建。这种重建基于个人“经验”、“感知”和“集体意识”。最初科学家认为人类通过视觉
- 交互设计师的一项重要工作就是进行产品原型设计(Prototype Design)。而产品原型设计最基础的工作,就是画出站点的大体wirefr
- 使用在Safari和WebKit中可用的CSS高级特性,你可以为你的网站和网络应用带来一个新的级别的令人兴奋的东西。WebKit是Safar
- 记得当时我们要跟网友天下合作,需要这样的一个鼠标划过放大的列表效果,就写了一个效果截图:演示代码:<!DOCTYPE html PUB
- 随机生成四位数验证码,包括汉字,数字,英文大小写。1.Servlet类package servlet;import java.awt.Bas
- 一、在访客的内心深处做导航我讨厌迷失,不管是在道路上或是在线网络上。猜想一下?您的访客也是这样的。就像我们期望看到的道路上的路标一样,来帮助
- 1.查询表名: 代码如下:select table_name,tablespace_name,temporary from user_tab
- 很多年前,我们就可以轻易的从很多国营商场、火车车厢、饭馆旅馆中看到墙上挂的那个小本本-意见薄,作为经营方与顾客沟通的
- 目录Session作用session 的工作机制:PHPSESSIONID的生产算法原理:php.ini配置如下:PHP Session工作
- 文本框 textarea 限制输入文字个数的的javascript代码,我们经常在评论留言页面我们需要在客户端限制访客的留言长度,当然最好我
- 我们先用 new 关键字 来创建一个ArrayList 对象,给数组的item赋值,把数组初
- HTTP(HyperTextTransferProtocol)是超文本传输协议的缩写,它用于传送WWW方式的数据,关于HTTP协议的详细内容
- 昨天Steve的 讲座涉及了一个我从没考虑的领域,在没法优化后台服务器的时候,如何合理的放置网页的元件让她们在浏览器里显示得更加快。这里,我
- 一些大型站点都有着非常一流的视觉外观,它们很可能在设计时使用了网格系统。网格可以是页面布局显得紧凑而且稳定,为设计师在设计站点时提供一个逻辑
- 众所周知windows平台漏洞百出,补丁一个接一个,但总是补也补不净。我把我所知道的看asp源码的方法总结了一下,并且用c#写了个应用程序来