Módosítsd a %ACTIVEMQ_BASE%/conf/activemq.xml fájlt, a felhasználónév és jelszó a %ACTIVEMQ_BASE%/conf/credentials.properties fájlban tárolódva van,
activemq.xml részletek a következők:
<!-- Az Apache Software Foundation-nek (ASF) egy vagy több licenc alatt Hozzájáruló licencszerződések. Lásd a NOTICE fájlt, amelyet terjesztettek Ez a mű további információért a szerzői jog tulajdonjogáról. Az ASF ezt a fájlt az Apache licenc, 2.0 verzió alapján licenceli Önnek (a "Engedély"); Ezt a fájlt csak akkor használhatod, ha a következőknek megfelel a Licence. Az engedély másolatát a Feleségen szerezheti meg.
http://www.apache.org/licenses/LICENSE-2.0
Hacsak nem írja elő az alkalmazandó törvény vagy írásban egyeztetett, szoftver a licenc alatt terjesztett "AHOGY VAN" ALAPON TERJED, BÁRMILYEN GARANCIA VAGY FELTÉTEL NÉLKÜL, AKÁR KIFEJEZETT, AKÁR BURKOLT MÓDON. Lásd a Licencet a jogosultságokra vonatkozó konkrét nyelvért, és a licenc szerinti korlátozások. --> <!-- START NYIPPET: példa --> <bab xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
<!-- Lehetővé teszi, hogy rendszertulajdonságokat használjunk változóként ebben a konfigurációs fájlban --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="helyszínek"> <value>file:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- Engedélyezi a naplókeresést a hawtio konzolon --> <bean id="logQuery" class="org.fusesource.insight.log.log4j.Log4jLogQuery" lazy-init="hamis" scope="singleton" init-method="start" destroy-method="stop"> </bean>
<!-- Az <broker> elemet az ActiveMQ bróker konfigurálására használják. --> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true">
<destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Önéletrajz – > <policyEntry queue="PER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Enterprise - > <policyEntry queue="COM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Állásvásár – > <policyEntry queue="RECR.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Mikro-toborzás --> <policyEntry queue="MCOM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Mikro álláskeresés - > <policyEntry queue="MPER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Backend - > <policyEntry queue="ERP.>" producerFlowControl="true" memoryLimit="10mb"> <!-- A constantPendingMessageLimitStrategy a megelőzésre szolgál Lassú téma, a fogyasztók blokkolják a termelőket és befolyásolják a többi fogyasztót azáltal, hogy korlátozzák a megőrzött üzenetek számát További információért lásd:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Terjesztési stratégia – > <dispatchPolicy> <!-- Sorrendben osztják el - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Helyreállítási Stratégia – > <subscriptionRecoveryPolicy> <!-- Csak az utolsó üzenetet állítsd vissza --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Először az üzenethivatkozást a memóriába mentik, és ha a memória kihasználtsága maximum, az üzenethivatkozás egy ideiglenes fájlba mentik --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy>
<!-- A managementContext segítségével konfigurálják, hogyan van ki az ActiveMQ JMX. Alapértelmezés szerint az ActiveMQ az MBean szervert használja, amelyet az indított a JVM. További információért lásd:
http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="false"/> </managementContext>
<!-- Konfiguráld az üzenet tartósságát a brókernek. Az alapértelmezett tartósság a mechanizmus a KahaDB tároló (amelyet a KahaDB címkével azonosít). További információért lásd:
http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB directory="E:/activemq_data" enableJournalDiskSyncs="false" indexWriteBatchSize="1000" indexCacheSize="10000" journalMaxFileLength="32mb"
/> </persistenceAdapter>
<plugins> <!-- Hitelesítés konfigurálása; Felhasználónév, jelszavak és csoportok --> <simpleAuthenticationPlugin> <users> <authenticationUser username="${activemq.username}" password="${activemq.password}" groups="admins"/> <hitelesítésFelhasználó felhasználónév="${per.username}" password="${per.password}" csoportok="személyes"/> <authenticationUser username="${mper.username}" password="${mper.password}" groups="mpersonal"/> <hitelesítésFelhasználó username="${com.username}" password="${com.password}" groups="company"/> <authenticationUser username="${mcom.username}" password="${mcom.password}" groups="mcompany"/> <hitelesítés Felhasználó felhasználónév="${erp.username}" password="${erp.password}" csoportok="erp"/> <authenticationUser username="${recr.username}" password="${recr.password}" groups="recr"/> </users> </simpleAuthenticationPlugin>
<!-- Konfiguráljunk egy célalapú hitelesítési mechanizmust --> <authorizationPlugin> <map> <authorizationMap> <authorizationEntries> <authorizationEntry queue=">" read="admins" write="admins" admin="admins" /> <authorizationEntry queue="PER.>" read="personal, mpersonal, company, mcompany, erp, recr" write="personal" admin="personal" /> <authorizationEntry queue="MPER.>" read="personal, mpersonal, company, mcompany, erp, recr" write="mpersonal" admin="mpersonal" /> <authorizationEntry queue="COM.>" read="personal, mpersonal, company, mcompany, erp, recr" write="company" admin="company" /> <authorizationEntry queue="MCOM.>" read="personal, mpersonal, company, mcompany, erp, recr" write="mcompany" admin="mcompany" /> <authorizationEntry queue="ERP.>" read="personal, mpersonal, company, mcompany, erp, recr" write="erp" admin="erp" /> <authorizationEntry queue="RECR.>" read="personal, mpersonal, company, mcompany, erp, recr" write="recr" admin="recr" />
<authorizationEntry topic="ActiveMQ.Advisory.>" read="personal, mpersonal, company, mcompany, erp, recr" write="personal, mpersonal, company, mcompany, erp, recr" admin="personal, mpersonal, company, mcompany, erp, recr" /> </authorizationEntries> </authorizationMap> </map> </authorizationPlugin> </plugins>
<!-- A systemUsage szabályozza, mennyi helyet ad a brókernek Használd a gyorsítótár letiltása vagy a producerek lelassítása előtt. További információért lásd:
http://activemq.apache.org/producer-flow-control.html --> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage percentOfJvmHeap="100" /> </memoryUsage> <storeUsage> <storeUsage limit="1 gb"/> </storeUsage> <tempUsage> <tempUsage limit="100 mb"/> </tempUsage> </systemUsage> </systemUsage>
<!-- A transzportcsatlakozók egy adott protokollon keresztül az ActiveMQ-t teszik ki ügyfelek és más brókerek. További információért lásd:
http://activemq.apache.org/configuring-transports.html --> <transportConnectors> <!-- DOS védelem, korlátozd az egyidejű kapcsolatokat 1000-re, a képkockaméretet pedig 100MB-ra --> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors>
<!-- elpusztítani a tavaszi kontextust a leállásnál, hogy megállítsák a mólót --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
</broker>
<!-- Engedélyezze a webkonzolokat, REST és Ajax API-kat és demókat A webkonzolok alapértelmezetten bejelentkezést igényelnek, ezt letilthatod a jetty.xml fájlban
További részletekért nézze meg a ${ACTIVEMQ_HOME}/conf/jetty.xml oldalt --> <import resource="jetty.xml"/>
</beans> <!-- VÉGE SNIPPET: példa -->
credentials.properties:
## --------------------------------------------------------------------------- ## Az Apache Software Foundation (ASF) által egy vagy több néven licencelve ## Közreműködői licencszerződések. Lásd a NOTICE fájlt, amelyet terjesztettek ## további információért a szerzői joggal kapcsolatban. ## Az ASF ezt a fájlt az Apache licenc 2.0 verzió alapján adja neked ## (a "Licenc"); Ezt a fájlt csak akkor használhatod, ha a következőknek megfelel ## A Licenc. Az engedély másolatát a Feleségen szerezheti meg. ## ## http://www.apache.org/licenses/LICENSE-2.0 ## ## Hacsak nem írja elő az alkalmazandó törvény vagy írásban egyeztetett, szoftver a ## a licenc alatt terjesztett "AHOGY VAN" ALAPON TERJED, ## BÁRMILYEN GARANCIA VAGY FELTÉTEL NÉLKÜL, AKÁR KIFEJEZETT, AKÁR BURKOLTATOTT. ## Lásd a Licencet a jogosultságokra vonatkozó konkrét nyelvért, és ## korlátozások az engedély alapján. ## ---------------------------------------------------------------------------
# Megadja azokat a hitelesítő adatokat, amelyeket az összetevők (például webkonzol) használnak a bróker eléréséhez
activemq.username=*** activemq.password=***
per.username=*** per.password=***
mper.username=*** mper.password=***
com.username=*** com.password=***
mcom.username=*** mcom.password=***
erp.username=*** erp.password=***
recr.username=*** recr.password=***
A fenti konfiguráció ma rendellenességet talált a sorfigyelésben, és végül itt jelent meg:
Mivel a sorfigyelő projekt adminisztrátora a rendszer/menedzser (webapps\admin\WEB-INF\webconsole-embedded.xml
admins csoport, amelyhez engedélyek szükségesek
|