草庐IT

sockets - 了解WebSockets

全部标签

go - 在 go 程序后台运行的 Websockets 导致 100% CPU 使用率

我在我的go程序中实现了网络套接字,以便在其他进程发生时定期在后台更新三个变量。自从这样做以来,程序几乎立即开始占用100%的CPU使用率,我不确定为什么。这里是有问题的代码:streamOneHandler:=func(event*websockets.Event){varOne,err=strconv.ParseFloat(event.Number,64)}streamTwoHandler:=func(event*websockets.Event){varTwo,err=strconv.ParseFloat(event.Number,64)}streamThreeHandler:=

sockets - 如何处理 go 中的粘性 tcp 数据包?

我有一个tcp服务器和一个客户端,服务器执行以下操作funcproviderCallback(connnet.Conn){reader:=bufio.NewReader(conn)varerrerrorfor{lenbyte,_:=reader.Peek(4)reader.Discard(4)slen:=int(binary.BigEndian.Uint32(lenbyte))data,err=reader.Peek(slen)process(data)reader.Discard(slen)}}客户端发送数据包的速度似乎快于进程可以处理的速度,因此我想在bufio中缓冲请求并稍后处理

go - 了解字符串转义序列

我是新手,所以对字节概念有很多困惑。在浏览一些go代码时,我遇到了类似的事情[]byte("\xd2\xfd\x88g\xd5\r-\xfe")它是十六进制还是字节格式?上面的g,r-,e等字符代表什么?以及如何在日志中打印出来? 最佳答案 []byte("\xd2\xfd\x88g\xd5\r-\xfe")是转换为[]byte类型的解释字符串文字,一个byteslice。这里它被分成字节值:[\xd2,\xfd,\x88,g,\xd5,\r,-,\xfe]或者,以十六进制字节表示,[d2,fd,88,67,d5,0d,2d,fe]

sockets - 如何在 TLS 监听器中验证对等证书

我正在编写一个TLS监听器并接受新连接。在继续之前,必须根据SHA1列表验证新连接。问题是tls.Listen()返回接口(interface)net.Listener的监听器。这意味着Accept()将产生简单的net.Conn而不是提供ConnectionState()的tls.Conn。PeerCertificates.接受的net.Conn太基础了,但是当我转换为更具体的*tls.Conn类型时,我收到运行时异常。packagemainimport("crypto/tls""fmt""net")typeServicestruct{listenernet.Listener}fun

go - 需要了解 goroutines

这个问题在这里已经有了答案:Goroutinedoesnotexecuteiftime.Sleepincluded(1个回答)关闭6年前。初学Go语言编程,循序渐进在实践中,我发现了goroutines的随机行为。如果我调用goroutine(sleep时间为1秒的函数),有时它会成功完成,有时却不会:packagemainimport("fmt""time")funct(iint){fmt.Println("Infunct")time.Sleep(1)}funct1(iint){fmt.Println("Infunct1")time.Sleep(1)}funcmain(){fmt.P

sockets - 如何用 Go 读取 FFMPEG?

如何读取从ffmpeg发送的UDP?我写了一个脚本来监听UDP数据包并将它们写入文件,但是该文件是无效的并且几乎是两倍大小。这是我发送数据的方式:ffmpeg-ivideo.mp4-c:aaac-ar48000-ab196k\-ac2-strict-2-c:vlibx264-vb500k-r25-s320x240\-ss00.000-fmp4-movflagsfrag_keyframe+empty_moov\udp://127.0.0.1:1936这是Go中的代码。它应该简单地将视频写入一个新的视频文件:packagemainimport("net""os")funcmain(){va

sockets - io.复制: How to know if a socket is closed or disconnected

我有一个简单的程序,它将程序的stdin、stdout和stderr连接到一个套接字,就像这样,gofunc(){deferconn.Close();deferstdin.Close();io.Copy(stdin,conn);}();gofunc(){deferconn.Close();deferstdout.Close();deferstderr.Close();io.Copy(conn,stdout);io.Copy(conn,stderr);}();select{}我有两个问题,我必须通过执行select{}让这两个goroutine保持运行当套接字断开连接时,无法通知它。如果

go - 了解 golang channel 。所有的goroutines都睡着了——死锁【围棋之旅,爬虫】

当一个从未接触过多线程程序的PHP开发人员开始学习golang和channel时,可能会发生这种情况。我正在进行围棋之旅的最后一个练习,[Exercise:WebCrawler](在此之前,我对其他练习没有任何问题)虽然我正在尝试编写尽可能简单的代码,我的Crawl方法如下所示:funcCrawl(urlstring,depthint,fetcherFetcher){//kickoffcrawlingbypassinginitialUrltoaJobqueueQueuegorun说我不应该写任何go代码然后返回PHP:fatalerror:allgoroutinesareasleep-

go - 使用 gob 在 Go 中编码 websockets

我正在使用Go中的websockets编写一个聊天应用程序。将有多个聊天室,想法是将连接到聊天室的所有websocket存储在Redis列表中。为了在Redis中存储和检索websockets,我必须对它们进行编码/解码,并且(根据this问题)我认为我可以为此使用gob。我正在使用github.com/garyburd/redigo/redis作为Redis和github.com/gorilla/websocket作为我的websocket库。我的函数看起来像:funcaddWebsocket(roomstring,ws*websocket.Conn){conn:=pool.Get(

sockets - 监听套接字时域使用有什么区别?

我在查看的一些示例之间发现了一些差异,并意识到有些使用域而有些则不使用。两者之间的真正区别是什么?net.Listen("tcp",":8080")net.Listen("tcp","localhost:8080") 最佳答案 它有默认参数,表示0.0.0.0、127.0.0.1、localhost。就是方便。net.Listen("tcp",":8080")在这里你可以硬绑定(bind)任何域。net.Listen("tcp","localhost:8080") 关于sockets-监