simple

喂我喜欢伱 2015-03-17

展开全文

一、序言

有了缓存，还是喜欢用注解去使用，本想和spring 写一个类似ehcache 的东西，后来发google 已经提供了spring 和memcache 的注解配置，那就先拿来用用了~。~。

二、基本配置：

2.1 先把spring 和 memcached 结合起来，创建一个spring-xmemcached.xml 的文件

Java代码

<bean id="xmemcacheBuilder" class="net.rubyeye.xmemcached.XMemcachedClientBuilder">
<constructor-arg>
<list>
<bean class="java.net.InetSocketAddress">
<constructor-arg>
<value>localhost</value>
</constructor-arg>
<constructor-arg>
<value>11211</value>
</constructor-arg>
</bean>
<bean class="java.net.InetSocketAddress">
<constructor-arg>
<value>localhost</value>
</constructor-arg>
<constructor-arg>
<value>11212</value>
</constructor-arg>
</bean>
</list>
</constructor-arg>
<constructor-arg>
<list>
<value>1</value>
<value>2</value>
</list>
</constructor-arg>
<property name="connectionPoolSize" value="2"/>
<property name="commandFactory">
<bean class="net.rubyeye.xmemcached.command.BinaryCommandFactory"/>
</property>
<property name="sessionLocator">
<bean class="net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"/>
</property>
</bean>
<bean name="xmemcachedClient" factory-bean="xmemcacheBuilder" factory-method="build" destroy-method="shutdown"/>

测试一下：可以操作就表示基本配置成功了

Java代码

ApplicationContext context = new ClassPathXmlApplicationContext("spring/spring-xmemcached.xml");
MemcachedClient client = (MemcachedClient) context.getBean("xmemcachedClient");
System.out.println(client);
client.add("name",100,"张三");
System.out.println(client.get("name"));
client.delete("name");
System.out.println(client.get("name"));

还是可以参考 https://code.google.com/p/xmemcached/wiki/User_Guide_zh

三、spring+memcached 注解的试用

3.1 引入依赖：

Java代码

<dependency>
<groupId> com.google.code.simple-spring-memcached </groupId>
<artifactId> xmemcached-provider </artifactId>
<version>3.5.0</version>
</dependency>

3.2 基本配置：

Java代码

<context:component-scan base-package="com.raycloud.plugin.memcache"/>
<aop:aspectj-autoproxy />
<import resource="classpath:simplesm-context.xml" />
<bean name="defaultMemcachedClient" class="com.google.code.ssm.CacheFactory">
<property name="cacheClientFactory">
<bean name="cacheClientFactory" class="com.google.code.ssm.providers.xmemcached.MemcacheClientFactoryImpl" />
</property>
<property name="addressProvider">
<bean class="com.google.code.ssm.config.DefaultAddressProvider">
<property name="address" value="127.0.0.1:11211,127.0.0.1:11212" />
</bean>
</property>
<property name="configuration">
<bean class="com.google.code.ssm.providers.CacheConfiguration">
<property name="consistentHashing" value="true" />
</bean>
</property>
</bean>
<bean class="com.google.code.ssm.Settings">
<property name="order" value="500" />
</bean>

3.3 测试一下：我们建立TestDao 和 Test 类，记得在扫描的package 下哦！

Java代码

import com.google.code.ssm.api.ParameterValueKeyProvider;
import com.google.code.ssm.api.ReadThroughSingleCache;
import org.springframework.stereotype.Component;
/**
* Created by qiqiang on 2014/12/22.
*/
@Component
public class TestDao {
@ReadThroughSingleCache(namespace = "test", expiration = 30000)
public long getUserById(@ParameterValueKeyProvider long id) throws Exception{
System.out.println("没有缓存命中");
return id;
}
}

Java代码

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:spring/spring-xmemcached.xml")
public class Test {
@Autowired
private TestDao testDao;
@org.junit.Test
public void x(){
try {
System.out.println( testDao.getUserById(2l)+"------------------------");
}catch (Exception e){
e.printStackTrace();
}
}
}

忘记了，还得加测试的依赖：

Java代码

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>3.2.4.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>

3.4 OK 就测试完成了，当然你也可以用spring 定义的缓存接口,和 ehcache 类似的啦，看配置：

为了配套依赖：

Java代码

<dependency>
<groupId> com.google.code.simple-spring-memcached </groupId>
<artifactId>spring-cache</artifactId>
<version>3.5.0</version>
</dependency>

Java代码

<cache:annotation-driven />
<bean name="cacheManager" class="com.google.code.ssm.spring.SSMCacheManager">
<property name="caches">
<set>
<bean class="com.google.code.ssm.spring.SSMCache">
<constructor-arg name="cache" index="0" ref="defaultCache" />
<constructor-arg name="expiration" index="1" value="300" />
<!-- @CacheEvict(..., "allEntries" = true) won't work because allowClear is false,
so we won't flush accidentally all entries from memcached instance -->
<!-- 这里表示我们不会全部清除所有缓存，使用ehcache 的时候我们就会发现， @CacheEvict(..., "allEntries" = true)
它是按配置的缓存名就行清除的，而memcached 我们是通过namespace 进行清除的，还有指定时间，这是我最喜欢的了~。~
-->
<constructor-arg name="allowClear" index="2" value="false" />
</bean>
</set>
</property>
</bean>
<bean name="defaultCache" class="com.google.code.ssm.CacheFactory">
<property name="cacheName" value="defaultCache"/>
<property name="cacheClientFactory">
<bean name="cacheClientFactory" class="com.google.code.ssm.providers.xmemcached.MemcacheClientFactoryImpl"/>
</property>
<property name="addressProvider">
<bean class="com.google.code.ssm.config.DefaultAddressProvider">
<property name="address" value="127.0.0.1:11211,127.0.0.1:11212"/>
</bean>
</property>
<property name="configuration">
<bean class="com.google.code.ssm.providers.CacheConfiguration">
<property name="consistentHashing" value="true"/>
</bean>
</property>
</bean>