import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Override
protected AbstractBeanDefinition getDefaultKeyValueTemplateBeanDefinition(
		RepositoryConfigurationSource configurationSource) {

	RootBeanDefinition redisKeyValueAdapterDefinition = new RootBeanDefinition(RedisKeyValueAdapter.class);

	DirectFieldAccessor dfa = new DirectFieldAccessor(configurationSource);
	AnnotationAttributes aa = (AnnotationAttributes) dfa.getPropertyValue("attributes");

	GenericBeanDefinition indexConfiguration = new GenericBeanDefinition();
	indexConfiguration.setBeanClass(aa.getClass("indexConfiguration"));

	ConstructorArgumentValues constructorArgumentValuesForRedisKeyValueAdapter = new ConstructorArgumentValues();
	constructorArgumentValuesForRedisKeyValueAdapter.addGenericArgumentValue(indexConfiguration);
	redisKeyValueAdapterDefinition.setConstructorArgumentValues(constructorArgumentValuesForRedisKeyValueAdapter);

	RootBeanDefinition keyValueTemplateDefinition = new RootBeanDefinition(KeyValueTemplate.class);
	ConstructorArgumentValues constructorArgumentValuesForKeyValueTemplate = new ConstructorArgumentValues();
	constructorArgumentValuesForKeyValueTemplate.addGenericArgumentValue(redisKeyValueAdapterDefinition);
	keyValueTemplateDefinition.setConstructorArgumentValues(constructorArgumentValuesForKeyValueTemplate);

	return keyValueTemplateDefinition;
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
/**
 * Spring data key value operations over Hazelcast. This is the instance to use Hazelcast as a generic key value store using Spring data.
 * Does not start Hazelcast instance listeners (lifecycle / partition migration)
 * @return
 * @throws Exception
 */
@Bean
@Primary
public KeyValueTemplate kvtemplate() throws Exception
{
  KeyValueTemplate kv = new KeyValueTemplate(hzKeyValueAdaptor());
  return kv;
  
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
/**
 * Spring data key value operations over Hazelcast. This is the instance to use Hazelcast as a generic key value store using Spring data.
 * Force start Hazelcast instance listeners (lifecycle / partition migration)
 * @return
 * @throws Exception
 */
@Bean
@Qualifier("kvTemplateJoinImmediate")
public KeyValueTemplate kvtemplateAndJoin() throws Exception
{
  KeyValueTemplate kv = new KeyValueTemplate(hzKeyValueAdaptorJoinImmediate());
  return kv;
  
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Override
protected AbstractBeanDefinition getDefaultKeyValueTemplateBeanDefinition(
		RepositoryConfigurationSource configurationSource) {

	BeanDefinitionBuilder adapterBuilder = BeanDefinitionBuilder.rootBeanDefinition(MapKeyValueAdapter.class);
	adapterBuilder.addConstructorArgValue(getMapTypeToUse(configurationSource));

	BeanDefinitionBuilder builder = BeanDefinitionBuilder.rootBeanDefinition(KeyValueTemplate.class);
	builder
			.addConstructorArgValue(ParsingUtils.getSourceBeanDefinition(adapterBuilder, configurationSource.getSource()));
	builder.setRole(BeanDefinition.ROLE_SUPPORT);

	return ParsingUtils.getSourceBeanDefinition(builder, configurationSource.getSource());
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
private static void assertKeyValueTemplateWithAdapterFor(Class<?> mapType, ApplicationContext context) {

		KeyValueTemplate template = context.getBean(KeyValueTemplate.class);
		Object adapter = ReflectionTestUtils.getField(template, "adapter");

		assertThat(adapter, is(instanceOf(MapKeyValueAdapter.class)));
		assertThat(ReflectionTestUtils.getField(adapter, "store"), is(instanceOf(mapType)));
	}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Before
public void setup() {

	KeyValueOperations operations = new KeyValueTemplate(new MapKeyValueAdapter());
	KeyValueRepositoryFactory keyValueRepositoryFactory = createKeyValueRepositoryFactory(operations);

	this.repository = getRepository(keyValueRepositoryFactory);
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Bean
public KeyValueTemplate keyValueTemplate() {
	return new KeyValueTemplate(new MapDbKeyValueAdapter());
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Before
public void setUp() throws InstantiationException, IllegalAccessException {
	this.operations = new KeyValueTemplate(HazelcastUtils.preconfiguredHazelcastKeyValueAdapter());
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Bean
public KeyValueOperations keyValueTemplate() {
	return new KeyValueTemplate(new MapKeyValueAdapter());
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Bean
public KeyValueTemplate mapKeyValueTemplate() {
	return new KeyValueTemplate(new MapKeyValueAdapter());
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
@Bean
public KeyValueOperations keyValueTemplate(HazelcastKeyValueAdapter keyValueAdapter) {
    return new KeyValueTemplate(keyValueAdapter);
}
 

import org.springframework.data.keyvalue.core.KeyValueTemplate; //导入依赖的package包/类
/**
 * <P>
 * {@link org.springframework.data.keyvalue.core.KeyValueOperations KeyValueOperations} are implemented by a
 * {@link org.springframework.data.keyvalue.core.KeyValueTemplate KeyValueTemplate} that uses an adapter class
 * encapsulating the implementation.
 * </P>
 * 
 * @return One Hazelcast instance wrapped as a key/value implementation
 */
@Bean
public KeyValueOperations keyValueTemplate() {
	HazelcastKeyValueAdapter hazelcastKeyValueAdapter = new HazelcastKeyValueAdapter(this.hazelcastInstance);
	return new KeyValueTemplate(hazelcastKeyValueAdapter);
}