Ignite 的使用过程(一)

下载安装与运行

进入https://ignite.apache.org/download.cgi#binaries 下载编译完成后的文件
解压完成后进入与bin的同级目录下执行 .\bin\ignite.bat .\examples\config\example-cache.xml
出现 ^– default [initSize=256.0 MiB, maxSize=1.6 GiB, persistenceEnabled=false]表示运行成功
注意，我因为jdk的问题导致运行脚本出现内存溢出的问题，一定要选择对正确的jdk与版本（我使用的是jdk8 64位）

程序中使用

下载所需要的jar包
ignite-core-2.4.0.jar（在下载的ignite包中的libs目录下）
ignite-spring-2.4.0.jar
spring-aop-4.3.7.RELEASE.jar
ignite-indexing-2.4.0.jar
ignite-spring-2.4.0.jar
cache-api-1.0.0.jar

代码：

Ignition.setClientMode(true);//这句表示此链接是一个客户端
Ignition.start("ignite/example-cache.xml");//文件与启动ignite的xml相同
Ignite ignite = Ignition.ignite();//获取一个ignite实例

获取要进行操作的缓存对象：

CacheConfiguration<Integer, Person> cacheOnlyPersonCfg = new CacheConfiguration<Integer, Person>("personCache");//动态创建名为personCache的缓存，也可以使用ignite.cache("personCache")来获取，前提是已经创建过
cacheOnlyPersonCfg.setIndexedTypes(Integer.class, Person.class); // 注意配置注册key和value是为了sql查询
// Get an instance of named cache.
final IgniteCache<Integer, Person> cache = ignite.getOrCreateCache(cacheOnlyPersonCfg);//"personCache"); //获取一个IgniteCache实例

开始进行存取操作

for (int i = 0; i < 3; i++) {Person ps = new Person();ps.setId(i);ps.setName("小明");cache.put(i, ps);
}Person ps = new Person();
ps.setId(5);
ps.setName("小明");SqlFieldsQuery qqq = new SqlFieldsQuery("INSERT INTO person(_key, _val) VALUES(?, ?)");
qqq.setArgs(111L, ps);
cache.query(qqq);SqlFieldsQuery sql2 = new SqlFieldsQuery("update person set name = ? where id = ?");
cache.query(sql2.setArgs("小明123", 1)).getAll();SqlQuery<Integer, Person> sql = new SqlQuery(Person.class, "1=1");
List<Cache.Entry<Integer, Person>> cursor = cache.query(sql).getAll();
if (cursor != null) {for (Cache.Entry<Integer, Person> p : cursor) {System.out.println(p.getValue().getName());}
}

可以看出ignite可以适用对象来直接操作，也可以使用sql来操作

Person.class

public class Person {@QuerySqlField(index=true)
private int id;
@QuerySqlField
private String name;
@QuerySqlField
private int city_id;/*** @return the id*/
public int getId() {return id;
}/*** @param id the id to set*/
public void setId(int id) {this.id = id;
}/*** @return the name*/
public String getName() {return name;
}/*** @param name the name to set*/
public void setName(String name) {this.name = name;
}/*** @return the city_id*/
public int getCity_id() {return city_id;
}/*** @param city_id the city_id to set*/
public void setCity_id(int city_id) {this.city_id = city_id;
}

ignite 文档地址

https://www.zybuluo.com/liyuj/note/1032897

Ignite 的使用过程(一)相关推荐

用Apache Ignite实现可扩展的数据网格
在本文中,我们将先介绍数据网格(Data Grid)的基本概念.属性.以及能够提供的服务,然后讨论如何设计可扩展的数据网格,以满足实际场景的业务需求. 什么是数据网格? 数据网格是一组能够提供共享数据 ...
Apache Ignite剖析
1.概述 Apache Ignite和Apache Arrow很类似,属于大数据范畴中的内存分布式管理系统.在<Apache Arrow 内存数据>中介绍了Arrow的相关内容,它统一了大 ...
ignite学习笔记
1.一个Ignite节点可以从命令行启动,可以用默认的配置也可以传递一个配置文件.可以启动很多很多的节点然后他们会自动地发现对方. 2.Ignite只需要一个ignite-core强依赖,通常你还需要 ...
Apache Cassandra和Apache Ignite：关系并置和分布式SQL
为什么80%的码农都做不了架构师?>>> 在上一篇文章中,回顾和总结了Cassandra中使用的查询驱动数据模型(或者说非常规数据模型)方法论的缺陷.事实证明,如果不对查询有深 ...
如何正确的探索 Microsoft Ignite The Tour
Microsoft Ignite The Tour 是一年一度微软为全球开发者.IT专家.安全专家以及数据专家提供的为期两天,包含众多核心产品的实践性技术培训.2019.12.10-2019.12.1 ...
讲重点，看趋势——Microsoft Ignite 2018的回顾和展望
一年一度的微软技术大会--Microsoft Ignite 2018上周在奥兰多召开,目前已经落下帷幕.我没有去现场,但据说这次的盛况空前,创下微软之最.确实,这些年来,微软内部非常重视 Iginte ...
.NET应用迁移到.NET Core（三）从商业角度看移植过程
2016年12月1日下午微软技术大会Microsoft Ignite China,有幸和大家分享一门课程,课程信息如下,欢迎大家到时来捧场.本文介绍下从商业角度看移植过程. . 创建项目移植进度表创 ...
apache ignite_通过示例获取Apache Ignite Baseline拓扑
apache ignite 点燃基准拓扑或BLT代表群集中的一组服务器节点,这些服务器节点将数据持久存储在磁盘上. 其中,N1-2和N5服务器节点是具有本机持久性的Ignite集群的成员,该集群使数据 ...
apache ignite_Apache Ignite变得简单：第一个Java应用程序
apache ignite 在本文中,我们将更进一步,让您完成第一个Ignite应用程序的创建,以从分布式缓存中进行读写操作. 作为第一个示例,我们将尽可能简单地向您展示如何用Java编写用于处理Ap ...
apache ignite_使用Apache Ignite优化Spark作业性能（第1部分）
apache ignite 来看看他们是如何工作的! 本文的某些部分摘自我的书< Apache Ignite的高性能内存计算> . 如果您对这篇文章感兴趣,请查看本书的其余部分,以获取更多 ...

Ignite 的使用过程(一)

Ignite 的使用过程(一)

下载安装与运行

程序中使用

ignite 文档地址

Ignite 的使用过程(一)相关推荐

最新文章

热门文章