Πώς να γράψετε τη δική Απλή Java Message Queue σας

Η ουρά μήνυμα Java γράφει δεδομένα σε ένα εικονικό φάκελο, έτσι δύο εφαρμογές μπορούν να διασυνδεθούν με τα δεδομένα του άλλου . Το μήνυμα ουρά λειτουργεί ως κεντρική σύνδεση , όπου και τα δύο προγράμματα αποκοιμιέμαι και να πάρει τα δεδομένα . Μπορείτε να γράψετε το δικό σας μήνυμα ουρά για να δημιουργήσει μια διεπαφή μεταξύ των δύο προγραμμάτων . Το βασικό μήνυμα της Java setup ουρά δημιουργεί μια τοποθεσία ουρά , δημιουργεί μια συνεδρία και στέλνει μηνύματα στην ουρά . Οδηγίες
Η

1 Ανοίξτε το λογισμικό προγραμματισμού Java και το σχέδιο για τον κωδικό ουρά . Κάντε διπλό κλικ στο αρχείο κώδικα για να το ανοίξετε στον επεξεργαστή . 2

Δημιουργήστε το URL ή τη θέση του αρχείου για την ουρά . Σε αυτό το παράδειγμα , η ουρά που έχει συσταθεί στο φάκελο C: \\ ουρά :

ουρά String = " c : \\ ουρά " ? ConnectionFactory συνδέουν = νέα ActiveMQConnectionFactory ( ουρά ) ? Msg Connection = connect.createConnection ( ) ? msg.start ( ) ?
εικόνων 3

Ξεκινήστε τη συνεδρία προορισμού . Αφού δημιουργήσετε τη θέση του φακέλου , θα πρέπει να ξεκινήσετε τη συνεδρία προορισμού για να ακούσετε για νέα μηνύματα . Ο παρακάτω κώδικας δημιουργεί τον ακροατή συνεδρία :

Προορισμός dest = session.createQueue ( ) ?
Η 4

Στείλτε ένα μήνυμα στην ουρά για να δοκιμάσουν τη νέα σύνοδο και υπηρεσία άμεσων μηνυμάτων. Σε αυτό το παράδειγμα , ένα μήνυμα κειμένου αποστέλλεται στην ουρά :

MessageProducer pro = session.createProducer ( προορισμού) ? TextMessage text = session.createTextMessage ( « το μήνυμά μου ")? Pro.send (κείμενο ) ?
Η
εικόνων