activeMq使用总结

最近,优化系统,提出使用activeMq作为消息中间件。

以前也简单使用过activeMQ,但没有深入的学习,这次经过一个多星期的学习和总结,对activeMQ有了更深入的了解!

在这里一些简单的安装,配置,以及一些发布者,消费者的创建就不再赘述!网上有很多资料。

在这里,我记录下,zookeeper和activeMq LevelDB 的集群的配置和使用。

1.zookeeper的配置。

首先复制3个zookeeper,下面是其中一个zookeeper的配置信息,箭头表示需要修改的部分。

zookeeper1 zoo.cfg的配置。因为我在一台服务器上部署,所以都是192.168.0.47。可以根据自己的需求来修改。


zookeeper2


然后在zookeeper下data文件夹下新建文件名为myid的文件,里面存放server.*,中*的内容,比如在zookeeper1的myid中存放1,在zookeeper2的myid中存放2。

以上是zookeeper的配置信息。

2、activeMq的配置。

(1)activemq.xml的配置。

replicas=“3”指的是我在集群中配置3个节点。zkAddress是3个zookeeper的地址,用逗号隔开。hostname:此节点成为master时用于通告slaver的主机名。如果未设置,它将自动确定。bind设置成tcp://0.0.0.0:0就可以,zkPath默认为/activemq/leveldb-stores。

三个activeMq的transportConnector 下openwire,uri分别配置成tcp://0.0.0.0:61616;tcp://0.0.0.0:61617;tcp://0.0.0.0:61618




(2)activeMq中内置jetty配置。

三个activeMq,内置jetty服务端口分别配置成8161,8162,8163。


3、客户端

BROKEURL=“failover:(tcp://192.168.0.47:61616,tcp://192.168.0.47:61617,tcp://192.168.0.47:61618)?maxReconnectAttempts=2&startupMaxReconnectAttempts=2&randomize=true”

上面红色配置不添加的话,程序会不停重连,activeMq服务断开后,程序会一直等待!


这是我第一次写的博客,有什么不对的请大家多多指教,希望能和大家一起学习,进步!