Rabbitmq surveille les collections et les canaux dans les pages Web sans messages

Questions et réponses du rseoc 2021-12-30 13:51:41 阅读数:420

rabbitmq surveille les collections et

L'école primairerabbitmq,MonrabbitmqLa version suivante:

img


J'ai écritproducer(Producteurs de messages),consumer(Consommateurs de messages)

// 1: Créer une usine de connexion ConnectionFactory connectionFactory = new ConnectionFactory(); // 2: Définir les propriétés de connexion connectionFactory.setHost("192.168.60.110");//Adresse de la machine virtuelle locale connectionFactory.setPort(5672);//Port par défaut,15672 Gestion des pages Web,5672 Pour AMQPPort connectionFactory.setVirtualHost("/"); connectionFactory.setUsername("admin"); connectionFactory.setPassword("admin"); Connection connection = null; Channel channel = null; try { // 3: Obtenir la connexion à partir de l'usine de connexion connection = connectionFactory.newConnection("Producteurs"); // 4: Obtenir le Canal à partir de la connexionchannel channel = connection.createChannel(); // 5: File d'attente des déclarationsqueueStocker les messages /* * Si la file d'attente n'existe pas,Crée * RabbitmqDeux noms de file d'attente identiques ne sont pas autorisés,Sinon, une erreur sera signalée. * * @params1: queue Nom de la file d'attente * @params2: durable Si la file d'attente est persistante * @params3: exclusive Est - il exclusif?,C'est - à - dire privé ou non,Si ouitrue,Verrouille la file d'attente actuelle,Aucun autre canal n'est accessible,Et la connexion se ferme automatiquement * @params4: autoDelete Supprimer automatiquement,Si le message est automatiquement supprimé lorsque le dernier consommateur est déconnecté. * @params5: arguments Vous pouvez définir les paramètres supplémentaires de la file d'attente,Définir la durée de validité de la file d'attente,Longueur maximale du message,Le cycle de vie du message de la file d'attente, etc.. * */ channel.queueDeclare("queue1", false, false, false, null); // 6: Contenu du message prêt à être envoyé String message = "Bonjour,Apprendre ensemble!!!"; // 7: Envoyer un message à l'intergicielrabbitmq-server // @params1: Commutateurexchange // @params2: Nom de la file d 'attente/routing // @params3: Configuration des propriétés // @params4: Contenu du message envoyé channel.basicPublish("", "queue1", null, message.getBytes()); System.out.println("Message envoyé avec succès!");

La console a envoyé un message avec succès

img

img


Monrabbitmq La page de surveillance a également vu queue1,

img

La question est:,collectionsEtchannel Aucun message détecté ,Maisqueue1Tout est sorti.,Preuvecellections La connexion doit être connectée. ,AccèschannelÇa marche aussi, Mais il n'y a pas d'information sur les deux. ,admin J'ai donné l'autorisation à l'Administrateur. (administrator) S'il vous plaît, répondez à toutes les questions. !

img

img




Adopter les réponses:

Il s'est déconnecté après l'opération.


版权声明:本文为[Questions et réponses du rseoc]所创,转载请带上原文链接,感谢。 https://primo.wiki/2021/12/202112231515398082.html