1

Ignite キャッシュに永続ストアを実装しようとしています。CacheJdbcPojoStoreFactory を使用しています。私のキャッシュ ストア ファクトリの初期化は次のようになります。

@Autowired
DataSorce datasource; 
@Bean  
public CacheJdbcPojoStoreFactory<?, ?> cacheJdbcdPojoStorefactory(){
CacheJdbcPojoStoreFactory<?, ?> factory = new CacheJdbcPojoStoreFactory<>();
factory.setDataSource(dataSource);
return factory;
 }

私のキャッシュの実装は次のようになります

CacheConfiguration pesonConfig = new CacheConfiguration();
pesonConfig.setName("personCache");
cacheJdbcdPojoStorefactory.setTypes(jdbcTypes.toArray(new JdbcType[jdbcTypes.size()]));
Collection<QueryEntity> qryEntities = new ArrayList<>();
qryEntities.add(qryEntity);
pesonConfig.setQueryEntities(qryEntities);
pesonConfig.setCacheStoreFactory((Factory<? extends CacheStore<Integer, Person>>) cacheJdbcdPojoStorefactory);
ROCCache<Integer, Person> personCache= rocCachemanager.createCache(pesonConfig);
personCache.put(1, p1);
personCache.put(2, p2)

（私は正しいクエリ Entities と JdbcTypes を渡しています。簡単にするために、ここではそのコードを示していません）しかし、このコードを実行すると、以下のスタックトレースが得られます

Failed to initialize cache store (data source is not provided).
at org.apache.ignite.internal.util.IgniteUtils.startLifecycleAware(IgniteUtils.java:8385)
at org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1269)
at org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1638)
at org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCachesStart(GridCacheProcessor.java:1563)
at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.startCaches(GridDhtPartitionsExchangeFuture.java:944)
at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:511)
at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:1297)
at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
at java.lang.Thread.run(Thread.java:745) 
Caused by: class org.apache.ignite.IgniteException: Failed to initialize cache store (datasource is not provided). at org.apache.ignite.cache.store.jdbc.CacheAbstractJdbcStore.start(CacheAbstractJdbcStore.java:297)
at org.apache.ignite.internal.util.IgniteUtils.startLifecycleAware(IgniteUtils.java:8381)
... 8 more

デバッグすると、データソース パラメータが cacheJdbcdPojoStorefactory オブジェクト内で正しく設定されていることがわかります。どこが間違っていますか？

4

1 に答える 1

0

データ ソース Bean をワイヤリングしてファクトリに設定する代わりに、その Bean ID を指定すると、ファクトリがアプリケーション コンテキストからそれをフェッチします。次に例を示します。

@Bean  
public CacheJdbcPojoStoreFactory<?, ?> cacheJdbcdPojoStorefactory(){
    CacheJdbcPojoStoreFactory<?, ?> factory = new CacheJdbcPojoStoreFactory<>();
    factory.setDataSourceBean("data-source-bean");
    return factory;
}

問題は、ファクトリがシリアル化されることですが、データ ソース フィールドは一時的です。これはsetDataSource()プロパティを非常に混乱させます。私はそれを非推奨にして作り直すべきだと思います。

于 2016-03-12T00:53:21.500 に答える