Hei ada! Saya bekerja di pembekal NIO, dan saya telah lutut - dalam dunia saluran Java Nio. Anda mungkin tertanya -tanya, "Apa yang ada di bumi adalah Java Nio, dan bagaimana saya mengendalikan akses serentak ke salurannya?" Nah, teruskan, dan saya akan memecahkannya untuk anda.
Mula -mula, mari kita turunkan penurunan cepat pada Java Nio. Java NIO (input/output baru) adalah alternatif kepada API Java I/O standard. Ia diperkenalkan di Java 1.4 untuk menyediakan cara pengendalian I/O yang lebih berskala dan cekap. Komponen utama Java NIO adalah saluran, penampan, dan pemilih. Saluran adalah seperti paip di mana aliran data, penampan adalah di mana data disimpan sementara, dan pemilih membenarkan satu benang untuk menguruskan pelbagai saluran.
Sekarang, akses serentak ke saluran Java Nio boleh menjadi sakit kepala yang sebenar. Bayangkan mempunyai pelbagai benang yang cuba mengakses saluran yang sama pada masa yang sama. Ia seperti sekumpulan orang yang cuba memerah melalui pintu sempit sekaligus - kekacauan! Tetapi jangan risau, ada cara untuk menangani perkara ini.
Salah satu cara paling mudah untuk mengendalikan akses serentak adalah melalui penyegerakan. Anda boleh menggunakan Java's Built - IndisegerakkanKata kunci untuk memastikan bahawa hanya satu benang yang dapat mengakses saluran pada satu masa. Contohnya:
import java.nio.channels.filechannel; import java.io.randomaccessfile; Kelas Awam SynchronizedChannelAccess {Saluran FileChannel Private; public SynchronizedChanNelAccess (String FilePath) melemparkan Pengecualian {RandomAccessFile File = New RandomAccessFile (FilePath, "RW"); saluran = file.getChannel (); } awam disegerakkan void writedata (byte [] data) melemparkan pengecualian {channel.write (java.nio.bytebuffer.wrap (data)); }}Dalam kod ini,writedataKaedah disegerakkan. Jadi, walaupun beberapa benang memanggil kaedah ini, hanya satu benang yang dapat melaksanakannya pada satu masa. Ini menghalang rasuah data dan isu -isu lain yang boleh timbul daripada akses serentak.
Tetapi inilah perkara itu. Penyegerakan boleh menjadi sedikit kesesakan. Ia menyampaikan akses ke saluran, yang bermaksud bahawa benang lain perlu menunggu giliran mereka. Ini boleh melambatkan permohonan anda, terutamanya jika anda mempunyai jumlah permintaan serentak yang tinggi.
Pendekatan lain ialah menggunakan kunci. Java menyediakanKunciantara muka dan pelaksanaannya sepertiReentrantlock. Inilah cara anda boleh menggunakannya:
import java.nio.channels.filechannel; import java.io.randomaccessfile; import java.util.concurrent.locks.lock; import java.util.concurrent.locks.reentrantlock; Kelas awam LockbasedChannelAccess {Saluran FileChannel Private; kunci kunci peribadi = reentrantLock baru (); public LockBasedChanNelAccess (String FilePath) melemparkan Pengecualian {RandomAccessFile File = New RandomAccessFile (FilePath, "RW"); saluran = file.getChannel (); } public void writedata (byte [] data) melemparkan pengecualian {lock.lock (); cuba {channel.write (java.nio.bytebuffer.wrap (data))); } akhirnya {lock.unlock (); }}}TheKunciantara muka memberi anda lebih banyak kawalan daripadadisegerakkankata kunci. Contohnya, anda boleh menggunakan kaedah sepertitrylock ()Untuk cuba memperoleh kunci tanpa menyekat. Jika kunci tidak tersedia, benang boleh melakukan sesuatu yang lain dan bukannya menunggu.
Sekarang, mari kita bercakap tentang bukan - menyekat I/O. Java Nio menyokong bukan menyekat I/O, yang merupakan permainan - changer ketika datang ke akses serentak. Dengan tidak menyekat I/O, benang boleh menyemak sama ada saluran siap untuk operasi (seperti membaca atau menulis) tanpa menyekat.
Berikut adalah contoh mudah untuk tidak menyekat I/O menggunakan aPemilih:
import java.nio.channels.socketchannel; import java.nio.channels.selector; import java.nio.channels.SelectionKey; import java.net.inetsocketaddress; import java.io.ioException; import java.nio.bytebuffer; import java.util.iterator; kelas awam nonblockingioExample {public static void main (string [] args) melemparkan ioException {selector selector = selector.Open (); Socketchannel Channel = SocketetchAnnel.Open (); Channel.ConfigureBlocking (palsu); Channel.Connect (baru inetocketAddress ("localhost", 8080)); Channel.Register (Selector, SelectionKey.OP_Connect); sementara (benar) {selector.Select (); Iterator <pecstionKey> kekunci = selector.selectedKeys (). Iterator (); manakala (kekunci.HasNext ()) {pemilihan kunci = kunci.next (); kunci.remove (); jika (key.isconnectable ()) {socketetchannel sc = (socketetchannel) key.channel (); jika (sc.isconnectionPending ()) {sc.FinishConnect (); } sc.Register (pemilih, pilihanKey.op_read); ByteBuffer buffer = byteBuffer.wrap ("Hello, Server!". GetBytes ()); sc.write (penampan); } else if (key.isReadable ()) {socketchannel sc = (socketetchannel) key.channel (); ByteBuffer buffer = byteBuffer.allocate (1024); sc.read (penampan); buffer.flip (); byte [] data = byte baru [buffer.limit ()]; buffer.get (data); System.out.println (rentetan baru (data)); }}}}}Dalam contoh ini,PemilihMembolehkan satu benang untuk menguruskan pelbagai saluran. Benang boleh menyemak saluran mana yang siap untuk operasi dan melakukan operasi tanpa menyekat. Ini jauh lebih cekap daripada menyekat I/O, terutamanya dalam persekitaran yang serentak.
Di pembekal NIO kami, kami telah melihat secara langsung bagaimana teknik -teknik ini dapat membuat perbezaan besar dalam prestasi aplikasi. Sama ada pelayan web yang mengendalikan beribu -ribu permintaan serentak atau aplikasi pemprosesan data yang berurusan dengan jumlah data yang besar, pengendalian akses serentak ke saluran Java NIO adalah penting.
Sekiranya anda masuk ke dalam kereta elektrik, anda mungkin berminat denganKereta elektrik nio et5. Ia adalah kenderaan yang anggun dan berkuasa yang mempamerkan inovasi dalam industri kereta elektrik.
Jadi, jika anda menghadapi cabaran dengan akses serentak ke saluran Java Nio dalam projek anda, jangan ragu untuk menjangkau. Kami mempunyai kepakaran dan pengalaman untuk membantu anda mengoptimumkan aplikasi anda. Sama ada ia melaksanakan mekanisme penyegerakan yang betul, menggunakan kunci dengan berkesan, atau memanfaatkan I/O yang tidak menyekat, kami boleh membimbing anda melalui proses tersebut.
Sekiranya anda berminat untuk membincangkan bagaimana kami dapat membantu dengan keperluan Java Nio anda, hanya lepaskan kami. Kami sentiasa bersembang dan bersemangat untuk meneroka bagaimana kami dapat menjadikan aplikasi anda lebih cekap dan boleh dipercayai.
Rujukan
- "Java Nio" - Dokumentasi Oracle
- "Jawa yang berkesan" - Joshua Bloch