Java ağ programlamayla daha önce ilgilendiyseniz, muhtemelen eski engelleme G/Ç modeline daha verimli, ölçeklenebilir bir alternatif olarak ortalıkta dolaşan "NIO" terimini duymuşsunuzdur. Java'nın Yeni Giriş/Çıkış (NIO) çerçevesinin kalbinde, genellikle yanlış anlaşılan ancak yüksek performanslı ağ uygulamaları oluşturmak için kritik olan bir bileşen olan SocketChannel bulunur. Önde gelen bir NIO teknoloji tedarikçisinde çalışan biri olarak, SocketChannels'ın küçük gerçek zamanlı uygulamalardan büyük ölçekli kurumsal sistemlere kadar her şeye nasıl güç verdiğini ilk elden gördüm ve gerçekte ne yaptıklarını, nasıl çalıştıklarını ve kodun ötesinde neden önemli olduklarını ayrıntılı olarak açıklamak istiyorum.
Temel bilgilerle başlayalım: NIO'dan önce Java, engelleyici bir G/Ç uygulaması olan java.net.Socket'i kullanıyordu. Bir program veri göndermek veya almak için bir engelleme yuvası kullandığında, tüm işlem bitene kadar duraklatılır ("engellenir"). Dolayısıyla, 1000 eşzamanlı bağlantınız varsa, her birini işlemek için 1000 ayrı iş parçacığına ihtiyacınız vardı ve bu da kaynak açısından ağırdı. İş parçacıkları belleği kaplar, içerik değiştirme için CPU yükü gerektirir ve bir iş parçacığı veri beklerken engellenirse aslında boşa harcanır. NIO, engellemeyen işlemleri tanıtarak bunu değiştirdi ve SocketChannel bunu mümkün kılan birincil sınıftır.
SocketChannel, amacı geleneksel Soket'e benzeyen, ancak engellemeyen özelliklere sahip, bir ağ akışı soketini temsil eden seçilebilir bir kanaldır. Bu, bir gönderme veya alma işleminin tamamlanmasını beklemek yerine, SocketChannel'ın programınıza okunmaya hazır veriler olduğunda veya veri yazmak için alan olduğunda bilgi verebileceği anlamına gelir. Ölçeklenebilirliğin büyüsü tam da burada devreye giriyor: Bağlantı başına bir iş parçacığı yerine, tüm kanalların hazır olup olmadığını izlemek için bir Seçici kullanarak binlerce SocketChannel'ı aynı anda yönetmek için az sayıda iş parçacığı (sadece bir tane bile) kullanabilirsiniz. Örneğin, bir sohbet sunucusu oluşturuyorsanız, tek bir iş parçacığı hangi SocketChannel'lardan gelen mesajların olduğunu kontrol edebilir, bunları işleyebilir ve bunları doğru istemcilere gönderebilir; her kullanıcı için yeni bir iş parçacığı oluşturmaya gerek yoktur.
Ancak SocketChannels yalnızca engellenmeyen G/Ç ile ilgili değildir; ayrıca NIO'nun bir diğer önemli iyileştirmesi olan tampon odaklı işlemleri de destekliyorlar. Geleneksel akışlarda, verileri tek seferde bir bayt okur veya yazarsınız; bu yavaştır. SocketChannel'lar, toplu olarak doldurabileceğiniz, çevirebileceğiniz, boşaltabileceğiniz ve temizleyebileceğiniz bitişik bellek blokları olan ByteBuffer nesneleriyle çalışır. Bu, programınızın yaptığı sistem çağrılarının sayısını azaltır; bu da performans açısından büyük bir kazançtır. Verileri okumak için bir SocketChannel kullandığınızda, doğrudan bir ByteBuffer'a okursunuz ve yazdığınızda, bir ByteBuffer'dan veri alıp ağ üzerinden gönderirsiniz. Özellikle dosyalar veya medya gibi büyük yükler söz konusu olduğunda verileri işlemenin çok daha etkili bir yoludur.
Şimdi SocketChannel'ların pratikte nasıl çalıştığına bakalım. SocketChannel oluşturmak için bir kurucu kullanmazsınız; statik open() yöntemini kullanırsınız. Açıldıktan sonra connect() ile uzak bir adrese bağlayabilirsiniz. Engellemesiz modu kullanıyorsanız (bu modu açıkça with.configureBlocking(false) etkinleştirmeniz gerekir), connect() yöntemi hemen geri döner ve daha sonra true değerini döndürünceye kadar FinishConnect() öğesini çağırarak bağlantıyı bitirmeniz gerekir. Seçicinin devreye girdiği yer burasıdır: SocketChannel'ı OP_CONNECT olayı için bir Seçiciye kaydedersiniz, böylece bağlantının ne zaman tamamlanmaya hazır olduğunu bilirsiniz.
Okumak için, kanalı OP_READ için kaydedersiniz ve Seçici kanalın hazır olduğunu seçtiğinde read() öğesini çağırır ve bir ByteBuffer iletirsiniz. Read() yöntemi okunan bayt sayısını döndürür; eğer -1 ise bu, bağlantının kapatıldığı anlamına gelir. Yazmak için OP_WRITE'a kaydolursunuz ve kanal hazır olduğunda ByteBuffer'ınızla write() öğesini çağırırsınız. Engellenmeyen yazma işlemleri tüm verileri tek seferde göndermeyebileceğinden, ne kadar gönderdiğinizi takip etmeniz ve tüm veriler bitene kadar veya kanal artık yazmaya hazır olmayana kadar yazmaya devam etmeniz gerekir.
NIO'da yeni olan ekiplerin SocketChannel ile geleneksel Socket arasındaki farkla mücadele ettiğini gördüm, o yüzden bunu açıklığa kavuşturalım. Socket sınıfı hala ortalıkta ve eski kodla uyumluluğa ihtiyacınız varsa SocketChannel'dan bir Socket alabilirsiniz, ancak SocketChannel engellemeyen, ölçeklenebilir işlemler için tasarlanmıştır. Ancak bu, hemen değiştirilecek bir şey değil; SocketChannels'ı kullanırken, özellikle de Selector modeliyle, bağlantıları ve veri akışını nasıl idare ettiğinizi yeniden düşünmeniz gerekiyor.
SocketChannels'ın yaygın kullanım alanlarından biri, yüksek performanslı web sunucuları veya API'lerdir. Örneğin, on binlerce eşzamanlı API isteğini işleyen bir hizmet oluşturuyorsanız, SocketChannels'ı bir Seçici ile kullanmak, tüm bu istekleri istek başına bir iş parçacığı yerine küçük bir iş parçacığı havuzuyla işlemenize olanak tanır. Bu, bellek kullanımını azaltır, gecikmeyi azaltır ve hizmetinizi yük altında daha dayanıklı hale getirir. Müşterilerin aynı donanım üzerinde soketleri engelleyen maksimum 500 eşzamanlı bağlantıdan SocketChannels ile 10.000'in üzerine çıktığını gördüm; bu tür performans kazanımları NIO'nun bugün bu kadar yaygın olarak kullanılmasının nedenidir.
Dikkat edilmesi gereken bir diğer nokta ise SocketChannel'ın hem TCP hem de UDP ile çalışmasıdır. Durun, hayır, durun, aslında DatagramChannel UDP içindir, SocketChannel ise özellikle TCP içindir. Bu yaygın bir karışıklıktır. TCP, çoğu web trafiğinin kullandığı güvenilir, akış odaklı protokoldür; dolayısıyla SocketChannels bunun için mükemmeldir. DatagramChannel'lar bağlantısız, güvenilmez UDP içindir, bu nedenle bir oyun sunucusu veya bir miktar veri kaybını tolere edebilecek gerçek zamanlı bir akış uygulaması oluşturuyorsanız bunun yerine bir DatagramChannel kullanırsınız. Ancak düzenli, güvenilir veri aktarımına ihtiyacınız varsa, gidilecek yol SocketChannel'dır.
Artık bir NIO tedarikçisi olarak, SocketChannel tabanlı çözümleri sistemlerine entegre etmek isteyen birçok şirketle çalışıyoruz ancak çoğu zaman optimizasyonla ilgili soruları oluyor. Bir ipucu ByteBuffer boyutlarınızı ayarlamaktır; çok küçük olursa daha fazla arabellek işlemi yaparsınız, çok büyükse hafızayı boşa harcarsınız. Bir diğeri ise mümkün olduğunda doğrudan ByteBuffer'ları kullanmaktır; bunlar JVM yığınının dışına tahsis edilir, bu da ağ üzerinden veri gönderilirken JVM ile yerel bellek arasındaki kopyalamayı azaltır. Direct ByteBuffer'lar, ek yükleri azaltabildikleri için dosya göndermek gibi büyük veri aktarımları için özellikle kullanışlıdır.
Ayrıca bazı yanlış anlaşılmalara da değinmek istiyorum. Bazı insanlar SocketChannel'ın yalnızca Java için olduğunu düşünüyor, ancak bekleyin; hayır, Java'nın NIO'su standart kitaplıkta uygulanır ve SocketChannel bunun temel bir parçasıdır. Bu bir üçüncü taraf aracı değildir, bu nedenle milyonlarca uygulamada savaşta test edilmiştir. Ancak bu, bunun üzerine inşa edemeyeceğiniz anlamına gelmez; popüler bir NIO çerçevesi olan Netty gibi birçok çerçeve, bağlantı havuzu oluşturma, SSL desteği ve protokol codec'leri gibi daha fazla özellik sağlamak için SocketChannel'ı kullanır. Bir ağ uygulaması oluşturuyorsanız, SocketChannel'ı saran Netty gibi bir çerçeve kullanmak size çok zaman kazandırabilir çünkü arabellekleri yönetme, karşı basıncı yönetme ve yeniden bağlanma gibi birçok düşük seviyeli ayrıntıyı yönetir.
Biraz vites değiştirelim çünkü müşterilerimizin birçoğunun, kablosuz güncellemeler ve bilgi-eğlence için ağırlıklı olarak bağlantılı sistemlere dayanan elektrikli araçlar gibi ağ çözümleriyle entegre olan teknolojiyle de ilgilendiğini biliyorum. Bağlantılı teknolojiden bahsetmişken, gelişmiş bağlantı özelliklerine sahip bir EV pazarındaysanız, yüksek performanslı dijital sistemlerle uyumlu, son teknoloji ağ özelliklerine sahip modeller sunan ONVO serisine göz atmak isteyebilirsiniz. Örneğin, ONVO L80 Ultra+ Price China, sağlam bağlantılara sahip popüler bir model olup, ister navigasyon ister akış için hareket halindeyken güvenilir, hızlı ağ erişimine ihtiyaç duyan sürücüler için mükemmeldir. Daha fazla alana ihtiyacınız varsa Onvo L90 Pro Yedi Koltuklu Sürüm 2025, geniş oturma alanı ve bağlantılı hizmetlerle sorunsuz bir şekilde çalışan entegre teknoloji sunarak onu aileler veya yol gezileri için mükemmel bir seçim haline getiriyor. Uygun fiyatlı bir seçenek arayanlar için, ONVO L60 2025 85kWh 4WD Sürümü performans ve bağlantıyı dengelerken İkinci El Tesla Firefly – Günlük İşe Gidiş için Kompakt Ekonomik Elektrikli Şehir Arabası, modern ağ uygulamalarıyla iyi çalışan bağlantılı özelliklere sahip, şehir içi sürüş için kompakt bir seçimdir. Bu EV'ler doğrudan SocketChannel ile ilgili olmasa da, ağ teknolojisinin arabalardan kurumsal sunuculara kadar günlük cihazlara nasıl entegre edildiğinin örnekleridir.
SocketChannels'a geri dön. Engellenmeyen G/Ç ile ilgili en büyük zorluklardan biri kısmi okuma ve yazma işlemlerini gerçekleştirmektir. Bir SocketChannel, bir çağrıda mesajın yalnızca bir kısmını okuyabileceğinden, geri kalan veriler gelene kadar kalan verileri ara belleğe almanız gerekir. Benzer şekilde, bir mesajın yalnızca bir kısmını yazabilirsiniz, dolayısıyla giden her mesajın durumunu takip etmeniz gerekir. Netty gibi çerçevelerin gerçekten parladığı yer burasıdır; durum yönetimini sizin için yönetirler, böylece bu mantığı sıfırdan oluşturmanıza gerek kalmaz. Ancak küçük, düşük gecikmeli bir uygulama oluşturuyorsanız, bu mantığı SocketChannel ve Selector ile kendiniz yazmak, maksimum kontrol için buna değer olabilir.
Güvenlik bir diğer önemli husustur. SocketChannels, verileri ağ üzerinden gönderilirken şifrelemenize olanak tanıyan SSLEngine sınıfı aracılığıyla SSL/TLS'yi destekler. SocketChannel'ı doğrudan sarmak yerine, verileri işlemek için bir SSLEngine kullanırsınız, ardından şifrelenmiş verileri SocketChannel'a yazarsınız veya şifresi çözülmüş verileri ondan okursunuz. Bu, ödeme işleme veya kullanıcı kimlik doğrulaması gibi hassas verileri işleyen uygulamalar için kritik öneme sahiptir. SSL'yi SocketChannels ile entegre ederken, SSL katmanının ne zaman veri göndermeye veya almaya hazır olduğunu bilmeniz için Seçicinin OP_HANDSHAKE olaylarını izleyebileceği SSL anlaşmasını doğru bir şekilde gerçekleştirmek önemlidir.
Gerçek dünyadan bir örnekten bahsedelim. Binlerce müşteriye fiyat güncellemelerini iletmesi gereken gerçek zamanlı bir hisse senedi takip sistemi oluşturduğunuzu varsayalım. Engelleme Soketi yaklaşımını kullandığınızda, istemci başına bir iş parçacığına ihtiyacınız olacaktır; 10.000 müşteriniz varsa bu pahalı olacaktır; her biri güncelleme göndermeyi bekleyen 10.000 iş parçacığına ihtiyacınız olacaktır. SocketChannels ile, Selector ile tüm SocketChannel'ları izlemek için tek bir iş parçacığı (veya küçük bir iş parçacığı havuzu) kullanabilirsiniz. Bir hisse senedi fiyatı değiştiğinde, güncellemeyi her bir SocketChannel'ın ByteBuffer'ına yazarsınız ve Seçici, her kanal verileri yazmaya hazır olduğunda sizi bilgilendirir. Bu şekilde, minimum ek yük ile binlerce müşteriye güncelleme göndererek, işlemlerinizi hızlı ve ölçeklenebilir hale getirebilirsiniz.
Bir NIO tedarikçisi olarak, birçok fintech şirketinin tam olarak bu tür bir sistem oluşturmasına yardımcı olduk ve onlar, engelleme yuvalarından SocketChannels'a geçtikten sonra verim ve gecikmede büyük gelişmeler gördüler. Ancak onlara SocketChannels'ın sihirli bir değnek olmadığını da hatırlatırız; uygulamanızı engellenmeyen G/Ç ile çalışacak şekilde tasarlamanız gerekir. Bu, G/Ç iş parçacıklarında uzun süren görevlerden kaçınmak anlamına gelir; çünkü bir G/Ç iş parçacığı hesaplama yaparken engellenirse diğer hazır kanalları işleyemez. G/Ç iş parçacıklarının yalnızca okuma ve yazma işlemlerine odaklanabilmesi için tüm ağır işlemleri çalışan iş parçacıklarına aktarmalısınız.
Başka bir nokta: SocketChannel'lar bağlantı odaklıdır, dolayısıyla sohbet uygulaması veya hisse senedi takibi gibi uzun ömürlü bağlantılar için iyi çalışırlar. Tek bir istek gönderip bağlantıyı kesen bir istemci gibi kısa ömürlü bir bağlantı kuruyorsanız, SocketChannel yine de çalışabilir, ancak engellemeyen bir bağlantı kurmanın ek yükü küçük yükler için buna değmeyebilir. Kısa ve basit istekler için engelleme Soketi daha etkili olabilir. Ancak uzun ömürlü, yüksek hacimli bağlantılar için SocketChannels net bir seçimdir.
SocketChannels'ın platformdan bağımsız olacak şekilde tasarlanmış Java NIO'nun kanal API'sinin bir parçası olduğunu belirtmenin de önemli olduğunu düşünüyorum. Bu, JVM doğru şekilde uygulandığı sürece SocketChannels için yazdığınız kodun farklı işletim sistemlerinde aynı şekilde çalışacağı anlamına gelir. Bu taşınabilirlik, Linux'tan Windows'a kadar farklı sunucularda çalışan kurumsal uygulamalar için büyük bir artı.
SocketChannels'ta yeniyseniz, birden fazla istemciyi yöneten basit bir echo sunucusu gibi küçük bir projeyle başlamanızı öneririm. Soket Kanallarını izlemek, istemcilerden veri okumak ve geri yazmak için bir Seçici kullanabilirsiniz. Bu, engellemeyen işlemlerin nasıl çalıştığını, arabelleklerin nasıl yönetileceğini ve birden fazla kanalı yönetmek için Seçicinin nasıl kullanılacağını anlamanıza yardımcı olacaktır. Bu konuda rahat olduğunuzda SSL'yi deneyebilir, ByteBuffers'ı yönlendirebilir ve kodu basitleştirmek için Netty gibi bir çerçeveyi entegre edebilirsiniz.
NIO tedarikçimizde ağ uygulamalarını optimize etmek için geliştiriciler ve kuruluşlarla çalışıyoruz ve SocketChannel da bunun temel bir parçası. İster küçük bir dahili araç ister büyük ölçekli bir web hizmeti oluşturuyor olun, SocketChannels'ın nasıl çalıştığını anlamak daha hızlı, daha ölçeklenebilir sistemler oluşturmanıza yardımcı olacaktır. Elektrikli araçlardan akıllı evlere ve kurumsal sunuculara kadar bağlantılı teknoloji daha yaygın hale geldikçe, verimli ağ G/Ç ihtiyacı da artacak ve SocketChannel'ı her geliştiricinin araç setinde bulunması gereken önemli bir araç haline getirecek.
Ağ uygulamalarınız için yüksek performanslı NIO çözümlerini entegre etmek istiyorsanız ekibimiz yardıma hazır. Ağ sistemlerinizin sorunsuz ve verimli bir şekilde çalışmasını sağlamak amacıyla özel NIO uygulamaları, optimizasyon hizmetleri ve destek sağlamak için her büyüklükteki işletmeyle çalışıyoruz. İster yeni bir uygulama geliştiriyor olun ister mevcut bir uygulamayı güncelliyor olun, ihtiyaçlarınızı karşılayacak bir çözüm üretebiliriz. Gereksinimlerinizi tartışmak ve daha iyi ağ bağlantılı uygulamalar oluşturmaya başlamak için bugün ekibimizle iletişime geçin.
Referanslar
Oracle. Java NIO Belgeleri: SocketChannel. https://docs.oracle.com/javase/8/docs/api/java/nio/channels/SocketChannel.html adresinden alındı
Net Projesi. Netty Çerçeve Belgeleri. https://netty.io/wiki/user-guide-for-4.x.html adresinden alındı
Topley, G. (2001). Java NIO: Java yeni G/Ç. O'Reilly Medya.