`

深入掌握JMS(一):JSM基础(转)

    博客分类:
  • JMS
阅读更多

1. JMS基本概念
     JMS(Java Message Service) 即Java消息服务。它提供标准的产生、发送、接收消息的接口简化企业 应用的开发。它支持两种消息通信模型:点到点(point-to-point)(P2P)模型和发布/订阅(Pub/Sub)模型。P2P 模型规定了一个消息只能有一个接收者;Pub/Sub 模型允许一个消息可以有多个接收者。
    对于点到点模型,消息生产者产生一个消息后,把这个消息发送到一个Queue(队列)中,然后消息接收者再从这个Queue中读取,一旦这个消息被一个接收者读取之后,它就在这个Queue中消失了,所以一个消息只能被一个接收者消费。
    与点到点模型不同,发布/订阅模型中,消息生产者产生一个消息后,把这个消息发送到一个Topic中,这个Topic可以同时有多个接收者在监听,当一个消息到达这个Topic之后,所有消息接收者都会收到这个消息。

简单的讲,点到点模型和发布/订阅模型的区别就是前者是一对一,后者是一对多。

2. 几个重要概念 
   Destination :消息发送的目的地,也就是前面说的Queue和Topic。创建好一个消息之后,只需要把这个消息发送到目的地,消息的发送者就可以继续做自己的事情,而不用等待消息被处理完成。至于这个消息什么时候,会被哪个消费者消费,完全取决于消息的接受者。
    Message :从字面上就可以看出是被发送的消息。它有下面几种类型:
        StreamMessage:Java 数据流消息,用标准流操作来顺序的填充和读取。
        MapMessage:一个Map类型的消息;名称为 string 类型,而值为 Java 的基本类型。
        TextMessage:普通字符串消息,包含一个String。
        ObjectMessage:对象消息,包含一个可序列化的Java 对象
        BytesMessage:二进制数组消息,包含一个byte[]。
        XMLMessage:  一个XML类型的消息。
    最常用的是TextMessage和ObjectMessage。
   Session: 与JMS提供者所建立的会话,通过Session我们才可以创建一个Message。
   Connection: 与JMS提供者建立的一个连接。可以从这个连接创建一个会话,即Session。
   ConnectionFactory: 那如何创建一个Connection呢?这就需要下面讲到的ConnectionFactory了。通过这个工厂类就可以得到一个与JMS提供者的连接,即Conection。
   Producer: 消息的生产者,要发送一个消息,必须通过这个生产者来发送。
   MessageConsumer: 与生产者相对应,这是消息的消费者或接收者,通过它来接收一个消息。
   前面多次提到JMS提供者,因为JMS给我们提供的只是一系列接口,当我们使用一个JMS的时候,还是需要一个第三方的提供者,它的作用就是真正管理 这些Connection,Session,Topic和Queue等。

  ConnectionFactory---->Connection--->Session--->Message
  Destination + Session------------------------------------>Producer
  Destination + Session------------------------------------>MessageConsumer 
     通过下面这个简图可以看出上面这些概念的关系。

 
    那么可能有人会问: ConnectionFactory和Destination 从哪儿得到?
    这就和JMS提供者有关了. 如果在一个JavaEE环境中, 可以通过JNDI查找得到, 如果在一个非JavaEE环境中, 那只能通过JMS提供者提供给我们的接口得到了.

分享到:
评论

相关推荐

    RuoYi-Vue 全新 Pro 版本,优化重构所有功能

    RuoYi-Vue 全新 Pro 版本,优化重构所有功能。基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 微信小程序,支持 RBAC 动态权限、数据权限、SaaS 多租户、Flowable 工作流、三方登录、支付、短信、商城、CRM、ERP、AI 等功能

    (源码)基于Spring Boot和MyBatis的订餐管理系统.zip

    # 基于Spring Boot和MyBatis的订餐管理系统 ## 项目简介 本项目是一个基于Spring Boot和MyBatis框架的订餐管理系统,旨在提供一个高效、易用的在线订餐平台。系统分为客户端和后台管理系统两部分,客户端面向普通用户,提供用户登录、退出、菜品订购和查看订单等功能后台管理系统面向管理员,提供管理员登录、退出、菜品管理(添加、查询、修改、删除)、订单处理、用户管理(添加、查询、删除)等功能。 ## 项目的主要特性和功能 ### 客户端功能 用户登录与退出用户可以通过系统进行登录和退出操作。 菜品订购用户可以浏览菜单并选择菜品进行订购。 查看订单用户可以查看自己的订单历史。 ### 后台管理系统功能 管理员登录与退出管理员可以通过系统进行登录和退出操作。 菜品管理 添加菜品管理员可以添加新的菜品到菜单中。 查询菜品管理员可以查询现有的菜品信息。 修改菜品管理员可以修改菜品的详细信息。

    Untitled Page.pdf

    Untitled Page.pdf

    CocosCreator开发视频教程含源码简易塔防开发3.61G

    CocosCreator开发视频教程含源码简易塔防开发3.61G提取方式是百度网盘分享地址

    (源码)基于Java的票务管理系统.zip

    # 基于Java的票务管理系统 ## 项目简介 本项目是一个基于Java的票务管理系统,旨在提供一个全面的票务管理解决方案,包括购票、退票、销售状态查询等功能。系统通过Java的Servlet技术处理HTTP请求,并与MySQL数据库进行交互,确保数据的准确性和一致性。 ## 项目的主要特性和功能 1. 购票功能用户可以通过系统购买票务,系统会记录购票信息并更新数据库。 2. 退票功能用户可以申请退票,系统会处理退票请求并更新票务状态。 3. 销售状态查询管理员可以查询特定用户或特定时间段的销售状态,包括月销售、类型销售等。 4. 用户登录验证系统提供用户登录验证功能,确保只有授权用户才能进行相关操作。 5. 数据库存储所有票务信息、用户信息和销售记录都存储在MySQL数据库中,确保数据的安全性和持久性。 ## 安装使用步骤 1. 环境准备 安装Java开发环境(JDK)。

    数据库开发学习教程(从基础到进阶逐步掌握数据库的设计、开发和优化技巧)

    本教程旨在帮助学习者从基础到进阶掌握数据库开发的核心技能。通过对数据库管理系统的安装、SQL 查询语言、数据库设计、查询优化、事务管理、数据库安全等方面的详细讲解,本教程为学习者提供了全面的数据库开发知识。通过实际操作和最佳实践的学习,你将能够设计高效、稳定的数据库系统,并有效地管理和优化数据存储与访问。

    (源码)基于MCU和C语言的数字时钟系统.zip

    # 基于MCU和C语言的数字时钟系统 ## 项目简介 这是一个数字时钟系统的设计与实现项目,结合了电路设计与嵌入式编程技术。本项目包含了电路设计、PCB板设计和基于微控制器(MSP4302553)的C语言程序开发。数字时钟功能包括时间显示、闹钟提醒等。 ## 项目的主要特性和功能 1. 基于微控制器MSP4302553实现数字时钟功能。 2. 支持时间显示,包括小时、分钟和秒。 3. 支持闹钟提醒功能。 4. PCB板设计,方便硬件制作和集成。 ## 安装使用步骤 假设用户已经下载了本项目的源码文件和相关硬件设计文件。 1. 安装并熟悉MSP430微控制器的编程环境,如Energia IDE。 2. 根据提供的PCB设计文件制作硬件电路,确保电路连接正确无误。 3. 将编译好的C语言程序烧录到MSP430微控制器中。 4. 完成硬件电路的组装和调试。确保数字时钟正常工作,显示时间准确。

    基于springboot推荐算法的在线课程推荐系统源码数据库文档.zip

    基于springboot推荐算法的在线课程推荐系统源码数据库文档.zip

    华为手机助手14.0.0.320

    华为手机助手14.0.0.320

    基于springboot+web的医疗设备管理系统源码数据库文档.zip

    基于springboot+web的医疗设备管理系统源码数据库文档.zip

    基于springboot大学生校园线上招聘系统源码数据库文档.zip

    基于springboot大学生校园线上招聘系统源码数据库文档.zip

    基于springboot校外兼职教师考勤管理系统源码数据库文档.zip

    基于springboot校外兼职教师考勤管理系统源码数据库文档.zip

    基于springboot竞赛管理系统源码数据库文档.zip

    基于springboot竞赛管理系统源码数据库文档.zip

    基于springboot的考研资讯系统源码数据库文档.zip

    基于springboot的考研资讯系统源码数据库文档.zip

    飞机大战代码文档.rar

    《飞机大战》是一款经典的游戏,其代码文档资源通常包含游戏的核心逻辑、图形界面设计、音效处理等多个方面。以下是对飞机大战代码文档资源的详细描述: 飞机大战的代码通常分为多个模块,每个模块负责不同的功能。常见的模块包括: 主程序模块:负责游戏的初始化、事件循环、碰撞检测、精灵更新和画面渲染等核心功能。 精灵模块:包含游戏中所有可见对象的类定义,如飞机、敌机、子弹、奖励物品等。这些类通常继承自pygame的Sprite类,并实现自己的绘制和更新方法。 背景模块:负责游戏背景的绘制和滚动效果。通常使用两张相同的背景图片来实现无缝滚动。 音效模块:负责游戏中的音效播放,如飞机发射子弹的声音、敌机被击中的声音等。 二、核心逻辑 游戏初始化:在游戏开始时,主程序模块会初始化游戏窗口、时钟、精灵组等对象,并加载游戏所需的图片和音效资源。 事件循环:主程序模块会不断监听用户输入和系统事件,如键盘按键、鼠标移动等,并根据事件类型执行相应的操作。

    FastReport v6.9.15 Enterprise FS for Delphi 11.0

    FastReport v6.9.15 Enterprise FS for Delphi 11.0 概览 欢迎使用FastReport v6.9.15 Enterprise FS 版本,这是一款专为Delphi 7至11.0设计的高效、强大的报表生成工具。FastReport以其易用性、丰富的功能和高性能,在Delphi开发社区中享有盛誉。此版本特别适配于Delphi 11.0环境,为企业级应用提供了完整的报表解决方案。 特性亮点 全面兼容:无缝集成于Delphi 7到11.0的所有版本,确保在最新的开发平台上也能稳定工作。 企业级功能:包括数据处理、图表展示、多层嵌套报表等高级特性,满足复杂报表的设计需求。 高速渲染:优化的渲染引擎使得大数据量报表的生成快速流畅。 可视化设计:直观的设计器界面,让开发者能够轻松创建和编辑报表模板。 多种导出格式:支持将报表导出为PDF、Excel、HTML等多种格式,便于数据分享和分析。 源码级集成(FS版本特色):提供源代码,便于深度定制和二次开发。 安装与使用 请先解压缩FastReport v6.9.15 Enterprise FS Delph

    FastReport企业版源代码6.6.17 支持10.4+ FastReport 简化管理工具2.0

    FastReport企业版源代码6.6.17 支持10.4+ FastReport 简化管理工具2.0 资源描述 本仓库提供FastReport 6.6.17企业版源代码,适用于Delphi 7和Delphi 27(10.4 Sydney)。此外,还包含FastReport简化管理工具2.0版本,由xander.xiao@gmail.com开发,发布于2020年5月27日。 什么是包简化管理? FastReport包含一系列设计包文件,手动安装这些包文件非常繁琐。为了简化这一过程,我们提供了一个解决方案,该方案不仅适用于FastReport,还可以应用于任何包管理。 解决方案概述 将所有包文件复制到一个由环境变量%ProjectHome%命名的文件夹中,其结构如下: %ProjectHome%\Bin:存放所有包的BPL文件(运行时和设计时文件) %ProjectHome%\LibD7:存放Delphi 7编译的单元文件和资源文件(如dcu、dcp、dfm、res等) %ProjectHome%\LibD26:存放Delphi XE 10 Rio编译的单元文件和资源文件(如dcu

    Cocos2d-x教程视频Windows环境下Visual Studio 2013中搭建Cocos2d-x 3.1集成开发环境

    Cocos2d-x教程视频Windows环境下Visual Studio 2013中搭建Cocos2d-x 3.1集成开发环境提取方式是百度网盘分享地址

    数据库设计管理课程设计系统设计报告(powerdesign+sql+DreamweaverCS)电脑销售信息管理系统

    数据库设计管理课程设计系统设计报告(powerdesign+sql+DreamweaverCS)电脑销售信息管理系统提取方式是百度网盘分享地址

    图像去噪matlab程序源码双边滤波

    图像去噪matlab程序源码双边滤波图像去噪matlab程序源码双边滤波提取方式是百度网盘分享地址

Global site tag (gtag.js) - Google Analytics