ActiveMQ(一):简述ActiveMQ及其机制
2015-06-26 14:56
260 查看
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。
ActiveMQ特性列表 :
列表内容多种语言和协议编写客户端。语言: Java, C, C++, C#, Ruby, Perl, Python, PHP。应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)
对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性
通过了常见J2EE服务器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上
支持多种传送协议:in-VM, TCP, SSL, NIO, UDP, JGroups, JXTA
支持通过JDBC和journal提供高速的消息持久化
从设计上保证了高性能的集群,客户端-服务器,点对点
支持Ajax
支持与Axis的整合
可以很容易得调用内嵌JMS provider,进行测试
安装使用activeMQ:
1.下载 ActiveMQ 5.8.0
http://activemq.apache.org/download.html
2.解压
3.进入bin目录,双击activemq.bat即可启动activeMQ
启动activemq.bat的效果如图:
4.启动成功后可以访问管理员界面:http://localhost:8161/admin ,默认用户名和密码是admin/admin,如果想修改用户名和密码的话,在conf/jetty-realm.properties中修改即可。
其中在导航菜单中,Queues是队列方式消息。Topics是主题方式消息。Subscribers消息订阅监控查询。Connections可以查看链接数,分别可以查看xmpp、ssl、stomp、openwire、ws和网络链接。Network是网络链接数监控。Send可以发送消息数据。
5.ActiveMQ消息有3种形式:
(1)点对点方式(point-to-point)
点对点的消息发送方式主要建立在Message Queue, Sender, reciever上,Message Queue存贮消息,Sender发送消息,receiver接收消息。具体点就是Sender Client 发送Message Queue,而receiver Client从Queue中接收消息和发送”消息已接收“到Queue,确认消息接收。消息发送客户端和接收客户端没有时间上的依赖,发送客户端可以在任何时刻发送消息到Queue,而不需要知道接收客户端是不是在运行。
(2)发布/订阅方式(publish/subscriber Messaging)
发布/订阅方式用于多个接收客户端的方式。作为发布订阅的方式,可能存在多个接收客户端,并且接收客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的消息。作为subscriber,在接收消息时有两种方法,destination的receive方法,和实现message listener接口的onMessage方法。
6.ActiveMQ接收和发送消息基本流程
发送消息的基本步骤:
(1)创建连接使用的工厂类 JMS ConnectionFactory。
(2)使用管理对象JMS ConnectionFactory建立连接Connection,并启动。
(3)使用连接Connection建立会话Session。
(4)使用会话Session和管理对象Destination创建消息生产者MessageSender。
(5)使用消息生产者MessageSender发送消息
消息接收者从JMS接收消息的步骤:
(1)创建连接使用的工厂类JMS ConnectionFactory。
(2)使用管理对象JMS ConnectionFactory建立连接Connection,并启动。
(3)使用连接Connection建立会话Session。
(4)使用会话Session和管理对象Destination创建消息接收者MessageReceiver。
(5)使用消息接收者MessageReceiver接收消息,需要用setMessageListener将MessageListener接口绑定到MessageReceiver,消息接收者必须实现了MessageListener接口,需要定义onMessage事件方法。
ActiveMQ特性列表 :
列表内容多种语言和协议编写客户端。语言: Java, C, C++, C#, Ruby, Perl, Python, PHP。应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)
对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性
通过了常见J2EE服务器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上
支持多种传送协议:in-VM, TCP, SSL, NIO, UDP, JGroups, JXTA
支持通过JDBC和journal提供高速的消息持久化
从设计上保证了高性能的集群,客户端-服务器,点对点
支持Ajax
支持与Axis的整合
可以很容易得调用内嵌JMS provider,进行测试
安装使用activeMQ:
1.下载 ActiveMQ 5.8.0
http://activemq.apache.org/download.html
2.解压
3.进入bin目录,双击activemq.bat即可启动activeMQ
启动activemq.bat的效果如图:
4.启动成功后可以访问管理员界面:http://localhost:8161/admin ,默认用户名和密码是admin/admin,如果想修改用户名和密码的话,在conf/jetty-realm.properties中修改即可。
其中在导航菜单中,Queues是队列方式消息。Topics是主题方式消息。Subscribers消息订阅监控查询。Connections可以查看链接数,分别可以查看xmpp、ssl、stomp、openwire、ws和网络链接。Network是网络链接数监控。Send可以发送消息数据。
5.ActiveMQ消息有3种形式:
(1)点对点方式(point-to-point)
点对点的消息发送方式主要建立在Message Queue, Sender, reciever上,Message Queue存贮消息,Sender发送消息,receiver接收消息。具体点就是Sender Client 发送Message Queue,而receiver Client从Queue中接收消息和发送”消息已接收“到Queue,确认消息接收。消息发送客户端和接收客户端没有时间上的依赖,发送客户端可以在任何时刻发送消息到Queue,而不需要知道接收客户端是不是在运行。
(2)发布/订阅方式(publish/subscriber Messaging)
发布/订阅方式用于多个接收客户端的方式。作为发布订阅的方式,可能存在多个接收客户端,并且接收客户端与发送客户端存在时间上的依赖。一个接收端只能接收他创建以后发送客户端发送的消息。作为subscriber,在接收消息时有两种方法,destination的receive方法,和实现message listener接口的onMessage方法。
6.ActiveMQ接收和发送消息基本流程
发送消息的基本步骤:
(1)创建连接使用的工厂类 JMS ConnectionFactory。
(2)使用管理对象JMS ConnectionFactory建立连接Connection,并启动。
(3)使用连接Connection建立会话Session。
(4)使用会话Session和管理对象Destination创建消息生产者MessageSender。
(5)使用消息生产者MessageSender发送消息
消息接收者从JMS接收消息的步骤:
(1)创建连接使用的工厂类JMS ConnectionFactory。
(2)使用管理对象JMS ConnectionFactory建立连接Connection,并启动。
(3)使用连接Connection建立会话Session。
(4)使用会话Session和管理对象Destination创建消息接收者MessageReceiver。
(5)使用消息接收者MessageReceiver接收消息,需要用setMessageListener将MessageListener接口绑定到MessageReceiver,消息接收者必须实现了MessageListener接口,需要定义onMessage事件方法。
相关文章推荐
- html学习笔记(3)-CSS padding margin border属性详解
- 在eclipse中将android项目生成apk并且给apk签名
- MVVM介绍
- Unity shader 官网文档全方位学习(一)
- Unable to instantiate fragment make sure class name exists, is public, and has an empty constructor
- html5手机 input file 上传图片 调用API
- Index downloads are disabled, search results may be incomplete.Maven 设置中央仓库
- 傅里叶分析 [作 者:韩 昊]
- NGUI减少drawcall 的总结
- Lucene.Net 2.3.1开发介绍 —— 一、接触Lucene.Net
- Python核心编程笔记--unicode编码
- 学习C++动态链接库基础 4000 知识 (主要关于QT项目)
- Linux操作系统安装LAMP环境
- 第一章 scala 基本语法
- Codeforces554A:Kyoya and Photobooks
- 10. Regular Expression Matching
- .Net学习笔记----2015-06-26(多态之虚方法、抽象类)
- html中表头的合并,类Excel
- .gitignore无效,不能过滤某些文件
- jQuery实现当按下回车键时绑定点击事件