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服务,使配置生效。