Ubah file %ACTIVEMQ_BASE%/conf/activemq.xml, nama pengguna dan kata sandi disimpan dalam file %ACTIVEMQ_BASE%/conf/credentials.properties,
activemq.xml rincian adalah sebagai berikut:
<!-- Dilisensikan ke Apache Software Foundation (ASF) di bawah satu atau beberapa perjanjian lisensi kontributor. Lihat file NOTICE yang didistribusikan dengan ini bekerja untuk informasi tambahan mengenai kepemilikan hak cipta. ASF melisensikan file ini kepada Anda di bawah Lisensi Apache, Versi 2.0 ("Lisensi"); Anda tidak boleh menggunakan file ini kecuali sesuai dengan Lisensi. Anda dapat memperoleh salinan Lisensi di
http://www.apache.org/licenses/LICENSE-2.0
Kecuali diwajibkan oleh hukum yang berlaku atau disetujui secara tertulis, perangkat lunak didistribusikan berdasarkan Lisensi didistribusikan atas dasar "SEBAGAIMANA ADANYA", TANPA JAMINAN ATAU KETENTUAN DALAM BENTUK APA PUN, baik tersurat maupun tersirat. Lihat Lisensi untuk bahasa tertentu yang mengatur izin dan batasan berdasarkan Lisensi. --> <!-- MULAI SNIPPET: contoh --> <kacang 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">
<!-- Memungkinkan kita untuk menggunakan properti sistem sebagai variabel dalam file konfigurasi ini --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <value>berkas:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- Memungkinkan pencarian log di konsol hawtio --> <bean id="logQuery" class="org.fusesource.insight.log.log4j.Log4jLogQuery" lazy-init="false" scope="singleton" init-method="mulai" destroy-method="berhenti"> </bean>
<!-- <broker> Elemen ini digunakan untuk mengonfigurasi 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 digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Lanjutkan – > <policyEntry queue="PER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Enterprise - > <policyEntry queue="COM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Job fair – > <policyEntry queue="RECR.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Rekrutmen mikro --> <policyEntry queue="MCOM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Pencarian kerja mikro - > <policyEntry queue="MPER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Backend - > <policyEntry queue="ERP.>" producerFlowControl="true" memoryLimit="10mb"> <!-- constantPendingMessageLimitStrategy digunakan untuk mencegah Konsumen topik lambat untuk memblokir produsen dan mempengaruhi konsumen lain dengan membatasi jumlah pesan yang disimpan Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Strategi distribusi - > <dispatchPolicy> <!-- Mendistribusikan secara berurutan - > <strictOrderDispatchPolicy/> </dispatchPolicy> Strategi Pemulihan <!-- - > <subscriptionRecoveryPolicy> <!-- Pulihkan hanya pesan terakhir --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Pertama-tama menyimpan referensi pesan di memori, dan jika penggunaan memori dimaksimalkan, referensi pesan disimpan dalam file sementara --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy>
<!-- managementContext digunakan untuk mengonfigurasi bagaimana ActiveMQ diekspos di JMX. Secara default, ActiveMQ menggunakan server MBean yang dimulai oleh JVM. Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="false"/> </managementContext>
<!-- Konfigurasikan persistensi pesan untuk broker. Persistensi default mekanisme adalah penyimpanan KahaDB (diidentifikasi oleh tag kahaDB). Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB directory="E:/activemq_data" enableJournalDiskSyncs="false" indexWriteBatchSize="1000" indexCacheSize="10000" journalMaxFileLength="32mb"
/> </persistenceAdapter>
<plugins> <!-- Mengonfigurasi autentikasi; Nama pengguna, kata sandi, dan grup --> <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>
<!-- Mari konfigurasikan mekanisme otorisasi berbasis tujuan --> <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, perusahaan, mcompany, erp, recr" /> </authorizationEntries> </authorizationMap> </map> </authorizationPlugin> </plugins>
<!-- systemUsage mengontrol jumlah ruang maksimum yang akan dilakukan broker Gunakan sebelum menonaktifkan caching dan/atau memperlambat produsen. Untuk informasi selengkapnya, lihat:
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>
<!-- Konektor transportasi mengekspos ActiveMQ melalui protokol tertentu ke klien dan broker lainnya. Untuk informasi selengkapnya, lihat:
http://activemq.apache.org/configuring-transports.html --> <transportConnectors> <!-- perlindungan DOS, batasi koneksi bersamaan hingga 1000 dan ukuran bingkai hingga 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>
<!-- menghancurkan konteks musim semi saat shutdown untuk menghentikan dermaga --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
</broker>
<!-- Aktifkan konsol web, API dan demo REST dan Ajax Konsol web memerlukan login secara default, Anda dapat menonaktifkannya di file jetty.xml
Lihat ${ACTIVEMQ_HOME}/conf/jetty.xml untuk lebih jelasnya --> <impor sumber daya="jetty.xml"/>
</beans> <!-- SNIPPET AKHIR: contoh -->
credentials.properties:
## --------------------------------------------------------------------------- ## Berlisensi ke Apache Software Foundation (ASF) di bawah satu atau lebih ## perjanjian lisensi kontributor. Lihat file NOTICE yang didistribusikan dengan ## karya ini untuk informasi tambahan mengenai kepemilikan hak cipta. ## ASF melisensikan file ini kepada Anda di bawah Lisensi Apache, Versi 2.0 ## ("Lisensi"); Anda tidak boleh menggunakan file ini kecuali sesuai dengan ## Lisensi. Anda dapat memperoleh salinan Lisensi di ## ## http://www.apache.org/licenses/LICENSE-2.0 ## ## Kecuali diwajibkan oleh hukum yang berlaku atau disetujui secara tertulis, perangkat lunak ## yang didistribusikan di bawah Lisensi didistribusikan atas dasar "SEBAGAIMANA ADANYA", ## TANPA JAMINAN ATAU KETENTUAN APA PUN, baik tersurat maupun tersirat. ## Lihat Lisensi untuk bahasa tertentu yang mengatur izin dan ## batasan di bawah Lisensi. ## ---------------------------------------------------------------------------
# Menentukan kredensial yang akan digunakan oleh komponen (seperti konsol web) untuk mengakses broker
activemq.username=*** activemq.password=***
per.username=*** per.kata sandi=***
mper.username=*** mper.password=***
com.nama pengguna =*** com.kata sandi=***
mcom.nama pengguna =*** mcom.kata sandi=***
erp.nama pengguna =*** erp.kata sandi=***
recr.username=*** recr.password=***
Konfigurasi di atas menemukan bahwa ada kelainan dalam pemantauan antrean hari ini, dan akhirnya menemukan bahwa masalahnya muncul di sini:
Karena akun yang digunakan dalam pemantauan antrean, admin proyek adalah system/manager(webapps\admin\WEB-INF\webconsole-embedded.xml
admins, yang memerlukan izin
|