|
|
Publié sur 30/05/2019 22:58:30
|
|
|
|
préface
Dans certains endroits, des files d’attente de messages sont utilisées pour garantir la précision du traitement de l’information. Par exemple, dans des situations de forte concurrence, les sites web effectuent le traitement des données. Aujourd’hui, cet article présente une simple démonstration de RabbitMQ. Avant d’entrer dans cet article, l’environnement RbMQ doit être installé à l’avance (car j’ai déjà installé l’environnement RbMQ local, et j’ai peur que la désinstallation ne cause certains problèmes : le registre n’est pas propre, donc je n’enregistrerai pas l’installation de l’environnement ici).
Environnement et outils
>Système Windows 10
>Services environnementaux RabbitMQ
>VS 2017
SMS
1 : Créer deux nouvelles applications console, à savoir « RabbitMQClien » et « RabbitMQServer ».
2 : Référer la dll « RabbitMQ.Client »
3 : Dans le projet RabbitMQClient, Program.cs, collez le code suivant
4 : Dans le projet RabbitMQServer, Program.cs, collez le code suivant
5 : F5 pour lancer le projet RabbitMQServer, dans la console, entrez les informations, appuyez sur entrée.
6 : Ne fermez pas la console de projet RabbitMQServer, cliquez droit sur le projet RabbitMQClient - > « Déboguer » - > « Démarrer une nouvelle instance »
Vous pouvez saisir des informations dans la console RabbitMQServer à droite pour les afficher à gauche. Le projet RabbitMQServer produit des messages. Le projet RabbitMQClient traite (consomme) les messages. Il s’agit du producteur et du consommateur dans la file d’attente des messages. Le code implique également le routage et les canaux.
Du côté du producteur de messages, déposez les informations à traiter dans la file d’attente des messages. Après avoir reçu le message, le consommateur peut traiter ces données en conséquence.
Si l’environnement est installé, l’adresse de port par défaut locale doit être http://localhost:15672/#/queues. Vous pouvez accéder directement au compte invité, ou configurer le compte et les permissions correspondantes en appuyant sur la ligne de commande.
Les informations que vous venez de saisir dans la console RabbitMQServer existent en fait d’abord dans la file d’attente des messages, vous pouvez d’abord fermer la fenêtre RabbitMQClient, puis entrer quelques informations dans la fenêtre, observer la file d’attente, et vous pouvez voir qu’il y a trois données dans la file.
Lorsque notre fenêtre RabbitMQClient démarre, le message disparaît automatiquement de la file d’attente après l’avoir reçu normalement. C’est le mécanisme de confirmation de la file de messages : une fois que les informations nécessaires sont correctement reçues, le consommateur renverra un état à la file de messages pour détruire le message. Si le consommateur ne reçoit pas le message, ou s’il y a une exception et ne retourne pas cette valeur de statut, le message restera dans la file d’attente jusqu’à ce qu’il soit consommé normalement, ce qui garantit l’exactitude du message.
Épilogue
Malheureusement, il y a très peu d’endroits où j’utilise des files d’attente de messages dans mes projets. Sans une compréhension approfondie, seuls les bases seront utilisées.
Il y a un trou dans la démo ci-dessus, et la connexion de RbMQ dans RabbitMQClient a une couche d’utilisation. Comme il s’agit d’un thread asynchrone, cela fera que le programme exécutera et recyclera la connexion RbMQ avant d’avoir fini de recevoir le message, et une erreur sera signalée. La façon de gérer ça est : retirer l’utilisation et la relâcher manuellement.
|
Précédent:« npm ERR ! Erreur : EPERM : exploitation non autorisée »Prochain:Introduction aux neuf logiciels de vision conventionnels
|
Publié sur 31/05/2019 09:12:21
|
