предговор
На някои места се използват опашки за съобщения, за да се гарантира точността на обработката на информация. Например, при ситуации с висока паралелност, уебсайтовете извършват обработка на данни. Днес тази статия записва просто демо на RabbitMQ. Преди да вляза в тази статия, RbMQ средата трябва да бъде инсталирана предварително (тъй като инсталирах локалната RbMQ среда и се страхувам, че деинсталирането може да създаде проблеми, че регистърът не е чист, затова няма да записвам инсталацията тук).
Среда и инструменти
>Система Windows 10
>Екологични услуги на RabbitMQ
>VS 2017
Текст
1: Създаване на две нови конзолни приложения, а именно "RabbitMQClient" и "RabbitMQServer".
2: Вижте dll "RabbitMQ.Client"
3: В проекта RabbitMQClient, Program.cs, поставете следния код
4: В проекта RabbitMQServer, Program.cs, поставете следния код
5: F5 за стартиране на проекта RabbitMQServer, в конзолата, въведете информацията, натиснете Enter.
6: Не затваряйте конзолата на проекта RabbitMQServer, кликнете с десен бутон върху проекта RabbitMQClient - > "Debug" - > "Стартирайте нов инстанс"
Можете да въведете информация в конзолата RabbitMQServer вдясно, за да я покажете отляво. Проектът RabbitMQServer създава съобщения. Проектът RabbitMQClient обработва (консумира) съобщения. Това са производителят и потребителят в опашката за съобщения. Кодът включва също маршрутизиране и канали.
От страна на създателя на съобщението пуснете информацията, която трябва да се обработи, в опашката за съобщения. След като получи съобщението, потребителят може да обработи тези данни съответно.
Ако средата е инсталирана, локалният стандартен порт адрес трябва да е http://localhost:15672/#/queues. Можеш директно да достъпиш гост акаунта или да конфигурираш акаунта и съответните права, като докоснеш командния ред.
Информацията, която току-що сте въвели в конзолата на RabbitMQServer, всъщност първо съществува в опашката за съобщения, можете първо да затворите прозореца на RabbitMQClient, след това да въведете няколко части информация в прозореца, да наблюдавате опашката за съобщения и да видите, че в нея има три части данни.
Когато нашият RabbitMQClient прозорец започне, съобщението автоматично изчезва от опашката за съобщения след като го получи нормално. Това е механизмът за потвърждение на опашката за съобщения – след като необходимата информация бъде точно получена, потребителят ще върне състояние в опашката за съобщения, за да унищожи съобщението. Ако потребителят не получи съобщението или ако има изключение и не върне тази стойност на статуса, съобщението остава в опашката докато не бъде консумирано нормално, което гарантира точността на съобщението.
Епилог
За съжаление има много малко места, където използвам опашки за съобщения в проектите си. Без задълбочено разбиране ще се използват само основите.
В горното демо има пропуск, а връзката на RbMQ в RabbitMQClient има слой на използване. Тъй като е асинхронна нишка, това ще накара програмата да се стартира и рециклира RbMQ връзката преди да приключи с получаването на съобщението, и ще бъде докладвана грешка. Начинът да се справиш с това е: премахни го с употреба и го освободи ръчно.
|
Публикувано в 30.05.2019 г. 22:58:30 ч.
|
|
|
|
Публикувано в 31.05.2019 г. 9:12:21 ч.
|
