[关闭]
@aloxc 2017-12-05T04:11:03.000000Z 字数 18595 阅读 640

我们一起学ignite之CacheStore

一起学 ignite cachestore 源码分析

之前测试了ignite中的数据网格（缓存）功能的cachestore，今天整理下代码发出来。
CacheLoadOnlyStoreExampleUsingMysql.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:util="http://www.springframework.org/schema/util"
  5.        xmlns:context="http://www.springframework.org/schema/context"
  6.        xsi:schemaLocation="
  7.         http://www.springframework.org/schema/beans
  8.         http://www.springframework.org/schema/beans/spring-beans.xsd
  9.         http://www.springframework.org/schema/util
  10.         http://www.springframework.org/schema/util/spring-util.xsd
  11.         http://www.springframework.org/schema/context
  12.         http://www.springframework.org/schema/context/spring-context.xsd">
  14.     <context:annotation-config/>
  15.     <context:component-scan base-package="com.github.aloxc.ignite.datagrid.store"/>
  16.     <!-- Datasource for sample in-memory H2 database. -->
  17.     <bean id="h2-example-db" class="org.h2.jdbcx.JdbcDataSource">
  18.         <property name="URL" value="jdbc:h2:tcp://localhost/mem:ExampleDb" />
  19.         <property name="user" value="sa" />
  20.     </bean>
  21.     <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="tybbs_user_datasource">
  22.         <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
  23.         <property name="url" value="jdbc:mysql://192.168.20.185:3306/b_user"></property>
  24.         <property name="username" value="xroot"></property>
  25.         <property name="password" value="l2lDm*xpass"></property>
  26.     </bean>
  29.     <bean id="cacheOnlyStoreFactoryExampleUsingMysql" class="com.github.aloxc.ignite.datagrid.store.CacheOnlyStoreFactoryExampleUsingMysql">
  30.         <property name="dataSource" ref="tybbs_user_datasource"></property>
  31.     </bean>
  32.     <bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
  34.         <property name="peerClassLoadingEnabled" value="true"/>
  35.         <property name="clientMode" value="true"/>
  36.         <property name="deploymentMode" value="SHARED"/>
  37.         <property name="marshaller">
  38.             <bean class="org.apache.ignite.internal.binary.BinaryMarshaller"/>
  39.         </property>
  40.         <property name="cacheConfiguration" >
  41.             <list>
  42.                 <bean class="org.apache.ignite.configuration.CacheConfiguration">
  43.                     <property name="cacheMode" value="PARTITIONED"/>
  44.                     <property name="writeThrough" value="true"/>
  45.                     <property name="readThrough" value="true" />
  46.                     <property name="backups" value="1"/>
  47.                     <property name="name" value="cacheOnlyUsingMysql"/>
  48.                     <property name="cacheStoreFactory">
  49.                         <bean class="javax.cache.configuration.FactoryBuilder.SingletonFactory">
  50.                             <constructor-arg ref="cacheOnlyStoreFactoryExampleUsingMysql" />
  51.                         </bean>
  52.                     </property>
  53.                     <property name="queryEntities">
  54.                         <util:list>
  55.                             <bean class="org.apache.ignite.cache.QueryEntity">
  56.                                 <property name="keyType" value="java.lang.Long"/>
  57.                                 <property name="valueType" value="com.github.aloxc.ignite.model.Person"/>
  58.                                 <property name="fields">
  59.                                     <map>
  60.                                         <entry key="id" value="java.lang.Long"/>
  61.                                         <entry key="first_name" value="java.lang.String"/>
  62.                                         <entry key="last_name" value="java.lang.String"/>
  63.                                         <entry key="resume" value="java.lang.String" />
  64.                                     </map>
  65.                                 </property>
  66.                                 <property name="indexes">
  67.                                     <list>
  68.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  69.                                             <constructor-arg name="field" value="id" />
  70.                                         </bean>
  71.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  72.                                             <constructor-arg name="field" value="first_name" />
  73.                                         </bean>
  74.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  75.                                             <constructor-arg name="field" value="resume"/>
  76.                                             <property name="indexType" value="FULLTEXT"/>
  77.                                         </bean>
  78.                                     </list>
  79.                                 </property>
  80.                             </bean>
  81.                         </util:list>
  82.                     </property>
  83.                 </bean>
  84.             </list>
  85.         </property>
  86.         <property name="discoverySpi">
  87.             <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
  88.                 <property name="ipFinder">
  89.                     <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
  90.                         <property name="addresses">
  91.                             <list> <value>192.168.16.68:47500..47509</value>                          <value>192.168.16.69:47500..47509</value>
  92. <value>192.168.16.70:47500..47509</value>
  93.                             </list>
  94.                         </property>
  95.                     </bean>
  96.                 </property>
  97.             </bean>
  98.         </property>
  99.     </bean>
  100. </beans>

