activeMQ使用
一、安装
1 linux上安装activeMq
wget http://124.202.164.7/files/507400000B64DC5C/mirror.bit.edu.cn/apache//activemq/5.15.3/apache-activemq-5.15.3-bin.tar.gz
2 解压 tar-zxvf +压缩包名字
3 cd到bin目录下 ./activemq start 启动
4 访问activeMQ web应用 查看 ip+8161 如果能连接上说明安装成功
点击manage activemq broker 登陆 默认登录名和密码是admin
登陆成功后点击queue 即可查看连接名字以及生产的消息消费情况
注:8161是activemq的web应用的端口,用来查看和管理activeqm的信息
61616是activemq的默认端口,连接的时候连接的是61616
二、使用
1 activeMq 的队列模式:生产者生产的消息,会被多个消费者平均消费
在github中:com.jxt.jms.queue 包下面的例子即为队列模式,启动两个消费者或者多个消费者 AppConsumer,再启动一个生产者,会产生100个消息,看控制台即可看到被消费者平均消费;
2 activeMq的主题模式:先运行两个或多个消费者,在启动一个生产者,消费者都会收到生产者产生的消息。
注:如果在订阅之前产生的消息,是不能被消费者消费的。
github地址:
https://github.com/jxt4995038/ActiveMqTest.git