如何解決EnyimMemcached異步化改造引起的內(nèi)存泄漏問(wèn)題,相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策,為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法,通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。
創(chuàng)新互聯(lián)建站服務(wù)項(xiàng)目包括塔什庫(kù)爾干塔吉克網(wǎng)站建設(shè)、塔什庫(kù)爾干塔吉克網(wǎng)站制作、塔什庫(kù)爾干塔吉克網(wǎng)頁(yè)制作以及塔什庫(kù)爾干塔吉克網(wǎng)絡(luò)營(yíng)銷策劃等。多年來(lái),我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,塔什庫(kù)爾干塔吉克網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到塔什庫(kù)爾干塔吉克省份的部分城市,未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!
6月30日我們發(fā)布了異步化改造后的博客程序之后,出現(xiàn)了高內(nèi)存、高CPU、高線程數(shù)的不理想情況。
經(jīng)過(guò)一周的追查,終于水落日出。引起不理想情況的根源是我們修改過(guò)的EnyimMemcached代碼存在內(nèi)存泄漏問(wèn)題。
而造成內(nèi)存泄漏的根源是我們沒(méi)有對(duì)SocketAsyncEventArgs進(jìn)行Dispose,實(shí)際情況是我們當(dāng)時(shí)根本沒(méi)注意到SocketAsyncEventArgs實(shí)現(xiàn)了IDispose接口,而這個(gè)小小的疏忽竟然折騰了我們一個(gè)星期。
存在內(nèi)存泄漏問(wèn)題的代碼是這樣寫的:
a) 異步從Socket中讀取數(shù)據(jù):
public async TaskReadBytesAsync(int count) { var args = new SocketAsyncEventArgs(); args.SetBuffer(new byte[count], 0, count); var awaitable = new SocketAwaitable(args); await this.socket.ReceiveAsync(awaitable); return args.Buffer; }
b) 異步向Socket中寫入數(shù)據(jù):
public async Task WriteSync(IList> buffers) { var args = new SocketAsyncEventArgs(); args.BufferList = buffers; var awaitable = new SocketAwaitable(args); await this.socket.SendAsync(awaitable); }
解決內(nèi)存泄漏問(wèn)題的方法很簡(jiǎn)單,using+Buffer.BlockCopy,代碼如下:
a) 改進(jìn)后的異步從Socket中讀取數(shù)據(jù):
public async TaskReadBytesAsync(int count) { using (var args = new SocketAsyncEventArgs()) { args.SetBuffer(new byte[count], 0, count); var awaitable = new SocketAwaitable(args); await this.socket.ReceiveAsync(awaitable); var receivedBytes = new Byte[args.BytesTransferred]; Buffer.BlockCopy(args.Buffer, 0, receivedBytes, 0, args.BytesTransferred); return receivedBytes; } }
b) 改進(jìn)后的異步向Socket中寫入數(shù)據(jù):
public async Task WriteSync(IList> buffers) { using (var args = new SocketAsyncEventArgs()) { args.BufferList = buffers; var awaitable = new SocketAwaitable(args); await this.socket.SendAsync(awaitable); } }
改進(jìn)后的代碼已發(fā)布至github:https://github.com/cnblogs/EnyimMemcached。
你也許會(huì)問(wèn)我們是如何監(jiān)測(cè)到內(nèi)存泄漏情況的呢?
我們借助于兩個(gè)工具:Windows任務(wù)管理器與性能監(jiān)視器。
1. 通過(guò)任務(wù)管理器,我們觀察到w3wp占用的內(nèi)存會(huì)持續(xù)增長(zhǎng),當(dāng)?shù)竭_(dá)5G左右,在8核8G的阿里云虛擬機(jī)上CPU就開始做坐過(guò)山車,只有回收程序池(重啟w3wp進(jìn)程)才能恢復(fù)正常。
2. 通過(guò)性能監(jiān)視器,我們監(jiān)測(cè)了兩個(gè)指標(biāo):
a) \.NET CLR Memory(w3wp)\# Bytes in all Heaps (針對(duì)托管內(nèi)存)
b) \Process(w3wp)\Private Bytes (針對(duì)非托管內(nèi)存)
觀察到的情況見下圖:
(綠色是Private Bytes)
Bytes in all Heaps與Private Bytes都會(huì)出現(xiàn)持續(xù)增長(zhǎng)。
而對(duì)SocketAsyncEventArgs進(jìn)行Dispose之后,性能監(jiān)視器看到的\.NET CLR Memory\# Bytes in all Heaps變成了這樣:
\Process\Private Bytes也與Bytes in all Heaps相映成輝:
一看到這樣的圖形,你應(yīng)該和我們一樣感覺到了GC在背后辛勤工作的身影。
看完上述內(nèi)容,你們掌握如何解決EnyimMemcached異步化改造引起的內(nèi)存泄漏問(wèn)題的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!