ActiveMQ共享存储部署时，关于slave关于锁的问题？

0 0

ActiveMQ共享存储部署时，关于slave关于锁的问题？0

现在用NFS作为共享存储， ActiveMQ的Master/Slave部署方式如下：

先启动Broker1，它先在NFS上创建了锁，也自然地它成Master。这时，再启动Broker2，看到Broker2有这样的日志：

2012-08-27 11:04:05,663 | INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[/usr/local/wxcTest/mnt/amqDir] | org.apache.activemq.broker.BrokerService | main
2012-08-27 11:04:05,701 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:04:15,703 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:04:25,706 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:04:35,709 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:04:45,712 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:04:55,714 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:05,717 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:15,719 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:25,722 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:35,725 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:45,727 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main
2012-08-27 11:05:55,730 | INFO | Database /usr/local/wxcTest/mnt/amqDir/lock is locked... waiting 10 seconds for the database to be unlocked. Reason: java.io.IOException: File '/usr/local/wxcTest/mnt/amqDir/lock' could not be locked. | org.apache.activemq.store.kahadb.MessageDatabase | main

..........................

这个日志正常不？从原理上说好像是正常的。

不过，让slave这样一直跑着去看是否能得到锁，总归不是一个好事，太浪费broker2机器的资源了吧？

再进一步说，共享存储模式下，slave等待锁的机制是怎样的？