go 的生态系统退化能不能给他刷退化?

酷勤网 – 程序员的那点事!
当前位置: >
浏览次数:次
我喜欢 Go. 常用它实现各种功能(包括在写本文时的这个博客). Go 很实用,但不够好。 不是说它有多差, 只是没那么好而已。
一门编程语言, 也许会用上一辈子, 所以选择的时候要注意。
本文专注于Go的各种吐槽。老生常谈的有之,鲜为人知的也有。
我用 Rust 和Haskell 作为参照 (至少, 我以为, 这俩都很不错)。 本文列出的所有问题, 都有解决方案。
那么问题来了
我们写代码可以用于许多不同的事情。假如我写了一个函数用来对一列数字求和,如果我可以用该函数对浮点数、整数以及其他任何类型进行求和那该多棒。如果这些代码包含了类型安全并且可以快速的写出用于整型相加、浮点型相加等的独立函数就更完美了。
好的解决方案:基于限制的泛型和基于参数的多态
到目前为止,我遇到的最好的泛型编程系统是rust和haskell所共用的那个。它一般被称作&被限制的类型&。在haskell中,这个系统被称作&type class&。而在Rust中,它被称作&traits&。像这样:
(Rust, version 0.11)
fnid&T&(item:T)-&T{
在上面这个简单了例子中,我们定义了一个泛型函数id。id函数将它的参数原封不动传回来。很重要的一点是这个函数可以接受任何类型的参数,而不是某个特定的类型。在Rust和haskell中,id函数保留了它参数的类型信息,使得静态类型检查可以顺利工作,并且没有为次在运行期付出任何代价。你可以使用这个函数来写一个克隆函数。
同样,我们可以应用这种方式来定义泛型数据结构。例如:
structStack&T&{
items:Vec&T&
dataStackt=Stack[t]
跟上面一样,我们在没有运行期额外消耗的情况下得到完全的静态类型安全。
现在,如果我们想写一个通用的函数,我们必须告诉编译器&这个函数只有在它的所有参数支持这个函数中所用用到的操作时,才有意义&。举个例子,如果我们想定义一个将它的三个参数相加,并返回其和的函数,我们必须告诉编译器:这三个参数必须支持加法运算。就象这样:
fnadd3&T:Num&(a:T,b:T,c:T)-&T{
add3::Numt=&t-&t-&t-&t
add3abc=a+b+c
在上面这个例子中,我们告诉haskell的编译器:&add3这个函数的参数必须是一个Num(算数数类型)&。因为编译器知道一个Num类型的参数支持加法,所以这个函数的表达式可以通过类型检查。在haskell中,这些限制也可应用于data关键字所做的定义中。这是一个可以优雅地定义百分之百类型安全的灵活泛型函数的方式。
go的解决方案:interface{}
Go的普通类型系统的结果是,Go对通用编程的支持很差。
你可以非常轻松的写通用方程。假如你想写一个可以打印被哈希的对象的哈希值。你可以定义一个拥有静态类型安全保证的interface,像这样:
typeHashableinterface{
Hash()[]byte
funcprintHash(itemHashable){
fmt.Println(item.Hash())
现在,你可以提供给printHash任何Hashable的对象,你也得到静态类型检查。这很好。
但如果你想写一个通用的数据结构呢?让我们写一个简单的链表。在Go里写通用数据结构的惯用方法是:
typeLinkedListstruct{
valueinterface{}
next*LinkedList
func(oldNode*LinkedList)prepend(valueinterface{})*LinkedList{
return&LinkedList{value,oldNode}
functail(valueinterface{})*LinkedList{
return&LinkedList{value,nil}
functraverse(ll*LinkedList){
ifll==nil{
fmt.Println(ll.value)
traverse(ll.next)
funcmain(){
node:=tail(5).prepend(6).prepend(7)
traverse(node)
发现什么了吗?value的类型是interface{}。interface{}就是所谓的&最高类型&,意味着所有其他的类型都是interface{}的子类型。这大致相当于Java中的Object。呀!(注意:对于Go中是否有最高类型还有争议,因为Go宣称没有子类型。不管这些,保留类比的情况。
在Go里面&正确&构建通用数据结构的方法是将对象设置为最高类,然后把它们放入到数据结构中。大约在2004年,Java就是这么做的。后来人们发现这完全违背了类型系统的本意。当你有这样的数据结构时,你完全消除了一个类型系统能提供的所有好处。比如,下面这个是完全有效的代码:
node:=tail(5).prepend(&Hello&).prepend([]byte{1,2,3,4})
而这在一个良好结构化的程序里完全没有意义。你可能期望的时一个整数链表,但在某个情况下,一些疲惫、靠咖啡清醒的程序员在截止日期前偶然在某处加入了一个字符串。因为Go里面的通用数据结构不知道它们值的类型,Go的编译器也不会改正,你的程序在你失去从interface{}里面捕获时将崩溃。
相同的问题在任何通用数据结构里都存在,无论是list、map、graph、tree、queue等。
语言可扩展性
高级语言通常有复杂任务的关键字和符号简写。比如,在很多语言中,迭代一个如数组一样的数据集合中所有元素的简写:
for(Stringname:names){...}
fornameinnames:...
如果我们能在任何集合类型上操作,不仅仅是那些语言内建类型(如数组),会很美好。
如果我们可以定义类型的相加也会很美好,那么我们可以这么做
point3 = point1 + point2
好的解决方案:把运算符视作函数
将内建的运算符和某个特别命名的函数对应起来,亦或将关键字视作特定函数的别名,这样做可以很好的解决该问题。
某些编程语言,像Python,Rust和Haskell允许我们重载运算符。我们只需要给我们自定义的类添加一个函数,自此,当我们使用某个运算符的时候(例如&+&),解释器(编译器)就会直接调用我们所添加的函数。在Python中,运算符&+&对应于__add__()函数。在Rust中,&+&运算符在Add这个trait中定义为add()函数。在Haskell中,&+&对应于Num这个type class中的(+)。
许多语言都有扩展关键字的方法,例如for-each循环。Haskell没有循环,但是像Rust,Java和Python这样的语言中都有&迭代器&这样的概念使得for-each循环可以应用于任何种类的数据集合结构。
某些人可能会用这个特性做一些很操蛋的事情,这是一个潜在的缺点。例如,某些疯狂的家伙使用&-&来代表两个向量之间的点乘。但这并不完全是运算符重载的问题。无论使用何种语言,都可以写出胡乱命名的函数。
Go的解决方案:没有
Go语言不支持操作符重载或者关键字扩展。
那么如果我们想给其他的东西(例如树,链表)实现range关键字的操作怎么办?太糟糕了。这不是语言的一部分。你这能在内建对象上使用range关键字。对于关键字make也一样,它不能给非内建数据结构申请内存和初始化。
最接近这个可以使用迭代器的关键字的方式是写一个包装函数,这个函数以目标数据结构为参数并返回一个可迭代的对象,我们通过使用这个对象在目标数据结构上迭代(译者注:参见设计模式中的迭代器模式或C++中的迭代器实现)。但是这样做可能会很慢并且复杂,而且无法保证不引入其他的bug。
对于这样一个问题,有人辩解道,&这样更容易让人理解代码,并且我看到的代码就是真正被执行的代码。&也就是说,如果Go语言允许我们扩展像range这样的东西,那么range本身的机制和实现就会变得复杂难以理解。我认为这样的说法没有什么营养,因为不管Go是否通过这种方式让其变得更简单,更易懂,人们总要进行这种在某些数据结构上进行迭代操作。如果我们不想把实现细节隐藏在range()函数里,我们就要把它隐藏在其他的工具函数里,没什么改进。所有的好代码都是易读的,大多数糟糕代码让人很难懂,很显然Go不能改变这个事实。
基础案例与失败条件
那么问题来了
当遇到递归的数据结构(如链表和树)时,我们希望找到一个途径来指出我们到达数据结构的末端。
当遇到可能会执行失败的函数或包含缺失数据片的数据结构时,我们希望找到一个途径明示我们遇到的几种失败情况。
Go 的方解决案: Nil (和多个返回值)
这回我先说 Go的, 才好引出其他更好解决方案的讨论.
Go 支持 null 指针(nil). 每次看到新的编程语言(如:tabula rasa), 实现这个导致 bug 满天飞的功能, 我替他们可惜.
null 指针的历史, 满满的都是 bug. 无论是历史, 还是现实, 我都看不出来, 数据存在内存地址为0x0 的地方有什么意义. 指向 0x0 的指针通常都有特定的含义.比如,返回类型是指针的函数出错, 会返回 0x0. 递归数据结构把0x0 当作基底(base case), 如: 树结构的页节点, 或链表的结尾.这也是 null 指针在Go 中的用法.
然而,这样使用null指针也是不安全的。事实上,null指针是类型系统的后门,它让你能够创造某个根本不是所属类型的实例。程序员有时候会忘记某个指针的值可能是null这个事实,这是一个很常见的情况。在最好的情况下,你的程序会挂掉,而在最坏的情况下,这会产生一个可以被人利用的漏洞。编译器无法轻易地阻止这种情况的发生,因为null指针破坏了语言的类型系统。
对于Go来说,使用多重返回值这个机制,利用它第二个返回值来返回一个代表&失败&的值是一个正确也被鼓励的做法。然而,这种机制很容易被忽略或者误用,并且在表示递归数据结构的时候没有什么用用处。
好的解决方案:代数数据类型和类型安全的错误模式
我们可以使用类型系统来包装错误状况,基底,而不是试图打破类型系统。
现在我们想要构建一个表示链表的类型。我们想表示两种情况:我们是否已经到达了链表的末尾,某个链表的节点上到底有没有被存放在那里的数据。一种类型安全的方式是分别使用不同的类型来表示这些情况,最后将它们组合成一个单独的类型(使用代数数据类型)。现在我们有一个叫做Cons的类型来表示一个存放有某些数据的链表,一个叫做End的类型来表示链表的末尾。我们可以这样写:
enumList&T&{
Cons(T,Box&List&T&&),
letmy_list=Cons(1,boxCons(2,boxCons(3,boxEnd)));
dataListt=End|Const(Listt)
letmy_list=Cons1(Cons2(Cons3End))
每个类型都为递归操作这个数据结构的算法声明了一个基底(End)。。Rust和Haskell都不允许null指针的出现,所以我们永远都不会碰到null指针解引用所造成的bug(除非我们做一些很大胆的底层操作)。
这些代数数据结构通过像模式匹配(后面讲它)这样的技术,允许我们写出非常明了的代码。
那么,我们如何得到一个可能返回或者不返回给定类型的数据的函数,或是一个可能内部包含或者没有包含一个给定类型的数据的数据结构呢?也就是说,我们如何将错误状况(failure condition)封装到我们的类型系统中来呢?Rust使用Option,Haskell使用一个叫Maybe的类型来解决这个问题。
我们想象这样一个函数,它所作的事情是搜索一个非空字符串的数组,寻找一个以这&H&开头的字符串,返回第一个找到的这样的字符串,如果没有找到,就返回某种错误状况。在Go语言中,我们可以通过返回nil来表示&没找到&这个错误。但是在Haskell和Rust中,不使用危险的指针,我们就可以安全地完成这个任务。
fnsearch&'a&(strings:&'a[String])-&Option&&'astr&{
forstringinstrings.iter(){
ifstring.as_slice()[0]=='H'asu8{
returnSome(string.as_slice());
search[]=Nothing
search(x:xs)=if(headx)=='H'thenJustxelsesearchxs
我们可以返回一个包含或者没有包含一个字符串的对象来代替返回一个字符串或者null指针的做法。使用search()函数的程序员也会很清楚地知道这个函数可能会失败(因为它返回的对象的类型已经这么说了),而且程序员必须处理这两种状况,否则报错。这样我们就跟null指针解引用所造成的bug说再见了。
类型推导(Type Inference)
给程序中的每个值都指定类型, 有时看起来点过老土。 某些场合, 值的类型显而易见,如
这里的 y 明显就是整形。更复杂点的,我们甚至可以根据函数的参数类型推断出它的返回类型(反之亦然)。
出色的解决方案: 通用类型推导(General Type Inference)
Rust 和 Haskell 都基于 Hindley-Milner类型系统, 他们都很擅长类型推导, 你可以实现像下面这样好玩的功能:
map::(a-&b)-&[a]-&[b]
letdoubleNumsnums=map(*2)nums
doubleNums::Numt=&[t]-&[t]
函数 (*2) 有一个 Num 类型参数, 返回也是一个Num 类型, Haskell由此推断a 和 b 也是 Num 类型. 最后推断出, 该函数有若干个 Num 类型参数, 返回若个 Num 类型的值. 这种方式比 Go 和 C++ 的简单类型推导强大多了. 有了它, 哪怕是结构复杂的程序, 就算我们不声明这么多显性类型, 编译器也能正确处理.
Go的解决方案 : :=
Go 支持 :=赋值操作符,用法如下:
foo := bar()
它的原理是: 查找 bar() 的返回类型, 然后赋给 foo. 下列代码的道理也一样:
auto foo = bar();
没什么稀奇的, 无非省去了人工查找函数 bar() 的返回类型, 在键盘上多敲几个字声明 foo 的类型那点时间而已.
不变性(Immutability)
不变性是指,在程序生成的时候,设好的值,以后不会再变。 它的优势很明显, 能减少因程序某个地方的数据结构改变,导致另一个地方出现问题的概率。
此外对程序优化也有利。
出色的解决方案: 默认使用不变性
程序员应当尽可能使用不可变数据结构。 不变性使得判断负面影响和安全性变得更简单。同时也能减少各种 Bug 。
Haskell 默认情况下, 所有的值都是不可变的。改变数据结构就意味着, 在保证正确性的前提下, 重新创建一个新的数据结构。由于Haskell 采用的是惰性求值(lazy evaluation)和永久性数据结构(persistent data structures), 所以运行的速度还是粉快的。Rust 属于系统级编程语言。不可能使用惰性求值,也就不能像Haskell 那样始终使用不变性。 因此,虽然 Rust 默认情况下,变量的值是不可变的。 但是,在需要的时候, 还是可以将变量设置成可变的。这样挺好,因为它迫使程序员问自己,底需不需要将这个变量设成可变的。这是很好的变成习惯, 对编译器优化代码也有好处。
Go 的方案: 无
Go 不支持这项功能。
控制流结构(Control Flow Structures)
控制流结构是高级编程语言有别于汇编的原因之一. 它允许我们在抽象层面, 有条理地控制程序流程. 毫无疑问, 所有高级语言都支持控制流结构, 否则, 我还说个毛啊. 可惜, 有那么几种相当不错的控制流结构 Go 不支持.
出色的解决方案:模式匹配和复合表达式
模式匹配配合数据结构或值使用的时候, 效果相当好.简直就是 case/switch 的加强版. 我们可以像这样对值进行匹配:
0|1=&action_1(),
2..9=&action_2(),
_=&action_3()
或者像这样解构数据结构(deconstruct data structures):
deg_kelvin=matchtemperature{
Celsius(t)=&t+273.15,
Fahrenheit(t)=&(t-32)/1.8+273.15
上面的例子, 有时也称作复合表达式.C和 Go 中的if和 case/switch 语句只用来控制程序流程, 不会返回值; 而 Rust 和 Haskell 的 if和 模式匹配语句则可以. 既然有值返回, 当然也能用来赋给其他东东. 这里给出一个 if 语句的例子:
x=if(y==&foo&)then1else2
Go 的方案: C语言风格的无值语句( Valueless Statements)
不是我故意找Go 的茬; 它确实有几个不错的的控制流元素, 如, 用于并行计算的 select.可惜没有我钟爱的复合表达式和模式匹配. Go 唯一支持赋值的语句, 是像这样的原子表达式 x := 5 或 x := foo().
嵌入式编程
给嵌入式系统编写程序与在一个有完整操作系统的计算机上编写程序有很大不同。某些语言相比而言更适合嵌入式编程的需要。
对于不少人赞成Go语言可以给机器人编程这件事我很疑惑。基于一些原因,Go语言并不适合用来为嵌入式系统编写程序。这一节并不是对Go语言的指责,Go语言并不是被设计用来编写嵌入式程序的语言。这一章节针对那些吹捧Go语言可以胜任嵌入式编程的人。
子问题 #1:堆和动态内存分配
堆是一块在运行期创建的可以存储任意数量对象的内存区域。我们将对堆的使用称作&动态内存分配&。
通常,在嵌入式系统中使用堆存储空间是不明智的。较大的内存开销和需要管理复杂的数据结构是主要的原因,尤其是当你在一块主频只有8MHz,RAM只有2KB的MCU上写程序的时候。
在实时系统(因为某一操作耗时过长就可能会跪的系统)中使用堆也是不明智的,因为对堆上空间的申请和释放所消耗的时间有很大的不确定性。举个例子,如果你的MCU正在控制一个火箭的引擎,就在这时,如果一个对栈空间的申请比平常多消耗了几百毫秒,导致对阀门的错误计时,就会发生大爆炸。
还有一些原因致使动态内存分配对嵌入式编程没有多大用。例如,许多使用堆的语言同时也拥有垃圾收集机制。垃圾收集机制经常会暂停整个程序一会儿,在堆上寻找垃圾(不再被程序使用的内存)并清除它们。这比单纯的堆空间申请更加具有不确定性。
好的解决方案:让动态内存分配成为可选项
Rust语言的标准库中有很多特性依赖于堆。然而,Rust语言的编译器支持完全关闭这些有关堆的语言特性,并且能够静态地确保这些特性在程序中不被使用。写出完全不使用堆的Rust程序是完全可行的。
Go语言的解决方案:没有
Go语言严重依赖于对堆的运用。没有可行的方式让Go程序完全不使用堆。这不是Go语言的问题。这在Go语言的目的应用领域完全没有问题。
Go并不是一门实时的语言,通常我们不能担保合理复杂的Go程序的执行时间。这可能有点费解,我来解释一下:Go相对而言很快,但不是实时的,这两个概念非常不同。执行速度快对嵌入式程序来说很重要,但是真正重要的是能否担保某些操作的最大执行时间,而这恰恰是Go不能预测的。这个问题有很大一部分是Go语言对于堆空间和垃圾收集机制的使用造成的。
Haskell也有相似的问题。Haskell同样由于对堆的大量使用而不能胜任嵌入式或者实时编程。然而,我没有看见任何人推荐使用Haskell对机器人编程,所以我不用指出这点。
子问题#2:不安全的底层代码
当我们写嵌入式程序的时候,写一些不安全的代码(不安全的的类型转换,或者指针运算)是不可避免的。在C或C++中,做这样的事情是很简单的。如果我需要向0x1234这个内存地址写入0xff这个值来点亮一个LED,我可以这样写:
*(uint8_t*)0x1234 = 0xFF;
这样做很危险,只有当我们写非常底层的系统代码的时候才有意义。这就是Go和Haskell没有简单的方式来做这样的事的原因:它们不是系统编程语言。
好的解决方案:将不安全的代码孤立开来
注重安全和系统编程的Rust语言有一个非常好的解决方案:unsafe代码块。unsafe代码块是一种显示地将不安全的代码分离出来的方式。我们通过如下的方式在Rust语言中向0x1234地址写入0xff:
*(0x1234 as *mut u8) = 0xFF;
如果我们在unsafe代码块外面做这样的事情,Rust的编译器会警告我们。这样允许我们在满足嵌入式编程需要的同时,保持了程序的安全和稳定。
Go的解决方案:没有
Go语言本来就不是为了做这样的事而出现的,所以没有任何内建的支持。
现在你可能会说,&那么为什么你说Go语言不好?这只是一大堆你的抱怨而已。你可以针对任何语言发牢骚。&没有语言是完美的,这很正确。然而,我希望我的抱怨能在某种程度上说明:
Go语言本质上没有干了什么新的事情
Go语言本身没有被良好地设计
Go语言是其他现代编程语言的退化
& 相关主题:如何在Go语言中使用Redis连接池 - 推酷
如何在Go语言中使用Redis连接池
一、关于连接池
一个数据库服务器只拥有有限的资源,并且如果你没有充分使用这些资源,你可以通过使用更多的连接来提高吞吐量。一旦所有的资源都在使用,那么你就不 能通过增加更多的连接来提高吞吐量。事实上,吞吐量在连接负载较大时就开始下降了。通常可以通过限制与可用的资源相匹配的数据库连接的数量来提高延迟和吞 吐量。
如果不使用连接池,那么,每次传输数据,我们都需要进行创建连接,收发数据,关闭连接。在并发量不高的场景,基本上不会有什么问题,一旦并发量上去了,那么,一般就会遇到下面几个常见问题:
性能普遍上不去
CPU 大量资源被系统消耗
网络一旦抖动,会有大量 TIME_WAIT 产生,不得不定期重启服务或定期重启机器
服务器工作不稳定,QPS 忽高忽低
要想解决这些问题,我们就要用到连接池了。连接池的思路很简单,在初始化时,创建一定数量的连接,先把所有长连接存起来,然后,谁需要使用,从这里取走,干完活立马放回来。 如果请求数超出连接池容量,那么就排队等待、退化成短连接或者直接丢弃掉。
二、使用连接池遇到的坑
最近在一个项目中,需要实现一个简单的 Web Server 提供 Redis 的 HTTP interface,提供 JSON 形式的返回结果。考虑用 Go 来实现。
首先,去看一下 Redis 官方推荐的 Go Redis driver。官方 Star 的项目有两个:Radix.v2 和 Redigo。经过简单的比较后,选择了更加轻量级和实现更加优雅的 Radix.v2。
Radix.v2 包是根据功能划分成一个个的 sub package,每一个 sub package 在一个独立的子目录中,结构非常清晰。我的项目中会用到的 sub package 有 redis 和 pool。
由于我想让这种被 fork 的进程最好简单点,做的事情单一一些,所以,在没有深入去看 Radix.v2 的 pool 的实现之前,我选择了自己实现一个 Redis pool。(这里,就不贴代码了。后来发现自己实现的 Redis pool 与 Radix.v2 实现的 Redis pool 的原理是一样的,都是基于 channel 实现的, 遇到的问题也是一样的。)
不过在测试过程中,发现了一个诡异的问题。在请求过程中经常会报 EOF 错误。而且是概率性出现,一会有问题,一会又好了。通过反复的测试,发现 bug 是有规律的,当程序空闲一会后,再进行连续请求,会发生3次失败,然后之后的请求都能成功,而我的连接池大小设置的是3。再进一步分析,程序空闲300秒 后,再请求就会失败,发现我的 Redis server 配置了 timeout 300,至此,问题就清楚了。是连接超时 Redis server 主动断开了连接。客户端这边从一个超时的连接请求就会得到 EOF 错误。
然后我看了一下 Radix.v2 的 pool 包的源码,发现这个库本身并没有检测坏的连接,并替换为新的连接的机制。也就是说我每次从连接池里面 Get 的连接有可能是坏的连接。所以,我当时临时的解决方案是通过增加失败后自动重试来解决了。不过,这样的处理方案,连接池的作用好像就没有了。技术债能早点 还的还是早点还上。
三、使用连接池的正确姿势
想到我们的 ngx_lua 项目里面也大量使用 redis 连接池,他们怎么没有遇到这个问题呢。只能去看看源码了。
经过抽象分离, ngx_lua 里面使用 redis 连接池部分的代码大致是这样的:
&&&&location&/pool&{&
&&&&&&&&content_by_lua_block&{&
&&&&&&&&&&&&local&redis&=&require&&resty.redis&&
&&&&&&&&&&&&local&red&=&redis:new()&
&&&&&&&&&&&&local&ok,&err&=&red:connect(&127.0.0.1&,&6379)&
&&&&&&&&&&&&if¬&ok&then&
&&&&&&&&&&&&&&&&ngx.say(&failed&to&connect:&&,&err)&
&&&&&&&&&&&&&&&&return&
&&&&&&&&&&&&end&
&&&&&&&&&&&&ok,&err&=&red:set(&hello&,&&world&)&
&&&&&&&&&&&&if¬&ok&then&
&&&&&&&&&&&&&&&&return&
&&&&&&&&&&&&end&
&&&&&&&&&&&&red:set_keepalive(1)&
&&&&&&&&}&
发现有个 set_keepalive 的方法,查了一下官方文档,方法的原型是 syntax: ok, err = red:set_keepalive(max_idle_timeout, pool_size) 貌似 max_idle_timeout 这个参数,就是我们所缺少的东西,然后进一步跟踪源码,看看里面是怎么保证连接有效的。
function&_M.set_keepalive(self,&...)&
&&&&local&sock&=&self.sock&
&&&&if¬&sock&then&
&&&&&&&&return&nil,&¬&initialized&&
&&&&if&self.subscribed&then&
&&&&&&&&return&nil,&&subscribed&state&&
&&&&return&sock:setkeepalive(...)&
至此,已经清楚了,使用了 tcp 的 keepalive 心跳机制。
于是,通过与 Radix.v2 的作者一些讨论,选择自己在 redis 这层使用心跳机制,来解决这个问题。
四、最后的解决方案
在创建连接池之后,起一个 goroutine,每隔一段 idleTime 发送一个 PING 到 Redis server。其中,idleTime 略小于 Redis server 的 timeout 配置。连接池初始化部分代码如下:
p,&err&:=&pool.New(&tcp&,&u.Host,&concurrency)&
errHndlr(err)&
go&func()&{&
&&&&for&{&
&&&&&&&&p.Cmd(&PING&)&
&&&&&&&&time.Sleep(idelTime&*&time.Second)&
使用 redis 传输数据部分代码如下:
func&redisDo(p&*pool.Pool,&cmd&string,&args&...interface{})&(reply&*redis.Resp,&err&error)&{&
&&&&reply&=&p.Cmd(cmd,&args...)&
&&&&if&err&=&reply.E&err&!=&nil&{&
&&&&&&&&if&err&!=&io.EOF&{&
&&&&&&&&&&&&Fatal.Println(&redis&,&cmd,&args,&&err&is&,&err)&
&&&&&&&&}&
&&&&return&
其中,Radix.v2 连接池内部进行了连接池内连接的获取和放回,代码如下:
//&Cmd&automatically&gets&one&client&from&the&pool,&executes&the&given&command&
//&(returning&its&result),&and&puts&the&client&back&in&the&pool&
func&(p&*Pool)&Cmd(cmd&string,&args&...interface{})&*redis.Resp&{&
&&&&c,&err&:=&p.Get()&
&&&&if&err&!=&nil&{&
&&&&&&&&return&redis.NewResp(err)&
&&&&defer&p.Put(c)&
&&&&return&c.Cmd(cmd,&args...)&
这样,我们就有了 keepalive 的机制,不会出现 timeout 的连接了,从 redis 连接池里面取出的连接都是可用的连接了。看似简单的代码,却完美的解决了连接池里面超时连接的问题。同时,就算 Redis server 重启等情况,也能保证连接自动重连。
已发表评论数()
请填写推刊名
描述不能大于100个字符!
权限设置: 公开
仅自己可见
正文不准确
标题不准确
排版有问题
主题不准确
没有分页内容
图片无法显示
视频无法显示
与原文不一致

参考资料

 

随机推荐