spring boot 整合 mecached

一、说明
     1.1 XMemcached客户端说明
     1.2 项目结构说明
     1.3 主要依赖
 二、spring boot 整合 memcached
        2.1 单机配置
         2.2 集群配置
         2.3 存储基本类型测试用例
         2.5 存储实体对象测试用例
 附：memcached 基本命令

正文

一、说明

1.1 XMemcached客户端说明

spring boot 官方并没有提供关于 memcached 的starter，所以我们这里还是采用XMemcached作为客户端进行整合。 XMemcached是基于java nio的memcached高性能客户端，支持完整的memcached协议，支持客户端分布并且提供了一致性哈希(consistent hash)算法的实现。

1.2 项目结构说明

memcached的整合配置位于config文件夹下。

1.3 主要依赖

 <!--memcached java 客户端-->
<dependency>
    <groupId>com.googlecode.xmemcached</groupId>
    <artifactId>xmemcached</artifactId>
    <version>2.4.5</version>
</dependency>

二、spring boot 整合 memcached

2.1 单机配置

@Bean
public MemcachedClient memcachedClient() {
    XMemcachedClientBuilder builder = new XMemcachedClientBuilder("192.168.200.201:11211");
    MemcachedClient memcachedClient = null;
try {
	memcachedClient = builder.build();
	} catch (IOException e) {
	e.printStackTrace();
}
	return memcachedClient;
}

2.2 集群配置

@Bean
public MemcachedClient memcachedClientForCluster() {

    List<InetSocketAddress> addressList = new ArrayList<InetSocketAddress>();
    addressList.add(new InetSocketAddress("192.168.200.201", 11211));
    addressList.add(new InetSocketAddress("192.168.200.201", 11212));
    // 赋予权重
    int[] weights = {1, 2};
    XMemcachedClientBuilder builder = new XMemcachedClientBuilder(addressList, weights);
    // 设置连接池大小
    builder.setConnectionPoolSize(10);
    // 协议工厂
    builder.setCommandFactory(new TextCommandFactory());
    // 分布策略，一致性哈希KetamaMemcachedSessionLocator或者ArraySessionLocator(默认)
    builder.setSessionLocator(new KetamaMemcachedSessionLocator());
    // 设置序列化器
    builder.setTranscoder(new SerializingTranscoder());
    MemcachedClient memcachedClient = null;
    try {
        memcachedClient = builder.build();
    } catch (IOException e) {
        e.printStackTrace();
    }
    return memcachedClient;
}

2.3 存储基本类型测试用例

xmemcached单机版本和集群版本注入的实例是相同的。

/**
 * @author : heibaiying
 * @description : Memcached 操作基本对象
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class MemSamples {

    @Autowired
    private MemcachedClient memcachedClient;

    @Test
    public void operate() throws InterruptedException, MemcachedException, TimeoutException {
        memcachedClient.set("hello", 0, "Hello,cluster xmemcached");
        String value = memcachedClient.get("hello");
        System.out.println("hello=" + value);
        memcachedClient.delete("hello");
        value = memcachedClient.get("hello");
        System.out.println("hello=" + value);
    }
}

2.5 存储实体对象测试用例

/**
 * @author : heibaiying
 * @description :Memcached 序列化与反序列化
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class MemObjectSamples {

    @Autowired
    private MemcachedClient memcachedClient;

    @Test
    public void operate() throws InterruptedException, MemcachedException, TimeoutException {
        memcachedClient.set("programmer", 0, new Programmer("xiaoming", 12, 5000.21f, new Date()));
        Programmer programmer = memcachedClient.get("programmer");
        System.out.println("hello ," + programmer.getName());
        memcachedClient.delete("programmer");
        programmer = memcachedClient.get("programmer");
        Assert.assertNull(programmer);
    }
}

附：memcached 基本命令

命令	格式	说明
新增 set	set key flags exTime length -> value	无论什么情况，都可以插入
新增 add	add key flags exTime length -> value	只有当key不存在的情况下，才可以插入
替换 replace	replace key flags exTime length -> value	只修改已存在key的value值
追加内容append	append key flags exTime length -> value	length表示追加的长度而不是总长度
前面追加prepend	prepend key flags exTime length -> value	length表示追加的长度而不是总长度
查询操作 get	get key
检查更新 cas	cas key flags exTime length version -> value	版本正确才更新
详细获取 gets	gets key	返回的最后一个数代表 key 的 CAS 令牌
删除 delete	delete key	将数据打一个删除标记
自增 incr	incr key 增加偏移量	incr和decr只能操作能转换为数字的Value
自减 decr	decr key 减少偏移量	desr不能将数字减少至0以下
清库	flush_all

6.5 KiB Raw Blame History Unescape Escape