從Java Socket非阻塞到Netty入門流程

fsmStudy 發(fā)布于2019-08-16 18:38 / 2149人閱讀

摘要：事件循環(huán)新連接接入連接上的數(shù)據(jù)讀取抽象連接抽象業(yè)務(wù)邏輯處理讀寫數(shù)據(jù)期間的業(yè)務(wù)層動(dòng)態(tài)鏈處理多個(gè)組成，讓消息可以層層處理數(shù)據(jù)接收基本的數(shù)據(jù)處理基于公眾號(hào)貓說學(xué)習(xí)交流群現(xiàn)架構(gòu)設(shè)計(jì)碼農(nóng)兼創(chuàng)業(yè)技術(shù)顧問，不羈平庸，熱愛開源，雜談程序人生與不定期干貨。

本博客 貓叔的博客，轉(zhuǎn)載請(qǐng)申明出處閱讀本文約 “4分鐘”
適讀人群：同學(xué)

Java IO，Socket非阻塞通信流程

這里我們使用一個(gè)內(nèi)嵌的永久循環(huán)，來讓Socket成為一個(gè)非阻塞的通信流程。

如上圖所示，ServerSocket是我們自建的一個(gè)類，通過啟動(dòng)線程，且線程內(nèi)置一個(gè)真循環(huán)，防止accept阻塞；

在客戶端監(jiān)聽類上，將監(jiān)聽到的socket作為參數(shù)，傳遞到客戶端監(jiān)聽類上，并再次啟動(dòng)線程，獲取一個(gè)InputStream，同時(shí)再次在這個(gè)剛剛啟動(dòng)線程內(nèi)置一個(gè)真循環(huán)，為的是不斷獲取信息并回寫；

這里要注意的是，第一個(gè)真循環(huán)是保證獲取新連接不會(huì)阻塞，第二個(gè)真循環(huán)是保證不停的獲取客戶端信息并回寫；

關(guān)于客戶端則通過端口和IP，啟動(dòng)線程，通過一個(gè)循環(huán)不停的向服務(wù)端寫數(shù)據(jù)；

Netty入門

基于上面的圖，我們也可以學(xué)習(xí)Netty相關(guān)的基礎(chǔ)入門。

NioEventLoop（事件循環(huán)）

1、新連接接入

2、連接上的數(shù)據(jù)讀取

Channel（抽象連接）

Socket、SocektChannel（IONIO）抽象

ChannelHandler（業(yè)務(wù)邏輯處理）

讀寫數(shù)據(jù)期間的業(yè)務(wù)層

PipeLine（動(dòng)態(tài)鏈處理）

多個(gè)ChannelHandler組成，讓消息可以層層處理

ByteBuf（數(shù)據(jù)接收）

基本的數(shù)據(jù)處理基于ByteBu

公眾號(hào)：Java貓說

學(xué)習(xí)交流群：728698035

現(xiàn)架構(gòu)設(shè)計(jì)（碼農(nóng)）兼創(chuàng)業(yè)技術(shù)顧問，不羈平庸，熱愛開源，雜談程序人生與不定期干貨。

GPU云服務(wù)器云服務(wù)器 socket非阻塞 socket阻塞與非阻塞 java從入門到精通 spark從入門到

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/75483.html

相關(guān)文章

Netty詳解

摘要：的產(chǎn)生原因是使的編程更容易。定義一個(gè)異步事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用框架，幫助快速開發(fā)高性能的客戶端與服務(wù)端。每一個(gè)一個(gè)客戶端請(qǐng)求注冊(cè)一個(gè)這個(gè)會(huì)處理這個(gè)請(qǐng)求的事件直到這個(gè)請(qǐng)求結(jié)束。近日在學(xué)習(xí)netty，卻發(fā)現(xiàn)沒那么容易上手，專研了幾天后算是弄清楚了netty到底是干什么的，所看資料比較多，此文章便把這些資料與我的思考做一個(gè)總結(jié)幫助大家更好入門。要更好理解netty首先要了解以下一些前置知識(shí) ...

worldligang 2019-08-15 13:42 評(píng)論0 收藏0
Netty序章之BIO NIO AIO演變

摘要：后改良為用線程池的方式代替新增線程，被稱為偽異步。最大的問題是阻塞，同步。每次請(qǐng)求都由程序執(zhí)行并返回，這是同步的缺陷。這些都會(huì)被注冊(cè)在多路復(fù)用器上。多路復(fù)用器提供選擇已經(jīng)就緒狀態(tài)任務(wù)的能力。并沒有采用的多路復(fù)用器，而是使用異步通道的概念。 Netty是一個(gè)提供異步事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用框架，用以快速開發(fā)高性能、高可靠的網(wǎng)絡(luò)服務(wù)器和客戶端程序。Netty簡(jiǎn)化了網(wǎng)絡(luò)程序的開發(fā)，是很多框架和公司...

VincentFF 2019-07-01 11:22 評(píng)論0 收藏0
Netty序章之BIO NIO AIO演變

摘要：后改良為用線程池的方式代替新增線程，被稱為偽異步。最大的問題是阻塞，同步。每次請(qǐng)求都由程序執(zhí)行并返回，這是同步的缺陷。這些都會(huì)被注冊(cè)在多路復(fù)用器上。多路復(fù)用器提供選擇已經(jīng)就緒狀態(tài)任務(wù)的能力。并沒有采用的多路復(fù)用器，而是使用異步通道的概念。 Netty是一個(gè)提供異步事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用框架，用以快速開發(fā)高性能、高可靠的網(wǎng)絡(luò)服務(wù)器和客戶端程序。Netty簡(jiǎn)化了網(wǎng)絡(luò)程序的開發(fā)，是很多框架和公司...

CntChen 2019-08-23 15:23 評(píng)論0 收藏0
入門架構(gòu)——單機(jī)高性能

摘要：協(xié)作方式在高并發(fā)場(chǎng)景中，必須要讓服務(wù)器同時(shí)維護(hù)大量請(qǐng)求連接，可能是一個(gè)服務(wù)進(jìn)程創(chuàng)建另一個(gè)進(jìn)程，也可能是一個(gè)服務(wù)線程去創(chuàng)建另一個(gè)線程，但連接結(jié)束后進(jìn)程或線程就銷毀了，這是一個(gè)巨大的浪費(fèi)一個(gè)自然的想法就是通過創(chuàng)建一個(gè)進(jìn)程線程池從而達(dá)到資源復(fù)用， showImg(https://segmentfault.com/img/bVbtgn1?w=313&h=208); 協(xié)作方式在高并發(fā)場(chǎng)景中，必...

UCloud 2019-08-16 17:43 評(píng)論0 收藏0
netty搭建web聊天室（1）

摘要：提供異步的事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用程序框架和工具，用以快速開發(fā)高性能高可靠性的網(wǎng)絡(luò)服務(wù)器和客戶端程序?？偨Y(jié)我們完成了服務(wù)端的簡(jiǎn)單搭建，模擬了聊天會(huì)話場(chǎng)景。之前一直在搞前端的東西，都快忘了自己是個(gè)java開發(fā)。其實(shí)還有好多java方面的東西沒搞過，突然了解到netty，覺得有必要學(xué)一學(xué)。介紹 Netty是由JBOSS提供的一個(gè)java開源框架。Netty提供異步的、事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用程序框...

izhuhaodev 2019-08-16 14:37 評(píng)論0 收藏0