activeMQ消息中间件的学习(一)
JMS (java message service ) java消息服务
消息模型
1.P2P
点对点
一个消费者,一个生产者,一个queue队列
每个消息都被发送到一个特定的队列,接收者从队列中获取消息。队列保留着消息,直到他们被消费或超时。
消息一旦被消费就不会保留到队列中
接收者一单收到消息需要给队列应答成功。
Psp适合每个消息都应当被消费。
2.发布publisher订阅 subscribes模式
一个生产者,多个消费者,一个topic(主题)
每个消费者消费之前都得像topic订阅msg
适合一个生产者多个消费者,也可以一对一,与生产的消息不被做任何处理
JMS消息的产生和消息是异步的,消费者通过两种方式消费信息
一. 同步。即订阅者或接受者调用receive 方法接受信息,在接到信息之前该方法处理阻塞状态。
二. 异步。设置一个监听,当有消息的时候调用onMessage方法。
编程:
ConnectionFactory 创建connection对象的工厂
Destination 实际上就是两种类型的对象,即消息队列 queue topic
Connection 中间件与客户端之间的连接可以创建session
Session 创建生产者消费者消息QueueSenderTopicPublisher
MessageListener 监听器,一旦收到信息就调用onMessage
ActiveMQ
消息中间件
优点:
1. 通道建立,数据消息的维护,发送。
2. 跨平台
安装与部署:
官方网站:http://activemq.apache.org/
下载,解压缩
双击win 64里面的activemq.bat运行
可以看到activemq的存放地址,以及浏览器要访问的地址.
测试,查看是否启动成功
Netstat –an|find “61616
C:\Documents andSettings\Administrator>netstat -an|find "61616"
TCP 0.0.0.0:61616 0.0.0.0:0 LISTENING
”
停止
Ctrl+Shift+C
ConnectionFactory => connection=> connection.start =>connection.createSession
Session创建队列,创建生产者消费者。做一些操作。