go語(yǔ)言+eof,go語(yǔ)言eof

我正在學(xué)習(xí)Go語(yǔ)言網(wǎng)絡(luò)編程部分，太抽象了有點(diǎn)看不懂啊，哪位大神能夠通俗易懂給我解釋下這個(gè)代碼的意思啊

本質(zhì)上，是作為文件處理的，發(fā)送是“write，print”，接受是“read”。

創(chuàng)新互聯(lián)公司長(zhǎng)期為上1000家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開(kāi)放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為峨邊彝族企業(yè)提供專業(yè)的成都網(wǎng)站建設(shè)、網(wǎng)站設(shè)計(jì)，峨邊彝族網(wǎng)站改版等技術(shù)服務(wù)。擁有10年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開(kāi)發(fā)。

連接相當(dāng)于打開(kāi)文件。

如何在go語(yǔ)言中使用redis連接池

1.在創(chuàng)建連接池之后，起一個(gè) go routine，每隔一段 idleTime 發(fā)送一個(gè) PING 到 Redis server。其中，idleTime 略小于 Redis server 的 timeout 配置。

2.連接池初始化部分代碼如下：

p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() { for { p.Cmd("PING") time.Sleep(idelTime * time.Second) } }()

3.使用 redis 傳輸數(shù)據(jù)部分代碼如下：

func redisDo(p *pool.Pool, cmd string, args ...interface{}) (reply *redis.Resp, err error) { reply = p.Cmd(cmd, args...) if err = reply.Err; err != nil { if err != io.EOF { Fatal.Println("redis", cmd, args, "err is", err) } } return }

4.其中，Radix.v2 連接池內(nèi)部進(jìn)行了連接池內(nèi)連接的獲取和放回，代碼如下：

// Cmd automatically gets one client from the pool, executes the given command // (returning its result), and puts the client back in the pool func (p *Pool) Cmd(cmd string, args ...interface{}) *redis.Resp { c, err := p.Get() if err != nil { return redis.NewResp(err) } defer p.Put(c) return c.Cmd(cmd, args...) }

這樣，就有了系統(tǒng) keep alive 的機(jī)制，不會(huì)出現(xiàn) time out 的連接了，從 redis 連接池里面取出的連接都是可用的連接了?？此坪?jiǎn)單的代碼，卻完美的解決了連接池里面超時(shí)連接的問(wèn)題。同時(shí)，就算 Redis server 重啟等情況，也能保證連接自動(dòng)重連。

golang中http請(qǐng)求體多次讀取的坑

報(bào)錯(cuò)信息如下：

[logid: 3628171316][json.err: EOF] [exception:EOF] goroutine 20521 [running]:

原因：

在請(qǐng)求體為json的請(qǐng)求中，調(diào)用了parsePostForm方法，方法大致內(nèi)容如下：

在這個(gè)方法中，會(huì)讀取http的請(qǐng)求體。

在這里被讀取的時(shí)候，后面又重新讀取一次，之后解json

后面讀到的請(qǐng)求體是空的，解json的時(shí)候就會(huì)報(bào)錯(cuò)EOF

總結(jié)：golang中http請(qǐng)求報(bào)錯(cuò)eof，多半是因?yàn)槎啻巫x取了請(qǐng)求體

Golang 報(bào)錯(cuò) expected 'package', found 'EOF'

文件夾備份導(dǎo)致的問(wèn)題

相同路徑下package同名

bak文件夾打包, 刪除bak, 報(bào)錯(cuò)消失

Go語(yǔ)言文件操作

本文主要介紹了Go語(yǔ)言中文件讀寫(xiě)的相關(guān)操作。

文件是什么？

計(jì)算機(jī)中的文件是存儲(chǔ)在外部介質(zhì)（通常是磁盤(pán)）上的數(shù)據(jù)集合，文件分為文本文件和二進(jìn)制文件。

os.Open() 函數(shù)能夠打開(kāi)一個(gè)文件，返回一個(gè) *File 和一個(gè) err 。對(duì)得到的文件實(shí)例調(diào)用 close() 方法能夠關(guān)閉文件。

為了防止文件忘記關(guān)閉，我們通常使用defer注冊(cè)文件關(guān)閉語(yǔ)句。

Read方法定義如下：

它接收一個(gè)字節(jié)切片，返回讀取的字節(jié)數(shù)和可能的具體錯(cuò)誤，讀到文件末尾時(shí)會(huì)返回 0 和 io.EOF 。舉個(gè)例子：

使用for循環(huán)讀取文件中的所有數(shù)據(jù)。

bufio是在file的基礎(chǔ)上封裝了一層API，支持更多的功能。

io/ioutil 包的 ReadFile 方法能夠讀取完整的文件，只需要將文件名作為參數(shù)傳入。

os.OpenFile() 函數(shù)能夠以指定模式打開(kāi)文件，從而實(shí)現(xiàn)文件寫(xiě)入相關(guān)功能。

