草庐IT

threads_connected

全部标签

http - 戈朗 : strategies to prevent connection reset by peer errors

该程序同时生成许多goroutines(getStock),我相信这会导致远程服务器立即断开连接。我不是要创建DOS,但我仍然想在不出现“连接重置”错误的情况下积极获取数据。最多只能有N(例如20)个同时连接的策略是什么?golang的Http客户端有内置GET请求队列吗?我仍在学习,如果能了解是否有针对此类代码的更好设计模式,那就太好了。输出$goruns1w.gosl(size):1280body:"AAPL",17.92body:"GOOG",32.13body:"FB",42.02body:"AMZN",195.83body:"GOOG",32.13body:"AMZN",19

postgresql - 连接 : connection timed out

我已经使用gosql包成功连接到Postgres数据库:...db,err:=sql.Open("postgres",connStr)然后我使用返回的数据库执行(长时间运行的)查询:rows,err:=db.Query(...)我得到了错误:dialtcpxx.xxx.xxx.xx:5432:connect:connectiontimedout我有几个问题:为什么连接超时?我能做些什么来防止它超时吗? 最佳答案 sql.Open()mayjustvalidateitsargumentswithoutcreatingaconnecti

postgresql - 通过 pq 连接到 PostgreSQL 数据库返回 "bad connection"错误

我正在使用两台不同的计算机在Go和PostgreSQL中制作一个网络应用程序。两台计算机上的设置相同(Ubuntu与最新版本的Go和PostgreSQL)。问题是我无法让我的应用程序连接到笔记本电脑上的数据库。我使用这段代码:func(db*Database)Dial(userstring,passwordstring,dbnamestring){varerrerrordb.Conn,err=sql.Open("postgres","user="+user+"password="+password+"dbname="+dbname+"sslmode=require")iferr!=ni

time - 戈朗 : throttle (time delay) function is not working in goroutine (works fine in main thread)

所以我正在编写一个实用程序来查询工作中的API,它们将每10秒限制为20次调用。很简单,我会将我的通话时间限制在自上次通话后至少0.5秒。在我尝试使用goroutine之前,我的Throttle实用程序运行良好。现在我正在使用结构/方法组合:func(c*CTKAPI)Throttle(){ifc.Debug{fmt.Println("\t\t\tEnteringThrottle()")}for{//incasesomethingelsemakesacallwhilewe'resleeping,weneedtore-checkift:=time.Now().Sub(c.LastCall

concurrency - 如何将多个 goroutine 同步到所选 goroutine 的终止(即 Thread.join())

我在上一个问题中问过这个问题,但有些人觉得我最初的问题不够详细(“为什么你会想要一个定时条件等待??”)所以这里有一个更具体的问题。我有一个goroutine正在运行,称之为服务器。它已经启动,将执行一段时间,然后执行它的操作。然后,它将退出,因为它已完成。在它执行期间,一些大量的其他goroutines开始。如果您愿意,可以将它们称为“客户端”线程。他们运行步骤A和步骤B。然后,他们必须等待“服务器”goroutine完成一段指定的时间,如果“服务器未完成”则以状态退出,如果完成则运行步骤C。(请不要告诉我如何重构此工作流。这是假设的,是给定的。无法更改。)一个正常、明智的方法是让服

go-zookeeper Connect 在没有有效连接的情况下返回

我有一个关于zookeeper的问题,我正在尝试使用go-zookeeper实现简单的服务发现,我正在使用go-zookeeper:https://github.com/samuel/go-zookeeper我的问题是每当我使用例如连接到zookeeper时:zoo_keeper,_,err:=zk.Connect(s,time.Second)函数立即返回,没有报错,但还没有真正有效的连接。现在,例如,如果我想创建znode,我需要检查什么以确保在这样做之前我有一个有效的连接? 最佳答案 在尝试了几件事之后,感谢Imesha的建议,

debugging - 有什么方法可以获取 'http: response.WriteHeader on hijacked connection' 错误的堆栈跟踪?

我们的Web应用程序正在将大量“http:response.WriteHeaderonhijackedconnection”消息记录到stderr。有什么方法可以让http库输出堆栈跟踪或其他调试信息以及此消息(或将其升级为错误),以便追踪位置在我们的应用程序中会发生这种情况吗? 最佳答案 由于永远不会返回错误,并直接写入http.Server.ErrorLog,这是您唯一可以拦截它的地方。您可以在调试器中运行它并在该点中断,但如果在生产环境中运行,这可能没有用。您可以使用io.Writer创建一个新的*log.Logger,当它遇

golang 运行时 : failed to create new OS thread (have 2049 already; errno=12)

我在MacOs上创建了很多goroutine,程序执行时出现错误。goRoutineId=3710,i=3683,len(chan)=2049runtime:failedtocreatenewOSthread(have2049already;errno=12)fatalerror:runtime.newosproc所以我想知道“无法创建新的OS线程”是什么意思,这是操作系统的限制,只是golang没有能力创建更多的goroutine?谢谢你帮助我。 最佳答案 这是操作系统的限制。我假设您使用的是Linux。根据thesourceof

Could not connect to Redis at 127.0.0.1:6379: 由于目标计算机积极拒绝,无法连接。(极简解决办法)

一、遇到问题。在需要启动Redis客户端的时候,会发现会报这个错误。报这个错误的原因就是Redis的服务端没有开启,那Redis的客户端是访问不了的 二、解决办法。1.解决的办法就是要启动服务端,让这个客户端可以访问到。启动服务端最简单不会出错的办法就是去安装目录下,直接双击启动服务端(redis-server.exe) 2.启动服务端成功界面,然后这个界面不要关掉  3.

php - 使用 PHP 的 TNT Express Connect 定价模块

我需要连接到TNTExpressconnect并获取给定重量和体积的产品的定价详细信息我正在使用PHP并尝试连接PHPPostXMLRequesttoserver(TNTExpressConnectPricingmodule)中的这行代码$Xml));$opts=array('http'=>array('method'=>'POST','header'=>'Content-type:application/x-www-form-urlencoded','content'=>$postdata));$context=stream_context_create($opts);$output