activemq

1.Activemq学习笔记1
面向消息的中间件：MOM利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行

分布式系统的集成。
一个MOM系统，通常包括客户端，message，MOM。
客户端发送或接受消息，message封装了要传递的内容，MOM可以存储和转发消息。通过MOM间接传递。
MOM好处：降低系统间通信复杂度，只需关心如何和MOM进行消息接受和发送
提高了消息的灵活性，不必阻塞等待。尤其时间无关或并行处理。
松散耦合：a系统变化不影响B系统

JMS概念
java消息服务应用程序接口，用于在分布式系统中发送消息或进行异步通信。是一个与平台无关的API，

大多MOM提供商对JMS提供支持。
包括两种消息模式：点对点和发布订阅
支持同步异步消息处理
一个JMS系统，包括以下部分：
JMS Client：客户端，用于发送或接受消息
Non-JMS client：不是使用JMS API
Message：消息，用于在不同的客户端之间交换
JMS Provider：JMS提供商，是消息系统（activeMQ）,可以同时支持JMS和non-JMS
Object：被管理的对象，预支的JMS对象，为客户端使用。

JMS规范：之定义了接口，并没有实现：

2.JMS消息模型
JMS模型简介：支持两种消息通信模型：点对点和发布订阅模式
publisher--topic--subscriber 只能由一个客户端消费
：只有一个消费者，时间无关性，消费者必须确认，非持久化的消息只发一次，持久化的消息严格发一次

。
send--queue--receiver  订阅者订阅了主题。只能订阅以后的消息
每条消息可有多个订阅者，订阅者只能消费订阅后的topic消息
非持久化订阅：订阅者必须保证为活动状态
持久化订阅：Message Provider会保存这些消息，
是否使用持久化订阅，需要根据业务场景判断。

3。ActiveMQ安装
解压
目录结构：bin放着命领文件
conf配置文件，包括broker，jetty，log等配置文件
data放置消息缓存，jetty中jsp编译class，amq日志
doc帮助文档
example应用实例
lib依赖包

配置：配置broker端口：activemq.xml
配置jetty端口，修改jetty中的内容

启动和停止：默认使用tcp 61616

监控：内置了jetty服务器，admin工程是管理控制台

4.通过ActiveMQ收发消息
队列和主题
在MQ中，消息模型有两种，队列和主题。队列点对点。
收发消息对象的创建过程：
初始化connnectionFactory
创建connection
connection创建session
Session创建Destination（包括queue和topic）
session创建消息生产者，创建消息消费者
session创建message，messageProducer发送到Destination


接口间的关系：
JMS定义了通用接口，队列接口和主题接口。后两者继承通用接口
ActiveMQ对这些规范接口都有实现，声明通用接口就可以了。

通过队列发送和接收消息，run接收，再发送

通过Topic发布和订阅消息，先运行订阅者，后运行发布者
总结：和jdbc过程很类似，就是重复代码过多，spring-jms提供便利的解决方案。

5.使用spring JMS收发消息
maven管理依赖
对类消息收发：JMS连接工厂，定义消息对类，配置JMS模板，消息生产者，消息消费者。
主题消息收发：pubsubDomain true

6.JMS消息类型
JMS规范中消息类型包括5种，TextMessage，BytesMessage，MapMessage，StreamMessage，

ObjectMessage
AcitveMq有对应实现。

7.activemq Master slave集群配置
集群可以提高ActiveMQ的高可用性，一旦一个Broker被kill，另一个可以迅速代替。Master、slave不支

持负载均衡，仅能解决单点故障。
有三种配置方案：基于共享文件系统，基于jdbc，基于可复制的level DB

客户端访问方式：failover
updateURIsURL

id，div ，class
cms


潭州学院
自定义标签
web-infi
不需要对外访问
readme
流程

8.导入activemq源码到eclipse
git导入源码
编译，打包


9.Broker Cluster
网状集群介绍：分为static Discovery和Dynamic Discovery
网状集群特点：客户端连接broker节点失效，自动连接到其他broker
Broker可以发现集群中其它Broker节点
消息可以在多个Broker之间路由
某个broker消费者挂掉，尚未消费的消息路由到其他broker
broker支持分布式的队列和主题
涉及到failover，Discovery of broker和networks of broker

failover：被连接的broker失效，通过failover机制自动连接其他broker
Discovery of broker：知道网络中还有那些broker节点：遍历列表
动态采用多播方式，动态发现。

networks of broker
节点网络：支持分布式的队列和主题。一个节点会相同的对待所有订阅，不管来自本地或远程。

静态集群
动态集群

network connector
管道订阅
双工-duplex

总结：支持了消息路由和负载均衡
存在单点故障，某个失效，造成数据丢失。
为了保证消息可靠性和支持负载均衡，采用broker cluster加master slave模式。

10.镜像队列
监视生产者和消费者之间的消息流，使用镜像队列，把发送到某个队列中的所有消息转发到名称类似的主

题。监视程序可以监听这个主题。

http://my.oschina.net/xiaoxishan/blog/388853