CacheLoadOnlyStoreExampleUsingMysql.java

  1. package com.github.aloxc.ignite.datagrid.store;
  3. import com.github.aloxc.ignite.model.Person;
  4. import org.apache.commons.logging.Log;
  5. import org.apache.commons.logging.LogFactory;
  6. import org.apache.ignite.Ignite;
  7. import org.apache.ignite.IgniteCache;
  8. import org.apache.ignite.IgniteException;
  9. import org.apache.ignite.Ignition;
  10. import org.apache.ignite.binary.BinaryObject;
  11. import org.apache.ignite.cache.CachePeekMode;
  12. import org.apache.ignite.cache.query.*;
  13. import org.apache.ignite.cache.store.CacheLoadOnlyStoreAdapter;
  14. import org.apache.ignite.lang.IgniteBiPredicate;
  16. import javax.cache.Cache;
  17. import java.text.SimpleDateFormat;
  18. import java.util.Date;
  19. import java.util.Iterator;
  20. import java.util.List;
  22. public class CacheLoadOnlyStoreExampleUsingMysql {
  23.     private static Log logger = LogFactory.getLog(CacheLoadOnlyStoreExampleUsingMysql.class);
  24.     private static String CACHE_NAME = CacheLoadOnlyStoreExampleUsingMysql.class.getSimpleName();
  26.     private static CacheOnlyStoreFactoryExampleUsingMysql cacheOnlyStoreFactoryExampleUsingMysql;
  27.     public static void main(String[] args) throws IgniteException {
  28.     new CacheLoadOnlyStoreExampleUsingMysql().doit();
  29.     }
  31.     public void doit(){
  32.         try (Ignite ignite = Ignition.start("com/github/aloxc/ignite/datagrid/store/CacheLoadOnlyStoreExampleUsingMysql.xml")) {
  34.             logger.error(">>> CacheLoadOnlyStoreExample started.");
  35.             CACHE_NAME = "cacheOnlyUsingMysql";
  36.             try (IgniteCache<Long, Person> cache = ignite.getOrCreateCache(CACHE_NAME)) {
  37.                 logger.error("cache.getName : " + cache.getName());
  39.                 logger.error("读取编号1的person" + cache.get(1L));
  40.                 IgniteCache<Long, BinaryObject> biCache = cache.withKeepBinary();
  42.                 ScanQuery<Long, BinaryObject> scan = new ScanQuery<>(
  43.                         new IgniteBiPredicate<Long, BinaryObject>() {
  44.                             @Override
  45.                             public boolean apply(Long id, BinaryObject person) {
  47.                                 boolean isTrue = person.<String>field("firstName").equals("Robert");
  48.                                 if (isTrue) {
  49.                                     logger.error("找到结果 id = " + id + "\t" + person);
  50.                                 } else {
  51.                                     logger.error(">>错误结果 id = " + id);
  52.                                 }
  53.                                 return isTrue;
  54.                             }
  55.                         }
  56.                 );
  57.                 QueryCursor cursor = biCache.query(scan);
  58.                 logger.error("执行扫描查找结果" + cursor.getAll());
  59.                 Iterator<Cache.Entry<Long, Person>> its = cache.iterator();
  60.                 while (its.hasNext()) {
  61.                     logger.error(its.next());
  62.                 }
  63.                 logger.error("缓存中所有数据条数 = " + cache.size(CachePeekMode.PRIMARY));
  64.                 Person person5 = cache.get(5L);
  65.                 logger.error("读取编号5的person" + person5);
  66.                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  67.                 person5.setLastName("lastName-" + sdf.format(new Date()));
  68.                 cache.replace(person5.getId(),person5);
  69.                 logger.error("待更新编号5的person" + person5);
  70.                 Thread.sleep(2000);
  71.                 for (int i = 0; i < 10; i++) {
  72.                     Person maxPerson = getMaxPerson();
  73.                     logger.error("最大一个person"+maxPerson);
  74. //                try{
  75. //                    logger.error(">>> 读取一个不存在的person: " + cache.get(maxPerson.getId() + 1L));
  76. //                }catch (Exception e){
  77. //                    logger.error("读取一个不存在的person异常"+e.getMessage());
  78. //                }
  79.                     maxPerson.setId(maxPerson.getId() + 1L);
  80.                     maxPerson.setFirstName("max-first-" + maxPerson.getId());
  81.                     maxPerson.setLastName("max-last-" + maxPerson.getId());
  82.                     maxPerson.setResume("resume-" + maxPerson.getId());
  83.                     boolean maxTrue = cache.putIfAbsent(maxPerson.getId(),maxPerson);
  84.                     logger.error("新增记录结果" + maxTrue);
  85.                 }
  87.                 SqlQuery sqlQuery = new SqlQuery(Person.class," id<10  order by id desc limit 2,2");
  88.                 logger.error("执行sqlQuery分页查找结果" + cache.query(sqlQuery).getAll());
  89.                 Person maxPerson = getMaxPerson();
  90.                 maxPerson.setId(maxPerson.getId() + 1L);
  91.                 maxPerson.setFirstName("max-first-" + maxPerson.getId());
  92.                 maxPerson.setLastName("max-last-" + maxPerson.getId());
  93.                 maxPerson.setResume("中华 人民共和国-" + maxPerson.getId());
  94.                 boolean maxTrue = cache.putIfAbsent(maxPerson.getId(),maxPerson);
  95.                 logger.error("新增[中华人民共和国]记录结果" + maxTrue + "\t" + maxPerson);
  96.                 logger.error("执行文本查找[中华]结果" + cache.query(new TextQuery<Long,Person>(Person.class,"中华")).getAll());
  97.                 logger.error("执行文本查找[共和]结果" + cache.query(new TextQuery<Long,Person>(Person.class,"共和")).getAll());
  98.                 SqlFieldsQuery sqlFieldsQuery = new SqlFieldsQuery("select * from person where id>?  order by id desc limit 2,2 ");
  99.                 sqlFieldsQuery.setArgs(10);
  100.                 logger.error("执行sqlFieldsQuery分页查找结果" + cache.query(sqlFieldsQuery).getAll());
  101.                 sqlFieldsQuery = new SqlFieldsQuery("select * from person where resume like '%resume-%5%'  order by id desc limit 2,2 ");
  102.                 logger.error("执行sqlFieldsQuery分页查找结果2" + cache.query(sqlFieldsQuery).getAll());
  103.                 sqlFieldsQuery = new SqlFieldsQuery("select * from person where resume like '%中华%'  order by id desc limit 2,2 ");
  104.                 logger.error("执行sqlFieldsQuery分页查找结果3" + cache.query(sqlFieldsQuery).getAll());
  105.                 sqlFieldsQuery = new SqlFieldsQuery("select * from person where resume like '%民共%'  order by id desc limit 2,2 ");
  106.                 logger.error("执行sqlFieldsQuery分页查找结果4" + cache.query(sqlFieldsQuery).getAll());
  107.                 sqlFieldsQuery = new SqlFieldsQuery("select * from person where resume like '%共和%'  order by id desc limit 2,2 ");
  108.                 logger.error("执行sqlFieldsQuery分页查找结果5" + cache.query(sqlFieldsQuery).getAll());
  109.                 sqlFieldsQuery = new SqlFieldsQuery("select * from person where id>10 and resume like '%共和%'  order by id desc limit 2,2 ");
  110.                 logger.error("执行sqlFieldsQuery分页查找结果6" + cache.query(sqlFieldsQuery).getAll());
  111.             }catch (Exception e){
  112.             }
  113.             finally {
  115.             }
  116.         }
  117.     }
  119.     private Person getMaxPerson(){
  120.         IgniteCache<Long,Person> cache = Ignition.ignite().cache(CACHE_NAME);
  121.         SqlFieldsQuery query = new SqlFieldsQuery("SELECT * FROM person order by id desc limit 1");
  122.         QueryCursor<List<?>> cursor = cache.query(query);
  123.         List<List<?>> list = cursor.getAll();
  124.         logger.error(list);
  125.         Person person = (Person) list.get(0).get(1);
  126.         return person;
  127.     }
  128. }

