Golang 实现Socket服务端和客户端使用TCP协议通讯

 更新时间:2020年12月17日 11:05:12   作者:冷月醉雪  
这篇文章主要介绍了Golang 实现Socket服务端和客户端使用TCP协议通讯,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

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)
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。如有错误或未考虑完全的地方,望不吝赐教。

相关文章

  • Golang负载均衡和保活设计原理示例探究

    Golang负载均衡和保活设计原理示例探究

    这篇文章主要为大家介绍了Golang负载均衡和保活设计原理示例探究,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2024-01-01
  • golang生成指定位数的随机数的方法

    golang生成指定位数的随机数的方法

    这篇文章主要介绍了golang生成指定位数的随机数的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-10-10
  • Go获取与设置环境变量的方法详解

    Go获取与设置环境变量的方法详解

    go环境变量的配置其实说真的说难也难,说不难也不难,只要配置成功过一次以后后面都很简单,但是最好是要做好笔记,这篇文章主要给大家介绍了关于Go获取与设置环境变量的相关资料,需要的朋友可以参考下
    2021-11-11
  • Go语言中的速率限流策略全面详解

    Go语言中的速率限流策略全面详解

    这篇文章主要为大家介绍了Go语言中的速率限流策略全面详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-11-11
  • Go REFLECT Library反射类型详解

    Go REFLECT Library反射类型详解

    这篇文章主要为大家介绍了Go REFLECT Library反射类型详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-08-08
  • go语言实现简单的并发网页爬虫示例

    go语言实现简单的并发网页爬虫示例

    在这个章节中,我们将会结合之前的知识点,实现一个简易的并发网页爬虫,我们的爬虫会先爬取一个起始页面,提取出所有的链接,然后并发地爬取这些链接,有需要的朋友可以借鉴参考下,希望能够有所帮助
    2023-08-08
  • 一文教你打造一个简易的Golang日志库

    一文教你打造一个简易的Golang日志库

    这篇文章主要为大家详细介绍了如何使用不超过130行的代码,通过一系列golang的特性,来打造一个简易的golang日志库,感兴趣的小伙伴可以了解一下
    2023-06-06
  • GO中的时间操作总结(time&dateparse)

    GO中的时间操作总结(time&dateparse)

    日常开发过程中,对于时间的操作可谓是无处不在,但是想实现时间自由还是不简单的,多种时间格式容易混淆,本文为大家整理了一下GO中的时间操作,有需要的可以参考下
    2023-09-09
  • 深入理解Golang中的Protocol Buffers及其应用

    深入理解Golang中的Protocol Buffers及其应用

    本篇文章将深入探讨 Go 语言中使用 Protobuf 的基础知识、常见应用以及最佳实践,希望能帮大家了解如何在项目中高效利用 Protobuf
    2024-11-11
  • Go语言字符串处理库strings包详解

    Go语言字符串处理库strings包详解

    本文详细介绍了Go语言中的strings库的使用方法,包括字符串的查找、替换、分割、比较、大小写转换等操作,strings库是Go语言中非常重要且功能丰富的标准库,几乎涵盖了所有字符串处理的需求
    2024-09-09

最新评论