Я обычно вижу поврежденные очереди в нашем activemq5.4.2, что означает, что очереди искажены, и мне пришлось удалить файлы kahaDB и отослать брокера, чтобы решить эту проблему.все сообщения, хранящиеся в очереди, теряются во время.Как предотвратить это поврежденные очереди без потери данных?
Ниже приведены журналы работы брокера, ОШИБКА |Не удалось сбросить пакетирование |org.apache.activemq.store.kahadb.KahaDBStore |ActiveMQ Broker [AMQBROKER-TEST] Планировщик java.lang.IllegalStateException: PageFile не загружается в org.apache.kahadb.page.PageFile.assertLoaded (PageFile.java:715) в org.apache.kahadb.page.PageFilet.x (PageFile.java:239) в org.apache.activemq.store.kahadb.KahaDBStore $ KahaDBMessageStore.resetBatching (KahaDBStore.java:510) в org.apache.activemq.store.ProxyMessageStore.resetBatching (atxyMessage: atg).apache.activemq.broker.region.cursors.QueueStorePrefetch.resetBatch (QueueStorePrefetch.java:85) в org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch (AbstractStoreCursor.java.25).broker.region.cursors.AbstractStoreCursor.reset (AbstractStoreCursor.java:108) в org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset (StoreQueueCursor.java:157) в org.apache.kerregion.bg.Queue.doBrowse (Queue.java:1026) в org.apache.activemq.broker.region.Queue.expireMessages (Queue.java:783) в org.apache.activemq.broker.region.Queue.access $ 100 (Queue.java:83) в org.apache.activemq.broker.region.Queue $ 2.run (Queue.java:123) в org.apache.activemq.thread.SchedulerTimerTask.run (SchedulerTimerTask.java:33) в java.util.TimerThread.mainLoop (Timer.java:512) в java.util.TimerThread.run (Timer.java:462) INFO |Транспорт не удался: java.net.SocketException: Сломанный канал |org.apache.activemq.broker.TransportConnection.Transport |Async Exception Handler
ПРЕДУПРЕЖДЕНИЕ |Не удалось зарегистрировать MBean: org.apache.activemq: BrokerName = AMQBROKER-TEST, Type = Queue, Destination = _ onEvent & X171249188Y1Z INFO |Транспорт не удался: java.net.SocketException: Сломанный канал INFO |Ошибка транспорта: java.net.SocketException: сброс подключения INFO |Сбой транспорта: java.io.EOFException