předmluva
Na některých místech se k zajištění přesnosti zpracování informací používají fronty zpráv. Například v situacích s vysokou souběžností webové stránky zpracovávají data. Dnes tento článek zaznamenává jednoduchou ukázku RabbitMQ. Než začnu tento článek, musí být prostředí RbMQ nainstalováno předem (protože jsem dříve instaloval lokální prostředí RbMQ a obávám se, že odinstalace způsobí problémy, protože registr není čistý, takže instalaci prostředí zde nezaznamenám).
Prostředí a nástroje
>Systém Windows 10
>RabbitMQ Environmentální služby
>VS 2017
Text
1: Vytvořit dvě nové konzolové aplikace, konkrétně "RabbitMQClient" a "RabbitMQServer".
2: Odkazujte na "RabbitMQ.Client" dll
3: V projektu RabbitMQClient Program.cs vložte následující kód
4: V projektu RabbitMQServer Program.cs vložte následující kód
5: F5 pro spuštění projektu RabbitMQServer, v konzoli zadejte informace, stiskněte enter.
6: Nezavírejte konzoli projektu RabbitMQServer, klikněte pravým tlačítkem na projekt RabbitMQClient - > "Debug" > "Začít novou instanci"
Informace můžete zadat do konzole RabbitMQServer vpravo, abyste je zobrazili vlevo. Projekt RabbitMQServer produkuje zprávy. Projekt RabbitMQClient zpracovává (spotřebovává) zprávy. To je producent a spotřebitel ve frontě zpráv. Kód také zahrnuje směrování a kanály.
Na straně tvůrce zpráv vložte informace k zpracování do fronty zpráv. Po obdržení zprávy může spotřebitel tato data podle potřeby zpracovat.
Pokud je prostředí nainstalované, lokální výchozí portová adresa by měla být http://localhost:15672/#/queues. K hostovskému účtu se můžete připojit přímo, nebo si můžete účet a příslušná oprávnění nastavit klepnutím na příkazovou řádku.
Informace, které jste právě zadali do konzole RabbitMQServer, ve skutečnosti nejdříve existují ve frontě zpráv, můžete nejprve zavřít okno RabbitMQClient, pak zadat několik informací do okna, sledovat frontu zpráv a uvidíte, že ve frontě jsou tři datová data.
Když se spustí naše okno RabbitMQClient, zpráva automaticky zmizí z fronty zpráv po jejím normálním přijetí. Toto je potvrzovací mechanismus fronty zpráv – jakmile jsou potřebné informace správně přijaty, spotřebitel vrátí stav do fronty zpráv, aby zprávu zničil. Pokud spotřebitel zprávu neobdrží, nebo pokud existuje výjimka a tuto hodnotu stavu nevrátí, zpráva zůstane ve frontě, dokud není zpráva normálně spotřebována, což zajišťuje její přesnost.
Epilog
Bohužel je jen velmi málo míst, kde ve svých projektech používám fronty zpráv. Bez hlubokého porozumění budou použity jen základy.
V předchozím demu je díra a propojení RbMQ v RabbitMQClient má vrstvu používání. Protože jde o asynchronní vlákno, program spustí a recykluje RbMQ Connection dříve, než dokončí přijetí zprávy, a bude nahlášena chyba. Jak to řešit, je: vyjmout a uvolnit ručně.
|
Zveřejněno 30.05.2019 22:58:30
|
|
|
|
Zveřejněno 31.05.2019 9:12:21
|