CacheOnlyStoreFactoryExampleUsingMysql.java

  1. package com.github.aloxc.ignite.datagrid.store;
  3. import com.github.aloxc.ignite.model.Person;
  4. import org.apache.ignite.cache.store.CacheStore;
  5. import org.apache.ignite.lang.IgniteBiInClosure;
  6. import org.apache.ignite.resources.SpringResource;
  7. import org.jetbrains.annotations.Nullable;
  8. import org.springframework.jdbc.core.support.JdbcDaoSupport;
  9. import org.springframework.jdbc.datasource.DriverManagerDataSource;
  10. import org.springframework.stereotype.Component;
  12. import javax.cache.Cache;
  13. import javax.cache.integration.CacheLoaderException;
  14. import javax.cache.integration.CacheWriterException;
  15. import java.io.Serializable;
  16. import java.util.Collection;
  17. import java.util.List;
  18. import java.util.Map;
  20. /**
  21.  * Created by Administrator on 2016/12/1.
  22.  */
  23. @Component
  24. public class CacheOnlyStoreFactoryExampleUsingMysql extends JdbcDaoSupport implements CacheStore<Long,Person>,Serializable{
  25.     private final static String TABLE_NAME = "ignite_person";
  26.     private static final long serialVersionUID = -309306329114471641L;
  28.     @SpringResource(resourceName = "tybbs_user_datasource")
  29.     private transient DriverManagerDataSource tybbs_user_datasource;
  32.     @Override
  33.     public void loadCache(final IgniteBiInClosure<Long, Person> igniteBiInClosure, @Nullable Object... objects) throws CacheLoaderException {
  34.         logger.error("spring配置文件中的数据ds " + (tybbs_user_datasource != null ? tybbs_user_datasource : null));
  35.         logger.error("spring配置文件中的数据ds " + this.getDataSource());
  36.         super.setDataSource(tybbs_user_datasource);
  37.         logger.error("从数据库加载所有数据");
  38.         long start = System.currentTimeMillis();
  39.         StringBuffer sql = new StringBuffer();
  40.         sql.append("SELECT `id`,");
  41.         sql.append("`first_name`, `last_name`,`resume`");
  43.         sql.append(" FROM `").append(TABLE_NAME).append("` WHERE 1 = 1");
  44.         sql.append(" ORDER BY `id` DESC");
  45.         logger.error("spring jdbc Template 是否为空 " + (this.getJdbcTemplate() == null));
  46.         List<Person> list = this.getJdbcTemplate().query(sql.toString(), new CacheLoadOnlyStoreRowMapper<Person>());
  48.         for(Person person : list){
  49.             igniteBiInClosure.apply(person.getId(),person);
  50.         }
  51.         logger.error("从数据库加载所有数据花费" + (System.currentTimeMillis() - start) + "毫秒");
  52.     }
  57.     @Override
  58.     public void sessionEnd(boolean b) throws CacheWriterException {
  60.     }
  62.     @Override
  63.     public Person load(Long id) throws CacheLoaderException {
  64.         logger.error("从数据库加载数据" + id);
  65.         long start = System.currentTimeMillis();
  66.         StringBuffer sql = new StringBuffer();
  67.         sql.append("SELECT `id`,");
  68.         sql.append("`first_name`, `last_name`,`resume`");
  69.         sql.append(" FROM `").append(TABLE_NAME).append("` WHERE id = ?");
  70.         Person person = this.getJdbcTemplate().queryForObject(sql.toString(),new CacheLoadOnlyStoreRowMapper<Person>(),id);
  71.         logger.error("从数据库加载数据花费" + (System.currentTimeMillis() - start) + "毫秒");
  72.         return person;
  73.     }
  75.     @Override
  76.     public Map<Long, Person> loadAll(Iterable<? extends Long> iterable) throws CacheLoaderException {
  77.         return null;
  78.     }
  80.     @Override
  81.     public void write(Cache.Entry<? extends Long, ? extends Person> entry) throws CacheWriterException {
  83.         logger.error("开始更新数据到数据库中" + entry.getKey()) ;
  84.         long start = System.currentTimeMillis();
  85.         long id = entry.getKey();
  86.         Person p = entry.getValue();
  87.         StringBuffer sql = new StringBuffer();
  88.         sql.append("update `").append(TABLE_NAME).append("` set first_name = ? ").append(" , last_name = ?,resume = ? where id = ? ");
  89.         int result = this.getJdbcTemplate().update(sql.toString(),p.getFirstName(),p.getLastName(),p.getResume(),p.getId());
  90.         logger.error("更新数据到数据库中,花费" + (System.currentTimeMillis() - start) + "毫秒,影响行数 = " + result);
  91.         if(result == 0){//是新增数据，需要使用insert语句
  92.             start = System.currentTimeMillis();
  93.             sql.delete(0,sql.length() - 1);
  94.             //在CacheStore的所有方法中需要自己捕获除CacheStore接口类中的方法定义上的异常，否则可能会出现一些预料外的情况。
  95.             sql.append("insert into `").append(TABLE_NAME).append("` (`id`,`first_name`,`last_name`,`resume`) values(?,?,?,?);");
  96.             result = this.getJdbcTemplate().update(sql.toString(),p.getId(),p.getFirstName(),p.getLastName(),p.getResume());
  97.             logger.error("插入数据到数据库中,花费" + (System.currentTimeMillis() - start) + "毫秒,影响行数 = " + result);
  98.         }
  100.     }
  102.     @Override
  103.     public void writeAll(Collection<Cache.Entry<? extends Long, ? extends Person>> collection) throws CacheWriterException {
  104.         logger.error("开始更新所有数据到db中,需要更新的数据量" + collection.size());
  105.         long start = System.currentTimeMillis();
  107.         logger.error("更新所有数据到db中花费" + (System.currentTimeMillis() - start) + "毫秒");
  108.     }
  110.     @Override
  111.     public void delete(Object o) throws CacheWriterException {
  113.     }
  115.     @Override
  116.     public void deleteAll(Collection<?> collection) throws CacheWriterException {
  118.     }
  119. }

