JMS及ActiveMQ介绍与部署应用课件

1、作者：王磊2016/3/30JMS及ActiveMQ介绍与部署应用文档结构文档结构 JMS简单介绍 ActiveMQ介绍 ActiveMQ安装与部署 ActiveMQ开发DEMO 结束语JMS及ActiveMQ介绍与部署应用JMS定义定义JMSJMS英文全称为英文全称为Java Message Service,Java Message Service,翻译为翻译为JavaJava消息消息服务。服务。是一个是一个JavaJava平台中关于面向平台中关于面向消息中间件消息中间件（MOMMOM）的）的APIAPI，用于在两个应用程序之间，或分布式系，用于在两个应用程序之间，或分布式系统中发送消息，进

2、行统中发送消息，进行异步异步通信通信。随着技术的发展，随着技术的发展，JMSJMS实现厂商已经逐步支持各种实现厂商已经逐步支持各种类型语言的客户端访问消息服务，使类型语言的客户端访问消息服务，使JMSJMS具有更广阔的具有更广阔的应用前景。应用前景。JMS及ActiveMQ介绍与部署应用JMS特点特点 跨语言、跨平台、跨应用 高性能（每秒数据吞吐量GB级） 实时性好（发送消息的速度快） 异步（解耦，高可靠性） 支持集群（部分厂商实现，master-slaver、broker cluster等模式）JMS及ActiveMQ介绍与部署应用JMS应用典型场景应用典型场景 消耗时间和资源较多的请求，比

3、如电商网站的下单请求，使用JMS消息队列，异步处理订单。 异构平台之间通讯，比如C#与j2ee应用间的通讯。 多应用系统间的集成、数据传递，比如电网运行系统中各应用间数据传递。JMS及ActiveMQ介绍与部署应用JMS体系架构体系架构 提供者：连接面向消息中间件的，JMS接口的一个实现。 客户：生产或消费基于消息的Java的应用程序或对象。 生产者：创建并发送消息的JMS客户。 消费者：接收消息的JMS客户。 消息：包括可以在JMS客户之间传递的数据的对象。 队列：一个容纳那些被发送的等待阅读的消息的区域。 主题：一种支持发送消息给多个订阅者的机制。JMS及ActiveMQ介绍与部署应用JM

4、S对象模型对象模型 连接工厂（Connection Factory） 连接（Connection） 会话（Session） 目的（Destination：Queue、Topic） 生产者（Message Producer） 消费者（Message Consumer）JMS及ActiveMQ介绍与部署应用JMS消息模型消息模型 点对点（Point-to-Point）。在点对点的消息系统中，消息分发给一个单独的使用者。点对点消息往往与队列（javax.jms.Queue）相关联。 发布/订阅（Publish/Subscribe）。发布/订阅消息系统支持一个事件驱动模型，消息生产者和消费者都参与消息

5、的传递。生产者发布事件，而使用者订阅感兴趣的事件，并使用事件。该类型消息一般与特定的主题（javax.jms.Topic）关联。JMS及ActiveMQ介绍与部署应用JMS消息存储方式消息存储方式 NON_PERSISTENT：禁止固化消息，仅将消息放到内存中，适合消息量较少、可靠性要求不高的系统。 PERSISTENT：固化消息，将消息以文件或者数据库的方式进行固化，可有效提高可靠性，但会降低性能。JMS及ActiveMQ介绍与部署应用JMS消息格式消息格式 StreamMessage：Java原始值的数据流 MapMessage：键-值对 TextMessage：字符串对象（最常用） Ob

6、jectMessage：序列化的 Java对象 BytesMessage：字节流JMS及ActiveMQ介绍与部署应用JMS消息实体消息实体 消息头（必须）：包含用于识别和为消息寻找路由的操作设置。 消息属性（可选）：包含额外的属性，支持其他提供者和用户的兼容。 消息体（可选）：消息具体内容。JMS及ActiveMQ介绍与部署应用JMS提供提供者实现者实现 ActiveMQ：apache出品，开源，目前最流行，不支持超大规模。 RabbitMQ：mozilla出品，开源，不支持事务，erlang语言开发。 RocketMQ：阿里巴巴出品，部分开源，该公司内部大量使用，集群50台，日消息量百亿级

7、。 SonicMQ：progress出品，商业，部分国内网站使用。 ZeroMQ：C语言开发，效率极高，但不成熟，开源。JMS及ActiveMQ介绍与部署应用ActiveMQ定义定义 MQ即Message Queue。Apache出品，最流行的，能力强劲的开源消息总线，是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现 已经在很多公司得到应用，社区成熟，学习文档多。JMS及ActiveMQ介绍与部署应用ActiveMQ特性特性 支持多语言和多协议 完全支持持久化、事务 支持内嵌至Spring 支持部署至JBoss、WebLogic等服务器上 支持集群 友好管理界面

8、，测试方便JMS及ActiveMQ介绍与部署应用ActiveMQ下载与安装下载与安装1、到官网下载对应操作系统的压缩包JMS及ActiveMQ介绍与部署应用ActiveMQ下载与安装下载与安装2、将压缩包解压。Windows使用好压、360压缩、winrar等软件；Linux使用tar、unzip等指令JMS及ActiveMQ介绍与部署应用ActiveMQ下载与安装下载与安装3、运行主目录下bin/activemq.bat(windows)，bin/activemq(linux)来启动服务。JMS及ActiveMQ介绍与部署应用ActiveMQ部署部署Linux下注册服务并使其开机启动：1、在

9、activemq脚本中增加下图中白底两行注释2、ln -snf ./bin/activemq /etc/init.d/activemq3、chkconfig -add activemq4、chkconfig activemq onJMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO配置服务端链接类型、ip、端口，修改./conf/activemq.xml文件中的transportConnectors节点：支持tcp,udp,nio,ssl,http,https,vm等多种协议。统一语法：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 配置链接用户名密码

10、，为./conf/activemq.xml文件中节点增加如下节点：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 配置服务端管理员密码，修改./conf/perties文件： 将权限检查设为true，修改./conf/jetty.xml文件中的如下节点：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO输入网址弹出输入框，输入刚才配置文件中admin的密码进行登录：登录成功页面如下：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 客户端编程通用步骤：JMS及ActiveMQ介绍与部署应用Activ

11、eMQ开发开发DEMO 客户端配置maven依赖：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO客户端整合进Spring，引入schema：创建ConnectionFactory或者PooledConnectionFactory(线程安全)：创建Connection(线程安全):JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 创建消息发送者模板（线程安全，竞争session）： pubSubDomain属性改为true即为topic类型消息JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO将模板注入：在代码中执行发送：可发送任

12、意类型的消息，推荐发送Text类型。上面代码中的”LoanUpdate”即为消息目的地标识，拥有同样标识的消息接收客户端可以接收该消息。JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO配置消息接收监听（异步方式）：执行监听的类（实现MessageListener接口）：JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 服务端最小maven依赖 如果需要数据库固化，需要引入activemq-kahadb-store等拓展包JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO 将服务内嵌至Spring，随jvm启动JMS及ActiveMQ介绍与部署应用ActiveMQ开发开发DEMO内嵌认证配置JMS及A