APP正在开发中...
返回顶部
您的位置： 主页 > 服务器 > linux >

收藏
分享到

Apache Ignite缓存基本操作实例

linux 来源：互联网 作者：佚名 发布时间：2025-07-24 07:53:53 人浏览
摘要

这段内容主要讲解了Apache Ignite中缓存（IgniteCache）的基本操作，包括获取缓存、创建缓存、销毁缓存、执行原子操作以及异步操作等。下面我将用中文对这些内容进行详细解释，帮助你更好地

这段内容主要讲解了 Apache Ignite 中缓存（IgniteCache）的基本操作，包括获取缓存、创建缓存、销毁缓存、执行原子操作以及异步操作等。下面我将用中文对这些内容进行详细解释，帮助你更好地理解。

一、获取缓存实例（Getting an Instance of a Cache）

所有对缓存的操作都必须通过 IgniteCache 实例来完成。你可以获取一个已经存在的缓存，或者动态创建一个新缓存。

示例代码：

1

2

3

Ignite ignite = Ignition.ignite();

// 获取名为 "myCache" 的缓存实例

IgniteCache<Integer, String> cache = ignite.cache("myCache");

?? 注意：不同缓存的泛型类型可能不同，比如 IgniteCache<Integer, String> 和 IgniteCache<String, Person> 是不同的类型。

二、动态创建缓存（Creating Caches Dynamically）

你也可以在运行时动态创建一个缓存，使用 getOrCreateCache() 方法。如果缓存已经存在，就直接返回；如果不存在，就根据配置创建。

示例代码：

1

2

3

4

CacheConfiguration<Integer, String> cfg = new CacheConfiguration<>();

cfg.setName("myNewCache");

cfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);

IgniteCache<Integer, String> cache = ignite.getOrCreateCache(cfg);

配置说明：

  • setName(...)：设置缓存名称。
  • setAtomicityMode(...)：设置缓存的原子性模式（例如 TRANSACTIONAL 或 ATOMIC）。
  • 还可以设置很多其他参数，比如备份数量、缓存模式（分区/复制）等。

注意事项：

  • 如果在集群拓扑发生变化（如节点加入或退出）时调用 getOrCreateCache()，可能会抛出异常：

1

javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException: Failed to start/stop cache, cluster state change is in progress.
  • 遇到这个异常时，建议稍后重试。

三、销毁缓存（Destroying Caches）

使用 destroy() 方法可以从整个集群中删除一个缓存。

示例代码：

1

2

3

Ignite ignite = Ignition.ignite();

IgniteCache<Long, String> cache = ignite.cache("myCache");

cache.destroy();  // 删除名为 "myCache" 的缓存

?? 注意：此操作是不可逆的，会删除所有节点上的缓存数据和配置。

四、基本原子操作（Basic Atomic Operations）

获取到缓存后，可以进行常见的 put、get、remove 等操作。

示例代码：

1

2

3

4

5

6

7

8

9

IgniteCache<Integer, String> cache = ignite.cache("myCache");

// 存入数据

for (int i = 0; i < 10; i++) {

    cache.put(i, Integer.toString(i));

}

// 获取数据

for (int i = 0; i < 10; i++) {

    System.out.println("Got [key=" + i + ", val=" + cache.get(i) + ']');

}

批量操作注意事项：

  • 使用 putAll()、removeAll() 等批量操作时，是作为一系列原子操作执行的。
  • 如果部分操作失败，会抛出 CachePartialUpdateException，并包含失败的 key 列表。
  • 如果希望批量操作作为一个整体完成，建议使用 事务。

五、条件更新操作（Conditional Updates）

Ignite 提供了一些带有条件判断的更新方法，用于实现线程安全的更新逻辑。

示例代码：

1

2

3

4

5

6

7

8

9

10

11

12

// 如果 key 不存在，则插入，返回旧值

String oldVal = cache.getAndPutIfAbsent(11, "Hello");

// 如果 key 不存在，插入，返回是否成功

boolean success = cache.putIfAbsent(22, "World");

// 如果 key 存在，替换，返回旧值

oldVal = cache.getAndReplace(11, "New value");

// 如果 key 存在，替换，返回是否成功

success = cache.replace(22, "Other new value");

// 如果值匹配，才替换

success = cache.replace(22, "Other new value", "Yet-another-new-value");

// 如果值匹配，才删除

success = cache.remove(11, "Hello");

六、异步操作（Asynchronous Execution）

Ignite 的很多缓存操作都有对应的 异步版本，方法名通常带有 Async 后缀。

示例代码：

1

2

3

4

// 同步 get

V get(K key);

// 异步 get

IgniteFuture<V> getAsync(K key);

异步操作的处理方式：

  • 返回一个 IgniteFuture 对象，表示异步操作的结果。
  • 可以阻塞等待结果，也可以注册监听器来非阻塞地处理结果。

