AMQP / RabbitMQ
Το Restorm υλοποιεί το AMQP 0-9-1, το πρωτόκολλο του RabbitMQ.
Δεξί κλικ στο δέντρο ▸ Προσθήκη ▸ Αίτημα AMQP.
Κοινή διαμόρφωση
Section titled “Κοινή διαμόρφωση”| Πεδίο | Ρόλος |
|---|---|
| URL | amqp:// ή amqps:// |
| Vhost | Ο εικονικός υπολογιστής· / εξ ορισμού |
| Χρήστης / Κωδικός πρόσβασης | Ο κωδικός δέχεται τιμή τύπου Μυστικό |
| Λειτουργία | publish, subscribe ή browse |
Λειτουργία publish
Section titled “Λειτουργία publish”| Πεδίο | Ρόλος |
|---|---|
| Ανταλλαγή | Το όνομα της ανταλλαγής· μια κενή συμβολοσειρά δηλώνει την προεπιλεγμένη ανταλλαγή |
| Κλειδί δρομολόγησης | Το κλειδί δρομολόγησης, που δέχεται {{variables}} |
| Ωφέλιμο φορτίο | Το σώμα του μηνύματος |
Λειτουργία subscribe
Section titled “Λειτουργία subscribe”| Πεδίο | Ρόλος |
|---|---|
| Ουρά | Η ουρά που καταναλώνεται |
| Αυτόματη επιβεβαίωση | Ενεργή εξ ορισμού· απενεργοποιήστε την για να παρατηρήσετε τη συμπεριφορά επαναπαράδοσης |
| Prefetch | Ο μέγιστος αριθμός μη επιβεβαιωμένων μηνυμάτων εν πτήσει |
Λειτουργία browse
Section titled “Λειτουργία browse”Συμβουλεύεται το περιεχόμενο μιας ουράς χωρίς να το καταναλώσει: το Restorm αντλεί από αυτήν έναν περιορισμένο αριθμό μηνυμάτων (50 εξ ορισμού) και τα επαναφέρει στη θέση τους.
Είναι η λειτουργία που θέλουμε για να απαντήσουμε στο «τι υπάρχει σε αυτή την ουρά αναμονής;» χωρίς να διαταράξουμε το σύστημα. Είναι διαθέσιμη στην καρτέλα του αιτήματος· σε αντίθεση με τις άλλες δύο λειτουργίες, δεν έχει ειδική ενέργεια σεναρίου.
Μέσα σε ένα σενάριο
Section titled “Μέσα σε ένα σενάριο”Σύνδεση AMQP (καταναλώνει την ουρά σε λειτουργία subscribe και εκπέμπει
ένα συμβάν ανά μήνυμα), Δημοσίευση AMQP (δημοσιεύει στην ανταλλαγή και στο
κλειδί δρομολόγησης του αιτήματος) και Κλείσιμο σύνδεσης AMQP. Δείτε
Συνδέσεις και ροές.
Αποσπάσματα κώδικα
Section titled “Αποσπάσματα κώδικα”Οκτώ στόχοι: JavaScript (amqplib, σε δημοσίευση, κατανάλωση και επιθεώρηση),
Python (pika), amqp-publish και amqp-consume (amqp-tools), rabbitmqadmin.