JAIN SLEE 中Container Managed Persistent (CMP)

在 JAIN SLEE 中，Container Managed Persistent (CMP) 是一种机制，它允许应用程序开发人员定义一些持久化的状态，而不需要自己去编写代码来保存或恢复这些状态。容器（应用服务器）会自动处理这些数据的存储、加载和恢复。CMP 的使用在某些场景中非常方便，例如处理电信服务中的会话状态、活动数据等，它能够保证系统即使重启或出现故障，数据也能自动恢复。

1. 什么是 CMP？

  • Container（容器）：是指运行应用程序的环境，它可以是一个应用服务器，如 JBoss、WebLogic 等，它负责管理应用程序的生命周期、资源和组件的交互。
  • Managed（管理）：容器会自动管理应用程序的一些特定资源，比如存储和恢复对象状态。
  • Persistent（持久化）：是指将数据保存到某种存储介质上（通常是数据库），即使应用程序停止或崩溃，数据也不会丢失。

2. CMP 的工作原理

在 JAIN SLEE 中，SBB (Service Building Block) 是一个核心组件，SBB 包含服务逻辑和状态。CMP 机制帮助 SBB 将这些状态数据自动持久化。开发者只需通过定义 CMP 字段，容器会在需要时自动将它们保存到数据库中，而当 SBB 恢复时，容器会自动从数据库加载这些数据。

3. 如何使用 CMP —— 详细示例

1. 定义 SBB 类和 CMP 字段

首先，你需要在 SBB 中定义需要持久化的状态字段。通常，这些字段通过 abstract 方法定义，并且容器将负责管理它们的存取操作。

import javax.slee.Sbb;
import javax.slee.ActivityContextInterface;public abstract class ConferenceSbb implements Sbb {// 定义持久化的 CMP 字段public abstract void setConferenceId(String id);  // 设置会议IDpublic abstract String getConferenceId();         // 获取会议IDpublic abstract void setParticipantCount(int count);  // 设置参与者数量public abstract int getParticipantCount();            // 获取参与者数量// 处理电话呼入事件public void onCallStart(CallEvent event, ActivityContextInterface aci) {int currentCount = getParticipantCount();  // 获取当前参与者数量setParticipantCount(currentCount + 1);     // 增加参与者数量}// 处理电话挂断事件public void onCallEnd(CallEvent event, ActivityContextInterface aci) {int currentCount = getParticipantCount();  // 获取当前参与者数量setParticipantCount(currentCount - 1);     // 减少参与者数量}
}

解释：

  • getConferenceId() 和 getParticipantCount() 是两个 CMP 字段，通过抽象方法定义，容器会管理这些字段的存储和恢复。
  • onCallStart() 和 onCallEnd() 事件处理方法修改 CMP 字段的值（例如电话会议的参与人数），并由容器负责将这些修改持久化到数据库中。
2. 配置持久化（CMP 配置）

为了让容器知道需要管理哪些字段以及如何持久化它们，需要在 SBB 的部署描述文件中进行配置。

在 JAIN SLEE 中，通常会在 sbb-jar.xml 中指定 CMP 字段。假设我们需要持久化 ConferenceId 和 ParticipantCount，配置如下：

<sbb><sbb-name>ConferenceSBB</sbb-name><sbb-class-name>com.example.ConferenceSbb</sbb-class-name><!-- 定义 CMP 字段 --><cmp-fields><cmp-field><cmp-field-name>conferenceId</cmp-field-name></cmp-field><cmp-field><cmp-field-name>participantCount</cmp-field-name></cmp-field></cmp-fields>
</sbb>

解释：

  • sbb-name 是 SBB 的名字，sbb-class-name 是 SBB 类的完整路径。
  • <cmp-fields> 标签定义了需要由容器管理的字段。
  • 每个 <cmp-field> 标签表示一个需要持久化的字段，比如 conferenceId 和 participantCount。
3. 配置数据源

CMP 通常依赖于数据库进行持久化，因此需要在应用服务器中配置一个数据源，容器会使用该数据源进行数据库操作。

在 JBoss 这样的应用服务器中，你需要配置一个数据源（例如 datasource.xml）：

<datasources><datasource><jndi-name>java:/MySbbDatasource</jndi-name><connection-url>jdbc:mysql://localhost:3306/sbb_db</connection-url><driver-class>com.mysql.jdbc.Driver</driver-class><user-name>root</user-name><password>password</password></datasource>
</datasources>