示例监听器：

1

2

3

IgniteCompute compute = ignite.compute();

IgniteFuture<String> fut = compute.callAsync(() -> "Hello World");

fut.listen(f -> System.out.println("Job result: " + f.get()));

七、线程池与闭包执行（Closures Execution and Thread Pools）

  • 如果异步操作在注册监听器前就已经完成，监听器会由当前线程 同步执行。
  • 如果异步操作还未完成，监听器会在操作完成后由线程池中的线程 异步执行。
    • 缓存操作的异步回调通常由 系统线程池 执行。
    • 计算任务的异步回调通常由 公共线程池 执行。

注意事项：

  • 不要在监听器中再调用同步的缓存或计算操作，这可能导致 线程池饥饿（pool starvation） 或 死锁。
  • 如需嵌套异步操作，可以使用 自定义线程池 来避免资源争用。

总结表格

操作类型 描述
获取缓存 通过 ignite.cache("name") 获取缓存实例
创建缓存 使用 getOrCreateCache(cfg) 动态创建缓存
销毁缓存 调用 cache.destroy() 删除缓存
原子操作 put, get, remove 等基本操作
条件更新 putIfAbsent, replace, remove 等带条件操作
异步操作 使用 xxxAsync() 方法和 IgniteFuture
线程池 监听器可能由系统或公共线程池执行，避免同步调用

如果你是刚开始学习 Ignite，理解这些基本缓存操作非常重要。它们是构建分布式缓存应用的基础。对于更复杂的场景，如事务、查询、索引等，请参考 Ignite 的高级功能文档。
版权声明 : 本文内容来源于互联网或用户自行发布贡献，该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权， 违法违规的内容， 请发送邮件至2530232025#qq.cn(#换@)举报，一经查实，本站将立刻删除。

您可能感兴趣的文章 :

原文链接 :
相关文章

  • Linux中的HTTPS协议原理

    Linux中的HTTPS协议原理
    不是有了HTTP了吗？？为什么还要有HTTPS呢？？ HTTPS也是一个应用层协议，是在HTTP协议的基础上引入的一个加密层，他的产生是由于HTTP协议内
  • Apache Ignite缓存基本操作实例
    这段内容主要讲解了Apache Ignite中缓存（IgniteCache）的基本操作，包括获取缓存、创建缓存、销毁缓存、执行原子操作以及异步操作等。下面

  • K8s使用kubectl访问api-server失败,node“XXX“ not foun

    K8s使用kubectl访问api-server失败,node“XXX“ not foun
    K8s 使用 kubectl 访问 api-server 失败，报错node XXX not found。本文提供一种解决思路。 解决步骤 （1）使用 kubectl 1 kubectl get node The connection to th

  • Linux线程之线程的创建、属性、回收、退出、取消

    Linux线程之线程的创建、属性、回收、退出、取消
    1. 线程号 进程号在系统中唯一，但线程号只在其所属进程环境中有效。 （1）pthread_self函数 1 2 3 4 5 6 7 8 9 #includepthread.h pthread_t pthread_self(v
  • Linux journal日志大小限制与管理
    Linux journal 日志大小限制与管理详解 在使用基于systemd的 Linux 系统时，日志系统默认采用journald来管理系统日志。相比传统的rsyslog或syslog，
  • linux服务之.service文件使用及说明
    .service文件是 Linux 系统中systemd服务管理器的配置文件，用于定义如何启动、管理和监控系统服务（如后台程序、守护进程等）。以下是它的

  • Linux SSHD启动失败:OpenSSL版本不匹配问题分析与解

    Linux SSHD启动失败:OpenSSL版本不匹配问题分析与解
    Linux SSHD 启动失败：OpenSSL 版本不匹配问题分析与解决 在 Linux 服务器上，sshd可能因 OpenSSL 版本不匹配而启动失败，具体错误信息如下： 1
  • Linux中SSH服务配置的全面指南
    作为网络安全工程师，SSH（Secure Shell）服务的安全配置是我们日常工作中不可忽视的重要环节。本文将从基础配置到高级安全加固，全面解
  • Linux nmcli设置bond的过程
    nmcli是NetworkManager提供的网络管理工具，nmcli设置的bond可以持久化，因为会写入配置文件，下面我们就来通过nmcli来配置bond聚合口。 2、配置
  • 解决CentOS7下yum失效问题
    centos7已经停止支持，yum源也失效了 ，但是我们服务用的都是CentOS7 ，也不会轻易升级。so 我们只能找找替代方案，很幸运发现阿里云的yum源
推荐阅读
最新更新
友情链接
  • 本站所有内容来源于互联网或用户自行发布，本站仅提供信息存储空间服务，不拥有版权，不承担法律责任。如有侵犯您的权益，请您联系站长处理！
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计