从头到尾讲解EJB MDB(消息驱动bean)二——MDB实现技术

2024-02-15 23:08

本文主要是介绍从头到尾讲解EJB MDB(消息驱动bean)二——MDB实现技术,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

五、将消息驱动 bean和目的地或终端关联

        

 

当消息驱动 bean 被部署在容器时,它与目的地或终端建立关联。将消息驱动 bean与目的地或终端建立关联是部署人员的责任。

JMS 消息驱动 bean

当bean被部署到容器时, JMS消息驱动bean与JMS目的地(Queue或Topic)建立关联。将消息驱动bean与Queue 或 Topic 建立关联是部署者的责任。

Bean 提供者可以通过使用 MessageDriven 注释符的 activationConfig 元素或使用 activation-config-property 部署元素告诉部署者消息驱动 bean 是与队列还是与主题建立关联。 用于指定与bean关联的目的地类型的属性名是destinationType。这个属性的值必须是javax.jms.Queue或 javax.jms.Topic。

 

1、Queue:点对点消息传递

通过点对点(PTP)的消息传递模型,一个应用程序可以向另一个应用程序发送消息。在此传递模型中,目标类型是队列。消息首先被传送至队列目标,然后从该队列将消息传送至对此队列进行监听的某个消费者,如下图:

一个队列可以关联多个队列发送方和接收方,但一条消息仅传递给一个接收方。如果多个接收方正在监听队列上的消息,JMS Provider将根据“先来者优先”的原则确定由哪个接收方接收下一条消息。如果没有接收方在监听队列,消息将保留在队列中,直至接收方连接到队列为止。这种消息传递模型是传统意义上的拉模型,在此模型中,消息不是自动推送给客户端的,而是要有客户端从队列中请求获得。

         2、Topic: 发布/订阅消息传递

通过发布/订阅(pub/sub)消息传递模型,应用程序能够将一条消息发送到多个接收方。在此传送模型中,目标类型是主题。消息首先被传送至主题目标,然后传送至所有已订阅此主题的活动消费者。如下图:

Pub/sub消息传递模型允许多个主题订阅者接收同一条消息。JMS一直保留消息,直至所有主题订阅者都收到消息为止。Pub/sub消息传递模型基本上是一个推模型。在该模型中,消息会自动广播,消费者无须通过主动请求方式获得新的消息。

 

六、MDB实现技术

MDB采用池化技术来实现,之所以可以采用池化技术,是因为MDB的客户端不与具体的MDB实例进行通信,相反是通过一种松耦合的方式来实现。首先客户发送消息给EJB容器的消息目的地,然后EJB容器再将消息发送到具体订阅此目的地的MDB实例。

    EJB容器也为每一个MDBclass维护一个实例池,当有消息发送到此MDB订阅的目的地时,EJB容器就会挑选一个MDB class的实例来接受和处理消息。

池化技术:客户端不直接于bean class的实例进行通信,而是通过bean class所暴漏的远程或者本地接口来通信,再进一步的讲就是通过bean class的代理存根来与EJB容器通信。这样以来就可以为每一个bean class维护一个的实例池,然后用这些实例来为大量的客户进行服务。

MDB采用激活机制来降低服务器资源的消耗,当EJB容器资源不够的时候,它就会选择一些能被钝化的实例,将其序列化到磁盘上,当需要的时候,再将其从磁盘恢复到内存中。

 

这篇关于从头到尾讲解EJB MDB(消息驱动bean)二——MDB实现技术的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/712810

相关文章

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

python设置环境变量路径实现过程

《python设置环境变量路径实现过程》本文介绍设置Python路径的多种方法:临时设置(Windows用`set`,Linux/macOS用`export`)、永久设置(系统属性或shell配置文件... 目录设置python路径的方法临时设置环境变量(适用于当前会话)永久设置环境变量(Windows系统

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali

Spring Security 单点登录与自动登录机制的实现原理

《SpringSecurity单点登录与自动登录机制的实现原理》本文探讨SpringSecurity实现单点登录(SSO)与自动登录机制,涵盖JWT跨系统认证、RememberMe持久化Token... 目录一、核心概念解析1.1 单点登录(SSO)1.2 自动登录(Remember Me)二、代码分析三、

PyCharm中配置PyQt的实现步骤

《PyCharm中配置PyQt的实现步骤》PyCharm是JetBrains推出的一款强大的PythonIDE,结合PyQt可以进行pythion高效开发桌面GUI应用程序,本文就来介绍一下PyCha... 目录1. 安装China编程PyQt1.PyQt 核心组件2. 基础 PyQt 应用程序结构3. 使用 Q

springboot自定义注解RateLimiter限流注解技术文档详解

《springboot自定义注解RateLimiter限流注解技术文档详解》文章介绍了限流技术的概念、作用及实现方式,通过SpringAOP拦截方法、缓存存储计数器,结合注解、枚举、异常类等核心组件,... 目录什么是限流系统架构核心组件详解1. 限流注解 (@RateLimiter)2. 限流类型枚举 (

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释:举个例子:✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多

Python实现批量提取BLF文件时间戳

《Python实现批量提取BLF文件时间戳》BLF(BinaryLoggingFormat)作为Vector公司推出的CAN总线数据记录格式,被广泛用于存储车辆通信数据,本文将使用Python轻松提取... 目录一、为什么需要批量处理 BLF 文件二、核心代码解析:从文件遍历到数据导出1. 环境准备与依赖库

linux下shell脚本启动jar包实现过程

《linux下shell脚本启动jar包实现过程》确保APP_NAME和LOG_FILE位于目录内,首次启动前需手动创建log文件夹,否则报错,此为个人经验,供参考,欢迎支持脚本之家... 目录linux下shell脚本启动jar包样例1样例2总结linux下shell脚本启动jar包样例1#!/bin