其中：

name ：要打開(kāi)的文件名 flag ：打開(kāi)文件的模式。模式有以下幾種：

perm ：文件權(quán)限，一個(gè)八進(jìn)制數(shù)。r（讀）04，w（寫(xiě)）02，x（執(zhí)行）01。

Go 語(yǔ)言自我提升 (三次握手 - 四次揮手 - TCP狀態(tài)圖 - udp - 網(wǎng)絡(luò)文件傳輸)

三次握手：

1. 主動(dòng)發(fā)起連接請(qǐng)求端（客戶端），發(fā)送 SYN 標(biāo)志位，攜帶數(shù)據(jù)包、包號(hào)

2. 被動(dòng)接收連接請(qǐng)求端（服務(wù)器），接收 SYN，回復(fù) ACK，攜帶應(yīng)答序列號(hào)。同時(shí)，發(fā)送SYN標(biāo)志位，攜帶數(shù)據(jù)包、包號(hào)

3. 主動(dòng)發(fā)起連接請(qǐng)求端（客戶端），接收SYN 標(biāo)志位，回復(fù) ACK。

被動(dòng)端（服務(wù)器）接收 ACK —— 標(biāo)志著三次握手建立完成（ Accept()/Dial() 返回）

四次揮手：

1. 主動(dòng)請(qǐng)求斷開(kāi)連接端（客戶端），發(fā)送 FIN標(biāo)志，攜帶數(shù)據(jù)包

2. 被動(dòng)接受斷開(kāi)連接端（服務(wù)器），發(fā)送 ACK標(biāo)志，攜帶應(yīng)答序列號(hào)。 —— 半關(guān)閉完成。

3. 被動(dòng)接受斷開(kāi)連接端（服務(wù)器），發(fā)送 FIN標(biāo)志，攜帶數(shù)據(jù)包

4. 主動(dòng)請(qǐng)求斷開(kāi)連接端（客戶端），發(fā)送最后一個(gè) ACK標(biāo)志，攜帶應(yīng)答序列號(hào)?！?發(fā)送完成，客戶端不會(huì)直接退出，等 2MSL時(shí)長(zhǎng)。

等 2MSL待目的：確保服務(wù)器收到最后一個(gè)ACK

滑動(dòng)窗口：

通知對(duì)端本地存儲(chǔ)數(shù)據(jù)的緩沖區(qū)容量。—— write 函數(shù)在對(duì)端緩沖區(qū)滿時(shí)，有可能阻塞。

TCP狀態(tài)轉(zhuǎn)換：

1. 主動(dòng)發(fā)起連接請(qǐng)求端：

CLOSED —— 發(fā)送SYN —— SYN_SENT(了解) —— 接收ACK、SYN，回發(fā) ACK —— ESTABLISHED (數(shù)據(jù)通信)

2. 主動(dòng)關(guān)閉連接請(qǐng)求端：

ESTABLISHED —— 發(fā)送FIN —— FIN_WAIT_1 —— 接收ACK —— FIN_WAIT_2 (半關(guān)閉、主動(dòng)端)

—— 接收FIN、回復(fù)ACK —— TIME_WAIT (主動(dòng)端) —— 等 2MSL 時(shí)長(zhǎng) —— CLOSED

3. 被動(dòng)建立連接請(qǐng)求端：

CLOSED —— LISTEN —— 接收SYN、發(fā)送ACK、SYN —— SYN_RCVD —— 接收 ACK —— ESTABLISHED (數(shù)據(jù)通信)

4. 被動(dòng)斷開(kāi)連接請(qǐng)求端：

ESTABLISHED —— 接收 FIN、發(fā)送 ACK —— CLOSE_WAIT —— 發(fā)送 FIN —— LAST_ACK —— 接收ACK —— CLOSED

windows下查看TCP狀態(tài)轉(zhuǎn)換：

netstat -an | findstr? 端口號(hào)

Linux下查看TCP狀態(tài)轉(zhuǎn)換：

netstat -an | grep? 端口號(hào)

TCP和UDP對(duì)比:?

TCP: 面向連接的可靠的數(shù)據(jù)包傳遞。針對(duì)不穩(wěn)定的網(wǎng)絡(luò)層，完全彌補(bǔ)。ACK

UDP：無(wú)連接不可靠的報(bào)文傳輸。針對(duì)不穩(wěn)定的網(wǎng)絡(luò)層，完全不彌補(bǔ)。還原網(wǎng)絡(luò)真實(shí)狀態(tài)。

優(yōu)點(diǎn)???????????????????????????????????????????????????????????? 缺點(diǎn)

TCP：可靠、順序、穩(wěn)定 ???????????????????????????????????? 系統(tǒng)資源消耗大，程序?qū)崿F(xiàn)繁復(fù)、速度慢

UDP：系統(tǒng)資源消耗小，程序?qū)崿F(xiàn)簡(jiǎn)單、速度快 ???????????????????????? 不可靠、無(wú)序、不穩(wěn)定

