专栏首页Golang语言社区51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记

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

服务端运行效果

客户端运行效果


本文分享自微信公众号 - Golang语言社区(Golangweb)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2018-02-20

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Golang语言社区--理解 go interface 的 5 个关键点

    大家好,我是社区主编彬哥,本篇文章是给大家转载的关于Go语言中interface相关的。

    李海彬
  • Golang语言社区--Go语言基础第五节流程控制

    大家好,我是Golang语言社区(www.Golang.LTD)主编彬哥,今天给大家带来的是关于go语言中的流程控制。

    李海彬
  • golang调试工具Delve

    Devle是一个非常棒的golang 调试工具,支持多种调试方式,直接运行调试,或者attach到一个正在运行中的golang程序,进行调试。

    lpxxn
  • Golang语言社区--Go语言学习资料下载(PDF文件、视频)

    大家好,我是社区主编彬哥,今天给大家整理了部分的GO语言相关的学习资料;已经上传至百度网盘;欢迎下载;后面会持续更新:

    李海彬
  • Golang语言社区--go语言编写Web程序

    首先,要有一个Linux, OS X, or FreeBSD系统,可以运行go程序。如果没有的话,可以安装一个虚拟机(如VirtualBox)或者 Virtua...

    李海彬
  • Go语言六周年,2016年初发布Go 1.6

    原文出处: Andrew Gerrand 译文出处:oschina 2009年11月10日,Go 语言作为开源项目正式发布。从那开始,已经有超过 780...

    wangxl
  • Golang语言社区--Go语言基础第四节类型

    大家好,我是Golang语言社区主编彬哥,这节给大家讲解Go语言中的类型。

    李海彬
  • Golang语言社区--go语言执行cmd命令关机、重启等

    大家好,我是Golang语言社区主编彬哥,这篇给大家带来关于Go语言操作cmd命令执行windows平台的相关操作

    李海彬
  • Go语言入门

    最近准备学点新东西,聊聊Go语言入门。 Go是google 09年推出的编程语言,Go语言专门针对多处理器系统应用程序的编程进行了优化,使用Go编译的程序可以媲...

    大数据和云计算技术
  • Golang语言社区--Go语言基础第六节函数

    大家好,我是Golang语言社区主编彬哥,本篇给大家带来的是关于Go语言中的函数。

    李海彬

扫码关注云+社区

领取腾讯云代金券