golang之tcp自动重连实现方法
2018-10-15 17:34
阅读:778
操作系统: CentOS 6.9_x64
go语言版本: 1.8.3
问题描述
现有一个tcp客户端程序,需定期从服务器取数据,但由于种种原因(网络不稳定等)需要自动重连。
测试服务器示例代码:
解决方案
/* tcp client with reconnect */ 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自动重连。
好,就这些了,希望对你有帮助。
以上这篇golang之tcp自动重连实现方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。
上一篇:利用Go语言追加内容到文件末尾
文章来自:搜素材网的编程语言模块,转载请注明文章出处。
文章标题:golang之tcp自动重连实现方法
文章链接:http://soscw.com/index.php/essay/18772.html
文章标题:golang之tcp自动重连实现方法
文章链接:http://soscw.com/index.php/essay/18772.html
评论
亲,登录后才可以留言!