使用場(chǎng)景：

TCP：大文件、可靠數(shù)據(jù)傳輸。對(duì)數(shù)據(jù)的穩(wěn)定性、準(zhǔn)確性、一致性要求較高的場(chǎng)合。

UDP：應(yīng)用于對(duì)數(shù)據(jù)時(shí)效性要求較高的場(chǎng)合。網(wǎng)絡(luò)直播、電話會(huì)議、視頻直播、網(wǎng)絡(luò)游戲。

UDP-CS-Server實(shí)現(xiàn)流程：

1.? 創(chuàng)建 udp地址結(jié)構(gòu) ResolveUDPAddr(“協(xié)議”， “IP：port”) —— udpAddr 本質(zhì) struct{IP、port}

2.? 創(chuàng)建用于數(shù)據(jù)通信的 socket ListenUDP(“協(xié)議”, udpAddr ) —— udpConn (socket)

3.? 從客戶端讀取數(shù)據(jù)，獲取對(duì)端的地址 udpConn.ReadFromUDP() —— 返回：n，clientAddr， err

4.? 發(fā)送數(shù)據(jù)包給客戶端 udpConn.WriteToUDP("數(shù)據(jù)"， clientAddr)

UDP-CS-Client實(shí)現(xiàn)流程：

1.? 創(chuàng)建用于通信的 socket。 net.Dial("udp", "服務(wù)器IP：port") —— udpConn (socket)

2.? 以后流程參見(jiàn) TCP客戶端實(shí)現(xiàn)源碼。

UDPserver默認(rèn)就支持并發(fā)！

------------------------------------

命令行參數(shù)：在main函數(shù)啟動(dòng)時(shí)，向整個(gè)程序傳參。【重點(diǎn)】

語(yǔ)法： go run xxx.go ? argv1 argv2? argv3? argv4 。。。

xxx.exe:? 第 0 個(gè)參數(shù)。

argv1 ：第 1 個(gè)參數(shù)。

argv2 ：第 2 個(gè)參數(shù)。

argv3 ：第 3 個(gè)參數(shù)。

argv4 ：第 4 個(gè)參數(shù)。

使用： list := os.Args? 提取所有命令行參數(shù)。

獲取文件屬性函數(shù)：

os.stat(文件訪問(wèn)絕對(duì)路徑) —— fileInfo 接口

fileInfo 包含兩個(gè)接口。

Name() 獲取文件名。不帶訪問(wèn)路徑

Size() 獲取文件大小。

網(wǎng)絡(luò)文件傳輸 —— 發(fā)送端（客戶端）

1.? 獲取命令行參數(shù)，得到文件名（帶路徑）filePath list := os.Args

2.? 使用 os.stat() 獲取文件名（不帶路徑）fileName

3.? 創(chuàng)建用于數(shù)據(jù)傳輸?shù)?socket? net.Dial("tcp"， “服務(wù)器IP+port”) —— conn

4.? 發(fā)送文件名(不帶路徑)? 給接收端， conn.write()

5.? 讀取接收端回發(fā)“ok”，判斷無(wú)誤。封裝函數(shù) sendFile(filePath, conn) 發(fā)送文件內(nèi)容

6.? 實(shí)現(xiàn) sendFile(filePath,? conn)

1) 只讀打開(kāi)文件 os.Open(filePath)

for {

2) 從文件中讀數(shù)據(jù)? f.Read(buf)

3) 將讀到的數(shù)據(jù)寫(xiě)到socket中? conn.write(buf[:n])

4）判斷讀取文件的結(jié)尾。 io.EOF. 跳出循環(huán)

}

網(wǎng)絡(luò)文件傳輸 —— 接收端（服務(wù)器）

1. 創(chuàng)建用于監(jiān)聽(tīng)的 socket net.Listen() —— listener

2. 借助listener 創(chuàng)建用于通信的 socket listener.Accpet()? —— conn

3. 讀取 conn.read() 發(fā)送端的文件名，保存至本地。

4. 回發(fā) “ok”應(yīng)答發(fā)送端。

5. 封裝函數(shù)，接收文件內(nèi)容 recvFile(文件路徑)

1) f = os.Create(帶有路徑的文件名)

for {

2）從 socket中讀取發(fā)送端發(fā)送的文件內(nèi)容。 conn.read(buf)

3)? 將讀到的數(shù)據(jù) 保存至本地文件 f.Write(buf[:n])

4)? 判斷讀取conn 結(jié)束，代表文件傳輸完成。 n == 0? break

}

網(wǎng)站欄目：go語(yǔ)言+eof,go語(yǔ)言eof
網(wǎng)站地址：http://www.muchs.cn/article28/hchocp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供建站公司、定制開(kāi)發(fā)、微信小程序、定制網(wǎng)站、虛擬主機(jī)、響應(yīng)式網(wǎng)站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容