Spremenite datoteko %ACTIVEMQ_BASE%/conf/activemq.xml, uporabniško ime in geslo sta shranjena v datoteki %ACTIVEMQ_BASE%/conf/credentials.properties,
activemq.xml podrobnosti so naslednje:
<!-- Licencirano pri Apache Software Foundation (ASF) pod enim ali več Licenčne pogodbe za sodelavce. Oglejte si datoteko NOTICE, razdeljeno z To delo za dodatne informacije o lastništvu avtorskih pravic. ASF vam to datoteko licencira pod licenco Apache, različica 2.0 ("Licenca"); Te datoteke ne smete uporabljati, razen v skladu z Licenco. Kopijo licence lahko pridobite na
http://www.apache.org/licenses/LICENSE-2.0
Razen če to zahteva veljavna zakonodaja ali je to pisno dogovorjeno, programska oprema distribuirano pod licenco, se distribuira na osnovi "TAK, KOT JE", BREZ ZAGOTOVIL ALI POGOJEV KAKRŠNIHKOLI OBLIK, bodisi izrečenih ali implicitnih. Oglejte si licenco za specifičen jezik, ki ureja dovoljenja, in omejitve po Licenci. --> <!-- START SNIPPET: primer --> <fižol 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">
<!-- Omogoča uporabo sistemskih lastnosti kot spremenljivk v tej konfiguracijski datoteki --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <ime lastnosti="lokacije"> <value>file:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- Omogoča iskanje dnevnikov v hawtio konzoli --> <bean id="logQuery" class="org.fusesource.insight.log.log4j.Log4jLogQuery" lazy-init="false" scope="singleton" init-method="začetek" uniči-metoda="ustavi"> </bean>
<!-- Ta <broker> element se uporablja za konfiguracijo ActiveMQ posrednika. --> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true">
<destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Življenjepis – > <policyEntry queue="PER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Enterprise - > <policyEntry queue="COM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Zaposlitveni sejem – > <policyEntry queue="RECR.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Mikro-novačenje --> <policyEntry queue="MCOM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Iskanje mikro zaposlitve - > <policyEntry queue="MPER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Backend - > <policyEntry queue="ERP.>" producerFlowControl="true" memoryLimit="10mb"> <!-- Za preprečevanje se uporablja strategija constantPendingMessageLimitStrategy počasni potrošniki s tem, da blokirajo proizvajalce in vplivajo na druge potrošnike z omejitvijo števila sporočil, ki se hranijo Za več informacij glejte:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategija distribucije - > <dispatchPolicy> <!-- Distribuirajte zaporedno - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Strategija okrevanja - > <subscriptionRecoveryPolicy> <!-- Obnovi le zadnje sporočilo --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Najprej shrani referenco sporočila v pomnilnik, in če je poraba pomnilnika maksimalna, se referenca sporočila shrani v začasno datoteko --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategyLimit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy>
<!-- ManagementContext se uporablja za konfiguracijo, kako je ActiveMQ izpostavljen v JMX. Privzeto ActiveMQ uporablja MBean strežnik, ki ga zažene JVM. Za več informacij glejte:
http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="false"/> </managementContext>
<!-- Nastavite trajnost sporočil za posrednika. Privzeta vztrajnost mehanizem je KahaDB shramba (označena z oznako kahaDB). Za več informacij glejte:
http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB imenik="E:/activemq_data" enableJournalDiskSyncs="false" indexWriteBatchSize="1000" indexCacheSize="10000" journalMaxFileLength="32mb"
/> </persistenceAdapter>
<plugins> <!-- Nastavitev avtentikacije; Uporabniško ime, gesla in skupine --> <simpleAuthenticationPlugin> <users> <authenticationUser username="${activemq.username}" password="${activemq.password}" groups="admins"/> <authenticationUser username="${per.username}" password="${per.password}" groups="personal"/> <authenticationUser username="${mper.username}" password="${mper.password}" groups="mpersonal"/> <avtentikacijaUporabniško uporabniško ime="${com.username}" geslo="${com.password}" skupine="podjetje"/> <avtentikacijaUporabniško uporabniško ime="${mcom.username}" geslo="${mcom.password}" skupine="mcompany"/> <authenticationUser username="${erp.username}" password="${erp.password}" groups="erp"/> <authenticationUser username="${recr.username}" password="${recr.password}" groups="recr"/> </users> </simpleAuthenticationPlugin>
<!-- Nastavimo mehanizem avtorizacije na podlagi cilja --> <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="osebno, mpersonalno, podjetje, mcompany, erp, recr" write="osebno, mpersonalno, podjetje, mcompany, erp, recr" admin="osebno, Mpersonal, četa, mCompany, ERP, RECR" /> </authorizationEntries> </authorizationMap> </map> </authorizationPlugin> </plugins>
<!-- SystemUsage nadzoruje največjo količino prostora, ki ga ima posrednik uporabi pred onemogočaštvom predpomnjenja in/ali upočasnjevanjem proizvajalcev. Za več informacij glejte:
http://activemq.apache.org/producer-flow-control.html --> <systemUsage> <systemUsage> <memoryUsage> <pomnilniška porabaPercentOfJvmHeap="100" /> </memoryUsage> <storeUsage> <omejitev uporabe v trgovini="1 gb"/> </storeUsage> <tempUsage> <tempUsage limit="100 mb"/> </tempUsage> </systemUsage> </systemUsage>
<!-- Transportni konektorji izpostavijo ActiveMQ preko določenega protokola stranke in drugi posredniki. Za več informacij glejte:
http://activemq.apache.org/configuring-transports.html --> <transportConnectors> <!-- zaščito DOS-a omejite sočasne povezave na 1000 in velikost okvirja na 100MB --> <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>
<!-- uničiti pomladni kontekst ob izklopu, da ustavite pomol --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
</broker>
<!-- Omogočite spletne konzole, REST in Ajax API-je ter demo posnetke Spletne konzole privzeto zahtevajo prijavo, to lahko onemogočite v jetty.xml datoteki
Za več podrobnosti si oglejte ${ACTIVEMQ_HOME}/conf/jetty.xml --> <import resource="jetty.xml"/>
</beans> <!-- KONČNI SNIPPET: primer -->
Credentials.Properties:
## --------------------------------------------------------------------------- ## Licencirano Apache Software Foundation (ASF) pod enim ali več ## Licenčne pogodbe za sodelavce. Oglejte si datoteko NOTICE, razdeljeno z ## to delo za dodatne informacije o lastništvu avtorskih pravic. ## ASF vam licencira to datoteko pod licenco Apache, različica 2.0 ## ("Licenca"); Te datoteke ne smete uporabljati, razen v skladu z ## Licenca. Kopijo licence lahko pridobite na ## ## http://www.apache.org/licenses/LICENSE-2.0 ## ## Razen če to zahteva veljavna zakonodaja ali je pisno dogovorjeno, programska oprema ## distribuirano pod licenco, se distribuira na osnovi "TAK, KOT JE", ## BREZ GARANCIJ ALI POGOJEV KAKRŠNIHKOLI OBLIK, bodisi izrečenih ali implicitnih. ## Oglejte si licenco za specifičen jezik, ki ureja dovoljenja in ## omejitve po Licenci. ## ---------------------------------------------------------------------------
# Določa poverilnice, ki jih bodo komponente (kot je spletna konzola) uporabljale za dostop do posrednika
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=***
Zgornja konfiguracija je ugotovila, da je danes prišlo do nepravilnosti v spremljanju vrste, in končno ugotovila, da se težava pojavi tukaj:
Ker je račun, ki se uporablja za spremljanje čakalne vrste, administrator projektov system/manager(webapps\admin\WEB-INF\webconsole-embedded.xml
Skupina administratorjev, ki zahteva dovoljenja
|