亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

go中的套接字回顯服務器

go中的套接字回顯服務器

Go
開心每一天1111 2021-06-02 21:23:09
我正在嘗試在 go 中實現一個簡單的套接字回顯服務器,這是代碼:package mainimport (    "fmt"    "net"    "sync")func echo_srv(c net.Conn, wg sync.WaitGroup) {    defer c.Close()    defer wg.Done()    for {            var msg []byte            n, err := c.Read(msg)            if err != nil {                    fmt.Printf("ERROR: read\n")                    fmt.Print(err)                    return            }            fmt.Printf("SERVER: received %v bytes\n", n)            n, err = c.Write(msg)            if err != nil {                    fmt.Printf("ERROR: write\n")                    fmt.Print(err)                    return            }            fmt.Printf("SERVER: sent %v bytes\n", n)    }}func main() {    var wg sync.WaitGroup    ln, err := net.Listen("unix", "./sock_srv")    if err != nil {            fmt.Print(err)            return    }    defer ln.Close()    conn, err := ln.Accept()    if err != nil {            fmt.Print(err)            return    }    wg.Add(1)    go echo_srv(conn, wg)    wg.Wait()}出于某種原因,一旦客戶端連接, c.Read() 不會阻止并打印錯誤消息。所以,我的第一個問題是:在客戶端向套接字發送某些內容之前,不應該阻止 c.Read() 嗎?第二:打印錯誤消息后,服務器不會終止。這是我在 gdb 中執行程序時看到的:(gdb) run                                                                    Starting program: src/sockets/server/server                                  warning: Could not load shared library symbols for linux-vdso.so.1.          Do you need "set solib-search-path" or "set sysroot"?                        [Thread debugging using libthread_db enabled]                                Using host libthread_db library "/usr/lib/libthread_db.so.1".                [New Thread 0x7fffe7806700 (LWP 28594)]                                      [New Thread 0x7fffe7005700 (LWP 28595)]                                      ERROR: read                                                                  EOF^C                                                                        我在 Python 和 C 中有類似的回聲服務器,它們工作正常。為了完整起見,我還在下面發布了套接字客戶端應用程序(它適用于我的 C 和 Python 服務器)。
查看完整描述

2 回答

?
互換的青春

TA貢獻1797條經驗 獲得超6個贊

這是一個echo_srv為你工作。你也需要@jnml 的建議!


實際上分配一些緩沖區來接收 - 你做了一個 0 字節的緩沖區!

在EOF上整齊地退出

只寫收到的字節 msg[:n]


func echo_srv(c net.Conn, wg *sync.WaitGroup) {

    defer c.Close()

    defer wg.Done()


    for {

        msg := make([]byte, 1000)


        n, err := c.Read(msg)

        if err == io.EOF {

            fmt.Printf("SERVER: received EOF (%d bytes ignored)\n", n)

            return

        } else  if err != nil {

            fmt.Printf("ERROR: read\n")

            fmt.Print(err)

            return

        }

        fmt.Printf("SERVER: received %v bytes\n", n)


        n, err = c.Write(msg[:n])

        if err != nil {

            fmt.Printf("ERROR: write\n")

            fmt.Print(err)

            return

        }

        fmt.Printf("SERVER: sent %v bytes\n", n)

    }

}


查看完整回答
反對 回復 2021-06-21
?
絕地無雙

TA貢獻1946條經驗 獲得超4個贊

我沒有檢查它是否是罪魁禍首,但在“技術分析”方面,我注意到您的代碼中有一個錯誤:您將 a 的副本傳遞sync.Workgroup給echo_srv. 對副本所做的任何更改對原始實例都無效。


將簽名更改echo為:


func echo_srv(c net.Conn, wg *sync.WaitGroup)

然后像這樣調用它:


go echo_srv(conn, &wg)

附帶說明:_在慣用的 Go 代碼名稱中間不使用下劃線 ( )。慣用名稱將是例如。echoSrv反而。


查看完整回答
反對 回復 2021-06-21
  • 2 回答
  • 0 關注
  • 197 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號