1. Introductie tot ActiveMQ: Analyseer eerst zo'n scenario: wanneer we op de website winkelen, moeten we een bestelling plaatsen, een factuur aanmaken, betaling verwerken, een bestelling uitvoeren, verzenden, enzovoort. Wanneer een gebruiker echter een bestelling plaatst, wordt hij direct doorgestuurd naar de pagina "Bedankt voor uw bestelling". Niet alleen dat, maar als er geen vertraging is, ontvangt de gebruiker ook een e-mail. Als we de traditionele manier gebruiken om te implementeren, is het meestal het bedienen van de database en vervolgens verschillende interfaces en diensten aanroepen om op verschillende antwoorden te wachten, zodat het lang duurt om het resultaat van de volgende bestelling te zien; als er een probleem is in een bepaalde link, zal het orderresultaat een tijdlang niet zichtbaar zijn, voor moderne e-commerce is dit onaanvaardbaar. Dan kan ActiveMQ dit probleem heel goed oplossen: wanneer de gebruiker een bestelling plaatst, wordt ActiveMQ aangeroepen om de bestelling te verzenden, waarna het systeem terugkan naar de resultaatpagina, en wordt het hele bestelproces niet synchroon aangeroepen, en kan de achtergrond-JOB worden gechat en draaien. Als het volume van bestellingen in de receptie groot is, hoeft elke bestelling maar één keer te worden opgeroepen, en het achtergrondkantoor kan het niet allemaal tegelijk afhandelen? Neem je tijd, niemand dwingt je, orders staan in de rij in ActiveMQ, ze zullen niet geïrriteerd zijn. Dit scenario is ideaal voor een soort cachewachtrij, een berichtwachtrij genoemd, die veel producten kunnen implementeren, en overigens beantwoordt het de volgende mogelijke vraag: het is veel sneller dan een database.
Dit artikel begint bij de basis en leert samen de systeembesturingsomgeving van dit artikel: Window7 32-bit
2. Download het officiële ActiveMQ-website-downloadadres: http://activemq.apache.org/
3.运行ActiveMQ解压缩apache-activemq-5.10.0-bin.zip，然后双击apache-activemq-5.10.0inwin32activemq.bat运行ActiveMQ程序。
Zie de laatste regel van de console-uitvoer: "toegang tot alle MBeans is toegestaan" om te bewijzen dat de opstart succesvol was.
Na het starten van ActiveMQ kun je inloggen via de browser om in te loggen: http://localhost:8161/admin/ authenticatie is de standaardgebruikersnaam admin en het wachtwoord admin
(Het uitgangspunt is dat de Java-omgeving geïnstalleerd is)
Download de .NET-versie van de Dll:Apache.NMS-1.6.0-bin.zip en Apache.NMS.ActiveMQ-1.6.4-bin.zip tegelijkertijd
Download alles hier: http://archive.apache.org/dist/activemq/apache-nms/1.6.0/
3. Het eerste ActiveMQ-voorbeeld gebruikt C# om een informatiebron te schrijven, oftewel de producent:
De interface is heel eenvoudig: een Lable, een TextBox, een Button, voeg dan Apache.NMS.dll en Apache.NMS.ActiveMQ.dll referenties toe, vind ze in de andere twee downloadpakketten hierboven, let op het versienummer.
Je kunt op de knop klikken om berichten te verzenden, en deze berichten worden tijdelijk opgeslagen in ActiveMQ, en je kunt inloggen op de webpagina waar je net om een wachtwoord vroeg om het te bekijken.
Schrijf dan de ontvanger, dat wil zeggen de consument:
Voeg ook verwijzingen toe naar die 2 DLL's, de interface is heel eenvoudig met slechts één Lable:
Zodra je het opstart, zul je merken dat deze berichten hier zijn ontvangen en de serverzijde berichten zijn verwijderd.
4. Samenvatting Het bovenstaande implementeert een P2P-berichtwachtrij, die tijdelijk wordt opgeslagen en op verwerking wordt gewacht, en het bericht verdwijnt na verwerking, zodat aflevering, niet verloren en niet wordt gedropt. Deze modus kan slechts in beperkte gevallen worden gebruikt, en de klant kan er maar één hebben, die behoort tot de vorm van expresslevering, en niet aan de orderverwerkingsvereisten kan voldoen, de reden is heel eenvoudig: de zwarte lijst inspectielink verkrijgt deze orderinformatie, en de beoordelingslink kan niet worden verkregen, en in het volgende deel leren we "berichtgroep verzenden" samen, dat wil zeggen, roep, de bestelling komt eraan, iedereen begint druk te worden...
Opmerking: Het artikel wordt herdrukt, evenals het bericht van het artikel. Properties.SetString("filter","demo"); Dit hoeft niet ingesteld te worden!!
|
Geplaatst op 09-01-2017 14:41:52
|
|
|
|