解释：

  • jndi-name 是数据源的名称，JAIN SLEE 容器会通过这个名字查找数据源并与数据库进行交互。
  • connection-url 是数据库的连接地址，user-name 和 password 是数据库的认证信息。

4. CMP 的优点

  • 自动管理：开发人员不需要手动编写持久化逻辑，容器会自动保存和恢复数据。
  • 简化代码：业务逻辑与持久化逻辑分离，使代码更清晰。
  • 持久化保障：在系统重启或故障后，数据不会丢失，因为容器会自动将状态存储到持久性存储中。

5. 小结

Container Managed Persistence (CMP) 在 JAIN SLEE 中提供了一种方便的方式，帮助开发人员将 SBB 的状态数据自动保存到数据库中，并在需要时自动恢复。这种机制解放了开发者，使其专注于业务逻辑，而不用关心底层的数据存储和恢复操作。

应用步骤总结：

  1. 在 SBB 中定义抽象的 CMP 字段。
  2. 在部署描述文件（如 sbb-jar.xml）中指定哪些字段需要持久化。
  3. 配置容器的数据源，容器将自动管理状态的存储和恢复。

通过这些步骤，你可以轻松实现 SBB 的持久化管理，确保系统的健壮性和数据持久性。

在 JAIN SLEE 编码实现业务过程中，Container Managed Persistence (CMP) 提供了许多便利的功能，但在实际使用中，合理使用和优化 CMP 可以帮助提高系统的性能和健壮性。以下是一些 CMP 的高级用法和技巧，帮助在复杂的业务场景中更好地使用 CMP：

1. Lazy Loading（延迟加载）

延迟加载 是一种在实际需要时才加载数据的技术。对于 CMP 字段，容器会在需要访问时从数据库中加载这些数据，而不是一次性全部加载。这有助于减少数据库的访问频率，从而提升性能。

使用场景：

  • 当有些字段可能不经常被访问时，可以让容器根据需求加载它们，而不在每次调用时都去加载不必要的数据。

实现方式：

  • 虽然 CMP 本身不需要显式地配置延迟加载，但你可以通过尽量减少对不必要字段的访问，来间接触发延迟加载。也可以通过设计 SBB 来只访问必要的字段，降低系统的负载。

2. Optimistic Locking（乐观锁）

乐观锁 是一种并发控制机制，用于防止在多线程或分布式环境中发生数据冲突。默认情况下，CMP 依赖容器处理并发事务。如果多个事务同时修改同一个 CMP 字段，可能会引发数据一致性问题。

高级用法：

  • 通过实现乐观锁机制，你可以防止“脏写”（即事务间修改冲突）问题。这通常是通过为 CMP 字段添加版本号或时间戳来跟踪数据的变化。
  • 在进行更新操作时，检查当前版本号或时间戳是否匹配，确保数据在更新时没有被其他事务修改。

实现方法：

  • 在 SBB 中为某个字段（如 version 字段）设置版本控制，更新时确保版本的一致性。
public abstract class MySbb implements Sbb {// 定义一个版本控制的 CMP 字段public abstract int getVersion();public abstract void setVersion(int version);public void updateData() {int currentVersion = getVersion();// 更新数据逻辑// 检查版本号是否匹配if (currentVersion == expectedVersion) {setVersion(currentVersion + 1); // 更新版本号} else {throw new OptimisticLockException("Data has been modified by another transaction.");}}
}

3. Transactional Consistency（事务一致性）

JAIN SLEE 支持 Java 事务 API（JTA），事务机制对于确保 CMP 数据的一致性非常重要。在使用 CMP 的时候，通常会结合 JTA 来确保数据在发生错误时能自动回滚。

技巧：

  • 在业务逻辑中处理 CMP 字段时，应该尽量在事务中进行操作，这样可以确保即使发生了错误或异常，数据状态也能被正确回滚，不会出现部分更新的情况。

实现方法：

  • 使用 @TransactionManagement 注解或在 SBB 中显式地控制事务的边界。
