文档章节

golang之tcp自动重连

AllenOR灵感
 AllenOR灵感
发布于 2017/09/10 00:47
字数 386
阅读 66
收藏 0

操作系统: CentOS 6.9_x64

go语言版本: 1.8.3

问题描述

现有一个tcp客户端程序,需定期从服务器取数据,但由于种种原因(网络不稳定等)需要自动重连。

测试服务器示例代码:

/*
tcp server for test
E-Mail : Mike_Zhang@live.com
*/


package main

import (
    "fmt"
    "net"
    "os"
    "strings"
    "time"
)

func checkError(err error) {
    if err != nil {
        fmt.Println(err)
        os.Exit(1)
    }
}

func handleClient(conn net.Conn) {
    conn.SetReadDeadline(time.Now().Add(3 * time.Minute))
    request := make([]byte,1024)
    defer conn.Close()

    for {
        recv_len,err := conn.Read(request)
        if err != nil {
            fmt.Println(err)
            break
        }
        if recv_len == 0 {
            break
        }
        recvData := strings.TrimSpace(string(request[:recv_len]))
        fmt.Println("recv_len : ",recv_len)
        fmt.Println("recv_data : " + recvData)
        daytime := time.Now().String()
        conn.Write([]byte(daytime + "\n"))
        request = make([]byte,1024)
    }
}

func main() {
    bindInfo := ":12345"
    tcpAddr,err := net.ResolveTCPAddr("tcp4",bindInfo)
    checkError(err)
    listener,err := net.ListenTCP("tcp",tcpAddr)
    checkError(err)
    for {
        cc,err := listener.Accept()
        if err != nil {
            continue
        }
        go handleClient(cc)
    }
}
View Code

解决方案

/*
tcp client with reconnect
E-Mail : Mike_Zhang@live.com
*/

package main

import (
    "net"
    "fmt"
    "bufio"
    "time"
)

func doTask(conn net.Conn) {
    for {
        fmt.Fprintf(conn,"test msg\n")
        msg,err := bufio.NewReader(conn).ReadString('\n')
        if err != nil {
            fmt.Println("recv data error")
            break
        }else{
            fmt.Println("recv msg : ",msg)
        }
        time.Sleep(1 * time.Second)
    }

}

func main() {
    hostInfo := "127.0.0.1:12345"

    for {
        conn,err := net.Dial("tcp",hostInfo)
        fmt.Print("connect (",hostInfo)
        if err != nil {
            fmt.Println(") fail")
        }else{
            fmt.Println(") ok")
            defer conn.Close()
            doTask(conn)
        }
        time.Sleep(3 * time.Second)
    }
}

运行效果:

[root@local t1]# ./tcpClient1
connect (127.0.0.1:12345) ok
recv msg :  2017-06-12 21:10:32.110977137 +0800 CST

recv msg :  2017-06-12 21:10:33.111868746 +0800 CST

recv data error
connect (127.0.0.1:12345) fail
connect (127.0.0.1:12345) fail
connect (127.0.0.1:12345) ok
recv msg :  2017-06-12 21:10:43.117203432 +0800 CST

recv msg :  2017-06-12 21:10:44.11853427 +0800 CST

讨论

这里只是个简单的示例代码,实现了tcp自动重连。

好,就这些了,希望对你有帮助。

本文github地址:

https://github.com/mike-zhang/mikeBlogEssays/blob/master/2017/20170613_golang之tcp自动重连.rst

欢迎补充 

本文转载自:http://www.cnblogs.com/MikeZhang/p/golangTcpReconnect20170613.html

AllenOR灵感
粉丝 11
博文 2635
码字总数 83001
作品 0
程序员
私信 提问
编写稳定的基于Cocos2d-x的TCP连接类,集成LUA

1、创建一个Cocos-lua项目,集成TCP创建连接、发送TCP数据包、接收数据包、自动检测与服务器的心跳数据包,能自动重连。 2、封装的TCP连接类,能够在LUA中创建连接、发送数据、接收数据、网络...

李平
2018/08/18
0
0
B站直播:使用Golang重构,流量最大的推送功能

1 悲剧直播推送功能 ****** 1.1 B站直播推送功能的困境 ***B站直播有个推送功能,就是这里,看到那个红色的数字没有,显示你关注的主播开播人数。 然后每个进入B站的用户,不管是不是直播的观...

anoty
2016/10/22
1K
1
TCP 层的路由器--TcpRoute2

TcpRoute, TCP 层的路由器。对于 TCP 连接自动从多个线路(允许任意嵌套)、多个域名解析结果中选择最优线路。TcpRoute2 是 golang 重写的版本。 通过 socks5 代理协议对外提供服务。 代理功能...

GameXG
2015/12/31
4.6K
6
快速可靠协议--kcp-go

KCP是一个快速可靠协议,能以比 TCP浪费10%-20%的带宽的代价,换取平均延迟降低 30%-40%,且最大延迟降低三倍的传输效果。纯算法实现,并不负责底层协议(如UDP)的收发,需要使用者自己定义...

匿名
2016/03/07
1K
0
用 500 行 Golang 代码实现高性能的消息回调中间件

用500行 Golang 代码实现高性能的消息回调中间件 本文描述了如何实现一个消息回调中间件,得益于 golang 管道和协程的编程思想,通过巧妙的设计,只需要约500行代码就可以实现高性能、优雅关...

zamia
2017/09/24
0
0

没有更多内容

加载失败,请刷新页面

加载更多

DDD(五)

1、引言 之前学习了解了DDD中实体这一概念,那么接下来需要了解的就是值对象、唯一标识。值对象,值就是数字1、2、3,字符串“1”,“2”,“3”,值时对象的特征,对象是一个事物的具体描述...

MrYuZixian
今天
3
0
数据库中间件MyCat

什么是MyCat? 查看官网的介绍是这样说的 一个彻底开源的,面向企业应用开发的大数据库集群 支持事务、ACID、可以替代MySQL的加强版数据库 一个可以视为MySQL集群的企业级数据库,用来替代昂贵...

沉浮_
今天
4
0
解决Mac下VSCode打开zsh乱码

1.乱码问题 iTerm2终端使用Zsh,并且配置Zsh主题,该主题主题需要安装字体来支持箭头效果,在iTerm2中设置这个字体,但是VSCode里这个箭头还是显示乱码。 iTerm2展示如下: VSCode展示如下: 2...

HelloDeveloper
今天
6
0
常用物流快递单号查询接口种类及对接方法

目前快递查询接口有两种方式可以对接,一是和顺丰、圆通、中通、天天、韵达、德邦这些快递公司一一对接接口,二是和快递鸟这样第三方集成接口一次性对接多家常用快递。第一种耗费时间长,但是...

程序的小猿
今天
6
0
Python机器学习之数据探索可视化库yellowbrick

背景介绍 从学sklearn时,除了算法的坎要过,还得学习matplotlib可视化,对我的实践应用而言,可视化更重要一些,然而matplotlib的易用性和美观性确实不敢恭维。陆续使用过plotly、seaborn,...

yeayee
今天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部