草庐IT

handle_tcp_stream

全部标签

ubuntu - 获取连接拒绝 tcp 连接 SysLog Golang

我在golang的ubuntu16.4操作系统上使用syslog来记录如下错误。w,err=syslog.Dial("tcp","localhost:2114",syslog.LOG_ERR,"testapi")这里出现以下错误。调用tcp127.0.0.1:2114:getsockopt:连接被拒绝我已经尝试过以下事情。使用-sudoufwallow2114命令在防火墙中启用端口。禁用防火墙并尝试使用它。通过上述步骤尝试了其他端口。任何帮助将不胜感激。这是syslog.conf#/etc/rsyslog.confConfigurationfileforrsyslog.##Formor

macos - 无法连接到超过 140 个连接的 tcp 服务器?

我正在用golang构建一个TCP套接字服务器。它适用于少于~140个客户端连接。但是,如果我尝试将最大连接数设置为500,则在第140个客户端不连接到服务器后。我将文件描述符计数增加到1048576,但它仍然不起作用。$ulimit-n1048576我认为问题来自操作系统。(服务器和客户端在同一台机器上工作)所​​以操作系统信息:MacOS10.12Sierra64bit.有谁知道为什么我不能增加tcp连接数?github 最佳答案 我和你在同一个操作系统上,但我无法重现你的问题。我正在使用Go版本1.7.4。我没有在Go1.8上

go - TCP 将 Stdout 发送到客户端并从客户端读取 Stdin

我正在尝试通过tcp连接远程执行程序我想在客户端服务器之间实时共享标准输出和标准输入。我有以下没有错误处理的测试服务器:p我知道,目前我无法执行带参数的程序,但这很容易处理:)packagemainimport("bufio""bytes""fmt""net""os/exec""strings")funcmain(){l,_:=net.Listen("tcp",":420")deferl.Close()for{//Waitforaconnection.conn,_:=l.Accept()gofunc(cnet.Conn){for{msg,_:=bufio.NewReader(conn)

go - TCP 客户端无法正常工作 golang

我有一个用golang编写的rest-ful界面。我需要在每个端点上进行身份验证。身份验证完成后,我必须将其转发回tcp服务器。我创建了一个tcp客户端,来自channel的任何值都将发送到tcp服务器。该channel是从http请求正文中填充的。问题是,一旦我发出curl命令,客户端就会卡住,没有任何响应;所以很明显我做错了什么不知道错在哪里。有人对我的问题可能有什么见解吗?packagemainimport("bufio""encoding/json""flag""fmt""io/ioutil""log""net""net/http""net/http/httputil""net

c - O_NONBLOCK SOCK_STREAM 限制为 8192

我正在从C程序写入SOCK_STREAM正在从go程序监听的Unix域套接字,使用net.Listen("unix",sockname).当我将套接字设置为O_NONBLOCK使用fcntl(),我看到C程序在第一次写入时只写入了8192字节。失败后,我监控并回写剩余数据,但我服务器上读取的数据在这种情况下是无效的。当我不使用O_NONBLOCK时,然后整个8762字节被写在一个单一的写入中,一切都按预期工作。C客户端套接字连接if((fd=socket(AF_UNIX,SOCK_STREAM,0))==-1){return;}intflags=fcntl(fd,F_GETFL,0);

转到错误拨号 tcp : Protocol not available

当我尝试为restapiclint运行GO代码时出现错误:获取http://quotes.rest/qod.json:http:连接到代理时出错http://192.168.0.1:3128/:调用tcp192.168.0.1:3128:i/o超时此外,我在Goplayground中尝试了相同的代码。也出现了错误。可能是什么原因?我该如何解决这个问题?请帮我解决这个问题。我使用的代码是:-packagemainimport("net/http""fmt""io/ioutil")funcmain(){resp,er:=http.Get("http://quotes.rest/qod.js

go - Golang扫描函数中 "ERROR: IOError: closed stream"如何处理?

我在Golang代码中使用knifebootstrap命令来引导节点。有时食谱中有等待,等待超过10分钟。在这种情况下,我收到错误“错误:IOStream关​​闭”。有什么办法可以增加时间限制吗?我也在不断地从cmd的输出和错误流中读取日志。funcexecuteCMDWorkstation(cmd*exec.Cmd,projectId,cr_idstring)bool{stdout,err3:=cmd.StdoutPipe()iferr3!=nil{utils.Info.Println(err3)returnfalse}deferstdout.Close()stderr,err4:=

sockets - http: 接受错误:接受 tcp [::]:9000: accept4: 打开的文件太多; 1s 重试

进程的pid是1996291。/proc/1996291/fd中有65534个fd,大部分fd都是socket,像这样:lrwx------1rootroot64Dec3013:5910000->socket:[952574733]lrwx------1rootroot64Dec3013:5910001->socket:[952566188]我知道括号中的数字是套接字的inode。/proc/net/tcp中的每个套接字都应该有一个相同的inode。但是有的inode能找到,有的找不到:cat/proc/net/tcp|grep952574733如果我找到inode,输出如下:sllo

go - 当我从 tcp 缓冲区读取时,我应该为 mtu 值选择哪个数字

这是我准备好读取缓冲区时使用golang编写的代码:funcListen(){listen,_:=net.Listen("tcp4","127.0.0.1:7000")deferlisten.Close()for{conn,_:=listen.Accept()gohandler(&conn)}}funchandler(c*net.Conn){for{buf:=make([]byte,1464)n,_:=(*c).Read(buf)ifn==0{continue}}}1464是我的networkmtu1492-28IPHeader,那么我应该在这里输入哪个数字呢?我的网络使用ppoe协议

go - Kubernetes client-go Remotecommand Stream 何时完成?

我在这里使用这个远程命令https://github.com/kubernetes/client-go/blob/master/tools/remotecommand/remotecommand.go#L108在pod上执行命令并将结果流式传输到io.Writer。如上面命令中所述,链接中的函数仅在客户端或服务器断开连接时Stream才完成。由于Stream配置只附加了一个命令,为什么当命令退出时它不关闭?我怎么知道命令何时完成?特别是我正在将tar-cf-...的结果传输到客户端并想知道它何时完成。 最佳答案 我注意到Stream