Hari ini, saya membawakan anda artikel tentang interaksi Dubbo IO. .

Beberapa soalan menarik

Dubbo ialah rangka kerja RPC yang sangat baik dengan model benang yang rumit Dalam artikel ini, penulis menganalisis keseluruhan proses IO Dubbo daripada pengetahuan cetek saya sendiri. Sebelum kita mula, mari kita lihat dahulu soalan berikut:

• Apakah perbezaan dalam model benang antara netty3 dan netty4?
• Paket data mencapai penimbal soket sistem pengendalian, apa yang berlaku?
• Log yang dijana oleh Penyedia mengambil masa yang sangat singkat, tetapi pihak Pengguna tamat masa. Bagaimana kita boleh menyelesaikan masalah?
• Bolehkah paket data dihantar terus melalui paip di lapisan fizikal?
• Urutan perniagaan pengguna yang menanti adalah dalam Keadaan, pada pukul berapa ia terjaga?
• ...
• Seterusnya, penulis akan menggunakan Dubbo2.5.3 sebagai Pengguna dan 2.7.3 sebagai Pembekal untuk menerangkan keseluruhan proses interaksi Pengarang berdiri dalam perspektif paket data dan memberitahunya dalam orang pertama. Kencangkan tali pinggang keledar anda. . melancong.
  Pada suatu hari, saya hampir dihantar keluar, dan dikatakan bahawa saya akan pergi ke tempat bernama Dubbo 2.7.3 Provider.

Pada hari ini, urutan perniagaan memulakan panggilan kaedah, dalam FailoverClusterInvoker#doInvoke code> Saya memilih Penyedia, kemudian melalui pelbagai Penapis Pengguna, kemudian melalui saluran paip Netty3, dan akhirnya lulus <code style="font-size: 14px;word-wrap: break-word;padding: 2px 4px;border-radius : 4px ;margin: 0 2px;warna latar belakang: rgba(27,31,35,.05);font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;word-break: break-all;color: # ff6441; ">NioWorker#scheduleWriteIfNecessary kaedah, saya datang ke baris gilir writeTaskQueue NioWorker. FailoverClusterInvoker#doInvoke我選擇了一個(gè)Provider，然后經(jīng)過各種Consumer Filter，再經(jīng)過Netty3的pipeline，最后通過NioWorker#scheduleWriteIfNecessary方法，我來到了NioWorker的writeTaskQueue隊(duì)列中。

當(dāng)我回頭看主線程時(shí)，發(fā)現(xiàn)他在DefaultFuture中的Condition等待，我不知道他在等什么，也不知道他要等多久。

我在writeTaskQueue隊(duì)列排了一會隊(duì)，看到netty3 IO worker線程在永不停歇的執(zhí)行run方法，大家都稱這個(gè)為死循環(huán)。

最后，我很幸運(yùn)，NioWorker#processWriteTaskQueue

Apabila saya melihat kembali pada utas utama, saya mendapati bahawa dia sedang menunggu dalam Condition dalam DefaultFuture Saya tidak tahu apa yang dia tunggu atau berapa lama dia perlu menunggu.
Saya beratur dalam baris gilir writeTaskQueue untuk seketika dan melihat bahawa urutan pekerja IO netty3 sedang melaksanakan kaedah larian tanpa henti.

Akhirnya, saya bernasib baik, NioWorker#processWriteTaskQueue memilih saya, saya telah ditulis kepada penampan Soket sistem operasi Saya menunggu di penampan Bagaimanapun, saya akan merenungkan perjalanan hari ini, saya melalui dua kumpulan pelancongan, yang dipanggil rangkaian utama dan netty3 IO benang pekerja Baik, kedua-duanya Perkhidmatan semua kumpulan pelancongan adalah baik dan sangat cekap.

Saya hanya merakam apa yang saya lihat hari ini dan melukisnya ke dalam gambar Sudah tentu, saya mengabaikan bahagian yang tidak penting.

2. Sistem pengendalian menghantar paket data

1. Saya telah mengalami banyak perkara ajaib dalam penimbal soket sistem pengendalian.

2. Di tempat yang dipanggil lapisan pengangkutan, saya menambah nombor port sasaran dan nombor port sumber

3. Di tempat yang dipanggil lapisan rangkaian, saya menambah IP sasaran dan IP sumber, dan pada masa yang sama masa, melalui IP sasaran ANDed dengan topeng untuk mencari IP "lompat seterusnya"

   ???????? Di tempat yang dipanggil lapisan pautan data, saya menambah alamat MAC sasaran "hop seterusnya" melalui protokol ARP. Alamat MAC sumber??

Perkara yang paling menarik ialah kami mengambil bahagian kereta kabel setiap kali kami menukar kereta kabel, kami terpaksa mengubah suai alamat MAC sasaran dan alamat MAC sumber Saya kemudiannya, saya bertanya kepada rakan-rakan paket data saya industri yang sama dengan mod ini dipanggil "Lompat Seterusnya", lompat atas lompatan demi lompatan. Terdapat banyak paket data di sini Yang besar adalah dalam satu kereta kabel, dan yang lebih kecil diperah ke dalam satu kereta kabel Terdapat juga perkara yang mengerikan kereta (walaupun ini tidak penting kepada paket data kami), ini dipanggil membongkar dan melekat. Dalam tempoh ini, kami melepasi suis dan penghala, dan tempat ini sangat gembira untuk bermain.

Semestinya ada juga perkara yang tidak menyenangkan iaitu kesesakan kereta kabel di destinasi penuh, dan tiada masa untuk dibawa pergi, jadi tunggu sahaja. . dia boleh mengendalikan membongkar dan melekat.

Saya akan kekal dalam kumpulan benang AllChannelHandler buat sementara waktu, jadi saya juga melukis gambar untuk merakam perjalanan.

NioEventLoop#processSelectedKeys，再經(jīng)過pipeline中的各種入站handler，我來到了AllChannelHandler的線程池，當(dāng)然我有很多選擇，但是我隨便選了一個(gè)目的地，這里會經(jīng)歷解碼、一系列的Filter，才會來的目的地“業(yè)務(wù)方法”，NettyCodecAdapter#InternalDecoder

4. Satu paket data baru telah dijana di sebelah Penyedia

• 由業(yè)務(wù)線程經(jīng)過io.netty.channel.AbstractChannelHandlerContext#writeAndFlush
io.netty.channel.AbstractChannelHandlerContext#writeAndFlush