1. Εισαγωγή στο ActiveMQ Πρώτα αναλύστε ένα τέτοιο σενάριο: όταν ψωνίζουμε στον ιστότοπο, πρέπει να περάσουμε, να κάνουμε μια παραγγελία, να δημιουργήσουμε ένα τιμολόγιο, να επεξεργαστούμε την πληρωμή, να εκπληρώσουμε μια παραγγελία, να στείλουμε κ.λπ. Ωστόσο, όταν ένας χρήστης κάνει μια παραγγελία, ανακατευθύνεται αμέσως στη σελίδα "Ευχαριστώ για την παραγγελία σας". Όχι μόνο αυτό, αλλά εάν δεν υπάρξει καθυστέρηση, ο χρήστης θα λάβει επίσης ένα email. Εάν χρησιμοποιήσουμε τον παραδοσιακό τρόπο υλοποίησης, είναι γενικά να χειριστούμε τη βάση δεδομένων και στη συνέχεια να καλέσουμε διάφορες διεπαφές, διάφορες υπηρεσίες για να περιμένουμε διάφορες απαντήσεις, έτσι ώστε να χρειάζεται πολύς χρόνος για να δούμε το αποτέλεσμα της επόμενης παραγγελίας, εάν υπάρχει πρόβλημα σε έναν συγκεκριμένο σύνδεσμο, τότε το αποτέλεσμα της παραγγελίας δεν θα είναι ορατό για λίγο, για το σύγχρονο ηλεκτρονικό εμπόριο, αυτό είναι απαράδεκτο. Στη συνέχεια, το ActiveMQ μπορεί να λύσει αυτό το πρόβλημα πολύ καλά: όταν ο χρήστης κάνει μια παραγγελία, υπάρχει μια κλήση στο ActiveMQ για να υποβάλει την παραγγελία και, στη συνέχεια, το σύστημα μπορεί να επιστρέψει στη σελίδα αποτελεσμάτων και ολόκληρη η διαδικασία παραγγελίας δεν θα κληθεί συγχρονισμένα και το παρασκήνιο JOB μπορεί να συνομιλήσει και να εκτελεστεί. Εάν ο όγκος παραγγελιών της ρεσεψιόν είναι μεγάλος, κάθε παραγγελία χρειάζεται να κληθεί μόνο μία φορά και το γραφείο παρασκηνίου δεν μπορεί να τα χειριστεί όλα ταυτόχρονα; Πάρτε το χρόνο σας, κανείς δεν σας αναγκάζει, οι παραγγελίες περιμένουν στην ουρά στο ActiveMQ, δεν θα εκνευριστούν. Αυτό το σενάριο είναι ιδανικό για ένα είδος ουράς προσωρινής μνήμης, που ονομάζεται ουρά μηνυμάτων, την οποία μπορούν να εφαρμόσουν πολλά προϊόντα και, παρεμπιπτόντως, απαντά στην επόμενη πιθανή ερώτηση: είναι πολύ πιο γρήγορη από μια βάση δεδομένων. Αυτό το άρθρο ξεκινά από τα βασικά και μαθαίνει μαζί, το λειτουργικό περιβάλλον του συστήματος αυτού του άρθρου: Windοws7 32-bit 2. Κατεβάστε τη διεύθυνση λήψης του επίσημου ιστότοπου ActiveMQ: http://activemq.apache.org/ 3.运行ActiveMQ解压缩apache-activemq-5.10.0-bin.zip,然后双击apache-activemq-5.10.0inwin32activemq.bat运行ActiveMQ程序。 Δείτε την τελευταία γραμμή της εξόδου της κονσόλας: "επιτρέπεται η πρόσβαση σε όλα τα MBeans" για να αποδείξετε ότι η εκκίνηση ήταν επιτυχής. Μετά την εκκίνηση του ActiveMQ, μπορείτε να συνδεθείτε χρησιμοποιώντας το πρόγραμμα περιήγησης για να συνδεθείτε: http://localhost:8161/admin/ έλεγχο ταυτότητας, το προεπιλεγμένο όνομα χρήστη είναι διαχειριστής και ο κωδικός πρόσβασης είναι διαχειριστής (Η προϋπόθεση είναι ότι το περιβάλλον Java είναι εγκατεστημένο) Κατεβάστε την έκδοση .NET του Dll:Apache.NMS-1.6.0-bin.zip και Apache.NMS.ActiveMQ-1.6.4-bin.zip ταυτόχρονα Κατεβάστε τα όλα από εδώ:http://archive.apache.org/dist/activemq/apache-nms/1.6.0/ 3. Το πρώτο παράδειγμα ActiveMQ χρησιμοποιεί C# για να γράψει μια πηγή πληροφοριών, δηλαδή τον παραγωγό: Η διεπαφή είναι πολύ απλή, ένα Lable, ένα TextBox, ένα κουμπί και, στη συνέχεια, προσθέστε Apache.NMS.dll και Apache.NMS.ActiveMQ.dll αναφορές, βρείτε τις στα άλλα 2 πακέτα λήψης παραπάνω, δώστε προσοχή στον αριθμό έκδοσης.
Μπορείτε να κάνετε κλικ στο κουμπί για να στείλετε ορισμένα μηνύματα και αυτά τα μηνύματα θα αποθηκευτούν προσωρινά στο ActiveMQ και μπορείτε να συνδεθείτε στην ιστοσελίδα όπου μόλις ζητήσατε κωδικό πρόσβασης για να το δείτε.
Στη συνέχεια γράψτε στον δέκτη, δηλαδή στον καταναλωτή: Προσθέστε επίσης αναφορές σε αυτά τα 2 DLL, η διεπαφή είναι πολύ απλή με μόνο ένα Lable:
Μόλις το ξεκινήσετε, θα διαπιστώσετε ότι αυτά τα μηνύματα έχουν ληφθεί εδώ και τα μηνύματα από την πλευρά του διακομιστή έχουν διαγραφεί.
4. Περίληψη Τα παραπάνω υλοποιούν μια ουρά μηνυμάτων P2P, η οποία αποθηκεύεται προσωρινά και περιμένει για επεξεργασία και το μήνυμα εξαφανίζεται μετά την επεξεργασία, διασφαλίζοντας την παράδοση, δεν θα χαθεί και δεν θα απορριφθεί. Αυτή η λειτουργία μπορεί να χρησιμοποιηθεί μόνο σε περιορισμένες περιπτώσεις και ο πελάτης μπορεί να έχει μόνο μία, η οποία ανήκει στη μορφή ταχείας παράδοσης και δεν μπορεί να ικανοποιήσει τις απαιτήσεις επεξεργασίας παραγγελιών, ο λόγος είναι πολύ απλός: ο σύνδεσμος επιθεώρησης μαύρης λίστας λαμβάνει αυτές τις πληροφορίες παραγγελίας και ο σύνδεσμος αναθεώρησης δεν μπορεί να ληφθεί και η επόμενη ενότητα μαθαίνουμε "αποστολή ομάδας μηνυμάτων" μαζί, δηλαδή φωνάζουμε, έρχεται η παραγγελία, όλοι αρχίζουν να ασχολούνται...
Σημείωση: Το άρθρο ανατυπώνεται και το μήνυμα του άρθρου. Properties.SetString("filter","demo"); Αυτό δεν χρειάζεται να ρυθμιστεί!!
|