|
|
Опубликовано 30.05.2019 22:58:30
|
|
|
|
предисловие
В некоторых местах для обеспечения точности обработки информации используются очереди сообщений. Например, в условиях высокой параллелности веб-сайты выполняют обработку данных. Сегодня в этой статье представлена простая демо-версия 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 — > «Отладка» — > «Запустить новую экземпляр».
Вы можете ввести информацию в консоль RabbitMQServer справа, чтобы отобразить её слева. Проект RabbitMQServer создаёт сообщения. Проект RabbitMQClient обрабатывает (потребляет) сообщения. Это производитель и потребитель в очереди сообщений. Код также включает маршрутизацию и каналы.
На стороне производителя сообщения поместите информацию для обработки в очередь сообщений. После получения сообщения потребитель может обработать эти данные соответствующим образом.
Если среда установлена, локальный стандартный адрес порта должен быть http://localhost:15672/#/queues. Вы можете напрямую получить доступ к гостевой аккаунту или настроить учетную запись и соответствующие права, нажав на командную строку.
Информация, которую вы только что ввели в консоль RabbitMQServer, на самом деле сначала находится в очереди сообщений, вы можете сначала закрыть окно RabbitMQClient, затем ввести несколько данных в окно, понаблюдать за очередью сообщений и увидеть, что в очереди есть три элемента данных.
Когда запускается окно RabbitMQClient, сообщение автоматически исчезает из очереди сообщений после его нормального получения. Это механизм подтверждения очереди сообщений: после того как нужная информация будет получена точно, пользователь возвращает состояние в очередь сообщений, чтобы уничтожить сообщение. Если пользователь не получает сообщение или если есть исключение и не возвращает это значение, сообщение останется в очереди до нормального использования, что гарантирует точность сообщения.
Эпилог
К сожалению, очень мало мест, где я использую очереди сообщений в своих проектах. Без глубокого понимания используются только основы.
В приведённой выше демонстрации есть пробел, и связь RbMQ в RabbitMQClient имеет слой использования. Поскольку это асинхронный поток, это заставит программу запустить и повторить соединение RbMQ до завершения получения сообщения, и будет сообщена ошибка. Как с этим справиться: снимайте с помощью и выпускайте вручную.
|
Предыдущий:«Нпм ЭЭЭ! Ошибка: EPERM: эксплуатация не разрешена»Следующий:Введение в девять традиционных программ для зрения
|
Опубликовано 31.05.2019 9:12:21
|
