ファイル %ACTIVEMQ_BASE%/conf/activemq.xml を修正してください。ユーザー名とパスワードはファイル %ACTIVEMQ_BASE%/conf/credentials.properties に保存されます。
詳細activemq.xml以下の通りです。
<!-- Apache Software Foundation(ASF)に1つ以上のライセンスでライセンスされています 貢献者ライセンス契約。 以下で配布されたNOTICEファイルをご覧ください 本記事は著作権所有に関する追加情報として利用しています。 ASFはこのファイルをApache License, バージョン2.0の下であなたにライセンス供与します (「ライセンス」); このファイルは以下の基準を満たす場合以外は使用できません。 ライセンス。 ライセンスのコピーは以下で入手可能です。
http://www.apache.org/licenses/LICENSE-2.0
適用される法律で義務付けられているか、書面で合意されていない限り、ソフトウェア ライセンスの下で配布されるものは「現状通り」の方法で配布されます。 いかなる保証や条件も、明示的・黙示的ではありません。 権限を規定する具体的な文言については、ライセンスをご覧ください。 ライセンス上の制限事項。 --> <!-- START SNIPPET:例 --> <豆 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">
<!-- この設定ファイルでシステムプロパティを変数として使うことを可能にします --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <プロパティ名="locations"> <value>File:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- Hawtioコンソールでのログ検索を可能にします --> <bean id="logQuery" class="org.fusesource.insight.log.log4j.Log4jLogQuery" lazy-init="false" scope="singleton" init-method="start" destroy-method="stop"> </bean>
<!-- この<broker>要素はActiveMQブローカーの設定に使用されます。 --> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true">
<destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- 履歴書 – > <policyEntry queue="PER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- エンタープライズ - > <policyEntry queue="COM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- 就職フェア – > <policyEntry queue="RECR.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- マイクロリクルートメント ―― > <policyEntry queue="MCOM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- マイクロジョブ検索 - > <policyEntry queue="MPER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- バックエンド - > <policyEntry queue="ERP.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategyは、防止のために使われます 消費者の動きを遅らせて生産者をブロックし、他の消費者に影響を与える 保持されるメッセージの数を制限することで 詳細は以下の通りをご覧ください:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- 流通戦略 - > <dispatchPolicy> <!-- 順次配布 - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 回復戦略 - > <subscriptionRecoveryPolicy> <!-- 最後のメッセージのみを復元する --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Firstはメッセージ参照をメモリに保存し、メモリ使用量が最大になった場合はメッセージ参照を一時ファイルに保存します --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy>
<!-- managementContextは、ActiveMQの公開方法を設定するために使用されます。 JMX。 デフォルトでは、ActiveMQは起動されるMBeanサーバーを使用します。 JVMです。 詳細は以下の通りをご覧ください:
http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="false"/> </managementContext>
<!-- ブローカーのメッセージ永続化を設定してください。 デフォルトの永続性 メカニズムはKahaDBストア(kahaDBタグで識別)です。 詳細は以下の通りをご覧ください:
http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB directory="E:/activemq_data" enableJournalDiskSyncs="false" indexWriteBatchSize="1000" indexCacheSize ="10000" journalMaxFileLength="32mb"
/> </persistenceAdapter>
<plugins> <!-- 認証の設定;ユーザー名、パスワード、グループ --> <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"/> <authenticationUser username="${com.username}" password="${com.password}" groups="company"/> <authenticationUser username="${mcom.username}" password="${mcom.password}" groups="mcompany"/> <authenticationUser username="${erp.username}" password="${erp.password}" groups="erp"/> <authenticationUser username="${recr.username}" password="${recr.password}" groups="recr"/> </users> </simpleAuthenticationPlugin>
<!-- 宛先ベースの認可メカニズムを構成しましょう --> <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, personal, mpersonal、会社、mcompany、ERP、Recr」 /> </authorizationEntries> </authorizationMap> </map> </authorizationPlugin> </plugins>
<!-- systemUsageはブローカーが使用する最大容量を制御します キャッシュを無効にしたり、プロデューサーの動作を遅くする前に使用してください。 詳細は以下の通りをご覧ください:
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>
<!-- トランスポートコネクタは、特定のプロトコル上でActiveMQを次のように公開します。 顧客やその他のブローカー。 詳細は以下の通りをご覧ください:
http://activemq.apache.org/configuring-transports.html --> <transportConnectors> DOS保護<!--、同時接続数を1000回、フレームサイズを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>
<!--桟橋を止めるためにシャットダウン時にスプリングコンテキストを破壊します> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
</broker>
<!-- ウェブコンソール、REST、Ajax APIおよびデモを有効にしてください ウェブコンソールはデフォルトでログインが必要ですが、jetty.xmlファイルでこれを無効にできます
詳細は${ACTIVEMQ_HOME}/conf/jetty.xmlをご覧ください --> <import resource="jetty.xml"/>
</beans> <!-- エンドスニペット:例 -->
credentials.properties:
## --------------------------------------------------------------------------- ## Apache Software Foundation(ASF)に1つ以上のライセンスでライセンスされています ## 貢献者ライセンス契約。 以下で配布されたNOTICEファイルをご覧ください ## 著作権所有に関する追加情報のための作品です。 ## ASFはこのファイルをApacheライセンスバージョン2.0の下であなたにライセンスします。 ##(「ライセンス」); このファイルは以下の基準を満たす場合以外は使用できません。 ## ライセンス。 ライセンスのコピーは以下で入手可能です。 ## ## http://www.apache.org/licenses/LICENSE-2.0 ## ## 適用法で義務付けられているか、書面で合意されていない限り、ソフトウェア ## ライセンスの下で配布されるものは「現状通り」で配布されています。 ## いかなる保証や条件も、明示的または黙示的ではありません。 ## 許可を規定する具体的な文言についてはライセンスをご覧ください。 ## ライセンスの制限。 ## ---------------------------------------------------------------------------
# ブローカーにアクセスするためにコンポーネント(例えばウェブコンソール)が使用する認証情報を定義します
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=***
上記の構成では、今日のキュー監視に異常があり、最終的に問題はここに現れました:
キュー監視プロジェクト管理者はsystem/manager(webapps\admin\WEB-INF\webconsole-embedded.xml
権限が必要な管理者グループ
|