Person.java

  1. package com.github.aloxc.ignite.model;
  3. import org.apache.ignite.cache.affinity.AffinityKey;
  4. import org.apache.ignite.cache.query.annotations.QuerySqlField;
  5. import org.apache.ignite.cache.query.annotations.QueryTextField;
  7. import java.io.Serializable;
  8. import java.util.concurrent.atomic.AtomicLong;
  10. /**
  11.  * Person class.
  12.  */
  13. public class Person implements Serializable {
  15.     /** */
  16.     private static final AtomicLong ID_GEN = new AtomicLong();
  17.     private static final long serialVersionUID = 182338337431676877L;
  19.     /** Person ID (indexed). */
  20.     @QuerySqlField(index = true)
  21.     private Long id;
  24.     /** First name (not-indexed). */
  25.     @QuerySqlField
  26.     private String firstName;
  28.     /** Last name (not indexed). */
  29.     @QuerySqlField
  30.     private String lastName;
  32.     /** Resume text (create LUCENE-based TEXT index for this field). */
  33.     @QueryTextField
  34.     private String resume;
  37.     public Person() {
  38.         // No-op.
  39.     }
  41.     public Long getId() {
  42.         return id;
  43.     }
  45.     public void setId(Long id) {
  46.         this.id = id;
  47.     }
  50.     public String getFirstName() {
  51.         return firstName;
  52.     }
  54.     public void setFirstName(String firstName) {
  55.         this.firstName = firstName;
  56.     }
  58.     public String getLastName() {
  59.         return lastName;
  60.     }
  62.     public void setLastName(String lastName) {
  63.         this.lastName = lastName;
  64.     }
  66.     public String getResume() {
  67.         return resume;
  68.     }
  70.     public void setResume(String resume) {
  71.         this.resume = resume;
  72.     }
  73. }

