第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

無(wú)需輸入網(wǎng)絡(luò)撥號(hào)即可模擬網(wǎng)絡(luò)連接

無(wú)需輸入網(wǎng)絡(luò)撥號(hào)即可模擬網(wǎng)絡(luò)連接

Go
一只斗牛犬 2023-04-24 16:24:29
我目前正在研究 vendor go balancer 代碼。我需要?jiǎng)h除 tcp 撥號(hào)呼叫并在沒(méi)有呼叫的情況下模擬成功的連接。在下面的代碼中,有這一行:ds, err := net.Dial("tcp", backend.String());if err != nil {     log.Printf("failed to dial %s: %s", backend, err)     us.Close()         return}它所做的是撥號(hào)到 tcp 服務(wù)器,然后返回連接響應(yīng)ds,它在此處定義:https: //golang.org/pkg/net/#Dialds我需要的是在不做的情況下獲得tcp dialer。我正在嘗試在沒(méi)有任何實(shí)際 tcp 調(diào)用的情況下測(cè)試負(fù)載平衡器。所以,基本上,當(dāng)我們輸入handleConnectionwed 在 tcp 撥號(hào)之前創(chuàng)建一個(gè)網(wǎng)絡(luò)連接并使用這個(gè)網(wǎng)絡(luò)連接時(shí),它應(yīng)該在 tcp 撥號(hào)開(kāi)始之前模擬 100% 的網(wǎng)絡(luò)連接。func copy(wc io.WriteCloser, r io.Reader) {        defer wc.Close()    io.Copy(wc, r)}func handleConnection(us net.Conn, backend BA.Backend) {    if backend == nil {        log.Printf("no backend available for connection from %s",        us.RemoteAddr())        us.Close()        return    }    host, _, _ := net.SplitHostPort(us.RemoteAddr().String())    _, ok := dbAuthTokenData[host]; if !ok {        w := bufio.NewWriter(us)        w.WriteString("InvalidCredentials")        w.Flush()        us.Close()        return    }    ds, err := net.Dial("tcp", backend.String());if err != nil {        log.Printf("failed to dial %s: %s", backend, err)        us.Close()        return    }    // Ignore errors    go copy(ds, us)    go copy(us, ds)}func tcpBalance(bind string, backends BA.Backends) error {    log.Println("using tcp balancing")    ln, err := net.Listen("tcp", bind)    if err != nil {        return fmt.Errorf("failed to bind: %s", err)    }    log.Printf("listening on %s, balancing %d backends", bind,                                 backends.Len())    for {        conn, err := ln.Accept()        if err != nil {           log.Printf("failed to accept: %s", err)            continue        }        go handleConnection(conn, backends.Choose())    }    return err}我嘗試注釋掉go handleConnection(conn, backends.Choose())但失敗了。
查看完整描述

1 回答

?
倚天杖

TA貢獻(xiàn)1828條經(jīng)驗(yàn) 獲得超3個(gè)贊

您可以重構(gòu)代碼的模式是創(chuàng)建一個(gè)Dialer接口。在您的代碼示例中,您使用返回ds的io.ReadWriteCloser. 所以你不需要實(shí)現(xiàn)整個(gè)net.Conn接口。就像net.Conn里面的讀寫方法一樣,一切正常


type Dialer interface{

    Dial(network, address string) (io.ReadWriteCloser, error)

}

現(xiàn)在讓我們改變你的功能:


func handleConnection(us net.Conn, backend BA.Backend, d Dialer) {

    // ...


    // Code here stays

    ds, err := d.Dial("tcp", backend.String());if err != nil {

        log.Printf("failed to dial %s: %s", backend, err)

        us.Close()

        return

    }

    // ...

}

你的生產(chǎn)代碼可以工作,你現(xiàn)在需要定義一個(gè)netDialer包裝net.Dial()函數(shù)的類型。在您的測(cè)試中,您可以使用 atestDialer其中使用 a bytes.Buffer。


這回答了你的問(wèn)題:


無(wú)需輸入網(wǎng)絡(luò)撥號(hào)即可模擬網(wǎng)絡(luò)連接


查看完整回答
反對(duì) 回復(fù) 2023-04-24
  • 1 回答
  • 0 關(guān)注
  • 122 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)