草庐IT

安全网络

全部标签

go - 如何在 golang 网络服务器中使用 prometheus 监控请求成本时间

我有几个url可以访问,我想用prometheus监控每个请求的成本时间。但我不知道使用哪种指标来收集数据。有什么帮助吗?这是演示代码:packagemainimport("github.com/prometheus/client_golang/prometheus""io/ioutil""net/http""fmt""time")var(resTime=prometheus.NewSummaryVec(prometheus.SummaryOpts{Name:"response_time",Help:"costtimeperrequest",},[]string{"costTime"}

go - 带有内置网络爬虫的 Martini Go 服务器在几个小时后打开的文件太多

我构建了一个网络爬虫,提供一些有关其发现的http信息。爬虫作为goroutine运行,martini运行web服务器。过了一会儿,我开始得到2014/08/0110:23:51http:Accepterror:accepttcp[::]:3000:toomanyopenfiles;retryingin1s.我读到我应该尝试增加最大打开文件数我只是这个配置级别的新手并且不知道如何做到这一点。我在Ubuntu14.04上运行它。请问如何更改martini服务器的最大打开文件数,谢谢。 最佳答案 确保不要忘记关闭从http.Get获得的

go - 由于 slice 中的项目数正在变化,如何安全地从 slice 中删除项目

在我遍历用户slice后,我需要根据某些条件从slice中删除一些用户。我将多次遍历此用户slice,慢慢删除一些元素。我从其他语言了解到,在循环时从集合中删除项目是不安全的。所以我正在做的是将我想要删除的元素存储在maptoMutate中。原始循环完成后,我会继续尝试从slice中删除元素。toMutate:=make(map[int]User,100)foridx,u:=rangec.users{ifsomeCondition{toMutate[idx]=u}}然后我调用此函数从用户的slice中删除项目。foridx,u:=rangetoMutate{c.users=append

随着请求数量的增加,Go 网络服务器性能急剧下降

我正在使用wrk对一个用Go编写的简单网络服务器进行基准测试。服务器在具有4GBRAM的机器上运行。在测试开始时,代码服务高达2000个请求/秒,性能非常好。但随着时间的推移,进程使用的内存逐渐增加,一旦达到85%(我正在使用top进行检查),吞吐量就会下降到约100个请求/秒。一旦我重新启动服务器,吞吐量再次增加到最佳数量。性能下降是内存问题吗?为什么Go不释放这段内存?我的Go服务器看起来像这样:funcmain(){deferfunc(){//Waitforallmessagestodrainoutbeforeclosingtheproducerp.Flush(1000)p.Cl

unit-testing - 如何在不创建实际网络连接的情况下测试依赖于 net.Conn 的代码?

如果我有适用于net.Conn的代码,我如何在不实际创建与本地主机的网络连接的情况下为其编写测试?我在网上没有看到这个问题的解决方案;人们似乎要么忽略它(不进行测试),要么编写无法并行运行的测试(即使用实际的网络连接,这会耗尽端口),要么使用io.Pipe。不过,net.Conn定义了SetReadDeadline、SetWriteDeadline;而io.Pipe没有。net.Pipe也没有,尽管表面上声称要实现该接口(interface),但它只是通过以下方式实现:func(p*pipe)SetDeadline(ttime.Time)error{return&OpError{Op:

ssl - 获取网络/http : TLS handshake timeout golang

需要你的帮助packagemainimport("log""net/http")funcmain(){client:=&http.Client{}_,err:=client.Get("https://www.marathonbet.com/en/")iferr!=nil{log.Fatalf("%s\n",err)}}这总是返回:获取https://www.marathonbet.com/en/:net/http:TLS握手超时退出状态1我正在尝试:it并使用this库并做it但对我没有任何作用..所以,请帮助我。更新:在带有请求的Python2.7中,这有效:s=Session()r

multithreading - App Engine Channel API 的线程安全/原子性

当我尝试使用GoogleAppEngine的ChannelAPI从两个或多个goroutines和/或任务队列发送消息时会发生什么?例如gochannel.Send(context,clientID,"Hello")gochannel.Send(context,clientID,"World")我知道在GAEGo中,所有goroutines都被多路复用到一个线程上。然而,这仍然允许在I/O期间进行抢占,并且channel发送可能符合I/O的条件。GAE开发服务器似乎序列化了所有请求,所以我没有看到任何channel发送重叠。生产服务器似乎允许一些请求并发,但channel发送看起来是原

networking - 跨网络复制函数

我正在尝试使用Go编写代码,通过网络将闭包从计算机A传输到计算机B,以允许计算机B执行闭包。例如计算机A:c1:=func(){fmt.Println("HelloWorld")}//somehowtransferc1toComputerB计算机B:c2:=//receiveclosurefromComputerAc2()结果是在第二台计算机上打印“HelloWorld”。有人知道这个方法吗? 最佳答案 你不能这样做。至少在添加一些奇特的NaCl支持之前不会。 关于networking-

sockets - 限制连接到网络服务的客户端数量

如何限制连接到我的服务的客户端数量?我尝试了一个简单的计数器,但是如果客户端没有关闭就退出了他们的联系我不知道怎么弄的。请有人给我一些想法以便得到它吗?constMAX_CLIENTS=5varConnectedClientsintfuncmain(){ConnectedClients=0server,err:=net.Listen(CONN_TYPE,net.JoinHostPort(CONN_HOST,CONN_PORT))iferr!=nil{fmt.Println("ErrorListening",err.Error())os.Exit(1)}deferserver.Close

go - 使用 Go 客户端库创建实例组时无法定义网络?

通过GCPConsole创建非托管实例组时,我可以看到REST请求为:POSThttps://www.googleapis.com/compute/v1/projects/my-project/zones/us-east1-d/instanceGroups{"name":"ig-web","network":"https://www.googleapis.com/compute/v1/projects/my-project/global/networks/nomad-network","namedPorts":[{"name":"http","port":11080}]}然而,acco