|
|
Δημοσιεύτηκε στις 30/5/2019 10:58:30 μ.μ.
|
|
|
|
πρόλογος
Σε ορισμένα σημεία, χρησιμοποιούνται ουρές μηνυμάτων για να διασφαλιστεί η ακρίβεια της επεξεργασίας πληροφοριών. Για παράδειγμα, σε καταστάσεις υψηλής ταυτόχρονης χρήσης, οι ιστότοποι εκτελούν επεξεργασία δεδομένων. Σήμερα αυτό το άρθρο καταγράφει μια απλή επίδειξη του RabbitMQ. Πριν εισέλθετε σε αυτό το άρθρο, το περιβάλλον RbMQ πρέπει να εγκατασταθεί εκ των προτέρων (επειδή εγκατέστησα το τοπικό περιβάλλον RbMQ πριν και φοβάμαι ότι η απεγκατάσταση θα προκαλέσει κάποια προβλήματα ότι το μητρώο δεν είναι καθαρό, επομένως δεν θα καταγράψω την εγκατάσταση του περιβάλλοντος εδώ).
Περιβάλλον & Εργαλεία
>Σύστημα Windows 10
>Περιβαλλοντικές Υπηρεσίες RabbitMQ
>VS 2017
Κείμενο
1: Δημιουργήστε δύο νέες εφαρμογές κονσόλας, δηλαδή το "RabbitMQClient" και το "RabbitMQServer".
2: Ανατρέξτε στο "RabbitMQ.Client" dll
3: Στο έργο RabbitMQClient, Program.cs, επικολλήστε τον ακόλουθο κώδικα
4: Στο έργο RabbitMQServer, Program.cs, επικολλήστε τον ακόλουθο κώδικα
5: F5 για να ξεκινήσετε το έργο RabbitMQServer, στην κονσόλα, πληκτρολογήστε τις πληροφορίες, πατήστε enter.
6: Μην κλείσετε την κονσόλα έργου RabbitMQServer, κάντε δεξί κλικ στο έργο RabbitMQClient - > "Εντοπισμός σφαλμάτων" - > "Έναρξη νέας παρουσίας"
Μπορείτε να εισαγάγετε πληροφορίες στην κονσόλα RabbitMQServer στα δεξιά για να τις εμφανίσετε στα αριστερά. Το έργο RabbitMQServer παράγει μηνύματα. Το έργο RabbitMQClient επεξεργάζεται (καταναλώνει) μηνύματα. Αυτός είναι ο παραγωγός και ο καταναλωτής στην ουρά μηνυμάτων. Ο κώδικας περιλαμβάνει επίσης δρομολόγηση και κανάλια.
Από την πλευρά του παραγωγού μηνυμάτων, αποθέστε τις πληροφορίες προς επεξεργασία στην ουρά μηνυμάτων. Μετά τη λήψη του μηνύματος, ο καταναλωτής μπορεί να επεξεργαστεί αυτά τα δεδομένα ανάλογα.
Εάν το περιβάλλον είναι εγκατεστημένο, θα πρέπει να http://localhost:15672/#/queues η τοπική προεπιλεγμένη διεύθυνση θύρας. Μπορείτε να αποκτήσετε απευθείας πρόσβαση στον λογαριασμό επισκέπτη ή μπορείτε να διαμορφώσετε τον λογαριασμό και τα αντίστοιχα δικαιώματα πατώντας τη γραμμή εντολών.
Οι πληροφορίες που μόλις εισαγάγατε στην κονσόλα RabbitMQServer υπάρχουν στην πραγματικότητα πρώτα στην ουρά μηνυμάτων, μπορείτε να κλείσετε πρώτα το παράθυρο RabbitMQClient και, στη συνέχεια, να εισαγάγετε μερικές πληροφορίες στο παράθυρο, να παρατηρήσετε την ουρά μηνυμάτων και μπορείτε να δείτε ότι υπάρχουν τρία κομμάτια δεδομένων στην ουρά.
Όταν ξεκινήσει το παράθυρο RabbitMQClient, το μήνυμα θα εξαφανιστεί αυτόματα από την ουρά μηνυμάτων αφού το λάβετε κανονικά. Αυτός είναι ο μηχανισμός επιβεβαίωσης της ουράς μηνυμάτων, μόλις ληφθούν με ακρίβεια οι πληροφορίες που χρειαζόμαστε, ο καταναλωτής θα επιστρέψει μια κατάσταση στην ουρά μηνυμάτων για να καταστρέψει το μήνυμα. Εάν ο καταναλωτής δεν λάβει το μήνυμα ή εάν υπάρχει εξαίρεση και δεν επιστρέψει αυτήν την τιμή κατάστασης, το μήνυμα θα παραμείνει στην ουρά μέχρι να καταναλωθεί κανονικά το μήνυμα, γεγονός που διασφαλίζει την ακρίβεια του μηνύματος.
Επίλογος
Δυστυχώς, υπάρχουν πολύ λίγα μέρη όπου χρησιμοποιώ ουρές μηνυμάτων στα έργα μου. Χωρίς εις βάθος κατανόηση, θα χρησιμοποιηθούν μόνο τα βασικά.
Υπάρχει μια τρύπα στην παραπάνω επίδειξη και η σύνδεση του RbMQ στο RabbitMQClient έχει ένα επίπεδο χρήσης. Επειδή πρόκειται για ασύγχρονο νήμα, αυτό θα προκαλέσει την εκτέλεση του προγράμματος και την ανακύκλωση της σύνδεσης RbMQ πριν ολοκληρωθεί η λήψη του μηνύματος και θα αναφερθεί ένα σφάλμα. Ο τρόπος για να το αντιμετωπίσετε είναι: αφαιρέστε το χρησιμοποιώντας και αφήστε το χειροκίνητα.
|
Προηγούμενος:«npm ERR! Σφάλμα: EPERM: δεν επιτρέπεται η λειτουργία"Επόμενος:Εισαγωγή σε εννέα συμβατικά λογισμικά όρασης
|
Δημοσιεύτηκε στις 31/5/2019 9:12:21 π.μ.
|
