fluent的网络重连reconnect时间规则

func e(x, y float64) int {
	return int(math.Pow(x, y))
}

func (f *Fluent) reconnect() {
	go func() {
		for i := 0; ; i++ {
			err := f.connect()
			if err == nil {
				f.mu.Lock()
				f.reconnecting = false
				f.mu.Unlock()
				break
			} else {
				if i == f.Config.MaxRetry {
					panic("fluent#reconnect: failed to reconnect!")
				}
				waitTime := f.Config.RetryWait * e(defaultReconnectWaitIncreRate, float64(i-1))
				time.Sleep(time.Duration(waitTime) * time.Millisecond)
			}
		}
	}()
}

sleep时间按照指数倍增长

时间: 2024-07-29 23:28:00

fluent的网络重连reconnect时间规则的相关文章

移动平台游戏网络重连方案(转)

1.背景 移动网络信号波动频繁,给移动游戏开发者带来诸多困扰,处理不好会造成较差的用户体验以及重复扣道具等严重问题.因此弱网络问题在TDR技术评审中作为客户端重点挑战项,并且弱网络专项测试达标后方能上线.本文就过往项目中遇到的问题给出一种比较通用解决方案. 2.网络连接方式 通常游戏客户端都是通过创建socket与服务器取得连接,但也会根据使用场景划分成两种连接方式:TCP连接和HTTP连接. 1) TCP连接即我们常说的长连接.这种连接方式下socket连接一旦建立,通信双方即可相互发送数据,

用代码控制网络断开与重连

看到这个标题,如果你想说谁会这么蛋疼,有网不好好上,那么说明你还是一个纯洁的少年.自动重拨的需求所在多有,主要是为了绕过各大网站对相同IP地址的重复请求次数限制等等.具体的我不说了,说多了说我教坏小孩子.我最近研究这个只是因为我想写个软件自动播放和下载某个网站的视频,but这个网站一天只让同个IP免费看五个视频,我又抠不愿意花钱,但是又特别想多看多载几部.什么,你要我把网站地址告诉你?还是算了吧,传播XX(se)OO(qing)是违法的知道不. 按惯例,先声明:技术知识浩瀚无垠,笔者但求浅尝辄止

(1 Linux) 手动配置网络

Linux 手动配置网络 桥接 桥接:桥接模式就是将主机网卡与虚拟机虚拟的网卡利用虚拟网桥进行通信.在桥接的作用下,类似于把物理主机虚拟为一个交换机,所有桥接设置的虚拟机连接到这个交换机的一个接口上,物理主机也同样插在这个交换机当中,所以所有桥接下的网卡与网卡都是交换模式的,相互可以访问而不干扰.在桥接模式下,虚拟机ip地址需要与主机在同一个网段,如果需要联网,则网关与DNS需要与主机网卡一致.其网络结构如下图所示: 假设目前主机电脑的ip为 192.168.31.199 我们在配置虚拟机网络的

VS 2013驱动程序开发+VM双机调试(亲测+详解)

WIN10已上线,随之而来的是VS2015:微软在 "WDK7600" 以后就不再提供独立的内核驱动开发包了,而是必须首先安装微软集成开发环境VS,然后再从微软官网下载集成的WDK驱动程序开发包.或者离线安装的开发包 地址: https://msdn.microsoft.com/zh-cn/windows/hardware/hh852365.aspx 离线下载地址:百度云链接:http://pan.baidu.com/s/1i3KdUSH 密码:vp41 安装WDK后,本人使用的是VS

使用VS2012调试ReactOS源码

目录 一 下载并安装VS2012 二 下载并安装WDK80 三 下载ReactOS0315源码 四 下载并安装RosBE211 五 用RosBE命令行编译ReactOS源码 六 用VS2012编译ntoskrnl模块 七 制作ReactOS安装盘 八 用VirtualBox安装ReactOS 九 建立调试环境 十 调试ReactOS源码 一. 下载并安装VS2012 我安装的是VS2012_ULT_chs.iso, 网上随便下载 二. 下载并安装WDK8.0 下载地址: http://msdn.

Ubuntu软件更新时出错问题解决

apt-get instal update 提示:错误,无法解析域名等等之类的 网上解决办法一大堆,先别急着用网上的方法,来检查检查系统是否有网络连接 网络图标显示网络连接,等等,别被表面迷惑了,命令检查一下 先ping一下自己主机的 IP,看能不能ping通 ping 192.168.1.1 ping不通,转到下面方法一 ↓ 再ping一下外网 ping www.baidu.com 也ping不通,转到下面的方法一 ↓ 如果ping IP地址可以,ping外网不行,转到下面方法二 ↓ ----

从BSP模型到Apache Hama

? 什么是BSP模型 概述 BSP(Bulk Synchronous Parallel,整体同步并行计算模型)是一种并行计算模型,由英国计算机科学家Viliant在上世纪80年代提出.Google发布的一篇论文(<Pregel: A System for Large-Scale Graph Processing>)使得这一概念被更多人所认识,据说在Google 80%的程序运行在MapReduce上,20%的程序运行在Pregel上.和MapReduce一样,Google并没有开源Pregel

BGP路由协议详解(完整篇)

原文链接:http://xuanbo.blog.51cto.com/499334/465596/ 2010-12-27 12:02:45 上个月我写一篇关于BGP协议的博文,曾许诺过要完善这个文档,但因最近的工作和授课很忙,所以没有时间进行完善.为了实现这个承诺,我在去外地出差期间对BGP协议详解博文进行一些修改,其中内容包括了一些实验,以及一些内容的补充和深入阐述,更宜于网友们学习BGP路由协议.因为这个文档出来的很晚,也希望网友们见谅! 此BGP协议的内容也不算太难,一些关于BGP的高级应用

MiniFilter文件系统学习

Minfilter与legacy filter区别 比sfilter加载顺序更易控制. altitude被绑定到合适的位置. Minfilter在注册表服务项中有一项Altitude值 此值越高位置越靠前 (待考证 每一个minifilter驱动必须有一个叫做altitude的唯一标识符.一个minifilter驱动的altitude定义了它加载时在I/O栈中相对其他minifilter驱动的位置.值越小,栈中位置就越低 FSFilter Anti-Virus 320000-329999 此组包