zookeeper和ActiveMQ进程都在,但是MQ无法使用,也不能访问MQ的管理页面,其实还是没真正的启动。

搜了一圈,还是认为是有脏数据,但是并不像是在启动或停止服务的时候有发mq消息导致的。因为今天我就没运行代码他怎么发??!!!

最后还是得删除leveldb文件夹才行。将全部节点的 ./apache-activemq/data/leveldb文件夹删了就能启动了。(主要是我已经不需要已消费的消息了)

铁憨憨设计!!!

截取报错信息:

2020-07-10 10:06:56,232 | WARN  | unprocessed event state: AuthFailed | org.apache.activemq.leveldb.replicated.groups.ZKClient | main-EventThread
2020-07-10 10:06:56,293 | INFO  | Session establishment complete on server 192.168.7.75/192.168.7.75:1961, sessionid = 0x1002454300e0000, negotiated timeout = 4000 | org.apache.zookeeper.ClientCnxn | main-SendThread(192.168.7.75:1961)
2020-07-10 10:06:56,497 | INFO  | Not enough cluster members connected to elect a master. | org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
2020-07-10 10:06:56,501 | INFO  | Not enough cluster members have reported their update positions yet. | org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
2020-07-10 10:06:56,546 | INFO  | Promoted to master | org.apache.activemq.leveldb.replicated.MasterElector | main-EventThread
2020-07-10 10:06:56,617 | INFO  | Using the pure java LevelDB implementation. | org.apache.activemq.leveldb.LevelDBClient | ActiveMQ BrokerService[wfms_broker] Task-1
2020-07-10 10:06:56,744 | INFO  | No IOExceptionHandler registered, ignoring IO exception | org.apache.activemq.broker.BrokerService | LevelDB IOException handler.
java.io.IOException: com/google/common/util/concurrent/internal/InternalFutureFailureAccess
at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:40)[activemq-client-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.LevelDBClient.replay_init(LevelDBClient.scala:667)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.LevelDBClient.start(LevelDBClient.scala:558)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.DBManager.start(DBManager.scala:648)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.LevelDBStore.doStart(LevelDBStore.scala:312)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.replicated.MasterLevelDBStore.doStart(MasterLevelDBStore.scala:110)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)[activemq-client-5.15.10.jar:5.15.10]
at org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1.apply$mcV$sp(ElectingLevelDBStore.scala:230)[activemq-leveldb-store-5.15.10.jar:5.15.10]
at org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)[hawtdispatch-scala-2.11-1.22.jar:1.22]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_181]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_181]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_181]
2020-07-10 10:06:56,751 | INFO  | Stopped LevelDB[/soft/apache-activemq0/data/leveldb] | org.apache.activemq.leveldb.LevelDBStore | LevelDB IOException handler.

zookeeper和ActiveMQ进程都在,但是MQ无法使用,也不能访问MQ的管理页面,其实还是没真正的启动。搜了一圈,还是认为是有脏数据,但是并不像是在启动或停止服务的时候有发mq消息导致的。因为今天我就没运行代码他怎么发??!!!最后还是得删除leveldb文件夹才行。将全部节点的./apache-activemq/data/leveldb文件夹删了就能启动了。铁憨憨设计!!!截取报错信息:2020-07-10 10:06:56,232 | WARN | unprocesse...
基于 ZooKeeper 和Lev el DB搭建 ActiveMQ 集群 ,参考文章https://www.cnblogs.com/cac2020/p/9428255.html介绍来配置相关配置。 刚开始还是很顺利的,消息正常消费,控制台可以打开。 为了模拟 集群 高可用,统一kill掉了其中的 master 节点。 再次 启动 该节点发现异常:No IOExceptionHandler register ed , ignoring IO exception | org.apache. activemq .broker.BrokerSer
第一步:服务器配置 三台Ubuntu server准备好之后,假设它们的IP地址分别为192.168.0.11,192.168.0.12和192.168.0.13 安装 Zookeeper 需要先装JDK。 第二步: Zookeeper 安装参考:http://sxlkk.iteye.com/blog/2308556. 下面搭建 activemq 集群 ... 这只是把这个无法识别的域名映射到本地了,有点掩耳盗铃。我是真的需要访问这个www.xxx.com提供的接口,所以不能用改host解决。 搜到的别的奇形怪状的解释我就不提了,我这里出现的问题是: 这个www.xxx.com的接口提供者要求使用https访问,并且给了我两个证书:Interm ed iate.crt和Roo... 1.如果key是null r ed is.clients.j ed is.exceptions.J ed isDataException: value sent to r ed is cannot be null 2.如果value是null r ed is.clients.j ed is.exceptions.J ed isDataException: value sen... 如果要使用相对路径,前边一定不要有"/"; 比如:我设置我的SFTP根目录是【/home/TestFTPfolder】,他下边有一个【file】目录,我想知道这个【file】文件里有哪些文件, 所以调用chann el ...
为了实现 zookeeper +clickhouse 集群 读写分离,需要进行以下步骤: 1.安装 zookeeper 并配置 zookeeper 集群 ,将 zookeeper 的地址和端口号添加到clickhouse的配置文件中。 2.安装clickhouse并配置clickhouse 集群 ,将clickhouse的地址和端口号添加到clickhouse的配置文件中。 3.在clickhouse的配置文件中,将 zookeeper 的地址和端口号添加到以下两个参数中: ```xml < zookeeper > <node index="1"> <host>192.168.0.11</host> <port>2181</port> </node> </ zookeeper > 4.在clickhouse的配置文件中,将以下参数设置为1: ```xml <remote_servers> < cluster > <shard> <internal_replication>true</internal_replication> </shard> </ cluster > </remote_servers> 5.在clickhouse的配置文件中,将以下参数设置为0: ```xml <remote_servers> < cluster > <shard> <replica> <readonly>0</readonly> </replica> </shard> </ cluster > </remote_servers> 6.重启clickhouse服务,使配置生效。