Qu'est-ce qu'un message
Processus de communication asynchrone faiblement couplé
1. le producteur ; l'emplacement où le message est stocké est appelé la destination ; le composant qui reçoit le message est appelé le consommateur
2.
a. Point à point : La destination devient une file d'attente et le message ne peut être consommé qu'une seule fois
b. Publier-s'abonner : La destination devient le sujet, le consommateur est appelé abonné et le message peut être consommé par n'importe quel numéro
a. Utilisez l'injection de dépendances pour obtenir la fabrique de connexions ConnectionFactory et les objets Destination
b. Utilisez createConnection de la fabrique de connexions pour ouvrir la connexion Connection
c. Utilisez createSession of Connection pour créer une session et spécifier les paramètres de transaction
d. Utilisez le createProducer de la session pour créer la file d'attente de fret Producer
e. Utilisez createMessage de Session pour créer un message Message et définir
f. Utilisez l'envoi du producteur de la file d'attente de fret pour envoyer le message
g. Libérer des ressources
Remarque : Le processus ci-dessus est basé sur JavaEE 6. JavaEE 7 fournit un processus de développement A plus simple
a. La classe MDB doit implémenter directement ou indirectement l'interface d'écoute de message
b. Cela doit être concret et public, cela ne peut pas être un cours final ou abstrait
c. Il doit s'agir d'un POJO et ne peut pas être une sous-classe d'un autre MDB
d. Il doit y avoir un constructeur sans paramètres
e. Il ne peut pas y avoir de méthode finale
f. Aucune exception d'exécution ne peut être levée, car l'instance MDB sera terminée une fois lancée
a. Utilisez l'annotation @MessageDriven pour marquer la classe comme MDB et spécifier la configuration MDB
b. Implémentez l'interface MessageListener et implémentez la méthode onMessage
c. Implémenter la logique dans onMessage
a. destinationType : indique au conteneur si le MDB écoute une file d'attente ou un sujet
b. connectionFactoryJndiName : Spécifie la fabrique de connexions JDNI
utilisée pour créer la connexion JMS du MDB
c. destianName : Spécifiez la destination d'écoute
d.knowledgeMode : Spécifiez le mode de confirmation de session JMS
e. abonnementDurabilité : utilisé pour définir comme abonné durable
f. messageSelector : filtrer les messages
a. Créez des instances MDB et configurez-les
b. Injecter des ressources
c. Stocker dans une piscine gérée
d. Lors de la détection de la destination où le message arrive, supprimez le bean inactif du pool
e. Exécutez la méthode d'écoute de message, c'est-à-dire la méthode onMessage
f. Lorsque la méthode onMessage est exécutée, enregistrez le bean inactif dans le pool
g. Révoquer/détruire les beans de la piscine si nécessaire
.
7. Configurer la taille du pool MDB : Configurer selon le scénario et les besoinsRéférence
EJB 3 en action, deuxième éditionCe qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!