go-beastalk是beastalkd 的GO语言的一个客户端.
项目还在开发中,欢迎大家提意见
介绍
beastalkd是一个快速的、有各种用途的延迟队列和定时任务的不同点:定时任务以一定的周期或者在某个特定的时间运行。beastalk可以在延迟一段时间执行。一些使用场景:
用户下单5分钟后检查用户是否完成了支付一分钟后开始一个新的程序如何使用
Mac&Liux
安装并启动beatalkd服务器
gitcloehttps://github.com/kr/beastalkdcdbeastalkdmake./beastalkd使用示例
gogetgithub.com/liuzhegyag/gobeastalkcreateatest.gofile
packagemaiimport("fmt""github.com/liuzhegyag/gobeastalk")fucmai(){addr:="localhost:11300"//defieserveraddressewCo:=gobeastalk.NewCoectio(addr)//createewcoectiochael:=make(chait)//createitchaelputFuc:=fuc(){//defieafuctiowhichputsomemessagetooetubeid,_:=ewCo.PutWithTube("hello","test2",1)chael<-id}goputFuc()//rupreviousfuctioiago-routieid:=<-chael//waitutilwefiishputtigfmt.Pritf("Receivefromchaelmessageofaothergoroutie%d\",id)listeChael:=make(chastrig)//makealistechaelforreceivigresultsdealFuc:=fuc(bodystrig)bool{//defieafuctiotodealwithtubemessagesfmt.Pritf("receive%s\",body)listeChael<-bodyreturtrue}goewCo.Liste("test2",dealFuc)//rudealfuctioiaspecifiedgo-routigbody:=<-listeChael//waitourmessagefmt.Pritf("Listeoce%s\",body)ewCo.Close()//Closecoectio}Adruthis
gorutest.go
评论