golang之tcp自动重连

栏目: Go · 发布时间: 7年前

内容简介:golang之tcp自动重连

操作系统: 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

欢迎补充


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

未来简史

未来简史

[以色列] 尤瓦尔·赫拉利 / 林俊宏 / 中信出版集团 / 2017-2 / 68.00元

进入21世纪后,曾经长期威胁人类生存、发展的瘟疫、饥荒和战争已经被攻克,智人面临着新的待办议题:永生不老、幸福快乐和成为具有“神性”的人类。在解决这些新问题的过程中,科学技术的发展将颠覆我们很多当下认为无需佐证的“常识”,比如人文主义所推崇的自由意志将面临严峻挑战,机器将会代替人类做出更明智的选择。 更重要的,当以大数据、人工智能为代表的科学技术发展的日益成熟,人类将面临着从进化到智人以来z......一起来看看 《未来简史》 这本书的介绍吧!

Markdown 在线编辑器
Markdown 在线编辑器

Markdown 在线编辑器

HEX CMYK 转换工具
HEX CMYK 转换工具

HEX CMYK 互转工具

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具