| RabbitMQ | ||
|---|---|---|
| Generell informasjon | ||
| programtype | AMQP , meldingsorientert mellomvare _ | |
| utvikler | Pivotal programvare | |
| Tillatelse | Mozilla offentlig lisens | |
| Faktisk tilstand | Med støtte | |
| Språk | Engelsk | |
| Teknisk informasjon | ||
| Planlagt inn | Erlang | |
| Støttede plattformer | i386, x86_64 | |
| Versjoner | ||
| Siste stabile versjon | 3.10.5 (6. juni 2022 (4 måneder og 12 dager)) | |
| Teknisk assistanse | ||
| Rabbit Technologies Ltd (RTL), de opprinnelige utviklerne, gir støtte på bedriftsnivå og relaterte tjenester til organisasjoner som bruker RabbitMQ. Dokumentasjon kan også finnes på nettsiden deres, samt informasjon om RabbitMQ-installasjoner utført uten noen form for støtte ( i naturen ). | ||
| Lenker | ||
| Offesiell nettside Blogg kodelager | ||
RabbitMQ er en åpen kildekode-programvare for meldingshandel som fungerer som en mellomvare for meldinger . Den implementerer standarden Advanced Message Queuing Protocol ( AMQP ). RabbitMQ-serveren er skrevet i Erlang og bruker rammeverket Open Telecom Platform (OTP) for å bygge sine distribuerte kjørings- og failover-funksjoner. Rabbit Technologies Ltd., selskapet som utvikler den, ble kjøpt opp i april 2010 av SpringSource -divisjonen til VMWare . Per dette øyeblikk er det sistnevnte selskap som utvikler og støtter RabbitMQ. [ 1 ] Kildekoden er utgitt under Mozilla Public License . Fra mai 2013 , av en fagforening av selskaper, er Pivotal den nye sponsoren av prosjektet [ 2 ]
RabbitMQ-prosjektet består av ulike deler:
Denne delen gir Python -brukseksempler (ved bruk av Pika- pakken ) for en meldingsavsender og -mottaker.
Følgende kodebit etablerer tilkoblingen, sørger for at meldingskøen eksisterer, sender meldingen og lukker til slutt tilkoblingen.
#!/usr/bin/env python import pika # Vi importerer Pika - pakkeforbindelsen = pika . BlockingConnection ( pika . ConnectionParameters ( vert = 'localhost' )) # Få tilkobling til serverkanal = tilkobling . kanal () # Vi lager kommunikasjonskanalen . queue_declare ( queue = 'hei' ) # Vi erklærer meldingskøkanalen . basic_publish ( exchange = '' , routing_key = 'hei' , body = 'Hei verden!' ) # Publiser meldingen i køutskriften ( " [x] Sendt 'Hello World!'" ) # Vis hva som ble sendt på skjermen tilkobling . close () # Vi lukker forbindelsen.På samme måte mottar følgende program meldingen og skriver den ut på skjermen:
#!/usr/bin/env python import pika- tilkobling = pika . BlockingConnection ( pika . ConnectionParameters ( vert = 'localhost' )) kanal = tilkobling . kanal () kanal . queue_declare ( queue = 'hei' ) print ( ' [*] Venter på meldinger. For å avslutte trykk CTRL+C' ) def callback ( ch , metode , egenskaper , body ): print ( " [x] Mottatt %r " % body ) kanal . basic_consume ( kø = 'hei' , on_message_callback = tilbakeringing ) kanal . start_consuming ()