CacheLoadOnlyStoreRowMapper.java

  1. package com.github.aloxc.ignite.datagrid.store;
  3. import com.github.aloxc.ignite.model.Person;
  4. import org.apache.commons.logging.Log;
  5. import org.apache.commons.logging.LogFactory;
  6. import org.springframework.jdbc.core.RowMapper;
  8. import java.sql.ResultSet;
  9. import java.sql.SQLException;
  11. /**
  12.  * Created by Administrator on 2016/12/2.
  13.  */
  14. public class CacheLoadOnlyStoreRowMapper<T extends Person> implements RowMapper<Person> {
  15.     private static Log logger = LogFactory.getLog(CacheLoadOnlyStoreRowMapper.class);
  16.     @Override
  17.     public Person mapRow(ResultSet rs, int i) throws SQLException {
  18.         Person person = new Person();
  19.         person.setId(rs.getLong("id"));
  20.         person.setFirstName(rs.getString("first_name"));
  21.         person.setLastName(rs.getString("last_name"));
  22.         person.setResume(rs.getString("resume"));
  23.         logger.error("从数据库加载数据" + person);
  24.         return person;
  25.     }
  26. }
  1. CREATE TABLE `ignite_person` (
  2.   `id` bigint(20) NOT NULL,
  3.   `first_name` varchar(50) DEFAULT NULL,
  4.   `last_name` varchar(50) DEFAULT NULL,
  5.   `resume` varchar(255) DEFAULT NULL,
  6.   PRIMARY KEY (`id`)
  7. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

测试说明：需要把编译后的代码打包放到各ignite服务器的libs目录中，另外需要设置各ignite服务器的default-config.xml.
default-config.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:util="http://www.springframework.org/schema/util"
  5.        xmlns:context="http://www.springframework.org/schema/context"
  6.        xsi:schemaLocation="
  7.         http://www.springframework.org/schema/beans
  8.         http://www.springframework.org/schema/beans/spring-beans.xsd
  9.         http://www.springframework.org/schema/util
  10.         http://www.springframework.org/schema/util/spring-util.xsd
  11.         http://www.springframework.org/schema/context
  12.         http://www.springframework.org/schema/context/spring-context.xsd">
  14.     <context:annotation-config/>
  15.     <context:component-scan base-package="com.github.aloxc.ignite.datagrid.store"/>
  16.     <!-- Datasource for sample in-memory H2 database. -->
  17.     <bean id="h2-example-db" class="org.h2.jdbcx.JdbcDataSource">
  18.         <property name="URL" value="jdbc:h2:tcp://localhost/mem:ExampleDb" />
  19.         <property name="user" value="sa" />
  20.     </bean>
  21.     <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="tybbs_user_datasource">
  22.         <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
  23.         <property name="url" value="jdbc:mysql://192.168.20.185:3306/b_user"></property>
  24.         <property name="username" value="xroot"></property>
  25.         <property name="password" value="l2lDm*xpass"></property>
  26.     </bean>
  28.     <bean id="cacheOnlyStoreFactoryExampleUsingMysql" class="com.github.aloxc.ignite.datagrid.store.CacheOnlyStoreFactoryExampleUsingMysql">
  29.         <property name="dataSource" ref="tybbs_user_datasource"></property>
  30.     </bean>
  32.     <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
  34.         <property name="peerClassLoadingEnabled" value="true"/>
  35.         <property name="clientMode" value="false"/>
  36.         <property name="deploymentMode" value="SHARED"/>
  37.         <property name="marshaller">
  38.             <bean class="org.apache.ignite.internal.binary.BinaryMarshaller"/>
  39.         </property>
  41.         <property name="cacheConfiguration" >
  42.             <list>
  43.                 <bean class="org.apache.ignite.configuration.CacheConfiguration">
  44.                     <property name="cacheMode" value="PARTITIONED"/>
  45.                     <property name="writeThrough" value="true"/>
  46.                     <property name="readThrough" value="true" />
  47.                     <property name="name" value="cacheOnlyUsingMysql"/>
  48.                     <property name="backups" value="1"/>
  49.                     <property name="writeBehindEnabled" value="true" />
  50.                     <property name="writeBehindFlushSize" value="3" />
  51.                     <property name="writeBehindFlushFrequency" value="0" />
  52.                     <property name="writeBehindBatchSize" value="10" />
  53.                     <property name="cacheStoreFactory">
  54.                         <bean class="javax.cache.configuration.FactoryBuilder.SingletonFactory">
  55.                             <constructor-arg ref="cacheOnlyStoreFactoryExampleUsingMysql" />
  56.                         </bean>
  57.                     </property>
  58.                     <property name="queryEntities">
  59.                         <util:list>
  60.                             <bean class="org.apache.ignite.cache.QueryEntity">
  61.                                 <property name="keyType" value="java.lang.Long"/>
  62.                                 <property name="valueType" value="com.github.aloxc.ignite.model.Person"/>
  63.                                 <property name="fields">
  64.                                     <map>
  65.                                         <entry key="id" value="java.lang.Long"/>
  66.                                         <entry key="first_name" value="java.lang.String"/>
  67.                                         <entry key="last_name" value="java.lang.String"/>
  68.                                     </map>
  69.                                 </property>
  70.                                 <property name="indexes">
  71.                                     <list>
  72.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  73.                                             <constructor-arg name="field" value="id" />
  74.                                         </bean>
  75.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  76.                                             <constructor-arg name="field" value="first_name" />
  77.                                         </bean>
  78.                                     </list>
  79.                                 </property>
  80.                             </bean>
  81.                         </util:list>
  82.                     </property>
  83.                 </bean>
  84.             </list>
  85.         </property>
  87.     </bean>
  88. </beans>

测试过程中发现一些问题。
1. 当通过缓存读取一个不存在的对象的时候会发生异常。
2. 既需要在配置文件中指定bean的字段、索引，也需要在bean中通过注解指定相关字段的查询及索引，缺一不可。
3. 尽量不要用sql的like查询操作，可能会有你预想不到的情况，这个情况主要是指本来缓存有相关数据，但是通过like取不出我们期望的数据。应该使用textQuery查询。

ps：注意下本文中的代码及配置是通过把我测试代码中一些关于公司的测试环境的配置去掉了，可能本文的配置及代码会有少部分错误，如出现错误可发邮件给我。leerohwa#gmail.com，（#替换为@）

x

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注