草庐IT

Kafka中Zookeeper的作用

全部标签

networking - Golang DNS 解析不起作用

我已经阅读了很多书,但我就是找不到解决方案。我在谷歌云中打开了一个VPS,用Ubuntu启动了一个实例,并运行了一个我用Go编写的网络服务器,在端口80监听。我还在我的国家注册了一个域名www.crosslogic.com.ar,委托(delegate)如下这个:n1.crosslogic.com.ar130.211.196.55n2.crosslogic.com.ar130.211.196.55(需要两个,但我只有一个IP)当我在浏览器中输入IP时,一切正常,但当我尝试使用www.crosslogic.com.ar、crosslogic.com.ar或n1.crosslogic.co

testing - echo c.Get ("user") 在测试环境中不起作用

我正在尝试测试基于echo框架/路由器构建的golangAPI。我有以下测试......funcTestLogout(t*testing.T){loadConfig()db:=stubDBs(t)Convey("Whenyoupostto/logout",t,func(){Convey("withavalidtoken,youshouldgetaasuccessmsgandbeloggedout",func(){e:=echo.New()e.Use(middleware.JWTWithConfig(middleware.JWTConfig{SigningKey:[]byte("secr

XML Marshal 在此 Go 示例中不起作用

在此代码中,返回的元素x没有正文-我相信MarshalIndent无法正常工作。我将无法使用structRecord。是否有任何解决方法可以按预期返回值。packagemainimport"fmt"import"encoding/xml"import"time"typeRecordstruct{aint64`xml:"a,omitempty"`bint64`xml:"b,omitempty"`cint64`xml:"c,omitempty"`dint64`xml:"d,omitempty"`eint64`xml:"e,omitempty"`fstring`xml:"f,omitempt

go - Gogland 中的输入不起作用

我在Go中有一个简单的代码:packagemainimport("bufio""os""fmt")funcmain(){scanner:=bufio.NewScanner(os.Stdin)vartextstringfmt.Print("Enteryourtext:")scanner.Scan()text=scanner.Text()fmt.Println("Yourtextwas:",text)}当我在终端中运行代码或在Gogland中使用运行模式时,运行完美。但是,当我在Gogland中通过Debug模式运行相同的代码时,即使我键入Enter,也会继续读取输入。如何解决?或者这是一

go - Kafka 0.11/Golang Sarama 版本支持

我花了一些时间发现连接到Kafka0.11集群的Go应用程序使用的是旧的0.8.2版本的库,它在响应中缺少时间戳值。然后我发现不支持Kafka0.11.xAPI/版本(但他们正在努力)。我现在有两个解决方案。首先是在我的应用程序中明确设置所需的版本。其次是“调整”Sarama代码以使用版本0.10.x作为最低版本,使我能够使用所有0.10.xAPI/功能。我还在想为什么版本不是从我正在连接的Kafka代理中获取的?我无法从代码中理解它应该如何工作...我清楚地看到在sarama.Config.Version中设置或定义的版本,但我无法在连接后找到任何更新此值的内容给经纪人?我知道Pyt

go - 服务多个目录不起作用

有什么方法可以使用fasthttp框架为多个目录提供服务吗?为了同样的目的,我写了下面的代码。但是,这段代码并没有像我预期的那样工作。当我访问localhost:8080/path1时,它会抛出错误和警告,Cannotopenrequestedpath2017/10/1316:57:010.977#0000000100000001-127.0.0.1:8080127.0.0.1:48870-GEThttp://localhost:8080/path1-cannotopenfile"/home/test/path1":open/home/test/path1/path1:nosuchfi

go - 实现并发运行的 "done"模式但不起作用

我尝试在Go中实现“完成”模式以将错误通知给其他channel:这是我的代码:packagemainimport("fmt""time")funcparse(done>done这是我的可执行链接:PlayGolangURL但是当我运行时,我没有看到“streamclosed”这一行。请为我解释原因。 最佳答案 如果您运行的代码足够多,您会看到streamclosed。运行如下代码并检查日志文件:forIin`seq110`;dogorunmain.go>>./res.log2>&1;done我尝试用代码解释发生了什么。首先,defe

json - 嵌套结构的解码字段不起作用

给定以下结构typeFoostruct{Thingtime.Duration`json:"thing"`}typeBarstruct{FooEntrytime.Duration`json:"entry"`}我想自定义time.Duration格式并从json字符串加载Bar值,例如:{"thing":"hour","entry":"second"}所以我为Foo和Bar(https://play.golang.org/p/6v71eG_Xr98)覆盖了UnmarshalJSON:packagemainimport("encoding/json""fmt""time")typeFoost

string.endswith(“”)在IE中不起作用(不确定如何使用polyfill)

我在用string.endswith()通过JSON对象循环并找出对象的任何属性是否endswith一个"Value"基因。发现对象属性是否结束后"Value",我试图将属性的价值舍开2个小数,默认情况下是5个小数。这是我的代码varMyObj=[{"$id":"1","GeoName":"EAST","ReachValue":87.88221970554928,"ReachValue":90.71955219607294,"DepthValue":18.44377295716579,"ShareValue":16.732108234801206},{"$id":"2","GeoName":"

docker - 我尝试在 docker 中部署 gRPC (go) 服务器并在本地端口中公开端口,但端口绑定(bind)不起作用

我尝试在docker中部署gRPC服务器和mongodb。之后我尝试将docker端口绑定(bind)到我的本地端口。mongodb端口绑定(bind)工作正常。但是,gRPC服务器端口没有绑定(bind)我的本地端口ports:-"50051:50051"像这样我在docker-compose.yml中尝试过docker-compose.ymlservices:auth_server:container_name:auth_servicebuild:.command:gorunserver.govolumes:-.:/go/src/auth_serverworking_dir:/go