jms和activemq介绍与部署应用.pptx

JMS及ActiveMQ介绍与部署应用 作者：王磊 2016/3/30 文档结构 JMS简单介绍 ActiveMQ介绍 ActiveMQ安装与部署 ActiveMQ开发DEMO 结束语 JMS定义 JMS英文全称为Java Message Service,翻译为Java消息服务。是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。 随着技术的发展，JMS实现厂商已经逐步支持各种类型语言的客户端访问消息服务，使JMS具有更广阔的应用前景。 JMS特点 跨语言、跨平台、跨应用 高性能（每秒数据吞吐量GB级） 实时性好（发送消息的速度快） 异步（解耦，高可靠性） 支持集群（部分厂商实现，master-slaver、broker cluster等模式） JMS应用典型场景 消耗时间和资源较多的请求，比如电商网站的下单请求，使用JMS消息队列，异步处理订单。 异构平台之间通讯，比如C#与j2ee应用间的通讯。 多应用系统间的集成、数据传递，比如电网运行系统中各应用间数据传递。 JMS体系架构 提供者：连接面向消息中间件的，JMS接口的一个实现。 客户：生产或消费基于消息的Java的应用程序或对象。 生产者：创建并发送消息的JMS客户。 消费者：接收消息的JMS客户。 消息：包括可以在JMS客户之间传递的数据的对象。 队列：一个容纳那些被发送的等待阅读的消息的区域。 主题：一种支持发送消息给多个订阅者的机制。 JMS对象模型 连接工厂（Connection Factory） 连接（Connection） 会话（Session） 目的（Destination：Queue、Topic） 生产者（Message Producer） 消费者（Message Consumer） JMS消息模型 点对点（Point-to-Point）。在点对点的消息系统中，消息分发给一个单独的使用者。点对点消息往往与队列（javax.jms.Queue）相关联。 发布/订阅（Publish/Subscribe）。发布/订阅消息系统支持一个事件驱动模型，消息生产者和消费者都参与消息的传递。生产者发布事件，而使用者订阅感兴趣的事件，并使用事件。该类型消息一般与特定的主题（javax.jms.Topic）关联。 JMS消息存储方式 NON_PERSISTENT：禁止固化消息，仅将消息放到内存中，适合消息量较少、可靠性要求不高的系统。 PERSISTENT：固化消息，将消息以文件或者数据库的方式进行固化，可有效提高可靠性，但会降低性能。 JMS消息格式 StreamMessage：Java原始值的数据流 MapMessage：键-值对 TextMessage：字符串对象（最常用） ObjectMessage：序列化的 Java对象 BytesMessage：字节流 JMS消息实体 消息头（必须）：包含用于识别和为消息寻找路由的操作设置。 消息属性（可选）：包含额外的属性，支持其他提供者和用户的兼容。 消息体（可选）：消息具体内容。 JMS提供者实现 ActiveMQ：apache出品，开源，目前最流行，不支持超大规模。 RabbitMQ：mozilla出品，开源，不支持事务，erlang语言开发。 RocketMQ：阿里巴巴出品，部分开源，该公司内部大量使用，集群50台，日消息量百亿级。 SonicMQ：progress出品，商业，部分国内网站使用。 ZeroMQ：C语言开发，效率极高，但不成熟，开源。 ActiveMQ定义 MQ即Message Queue。Apache出品，最流行的，能力强劲的开源消息总线，是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现 已经在很多公司得到应用，社区成熟，学习文档多。 ActiveMQ特性 支持多语言和多协议 完全支持持久化、事务 支持内嵌至Spring 支持部署至JBoss、WebLogic等服务器上 支持集群 友好管理界面，测试方便 ActiveMQ下载与安装 1、到官网下载对应操作系统的压缩包 ActiveMQ下载与安装 2、将压缩包解压。Windows使用好压、360压缩、winrar等软件；Linux使用tar、unzip等指令 ActiveMQ下载与安装 3、运行主目录下bin/activemq.bat(windows)，bin/activemq(linux)来启动服务。 ActiveMQ部署 Linux下注册服务并使其开机启动： 1、在activemq脚本中增加下图中白底两行注释 2、ln -snf ./bin/activemq /etc/init.d/activemq 3、chkconfig --add activ