Kendi dijital ekosisteminizi kurarken, sistemler aras\u0131 ileti\u015fimin ne kadar kritik oldu\u011funu fark etmekle birlikte, bu ileti\u015fimi y\u00f6netmenin de ne denli yorucu olabilece\u011fini tecr\u00fcbe etmi\u015f olabilirsiniz. T\u0131pk\u0131 bir “Hermes Ajan\u0131”na s\u00fcrekli g\u00f6z kulak olmak gibi, harici veya karma\u015f\u0131k bir mesajla\u015fma altyap\u0131s\u0131n\u0131 idare etmek bazen sizi ciddi anlamda bunaltabilir. Peki ya bu y\u00fckten kurtulup, kontrol\u00fc tamamen kendi elinize alsayd\u0131n\u0131z? Bu makale, sizi mevcut karma\u015f\u0131k ve belki de maliyetli “Hermes Ajan\u0131” ba\u011f\u0131ml\u0131l\u0131\u011f\u0131n\u0131zdan kurtararak, kendi sunucunuzda g\u00fc\u00e7l\u00fc ve esnek bir mesaj arac\u0131s\u0131 (message broker) kurman\u0131n yollar\u0131n\u0131 ke\u015ffetmeye davet ediyor. Kendi sisteminizi bar\u0131nd\u0131rmak, sadece maliyetleri d\u00fc\u015f\u00fcrmekle kalmaz, ayn\u0131 zamanda performans, g\u00fcvenlik ve \u00f6l\u00e7eklenebilirlik \u00fczerinde tam kontrol sa\u011flar.<\/p>\n
Modern yaz\u0131l\u0131m mimarilerinde, \u00f6zellikle mikroservis (microservice) tabanl\u0131 sistemlerde, farkl\u0131 bile\u015fenler aras\u0131nda g\u00fcvenilir ve asenkron (asynchronous) ileti\u015fim kurmak hayati \u00f6neme sahiptir. Bu ileti\u015fimi sa\u011flayan arac\u0131ya “mesaj arac\u0131s\u0131” veya mecazi anlamda “Hermes Ajan\u0131” diyebiliriz. Bu ajan\u0131n g\u00f6revi, bir servisten gelen mesajlar\u0131 al\u0131p, ilgili di\u011fer servislere g\u00fcvenli bir \u015fekilde iletmektir. Ancak bu “ajan” d\u0131\u015far\u0131dan y\u00f6netilen bir hizmet oldu\u011funda veya karma\u015f\u0131k bir yap\u0131ya sahip oldu\u011funda, onunla u\u011fra\u015fmak, s\u00fcrekli bak\u0131m\u0131n\u0131 yapmak, performans\u0131n\u0131 izlemek ve maliyetlerini y\u00f6netmek zamanla yorucu bir hal alabilir. Bu durum, t\u0131pk\u0131 bir \u00e7ocuk bak\u0131c\u0131s\u0131 gibi, s\u00fcrekli onunla ilgilenmenizi gerektiren bir sorumlulu\u011fa d\u00f6n\u00fc\u015febilir.<\/p>\n
Bir\u00e7ok kurulu\u015f, mesajla\u015fma ihtiya\u00e7lar\u0131 i\u00e7in bulut tabanl\u0131 hizmetlere (AWS SQS, Azure Service Bus, Google Cloud Pub\/Sub gibi) y\u00f6nelir. Bu hizmetler ba\u015flang\u0131\u00e7ta kurulum ve y\u00f6netim kolayl\u0131\u011f\u0131 sunsa da, b\u00fcy\u00fcyen hacimler, \u00f6zel gereksinimler veya beklenmedik maliyet art\u0131\u015flar\u0131 nedeniyle zamanla sorun te\u015fkil edebilir. \u00d6rne\u011fin, y\u00fcksek mesaj hacmi veya \u00f6zel y\u00f6nlendirme (routing) kurallar\u0131 gerektiren senaryolarda, bulut hizmetlerinin esnekli\u011fi yetersiz kalabilir veya maliyetleri h\u0131zla f\u0131rlayabilir. Ayr\u0131ca, veri egemenli\u011fi (data sovereignty) veya belirli g\u00fcvenlik politikalar\u0131 nedeniyle verilerinizi kendi kontrol\u00fcn\u00fczde tutmak isteyebilirsiniz. Bu gibi durumlarda, kendi mesaj arac\u0131n\u0131z\u0131 (Hermes Ajan\u0131n\u0131z\u0131) kendi altyap\u0131n\u0131zda bar\u0131nd\u0131rmak, size daha fazla kontrol, \u00f6ng\u00f6r\u00fclebilirlik ve uzun vadede maliyet avantaj\u0131 sa\u011flayabilir. Kendi sunucunuzda bir mesaj arac\u0131s\u0131 kurmak, sadece teknik bir tercih de\u011fil, ayn\u0131 zamanda operasyonel ba\u011f\u0131ms\u0131zl\u0131k ve stratejik bir yat\u0131r\u0131md\u0131r. Bu sayede, sisteminizin omurgas\u0131n\u0131 olu\u015fturan ileti\u015fim katman\u0131n\u0131 tamamen kendi ihtiya\u00e7lar\u0131n\u0131za g\u00f6re \u015fekillendirebilir, performans\u0131n\u0131 optimize edebilir ve g\u00fcvenlik politikalar\u0131n\u0131z\u0131 taviz vermeden uygulayabilirsiniz. Bu yakla\u015f\u0131m, \u00f6zellikle hassas verilerle \u00e7al\u0131\u015fan veya y\u00fcksek performans gerektiren uygulamalar geli\u015ftiren \u015firketler i\u00e7in vazge\u00e7ilmez bir \u00e7\u00f6z\u00fcm sunar.<\/p>\n
“Hermes Ajan\u0131” metaforu, Antik Yunan mitolojisindeki tanr\u0131lar\u0131n habercisi Hermes’ten geliyor. T\u0131pk\u0131 Hermes’in mesajlar\u0131 bir yerden ba\u015fka bir yere g\u00fcvenli ve h\u0131zl\u0131 bir \u015fekilde ta\u015f\u0131mas\u0131 gibi, bir mesaj arac\u0131s\u0131 da da\u011f\u0131t\u0131k sistemlerdeki farkl\u0131 uygulamalar, servisler veya bile\u015fenler aras\u0131nda veri ve komutlar\u0131n g\u00fcvenilir bir \u015fekilde iletilmesini sa\u011flar. Teknik anlamda bir mesaj arac\u0131s\u0131 (message broker), bir yaz\u0131l\u0131m mimarisinin merkezi bir bile\u015fenidir ve g\u00f6ndericiler (producers) ile al\u0131c\u0131lar (consumers) aras\u0131nda mesaj al\u0131\u015fveri\u015fini y\u00f6netir. Bu, sistemlerin birbirleriyle do\u011frudan ileti\u015fim kurmak yerine, mesaj arac\u0131s\u0131 \u00fczerinden asenkron olarak haberle\u015fmelerine olanak tan\u0131r.<\/p>\n
Peki, bu neden bu kadar \u00f6nemli? Da\u011f\u0131t\u0131k sistemlerde, \u00f6zellikle mikroservis mimarilerinde, her servis kendi i\u015fini yapar ve genellikle di\u011fer servislerden ba\u011f\u0131ms\u0131zd\u0131r. Ancak bu servislerin birbiriyle etkile\u015fim kurmas\u0131 gerekti\u011finde, do\u011frudan HTTP \u00e7a\u011fr\u0131lar\u0131 yapmak yerine bir mesaj arac\u0131s\u0131 kullanmak bir\u00e7ok avantaj sunar. \u00d6ncelikle, asenkron ileti\u015fim sayesinde g\u00f6nderici servis, mesaj\u0131 g\u00f6nderdikten sonra al\u0131c\u0131 servisin yan\u0131t\u0131n\u0131 beklemeden kendi i\u015fine devam edebilir. Bu durum, sistemin genel yan\u0131t s\u00fcresini (response time) iyile\u015ftirir ve t\u0131kan\u0131kl\u0131klar\u0131 (bottlenecks) azalt\u0131r. \u0130kinci olarak, mesaj arac\u0131s\u0131, servisler aras\u0131nda ba\u011f\u0131ml\u0131l\u0131\u011f\u0131 (coupling) azalt\u0131r. G\u00f6nderici, al\u0131c\u0131n\u0131n ne zaman aktif oldu\u011funu veya nerede bulundu\u011funu bilmek zorunda de\u011fildir; sadece mesaj\u0131 arac\u0131ya b\u0131rak\u0131r. Al\u0131c\u0131 ise, mesaj arac\u0131s\u0131ndan kendisine gelen mesajlar\u0131 uygun oldu\u011funda i\u015fler. Bu esneklik, sistemin bak\u0131m\u0131n\u0131 kolayla\u015ft\u0131r\u0131r ve yeni servislerin eklenmesini veya mevcut servislerin de\u011fi\u015ftirilmesini basitle\u015ftirir.<\/p>\n
\u00dc\u00e7\u00fcnc\u00fc olarak, mesaj arac\u0131s\u0131 hata tolerans\u0131 (fault tolerance) ve dayan\u0131kl\u0131l\u0131k (durability) sa\u011flar. E\u011fer bir al\u0131c\u0131 servis ge\u00e7ici olarak kullan\u0131lamaz durumdaysa, mesajlar arac\u0131n\u0131n kuyru\u011funda (queue) bekletilir ve servis tekrar aktif oldu\u011funda i\u015flenir. Bu, veri kayb\u0131n\u0131 \u00f6nler ve sistemin genel g\u00fcvenilirli\u011fini art\u0131r\u0131r. Ayr\u0131ca, mesaj arac\u0131s\u0131 y\u00fck dengeleme (load balancing) yetenekleri sunar; ayn\u0131 mesaj\u0131 i\u015fleyebilecek birden fazla al\u0131c\u0131 servisi varsa, mesajlar\u0131 bu servislere e\u015fit \u015fekilde da\u011f\u0131tabilir. Ger\u00e7ek d\u00fcnya senaryolar\u0131nda, bir e-ticaret uygulamas\u0131nda sipari\u015f i\u015fleme, kullan\u0131c\u0131 bildirimleri g\u00f6nderme, b\u00fcy\u00fck veri analizi i\u00e7in veri ak\u0131\u015flar\u0131n\u0131 y\u00f6netme veya farkl\u0131 sistemler aras\u0131nda veri senkronizasyonu gibi bir\u00e7ok alanda mesaj arac\u0131lar\u0131 kullan\u0131l\u0131r. \u00d6rne\u011fin, bir kullan\u0131c\u0131 yeni bir sipari\u015f verdi\u011finde, sipari\u015f detaylar\u0131 bir mesaj olarak “Hermes Ajan\u0131”na g\u00f6nderilir. Bu mesaj\u0131, stok g\u00fcncelleyici, fatura olu\u015fturucu ve e-posta g\u00f6nderici gibi farkl\u0131 servisler al\u0131p kendi i\u015flerini asenkron olarak yapabilirler. Bu sayede, kullan\u0131c\u0131n\u0131n sipari\u015f onay\u0131 bekleme s\u00fcresi k\u0131sal\u0131r ve sistemin genel performans\u0131 artar. Bu temel kavramlar\u0131 anlamak, kendi “Hermes Ajan\u0131n\u0131z\u0131” neden ve nas\u0131l kurman\u0131z gerekti\u011fini daha iyi kavraman\u0131za yard\u0131mc\u0131 olacakt\u0131r.<\/p>\n
Kendi “Hermes Ajan\u0131n\u0131z\u0131” bar\u0131nd\u0131rma karar\u0131 ald\u0131ktan sonraki en kritik ad\u0131m, do\u011fru mesaj arac\u0131s\u0131 teknolojisini se\u00e7mektir. Piyasada bir\u00e7ok farkl\u0131 se\u00e7enek bulunmaktad\u0131r ve her birinin kendine \u00f6zg\u00fc avantajlar\u0131 ve dezavantajlar\u0131 vard\u0131r. Se\u00e7iminiz, projenizin \u00f6zel ihtiya\u00e7lar\u0131na, beklenen mesaj hacmine, dayan\u0131kl\u0131l\u0131k gereksinimlerine, geli\u015ftirme ekibinizin a\u015final\u0131\u011f\u0131na ve y\u00f6netim kolayl\u0131\u011f\u0131na ba\u011fl\u0131 olacakt\u0131r. Bu b\u00f6l\u00fcmde, en pop\u00fcler mesaj arac\u0131s\u0131 teknolojilerini inceleyelim ve hangi senaryolar i\u00e7in uygun olduklar\u0131n\u0131 de\u011ferlendirelim.<\/p>\n
RabbitMQ, Advanced Message Queuing Protocol (AMQP) standard\u0131n\u0131 uygulayan, a\u00e7\u0131k kaynakl\u0131 ve olduk\u00e7a pop\u00fcler bir mesaj arac\u0131s\u0131d\u0131r. Erlang programlama diliyle yaz\u0131lm\u0131\u015ft\u0131r ve y\u00fcksek performans, g\u00fcvenilirlik ve esnek y\u00f6nlendirme yetenekleri sunar.<\/p>\n
* Avantajlar\u0131<\/strong>: Apache Kafka, y\u00fcksek hacimli, ger\u00e7ek zamanl\u0131 veri ak\u0131\u015flar\u0131n\u0131 i\u015flemek \u00fczere tasarlanm\u0131\u015f da\u011f\u0131t\u0131k bir ak\u0131\u015f platformudur. Bir mesaj kuyru\u011fundan ziyade, bir da\u011f\u0131t\u0131k i\u015flem g\u00fcnl\u00fc\u011f\u00fc (distributed commit log) olarak d\u00fc\u015f\u00fcn\u00fclebilir.<\/p>\n * Avantajlar\u0131<\/strong>: Redis, genellikle bir anahtar-de\u011fer (key-value) veri deposu ve \u00f6nbellek olarak bilinse de, 5.0 s\u00fcr\u00fcm\u00fcyle birlikte eklenen Streams \u00f6zelli\u011fi sayesinde hafif ve h\u0131zl\u0131 bir mesaj kuyru\u011fu olarak da kullan\u0131labilir.<\/p>\n * Avantajlar\u0131<\/strong>: Se\u00e7im Kriterleri \u00d6zet Tablosu:<\/strong><\/p>\n | \u00d6zellik \/ Teknoloji | RabbitMQ | Apache Kafka | Redis Streams | Vaka analizi olarak, e\u011fer yeni bir mikroservis mimarisi kuruyor ve servisler aras\u0131 asenkron ileti\u015fimi sa\u011flamak istiyorsan\u0131z, ancak ayn\u0131 zamanda karma\u015f\u0131k y\u00f6nlendirme kurallar\u0131na ihtiyac\u0131n\u0131z varsa, RabbitMQ iyi bir ba\u015flang\u0131\u00e7 noktas\u0131 olacakt\u0131r. \u00d6te yandan, bir finans kurumu i\u00e7in milyonlarca i\u015flem verisini ger\u00e7ek zamanl\u0131 olarak analiz etmeniz gerekiyorsa veya IoT cihazlar\u0131ndan gelen sens\u00f6r verilerini s\u00fcrekli olarak i\u015flemek istiyorsan\u0131z, Apache Kafka’n\u0131n sundu\u011fu y\u00fcksek hacimli ak\u0131\u015f i\u015fleme yetenekleri vazge\u00e7ilmez olacakt\u0131r. E\u011fer basit bir anl\u0131k bildirim sistemi kuruyor ve mevcut Redis altyap\u0131n\u0131z\u0131 kullanmak istiyorsan\u0131z, Redis Streams h\u0131zl\u0131 ve verimli bir \u00e7\u00f6z\u00fcm sunabilir. Do\u011fru teknolojiyi se\u00e7mek, “Hermes Ajan\u0131n\u0131z\u0131n” uzun vadeli ba\u015far\u0131s\u0131 i\u00e7in kritik \u00f6neme sahiptir.<\/p>\n Kendi “Hermes Ajan\u0131n\u0131z\u0131” bar\u0131nd\u0131rma yolculu\u011funuzda, RabbitMQ pop\u00fclerli\u011fi, esnekli\u011fi ve geni\u015f topluluk deste\u011fi sayesinde m\u00fckemmel bir ba\u015flang\u0131\u00e7 noktas\u0131d\u0131r. Bu b\u00f6l\u00fcmde, RabbitMQ’yu bir Linux sunucusuna Docker kullanarak nas\u0131l kuraca\u011f\u0131n\u0131z\u0131 ve temel bir mesaj g\u00f6nderme\/alma uygulamas\u0131n\u0131 nas\u0131l geli\u015ftirece\u011finizi ad\u0131m ad\u0131m g\u00f6sterece\u011fiz. Docker kullanmak, kurulum s\u00fcrecini basitle\u015ftirir ve ba\u011f\u0131ml\u0131l\u0131k sorunlar\u0131n\u0131 ortadan kald\u0131r\u0131r.<\/p>\n Docker, uygulamalar\u0131 ve ba\u011f\u0131ml\u0131l\u0131klar\u0131n\u0131 izole edilmi\u015f konteynerler (containers) i\u00e7inde paketlemeye olanak tan\u0131yan bir platformdur. RabbitMQ’yu Docker ile kurmak, i\u015fletim sistemi ba\u011f\u0131ml\u0131l\u0131klar\u0131yla u\u011fra\u015fmadan h\u0131zl\u0131 ve temiz bir kurulum sa\u011flar. Ayr\u0131ca, farkl\u0131 ortamlarda (geli\u015ftirme, test, \u00fcretim) tutarl\u0131 bir kurulum elde etmenizi kolayla\u015ft\u0131r\u0131r.<\/p>\n E\u011fer sunucunuzda Docker ve Docker Compose kurulu de\u011filse, \u00f6ncelikle bunlar\u0131 kurman\u0131z gerekmektedir. \u00c7o\u011fu Linux da\u011f\u0131t\u0131m\u0131 i\u00e7in a\u015fa\u011f\u0131daki komutlar\u0131 kullanabilirsiniz:<\/p>\n <\/code> \u015eimdi RabbitMQ'yu Docker Compose kullanarak ba\u015flataca\u011f\u0131z. Proje dizininizde <\/code><\/p>\n Bu yap\u0131land\u0131rma dosyas\u0131: Dosyay\u0131 kaydettikten sonra, ayn\u0131 dizinde a\u015fa\u011f\u0131daki komutu \u00e7al\u0131\u015ft\u0131r\u0131n:<\/p>\n <\/code> \u015eimdi RabbitMQ ile etkile\u015fim kuracak basit bir Python uygulamas\u0131 yazal\u0131m. <\/code> <\/code> \u015eimdi de g\u00f6nderdi\u011fimiz mesaj\u0131 alacak bir t\u00fcketici uygulamas\u0131 yazal\u0131m. <\/code>
\n * Esnek Y\u00f6nlendirme<\/strong>: Exchange (de\u011fi\u015fim) t\u00fcrleri (direct, topic, fanout, headers) sayesinde mesajlar\u0131n belirli kuyruklara veya birden fazla kuyru\u011fa \u00e7ok esnek bir \u015fekilde y\u00f6nlendirilmesini sa\u011flar. Bu, karma\u015f\u0131k i\u015f ak\u0131\u015flar\u0131 ve farkl\u0131 t\u00fcketici gruplar\u0131 i\u00e7in idealdir.
\n * Dayan\u0131kl\u0131l\u0131k<\/strong>: Mesajlar\u0131n diskte kal\u0131c\u0131 (persistent) olarak saklanmas\u0131 ve onay mekanizmalar\u0131 (acknowledgements) sayesinde mesaj kayb\u0131n\u0131 minimuma indirir.
\n * Geni\u015f Dil Deste\u011fi<\/strong>: Bir\u00e7ok programlama dili i\u00e7in istemci k\u00fct\u00fcphaneleri (client libraries) bulunur (Python, Java, .NET, Ruby, Node.js vb.).
\n * Y\u00f6netim Aray\u00fcz\u00fc<\/strong>: Kullan\u0131\u015fl\u0131 bir web tabanl\u0131 y\u00f6netim paneli (RabbitMQ Management Plugin) ile kuyruklar\u0131, de\u011fi\u015fimleri, ba\u011flant\u0131lar\u0131 ve performans metriklerini kolayca izleyebilirsiniz.
\n* Dezavantajlar\u0131<\/strong>:
\n * S\u0131ral\u0131 \u0130\u015fleme K\u0131s\u0131tlar\u0131<\/strong>: Y\u00fcksek hacimli ve s\u0131ral\u0131 mesaj ak\u0131\u015flar\u0131 i\u00e7in Kafka kadar optimize de\u011fildir.
\n * Kaynak T\u00fcketimi<\/strong>: B\u00fcy\u00fck k\u00fcmelerde (clusters) y\u00f6netim ve operasyonel karma\u015f\u0131kl\u0131k artabilir.
\n* Kullan\u0131m Senaryolar\u0131<\/strong>: Mikroservisler aras\u0131 g\u00f6rev kuyruklar\u0131, asenkron bildirimler (e-posta, SMS), uzun s\u00fcreli arka plan i\u015flemleri, da\u011f\u0131t\u0131k i\u015f ak\u0131\u015flar\u0131. K\u00fc\u00e7\u00fck ve orta \u00f6l\u00e7ekli e-ticaret uygulamalar\u0131nda sipari\u015f i\u015fleme ve envanter g\u00fcncelleme gibi senaryolar i\u00e7in m\u00fckemmel bir se\u00e7imdir.<\/p>\nApache Kafka: Y\u00fcksek Hacimli Veri Ak\u0131\u015flar\u0131 ve Olay Tabanl\u0131 Mimari \u0130\u00e7in G\u00fc\u00e7l\u00fc<\/h4>\n
\n * Y\u00fcksek Performans ve \u00d6l\u00e7eklenebilirlik<\/strong>: Saniyede milyonlarca mesaj\u0131 i\u015fleyebilir ve yatay olarak kolayca \u00f6l\u00e7eklenebilir (horizontal scaling).
\n * Dayan\u0131kl\u0131l\u0131k ve Hata Tolerans\u0131<\/strong>: Veriler diskte kal\u0131c\u0131 olarak saklan\u0131r ve replikasyon (replication) mekanizmalar\u0131 sayesinde y\u00fcksek hata tolerans\u0131 sunar.
\n * Olay Tabanl\u0131 Mimari<\/strong>: Olay ak\u0131\u015flar\u0131n\u0131 (event streams) depolamak ve i\u015flemek i\u00e7in idealdir, bu da olay tabanl\u0131 mimariler ve ger\u00e7ek zamanl\u0131 analizler i\u00e7in temel olu\u015fturur.
\n * Veri Yeniden Oynatma<\/strong>: Mesajlar belirli bir s\u00fcre boyunca sakland\u0131\u011f\u0131 i\u00e7in, ge\u00e7mi\u015f olaylar\u0131 tekrar oynatma (replay) yetene\u011fi sunar.
\n* Dezavantajlar\u0131<\/strong>:
\n * Karma\u015f\u0131kl\u0131k<\/strong>: Kurulumu ve y\u00f6netimi RabbitMQ’ya g\u00f6re daha karma\u015f\u0131kt\u0131r, \u00f6zellikle b\u00fcy\u00fck k\u00fcmelerde.
\n * Kaynak T\u00fcketimi<\/strong>: Y\u00fcksek disk alan\u0131 ve bellek t\u00fcketimi olabilir.
\n * Basit Kuyruklar \u0130\u00e7in A\u015f\u0131r\u0131 Yetenekli<\/strong>: E\u011fer sadece basit bir g\u00f6rev kuyru\u011funa ihtiyac\u0131n\u0131z varsa, Kafka a\u015f\u0131r\u0131 yetenekli ve gereksiz yere karma\u015f\u0131k olabilir.
\n* Kullan\u0131m Senaryolar\u0131<\/strong>: B\u00fcy\u00fck veri ak\u0131\u015flar\u0131n\u0131 i\u015fleme, log toplama, ger\u00e7ek zamanl\u0131 analiz, olay kaynaklama (event sourcing), mikroservisler aras\u0131 olay tabanl\u0131 ileti\u015fim. B\u00fcy\u00fck \u00f6l\u00e7ekli veri analizi, IoT cihazlar\u0131ndan veri toplama veya finansal i\u015flemlerin ger\u00e7ek zamanl\u0131 takibi gibi senaryolar i\u00e7in vazge\u00e7ilmezdir.<\/p>\nRedis Streams: Hafif ve H\u0131zl\u0131 Kuyruklar \u0130\u00e7in<\/h4>\n
\n * H\u0131z<\/strong>: Bellek i\u00e7i (in-memory) yap\u0131s\u0131 sayesinde inan\u0131lmaz derecede h\u0131zl\u0131d\u0131r.
\n * Basitlik<\/strong>: Redis’i zaten kullan\u0131yorsan\u0131z, Streams \u00f6zelli\u011fini devreye almak olduk\u00e7a kolayd\u0131r.
\n * Consumer Groups<\/strong>: Kafka’dakine benzer t\u00fcketici gruplar\u0131 (consumer groups) ile mesajlar\u0131n birden fazla t\u00fcketici aras\u0131nda da\u011f\u0131t\u0131lmas\u0131n\u0131 sa\u011flar.
\n * K\u00fc\u00e7\u00fck Ayak \u0130zi<\/strong>: Di\u011fer mesaj arac\u0131s\u0131 \u00e7\u00f6z\u00fcmlerine g\u00f6re daha az kaynak t\u00fcketir.
\n* Dezavantajlar\u0131<\/strong>:
\n * Dayan\u0131kl\u0131l\u0131k K\u0131s\u0131tlar\u0131<\/strong>: Varsay\u0131lan olarak kal\u0131c\u0131 depolama (persistence) sunsa da, Kafka veya RabbitMQ kadar sa\u011flam de\u011fildir.
\n * \u00d6l\u00e7eklenebilirlik<\/strong>: B\u00fcy\u00fck veri ak\u0131\u015flar\u0131 i\u00e7in Kafka kadar \u00f6l\u00e7eklenebilir de\u011fildir.
\n * Geli\u015fmi\u015f \u00d6zellikler<\/strong>: Geli\u015fmi\u015f y\u00f6nlendirme veya karma\u015f\u0131k mesaj i\u015fleme yetenekleri sunmaz.
\n* Kullan\u0131m Senaryolar\u0131<\/strong>: Ger\u00e7ek zamanl\u0131 sohbet uygulamalar\u0131, anl\u0131k bildirimler, k\u0131sa \u00f6m\u00fcrl\u00fc g\u00f6rev kuyruklar\u0131, k\u00fc\u00e7\u00fck \u00f6l\u00e7ekli olay ak\u0131\u015flar\u0131. Mevcut Redis altyap\u0131s\u0131n\u0131 kullanarak h\u0131zl\u0131 ve basit bir mesajla\u015fma katman\u0131 olu\u015fturmak isteyenler i\u00e7in idealdir.<\/p>\n
\n| :—————— | :——————- | :——————- | :——————- |
\n| \u00d6l\u00e7eklenebilirlik<\/strong> | Orta – Y\u00fcksek | \u00c7ok Y\u00fcksek | D\u00fc\u015f\u00fck – Orta |
\n| Dayan\u0131kl\u0131l\u0131k<\/strong> | Y\u00fcksek | \u00c7ok Y\u00fcksek | Orta |
\n| Y\u00f6netim Kolayl\u0131\u011f\u0131<\/strong> | Orta | Y\u00fcksek | D\u00fc\u015f\u00fck |
\n| Mesaj Hacmi<\/strong> | Orta | \u00c7ok Y\u00fcksek | D\u00fc\u015f\u00fck |
\n| Karma\u015f\u0131kl\u0131k<\/strong> | Orta | Y\u00fcksek | D\u00fc\u015f\u00fck |
\n| Kullan\u0131m Alan\u0131<\/strong> | G\u00f6rev kuyruklar\u0131, RPC | Olay ak\u0131\u015flar\u0131, loglar | Anl\u0131k bildirimler, \u00f6nbellek |<\/p>\nAd\u0131m Ad\u0131m Kurulum: RabbitMQ ile Kendi Hermes Ajan\u0131n\u0131z\u0131 Hayata Ge\u00e7irin<\/h3>\n
Neden Docker ile RabbitMQ Kurulumu?<\/h4>\n
Ad\u0131m 1: Docker ve Docker Compose Kurulumu<\/h4>\n
\n# Docker kurulumu (Ubuntu i\u00e7in)\nsudo apt update\nsudo apt install apt-transport-https ca-certificates curl software-properties-common\ncurl -fsSL https:\/\/download.docker.com\/linux\/ubuntu\/gpg | sudo gpg --dearmor -o \/usr\/share\/keyrings\/docker-archive-keyring.gpg\necho \"deb [arch=$(dpkg --print-architecture) signed-by=\/usr\/share\/keyrings\/docker-archive-keyring.gpg] https:\/\/download.docker.com\/linux\/ubuntu $(lsb_release -cs) stable\" | sudo tee \/etc\/apt\/sources.list.d\/docker.list > \/dev\/null\nsudo apt update\nsudo apt install docker-ce docker-ce-cli containerd.io\n\n# Docker Compose kurulumu\nsudo curl -L \"https:\/\/github.com\/docker\/compose\/releases\/download\/v2.20.2\/docker-compose-$(uname -s)-$(uname -m)\" -o \/usr\/local\/bin\/docker-compose\nsudo chmod +x \/usr\/local\/bin\/docker-compose\n\n# Kullan\u0131c\u0131n\u0131z\u0131 docker grubuna ekleyin (iste\u011fe ba\u011fl\u0131, sudo kullanmadan docker komutlar\u0131n\u0131 \u00e7al\u0131\u015ft\u0131rmak i\u00e7in)\nsudo usermod -aG docker $USER\nnewgrp docker\n <\/code><\/pre>\n<\/div>\n
\nKurulumdan sonra, docker --version<\/code> ve docker-compose --version<\/code> komutlar\u0131n\u0131 \u00e7al\u0131\u015ft\u0131rarak kurulumun ba\u015far\u0131l\u0131 oldu\u011funu do\u011frulayabilirsiniz.<\/p>\nAd\u0131m 2: RabbitMQ Konteynerini Ba\u015flatma<\/h4>\n
docker-compose.yml<\/code> ad\u0131nda bir dosya olu\u015fturun ve i\u00e7ine a\u015fa\u011f\u0131daki i\u00e7eri\u011fi yap\u0131\u015ft\u0131r\u0131n:<\/p>\n\nversion: '3.8'\nservices:\n rabbitmq:\n image: rabbitmq:3-management\n hostname: my-rabbitmq\n ports:\n - \"5672:5672\" # AMQP portu\n - \"15672:15672\" # Y\u00f6netim aray\u00fcz\u00fc portu\n environment:\n RABBITMQ_DEFAULT_USER: user\n RABBITMQ_DEFAULT_PASS: password\n volumes:\n - rabbitmq_data:\/var\/lib\/rabbitmq\/mnesia\n\nvolumes:\n rabbitmq_data:\n driver: local\n <\/code><\/pre>\n<\/div>\n
\n* rabbitmq:3-management<\/code> imaj\u0131n\u0131 kullan\u0131r. Bu imaj, RabbitMQ'nun kendisiyle birlikte web tabanl\u0131 y\u00f6netim aray\u00fcz\u00fcn\u00fc (management plugin) de i\u00e7erir.
\n* 5672<\/code> portunu AMQP ileti\u015fimi i\u00e7in, 15672<\/code> portunu ise y\u00f6netim aray\u00fcz\u00fc i\u00e7in d\u0131\u015far\u0131ya a\u00e7ar.
\n* Varsay\u0131lan kullan\u0131c\u0131 ad\u0131 ve \u015fifreyi (user<\/code>\/password<\/code>) ayarlar. \u00dcretim ortam\u0131nda bu bilgileri mutlaka g\u00fc\u00e7l\u00fc ve g\u00fcvenli de\u011ferlerle de\u011fi\u015ftirin!<\/strong>
\n* rabbitmq_data<\/code> ad\u0131nda bir volume (birim) tan\u0131mlar. Bu, RabbitMQ verilerinin (kuyruklar, mesajlar vb.) konteyner yeniden ba\u015flat\u0131lsa bile kal\u0131c\u0131 olmas\u0131n\u0131 sa\u011flar.<\/p>\n\ndocker-compose up -d\n <\/code><\/pre>\n<\/div>\n
\nBu komut, RabbitMQ konteynerini arka planda ba\u015flatacakt\u0131r. Birka\u00e7 saniye i\u00e7inde RabbitMQ \u00e7al\u0131\u015f\u0131r durumda olacakt\u0131r. Taray\u0131c\u0131n\u0131zdan http:\/\/localhost:15672<\/code> adresine giderek y\u00f6netim aray\u00fcz\u00fcne eri\u015febilir ve user<\/code>\/password<\/code> ile giri\u015f yapabilirsiniz.<\/p>\nAd\u0131m 3: Python ile Basit Mesaj G\u00f6nderme (Producer) Uygulamas\u0131<\/h4>\n
pika<\/code> k\u00fct\u00fcphanesini kullanaca\u011f\u0131z. \u00d6ncelikle k\u00fct\u00fcphaneyi y\u00fckleyin:<\/p>\n\npip install pika\n <\/code><\/pre>\n<\/div>\n
\nArd\u0131ndan, producer.py<\/code> ad\u0131nda bir dosya olu\u015fturun ve i\u00e7ine a\u015fa\u011f\u0131daki kodu ekleyin:<\/p>\n\nimport pika\n\n# RabbitMQ ba\u011flant\u0131 parametreleri\nconnection_parameters = pika.ConnectionParameters(\n host='localhost',\n port=5672,\n credentials=pika.PlainCredentials('user', 'password')\n)\n\n# Ba\u011flant\u0131 kur\nconnection = pika.BlockingConnection(connection_parameters)\nchannel = connection.channel()\n\n# 'hello' ad\u0131nda bir kuyruk olu\u015ftur (e\u011fer yoksa)\nchannel.queue_declare(queue='hello')\n\n# Mesaj\u0131 kuyru\u011fa g\u00f6nder\nmessage = \"Merhaba, Hermes Ajan\u0131!\"\nchannel.basic_publish(\n exchange='', # Varsay\u0131lan exchange kullan\u0131yoruz\n routing_key='hello', # 'hello' kuyru\u011funa g\u00f6nder\n body=message\n)\n\nprint(f\" [x] '{message}' mesaj\u0131 g\u00f6nderildi.\")\n\n# Ba\u011flant\u0131y\u0131 kapat\nconnection.close()\n <\/code><\/pre>\n<\/div>\n
\nBu kod, RabbitMQ'ya ba\u011flan\u0131r, 'hello' ad\u0131nda bir kuyruk olu\u015fturur (e\u011fer zaten yoksa) ve bu kuyru\u011fa bir mesaj g\u00f6nderir.<\/p>\nAd\u0131m 4: Python ile Basit Mesaj Alma (Consumer) Uygulamas\u0131<\/h4>\n
consumer.py<\/code> ad\u0131nda bir dosya olu\u015fturun ve i\u00e7ine a\u015fa\u011f\u0131daki kodu ekleyin:<\/p>\n\nimport pika\nimport time\n\n# RabbitMQ ba\u011flant\u0131 parametreleri\nconnection_parameters = pika.ConnectionParameters(\n host='localhost',\n port=5672,\n credentials=pika.PlainCredentials('user', 'password')\n)\n\n# Ba\u011flant\u0131 kur\nconnection = pika.BlockingConnection(connection_parameters)\nchannel = connection.channel()\n\n# 'hello' ad\u0131nda bir kuyruk olu\u015ftur (e\u011fer yoksa)\nchannel.queue_declare(queue='hello')\n\nprint(' [*] Mesajlar\u0131 bekliyorum. \u00c7\u0131kmak i\u00e7in CTRL+C tu\u015flar\u0131na bas\u0131n.')\n\n# Mesaj geldi\u011finde \u00e7al\u0131\u015facak callback fonksiyonu\ndef callback(ch, method, properties, body):\n print(f\" [x] '{body.decode()}' mesaj\u0131 al\u0131nd\u0131.\")\n time.sleep(body.count(b'.')) # Mesaj\u0131 i\u015flemenin sim\u00fclasyonu\n ch.basic_ack(delivery_tag=method.delivery_tag) # Mesaj\u0131n ba\u015far\u0131yla i\u015flendi\u011fini onayla\n\n# Kuyruktan mesajlar\u0131 t\u00fcketmeye ba\u015fla\nchannel.basic_consume(\n queue='hello',\n on_message_callback=callback,\n auto_ack=False # Mesaj\u0131 manuel olarak onaylayaca\u011f\u0131z\n)\n\n# Sonsuz d\u00f6ng\u00fcde mesajlar\u0131 dinle\nchannel.start_consuming()\n <\/code><\/pre>\n<\/div>\n
\nBu kod, RabbitMQ'ya ba\u011flan\u0131r, 'hello' kuyru\u011funu dinler ve bir mesaj geldi\u011finde callback<\/code> fonksiyonunu \u00e7al\u0131\u015ft\u0131r\u0131r. basic_ack<\/code> komutu, mesaj\u0131n ba\u015far\u0131yla i\u015f<\/p>\n","protected":false},"excerpt":{"rendered":"Hermes Ajan\u0131n\u0131z\u0131 Kendi Sunucunuzda Bar\u0131nd\u0131r\u0131n: Mesaj Arac\u0131s\u0131 Y\u00f6netimine Modern Bir Yakla\u015f\u0131m Kendi dijital ekosisteminizi kurarken, sistemler aras\u0131 ileti\u015fimin ne kadar kritik oldu\u011funu fark etmekle birlikte, bu ileti\u015fimi y\u00f6netmenin de ne denli yorucu olabilece\u011fini tecr\u00fcbe etmi\u015f olabilirsiniz.","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"csco_page_header_type":"","csco_page_load_nextpost":"","csco_page_subscribe_form":"","csco_page_contact_form":"","footnotes":""},"categories":[1],"tags":[],"class_list":{"0":"post-41663","1":"post","2":"type-post","3":"status-publish","4":"format-standard","6":"category-genel","7":"cs-entry","8":"cs-video-wrap"},"yoast_head":"\n