import javax.transaction.UserTransaction;public abstract class MySbb implements Sbb {public void someBusinessMethod() {UserTransaction tx = ctx.getUserTransaction();try {tx.begin();// 修改 CMP 数据setMyCmpField("new value");// 其他业务逻辑tx.commit();} catch (Exception e) {tx.rollback();}}
}

4. Preloading（预加载）和 Caching（缓存）

预加载 和 缓存 是提升性能的重要技巧。对于频繁访问的 CMP 字段，频繁的数据库查询可能成为性能瓶颈。通过预加载或缓存数据，可以大幅降低数据库访问的频率。

使用场景：

  • 当某些字段被频繁读取时，可以考虑将这些字段在内存中缓存，减少数据库的访问开销。

实现方法：

  • 在 SBB 启动时预加载一些重要的 CMP 数据到内存中，并在需要时直接从缓存读取。
public abstract class CachedSbb implements Sbb {private Map<String, Object> cache = new HashMap<>();public void loadDataIntoCache() {String data = getMyCmpField();cache.put("key", data);}public String getCachedData() {return cache.get("key");}
}

5. Avoid Overuse of CMP（避免过度使用 CMP）

尽管 CMP 自动处理持久化非常方便，但过度依赖 CMP 可能会导致性能问题。并不是所有的状态都需要持久化，尤其是那些短期存在、生命周期较短的状态，建议直接存储在内存中，而不是每次都持久化到数据库。

技巧：

  • 将短期数据或临时状态保存在内存中，而不是使用 CMP，这样可以减轻数据库的负担。
  • 仅对重要的、需要持久化的业务状态使用 CMP。

示例：
假设有一个通话的状态数据，但通话结束后该状态可以被丢弃，那么不需要将这个状态存储到数据库中：

public class CallSbb implements Sbb {private transient String callSessionId;  // 临时数据，不需要持久化public void onCallStart() {callSessionId = generateSessionId();// 其他逻辑}public void onCallEnd() {callSessionId = null;  // 通话结束后不再需要此状态}
}

6. Custom Database Mapping（自定义数据库映射）

在一些场景中，默认的 CMP 映射可能不能满足业务需求。可以通过自定义映射，将 CMP 字段与数据库表中的特定列或表关联。

高级用法：

  • 通过配置文件或注解，指定某些 CMP 字段如何映射到数据库中的列。例如，将某个复杂对象序列化后存储到一个特定的数据库列中。

实现方法：
在部署描述文件中，你可以指定数据库表名、列名以及 CMP 字段的映射关系。某些应用服务器支持通过 XML 或注解定义自定义映射。

<cmp-field><cmp-field-name>customField</cmp-field-name><column-name>CUSTOM_COLUMN</column-name>
</cmp-field>

7. CMP 与分布式系统的结合

在分布式环境中，多个节点可能同时访问或修改 CMP 数据。为了防止冲突，JAIN SLEE 提供了一些机制确保数据的一致性。

技巧：

  • 结合分布式事务，确保多个节点的操作不会产生冲突。
  • 使用全局事务管理器（如 JTA）协调分布式系统中的事务，防止“脏读”和“脏写”问题。

8. 定期清理持久化数据

有些数据可能只在特定时间内有效，比如会话数据或临时的业务数据。为了避免 CMP 数据库膨胀，需要定期清理这些不再需要的数据。

技巧：

  • 设置定期任务（如 Cron 作业）清理过期或无效的持久化数据，确保数据库的效率不会被过量的历史数据影响。

总结

CMP 是 JAIN SLEE 中非常强大且方便的持久化机制，但要有效使用它，开发者需要关注以下几点：

  • 合理使用延迟加载和缓存来提升性能。
  • 使用乐观锁机制防止并发冲突。
  • 结合事务管理，确保数据一致性。
  • 谨慎选择需要持久化的数据，避免不必要的数据库访问。
  • 定期清理不再需要的数据，保持系统的健壮性。

通过这些技巧，开发者可以在使用 CMP 时更好地管理状态和数据库交互，确保系统在高并发和分布式环境中的稳定性和高效性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.xdnf.cn/news/146227.html

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

Vue使用代理方式解决跨域问题

Vue使用代理方式解决跨域问题

1、解决跨域问题 如果 Vue 前端应用请求后端 API 服务器&#xff0c;出现跨域问题&#xff08;CORS&#xff09;&#xff0c;如下图&#xff1a; 解决方法&#xff1a;在 Vue 项目中&#xff0c;打开 vue.config.js 配置文件&#xff0c;在配置文件中使用代理解决跨域问题。 …
阅读更多...
腾讯云ssl证书到期，续期免费证书并部署

腾讯云ssl证书到期，续期免费证书并部署

首先咱用的免费证书&#xff0c;现在最长90天有效期&#xff0c;今天又到期了&#xff0c;得及时续期避免关联资源访问受限。 我这个证书是关联了一个负载均衡和两个容器服务的&#xff08;如果您的应用是ngnix或其他的应用那和本文操作可能有点不一样&#xff09; 所以需要做…
阅读更多...
SpringCloud (1) 服务拆解

SpringCloud (1) 服务拆解

1 服务拆解和治理 1.1 服务拆解 微服务的核心就是服务拆分,将传统的大项目拆分为多个微型服务(服务或微服务),实现服务之间"高内聚(微服务职责单一),低耦合(微服务功能相对独立)"的目的 (1) 水平(横向)拆分:先搭出拆分框架,比如【公共服务】(比如:common服务,client…
阅读更多...
Redis作为单线程模型，为什么效率高、速度快呢？

Redis作为单线程模型，为什么效率高、速度快呢？

前言&#xff1a; 效率高、速度快是相较于数据库来说的&#xff08;MySQL、Orcale、SQL server&#xff09; 文章目录 一、单线程模式的工作流程二、为什么快&#xff1f; 一、单线程模式的工作流程 这里我们所说的单线程是指&#xff1a;Redis只使用一个线程&#xff0c;来处…
阅读更多...
从零到一：打造安全高效敦煌测评自养号体系

从零到一：打造安全高效敦煌测评自养号体系

敦煌测评自养号是一种提升店铺销售和排名的有效策略&#xff0c;卖家可以自行注册并管理买家账号&#xff0c;通过模拟真实买家行为为自家店铺进行测评和补单。以下是一些关键技巧&#xff0c;帮助卖家快速提升销售和排名&#xff1a; 一、账号注册与养号 环境搭建&#xff1…
阅读更多...
prober found high clock drift,Linux服务器时间不能自动同步，导致服务器时间漂移解决办法。

prober found high clock drift,Linux服务器时间不能自动同步，导致服务器时间漂移解决办法。

文章目录 一、场景二、问题三、解决办法&#xff08;一&#xff09;给服务器添加访问网络能力&#xff08;二&#xff09;手动同步1. 检查有没有安装ntp2. 没有安装ntp则离线安装ntp2.1 下载安装包2.2 安装2.3 启动 ntp 3. 设置内部时钟源3.1 编辑/etc/ntp.conf3.1 重启ntp服务…
阅读更多...
【vmware】vmware中手动安装vmwaretools

【vmware】vmware中手动安装vmwaretools

问题: vmware中点击安装vmwaretools时出现如下&#xff1a; VMware Tools 不再随旧版客户机操作系统的 VMware Workstation 一起提供。 请从 https://packages-prod.broadcom.com/tools/frozen/windows/winPreVista.iso 下载&#xff0c;并参阅 https://knowledge.broadcom.co…
阅读更多...
海外大带宽服务器连接失败怎么办?

海外大带宽服务器连接失败怎么办?

在全球化日益加深的今天&#xff0c;海外大带宽服务器已成为企业拓展国际市场、提升业务效率的重要工具。然而&#xff0c;面对复杂多变的网络环境和技术挑战&#xff0c;服务器连接失败的问题时有发生&#xff0c;这不仅影响了企业的正常运营&#xff0c;还可能带来经济损失和…
阅读更多...
VM虚拟机使用的镜像文件下载

VM虚拟机使用的镜像文件下载

文章目录 Windows系统进入微软官网下载工具以Windows10为例下载镜像文件 Windows系统 进入微软官网下载工具 微软中国官网&#xff1a;https://www.microsoft.com/zh-cn/ 以Windows10为例下载镜像文件 选择下载的路径 开始下载 安装windows10操作系统出现Time out问题及解决办…
阅读更多...
WPF DataGrid 动态修改某一个单元格的样式

WPF DataGrid 动态修改某一个单元格的样式

WPF DataGrid 动态修改某一个单元格的样式 <DataGrid Name"main_datagrid_display" Width"1267" Height"193" Grid.Column"1"ItemsSource"{Binding DataGridModels}"><DataGrid.Columns><!--ElementStyle 设…
阅读更多...
得物自建 Redis 无人值守资源均衡调度设计与实现

得物自建 Redis 无人值守资源均衡调度设计与实现

目录&#xff1a; 一、为什么要做资源均衡调度 二、为什么要做自动化资源均衡调度 三、如何合理选择迁移节点 四、如何保障迁移过程中可靠性1. 添加从节点2. 检查同步数据正常3. 执行主从切换4. 检查主从切换正常5. 删除待迁移节点6. 消息通知 五、迁移任务管理展示 六、总结 …
阅读更多...
酸枣病虫害智能化防控系统的探索与实践，基于YOLOv5全系列【n/s/m/l/x】参数模型开发构建枣类作物种植场景下酸枣病虫害智能检测识别系统

酸枣病虫害智能化防控系统的探索与实践，基于YOLOv5全系列【n/s/m/l/x】参数模型开发构建枣类作物种植场景下酸枣病虫害智能检测识别系统

智慧农业&#xff0c;作为现代农业的高级形态&#xff0c;通过集成物联网、大数据、人工智能等先进技术&#xff0c;实现了农业生产过程的精准化、智能化管理。在酸枣等经济作物的种植过程中&#xff0c;病虫害的及时监测与防控直接关系到作物的产量与质量&#xff0c;进而影响…
阅读更多...
LD3320语音识别模块的简单应用

LD3320语音识别模块的简单应用

文章目录 一、 前言二、硬件1.原理图2.产品参数 三、软件1.语音识别原理2.用户使用模式2.1 触发识别模式2.2 循环识别模式 3.语音识别程序3.1 并行方式读写3.2 初始化3.3 写入识别列表3.4 开始识别3.5 响应中断 4.烧写程序4.1 硬件连接4.2 打开STC-ISP软件4.3 按要求配置软件4.…
阅读更多...
F28335中断系统

F28335中断系统

1 中断介绍 1.1 中断概念 1.2 TMS320F28335 中断概述
阅读更多...
Python 中的 typing 模块常见用法

Python 中的 typing 模块常见用法

typing 模块是 Python 提供的一个标准库&#xff0c;主要用于为函数、变量和类定义类型提示&#xff08;Type Hints&#xff09;&#xff0c;从而提高代码的可读性和类型安全性。虽然 Python 是动态类型语言&#xff0c;但通过 typing 模块&#xff0c;开发者可以明确指定变量和…
阅读更多...
【Git 操作】Git 的基本操作

【Git 操作】Git 的基本操作

文章目录 1. Git 的配置2. 工作区、暂存区、版本库 1. Git 的配置 &#x1f427;①首先要新建一个目录&#xff0c;该目录用于放项目代码&#xff0c;在该目录下执行git init命令&#xff0c;用于创建一个 Git的本地仓库。 .git ⽬录是 Git 来跟踪管理仓库的。&#x1f427;②…
阅读更多...
【script】java武魂技展示：在java中使用不同的脚本语言 一文体现java生态的强大

【script】java武魂技展示：在java中使用不同的脚本语言 一文体现java生态的强大

我们经常听到java强大在于它的生态&#xff0c;对于生态的理解我们一般可能想到的是spring家族、微服务那一套中间件&#xff1b;其实java生态的强大也体现在它能使用各种脚本语言&#xff0c;博主最近在项目中考虑使用脚本语言以达到动态效果&#xff0c;因此顺带例举了常用的…
阅读更多...
prometheus通过nginx-vts-exporter监控nginx

prometheus通过nginx-vts-exporter监控nginx

Prometheus监控nginx有两种方式。 一种是通过nginx-exporter监控&#xff0c;需要开启nginx_stub_status,主要是nginx自身的status信息&#xff0c;metrics数据相对较少&#xff1b; 另一种是使用nginx-vts-exporter监控&#xff0c;但是需要在编译nginx的时候添加nginx-module…
阅读更多...
Vuex 入门与实战

Vuex 入门与实战

引言 Vuex 是 Vue.js 官方推荐的状态管理库&#xff0c;它可以帮助我们更好地管理 Vue 应用的状态。在大型应用中&#xff0c;组件之间的状态共享和通信是一个非常重要的问题&#xff0c;而 Vuex 提供了一种优雅的解决方案。 在 Vue 应用中&#xff0c;数据的流动一般是单向的…
阅读更多...
Android Perfetto 学习

Android Perfetto 学习

1、如何抓取性能日志 方式1、通过手机里的System Tracing抓取 1、点击Settings->System->Developer options->System Tracing->Record trace 打开 2、操作完成后&#xff0c;点击Settings->System->Developer options->System Tracing->Record trace…
阅读更多...
最新文章

Copyright @ 2022~2023