本人博客文章网址:https://www.peretang.com/basic-knowledge-of-message-driven-bean/
什么是消息
松散耦合的异步通信过程
1. 面向消息的中间件(MOM): 消息发送者称为生产者; 存储消息的位置称为目的地; 接受消息的组件称为消费者
2. 消息模型:
a. 点对点:目的地成为队列,消息只能被消费一次
b. 发布-订阅:目的地成为主体,消费者称为订阅者,消息能被任意数量消费
Java消息服务
1. JMS API:提供使用Java访问MOM(消息中间件)的统一标准方式
2. 开发消息生产者流程:
a. 使用依赖注入,获得连接工厂ConnectionFactory和目的地Destination对象
b. 使用连接工厂的createConnection打开连接Connection
c. 使用连接Connection的createSession创建会话Session并指定事务参数
d. 使用会话Session的createProducer创建货运队列Producer
e. 使用会话Session的createMessage创建消息Message并设置
f. 使用货运队列Producer的send发送消息
g. 释放资源
注意: 以上流程是基于JavaEE 6 的情况下, JavaEE 7 提供了更加简易的A开发流程
3. Message接口: 消息头, 消息属性, 消息体; 实现类: ObjectMessage传递对象, ByteMessage传递字节, MapMessage传递Map, StreamMessage传递流数据, TextMessage传递文字
消息驱动bean(MDB)
1. 优点:多线程,简化的消息代码
2. 设计原则:
a. MDB类必须直接或间接实现消息监听器接口
b. 必须是具体的公开的,不能是final和抽象类
c. 必须是POJO,不能是另一个MDB的子类
d. 必须有无参的构造器
e. 不能有final方法
f. 不能抛出任何运行时异常,因为当抛出是MDB实例将被终止
3. 使用MDB开发消费者流程
a. 使用注解@MessageDriven把类标记为MDB并且指定MDB配置
b. 实现MessageListener接口, 并实现onMessage方法
c. 在onMessage中实现逻辑
4. @MessageDriven: 注解被注解的类为MDB, 该注解有3个参数, name指定MDB的名称, messageListenerInterface指定MDB实现的消息接口(可以直接在类上implements接口), activationConfig用于指定专有的配置属性
5. MessageLisener: 把MDB注册为消息消费者, 可根据不同场景实现不同监听器接口
6. ActivationConfigProperty: 配置消息系统的配置信息
a. destinationType: 通知容器该MDB监听的是队列还是主题
b. connectionFactoryJndiName: 指定用于创建MDB的JMS连接的连接工厂JDNI
c. destianName: 指定正在监听的目的地
d. acknowledgeMode: 指定JMS会话确认模式
e. subscriptionDurability: 用于设置为持久订阅者
f. messageSelector: 过滤消息
7. MDB生命周期:
a. 创建MDB实例并设置它们
b. 注入资源
c. 存放到受管理的池中
d. 当检测到消息到达时监听的目的地时,从池中取出空闲bean
e. 执行消息监听器方法,即onMessage方法
f. 当onMessage方法执行完毕,把空闲bean存回池中
g. 根据需求从池中撤销/销毁bean
8. 从MDB发送消息: 从JNDI注入队列, 连接工厂对象, 然后和Java消息一样的操作
9. 管理事务: 正常情况下, 在onMessage方法前开启事务, 方法结束时提交事务. 可以通过消息上下文对象rollback事务
MDB最佳实践
1. 根据使用情况选择是否使用MDB
2. 选择消息模型: 应在程序设计时决定是PTP还是发布-订阅, 但幸运的是, 两者间切换仅仅需要修改配置即可
3. 保持模块化: MDB的onMessage方法不应该处理业务逻辑, 业务逻辑应该放在对应的会话bean, 并注入MDB, MDB负责调用对应的会话bean
4. 根据场景充分使用过滤器或划分目的地
5. 选择消息类型: 根据使用场景选择传输时使用的消息类型
6. 警惕有毒消息: 无法消费但又回滚了的消息会陷入无限循环的接收/回滚中, 虽然个别厂商有自己的处理死消息的实现, 但是在编程的时候要注意
7. 配置MDB池额大小: 根据场景和需求配置
相关推荐
1、文件内容：abrt-devel-2.1.11-60.el7.centos.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/abrt-devel-2.1.11-60.el7.centos.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、安装指导：私信博主，全程指导安装
房地产公司绩效管理办法(精品)
网卡驱动-r8169-linux-官方驱动，能翻墙的也可以去外网下，这里只是赚个积分，本人有时候也需要下载别人的资源，望理解，外网地址:https://www.realtek.com/Download/ToDownload?type=direct&downloadid=3378
基于非线性干扰观测器的自适应滑模反演控制策略在机械臂模型中的应用：神经网络MATLAB仿真研究,（文献+程序）基于非线性干扰观测器的自适应滑模反演控制 机械臂模型 神经网络 matlab仿真 滑膜 带原班文献 ,关键词：非线性干扰观测器; 自适应滑模反演控制; 机械臂模型; 神经网络; MATLAB仿真; 滑膜控制; 原班文献,基于非线性干扰观测器的机械臂自适应滑模反演控制：matlab神经网络仿真及原班文献解读
"电力电子方向入门学习：单相PWM整流无桥图腾柱pfc技术Simulink仿真实践，电压调控及优化性能探索",单相PWM整流无桥图腾柱pfc，simulink仿真 输入电压220v有效值 输出电压500v纹波在1%以内 功率因数为1 电流THD＜5% 开关频率20k 可作为电力电子方向入门学习～～ ,关键词：单相PWM整流；无桥图腾柱PFC；Simulink仿真；输入电压220V；输出电压500V；纹波；功率因数1；电流THD＜5%；开关频率20k；电力电子方向入门学习。,"单相PWM整流桥技术：无桥图腾柱PFC的Simulink仿真入门学习"
员工晋升申请表
项目已获导师指导并通过的高分毕业设计项目，可作为课程设计和期末大作业，下载即用无需修改，项目完整确保可以运行。 包含：项目源码、数据库脚本、软件工具等，该项目可以作为毕设、课程设计使用，前后端代码都在里面。 该系统功能完善、界面美观、操作简单、功能齐全、管理便捷，具有很高的实际应用价值。 项目都经过严格调试，确保可以运行！可以放心下载 技术组成 语言：java 开发环境：idea 数据库：MySql8.0 部署环境：Tomcat（建议用 7.x 或者 8.x 版本），maven 数据库工具：navicat
FPGA实现CameraLink相机Base模式解码与HDMI高清视频输出方案,FPGA采集CameraLink相机Base模式 本文详细描述了FPGA采集CameraLink相机Base模式解码输出的实现设计方案，思路是这样的，CameraLink相机输入到FPGA板子，FPGA使用内部逻辑资源实现LVDS视频解码，解析出像素时钟、行同步信号、场同步信号、数据有效信号、以及像素数据，然后将视频转为Xilinx的AXI4-Sream的视频流，经VDMA送入DDR3缓存，然后读取出视频再经过AXI4-Sream to Video Out通过HDMI接口输出视频，这是Xilinx图像处理常用的套路，可谓相当精巧的方案 ,核心关键词：FPGA; CameraLink相机; Base模式; LVDS视频解码; 像素时钟; 同步信号; 像素数据; Xilinx AXI4-Sream; VDMA; DDR3缓存; HDMI接口视频输出。,"FPGA实现CameraLink相机Base模式视频解码与输出设计"
各岗位职责及操作
内容概要：本文介绍了稳定视频人脸修复（Stable Video Face Restoration, SVFR）方法，这是一个为解决一般化视频人脸修复（Generalized Video Face Restoration, GVFR）而设计的统一框架。作者针对现有技术未能有效处理时间一致性和运动伪影的问题提出SVFR方法，并通过实验展示其相较于单任务模型，在盲脸修复、颜色化和修补方面的性能显著提升。GVFR整合了三种子任务（BFR, colorization, 和 inpainting），并通过联合框架提高了训练效果，利用了预训练稳定视频扩散模型（SVD）。文中还引入了统一面部修复框架来确保跨子任务的一致特征表征，并提出了一种新的面部先验损失函数，通过面部特征点辅助修复过程并提高稳定性。 适用人群：适用于从事计算机视觉特别是视频识别和图像处理的研究者和技术工程师。 使用场景及目标：①用于高质量的人脸恢复，特别是在老旧电影或低质量监控录像等场合；②增强人脸识别准确性，确保长时间视频中身份一致性；③应用于需要真实感强的画面处理环境如在线会议直播。 其他说明：这项工作中提出的SVFR不仅解决了当前的技术难题，还为未来相关领域的研究和发展提供了重要参考价值，尤其体现在它所建立的新范例上，即如何通过多任务监督从有限数据集中获得更好的表现。
2025年义务教育新课程标准生物(2022年版)必考试题含答案.docx
直播带货销售业绩表
内容概要：本文详细记录了一个完整的基于Hadoop平台的WordCount任务实现过程，从环境准备到最终成果展示，涵盖了关键步骤的具体操作流程。首先介绍了创建所需文件夹结构并上传原始文本文件至HDFS；其次详述了构建Maven项目来组织相关源代码，以及定义Map（映射）、Combine（组合）、Reduce（归约）三个重要的处理环节所对应的程序逻辑；然后阐述了项目打包、分发过程及远程节点上部署运行该作业的整体思路；最后，通过访问Web界面确认最终生成的统计报告保存路径及其部分内容，验证任务成功完成。 适用人群：适用于初学者及有一定经验的数据工程师或研究人员，特别是那些希望快速掌握MapReduce模型实际应用技巧的人士。 使用场景及目标：此教程可以帮助用户深入了解Apache Hadoop生态系统内的MapReduce计算范式的运作机制。它演示了如何借助命令行工具高效管理和查询大规模非结构化或半结构化的数据集，从而支持后续更加复杂的分析任务的需求探索。此外，对于正在寻找入门级实战演练的学习者而言，这也是非常有价值的练习资料，既包括理论概念的学习也提供了充分的机会来进行动手实验。 其他说明：为了确保最佳实践效果，请注意跟随文中指引逐步尝试每一个新概念的应用，尤其是在编码部分，尽量不要跳过任何一步骤，并积极查阅官方文档或其他权威参考资料作为补充材料，遇到困难时也不必气馁，多做几次重复试验往往能带来意外收获。同时考虑到性能优化的可能性，可以在适当时候调整配置参数，比如增大堆栈容量或者更改块副本数目等。
2025义务教育历史新课程标准（2022版）必考题库含答案.docx
显示效果视频
员工晋升管理规定
2025年义务教育英语课程标准（2022版）必考题库及答案.docx
项目已获导师指导并通过的高分毕业设计项目，可作为课程设计和期末大作业，下载即用无需修改，项目完整确保可以运行。 包含：项目源码、数据库脚本、软件工具等，该项目可以作为毕设、课程设计使用，前后端代码都在里面。 该系统功能完善、界面美观、操作简单、功能齐全、管理便捷，具有很高的实际应用价值。 项目都经过严格调试，确保可以运行！可以放心下载 技术组成 语言：java 开发环境：idea 数据库：MySql8.0 部署环境：Tomcat（建议用 7.x 或者 8.x 版本），maven 数据库工具：navicat
风储联合系统：直驱风机与储能技术的完美融合，创新能源存储解决方案,风储联合系统 直驱风机加储能系统 ,核心关键词：风储联合系统; 直驱风机; 储能系统; 联合系统。,"风储联动：直驱风机与储能系统的绿色能源集成"
双馈风力发电机模型研究：Simulink中的完美波形效果展示，涵盖DFIG模型对风速变化与电流电压特性的精准模拟。,双馈风力发电机模型研究（DFIG），simulink模型。 给定风速变化，电流与电压等波形效果完美。 ,核心关键词：双馈风力发电机模型研究（DFIG）; Simulink模型; 风速变化; 电流波形; 电压波形; 效果完美。,"双馈风力发电机Simulink模型研究：风速变化下的电流电压波形优化"