kafka Sender 傳送網路請求

2021-10-22 16:51:19 字數 1471 閱讀 9213

建立好連線 是的分支

/** * 步驟七:

* 建立傳送訊息的請求

** 建立請求

* 我們往partition上面去傳送訊息的時候,有一些partition他們在同一臺伺服器上面

* ,如果我們一分割槽乙個分割槽的傳送我們網路請求,那網路請求就會有一些頻繁

* 我們要知道,我們集群裡面網路資源是非常珍貴的。

* 會把發往同個broker上面partition的資料 組合成為乙個請求。

* 然後統一一次傳送過去,這樣子就減少了網路請求。

*/list

requests =

createproducerequests

(batches, now)

;//todo 傳送請求的操作

for(clientrequest request : requests)

//繫結 op_write

client.

send

(request, now);-

>

dosend

(request, now)

;private

void

dosend

(clientrequest request,

long now)

-> channel.

setsend

(send)

;public

void

setsend

(send send)

sender.run -

> client.poll -

> selector.poll

//我們剛剛確實是註冊了乙個key

if(readykeys >0||

!immediatelyconnectedkeys.

isempty()

)pollselectionkeys

//核心**,處理傳送請求的事件

//selector 註冊了乙個op_write

//selector 註冊了乙個op_read

if(channel.

ready()

&& key.

iswritable()

)}-> channel.

write()

;public send write()

throws ioexception

return result;

}private

boolean

send

(send send)

throws ioexception

Vue傳送網路請求

為什麼要用它呢?非常好解釋,配置和呼叫方式等非常混亂 編碼起來看起來就非常不好 所以真實開發中很少直接使用,而是使用jquery ajax 相對於傳統的ajax非常好用 為什麼不選擇它呢?首先,我們先明確一點 在vue的整個開發中都是不需要使用jquery了 那麼,就意味著為了方便我們進行網路請求,...

python網路爬蟲 Email傳送

與網頁通過http協議傳輸一樣,郵件是通過smtp mail transfer protocol 簡單郵件傳輸協議傳輸的。而且,和你使用網路伺服器的客戶端 瀏覽器 處理那些通過http協議傳輸的網頁一樣,email伺服器也有客戶端,像sendmail postfix和mailman等,都可以收發郵件...

傳送udp包 windows網路程式設計

int tmain int argc,tchar argv endif create socket destip inet addr ipstr video socket video sock.sin family af inet video sock.sin port htons video po...