安装方式

官方下载,解压至任意目录,命令行进入bin文件夹,执行./activemq startactivemq.bat start,访问http://localhost:8161/admin/ 输入用户名密码admin/admin进入管理页面。

关于消息的持久化特性、Session及确认特性

  • Session:发送动作是在一个Session会话周期内调用,同时需要主动调用session.commit()方法才会发送消息。commit方法可以多次调用,每次调用会把尚未发送的消息发送掉。

关于发送者和接收者的【分布式集群特性】

点对点模式

  • 发送者:对于同一个队列,可以有多个客户端发送消息,也即发送者并无客户端唯一标识。

  • 接收者:对于同一个队列,可以有多个客户端接收消息,客户端可以没有唯一标识。对同一条消息,无论客户端是否有不同的标识,都只会被某一个客户端接收到。

订阅者模式

  • 发送者:对于同一个主题,可以有多个客户端发送消息,也即发送者并无客户端唯一标识。

  • 接收者:对于同一个主题,客户端必须设定一个唯一的clientID,不同的clientID标识不同的客户端。对于同一条消息,不同clientID的客户端都会收到这一条消息。每条消息都有存活时间,可以在发送时设置producer的setTimeToLive指定,超过存活时间的消息会被销毁。接收者没有办法做到:对于相同分组的客户端,同一个主题的消息由该分组的任意一台客户端接收,以满足分布式无单点的要求。

    非持久订阅的topic,这种功能没有实现。但是持久订阅的topic,可以通过Composite Destination机制转换成针对具体的持久消费者的专用queue,从而实现多个client共同处理同一类消息。参见:http://blog.csdn.net/kimmking/article/details/9773085

ActiveMQ的集群与高可用

TODO

文档更新时间: 2018-11-10 20:12   作者:nick