Xmemcached使用之与Spring整合

标签: xmemcached spring | 发表时间:2014-06-23 14:26 | 作者:liyonghui160com
出处:http://www.iteye.com

 

 

<dependency>
    <groupId>com.googlecode.xmemcached</groupId>
    <artifactId>xmemcached</artifactId>
    <version>1.4.3</version>
    <type>pom</type>
</dependency>

 

项目启动配置文件:

 

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <bean id="propertyConfigurer"
          class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:memcachedconf.properties</value>
            </list>
        </property>
    </bean>
    <import resource="classpath:spring/clerk-memcached.xml"/>
</beans>

 

 

 

clerk-memcached.xml中代码如下:

 

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!--xmemcached 配置-->
    <bean name="xmemcachedClient" class="net.rubyeye.xmemcached.utils.XMemcachedClientFactoryBean"
          destroy-method="shutdown">
        <property name="servers" value="${memcached.servers}"/>
        <property name="weights">
            <list>
                  <value>1</value>
                  <value>2</value>
                  <value>3</value>
            </list>
        </property>
        <property name="connectionPoolSize" value="${memcached.connectionPoolSize}"/>
        <property name="sessionLocator">
            <bean class="net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator"/>
        </property>
        <property name="transcoder">
            <bean class="net.rubyeye.xmemcached.transcoders.SerializingTranscoder"/>
        </property>
        <property name="bufferAllocator">
            <bean class="net.rubyeye.xmemcached.buffer.SimpleBufferAllocator"/>
        </property>
        <property name="failureMode" value="true"/>
    </bean>
    <!--简单封装的memcached客户端-->
    <bean name="memcachedClient" class="com.si.util.Memcached">
        <property name="isOpen" value="${memcached.isOpen}"/>
        <property name="expires" value="${memcached.expires}"/>
        <property name="memcachedClient" ref="xmemcachedClient"/>
    </bean>
</beans>

 

 

其中各参数的意义:

参数

含义

servers

服务器列表,格式:ip:port

weights

主机映射:host1对应1号、host2对应2号..

sessionLocator

Session 分配器,有自带的,影响分布式

transcoder

通信编码方式

bufferAllocator

缓冲区分配器

 

 

 

memcachedconf.properties中的代码如下

 

 

#memcached开关
memcached.isOpen=true
#过期时间15分钟,单位(秒)
memcached.expires=3600
#memcached服务器列表
memcached.servers=host1:port1 host2:port2
#memcached 连接池大小
memcached.connectionPoolSize=30

 

 

com.si.clerk.util.Memcached的java类代码

 

 

package com.si.util;

import net.rubyeye.xmemcached.MemcachedClient;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import java.util.*;

public class Memcached {
    private static Log log = LogFactory.getLog(Memcached.class);
    private boolean isOpen; // Memcached 开关
    private int expires;    // 默认过期时间
    private MemcachedClient mc;

    /*
    add 仅当存储空间中不存在键相同的数据时才保存
     */
    public <T> void addWithNoReply(String key, T value) {
        this.addWithNoReply(key, expires, value);
    }

    /**
     * 设置键值对
     * @param key     key
     * @param expires 单位:秒,0 表示永不过期
     * @param value   必须是一个可序列化的对象, 可以是容器类型如:List,但容器里面保存的对象必须是可序列化的
     */
    public <T> void addWithNoReply(String key, int expires, T value) {
        if (StringUtil.isEmpty(key)) return;
        try {
            if (isOpen && mc != null) {
                mc.addWithNoReply(key, expires, value);
            }
        } catch(Exception e) {
            log.error(e.getMessage(), e);
        }
    }

    /*
    set 无论何时都保存
     */
    public <T> void set(String key, T value) {
        this.set(key, expires, value);
    }

    /**
     * 设置键值对
     * @param key     key
     * @param expires 单位:秒,0 表示永不过期
     * @param value   必须是一个可序列化的对象, 可以是容器类型如:List,但容器里面保存的对象必须是可序列化的
     */
    public <T> void set(String key, int expires, T value) {
        if (StringUtil.isEmpty(key)) return;
        try {
            if (isOpen && mc != null) {
                mc.set(key, expires, value);
            }
        } catch(Exception e) {
            log.error(e.getMessage(), e);
        }
    }

    /**
     * 根据key获得值
     * @param key key
     * @return value
     */
    public <T> T get(String key) {
        try {
            if (!StringUtil.isEmpty(key) && isOpen && mc != null) {
                return (T)mc.get(key);
            }
        } catch(Exception e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }

    /**
     * 给每个原始key加上前缀后,再查。
     * @param keys                 原始key
     * @param memcachedKeyPrefix   前缀
     * @return
     */
    public <T> Map<String, T> getMulti(Collection keys, String memcachedKeyPrefix) {
        if (CommonTools.isEmpty(keys)) return null;
        if ("".equals(memcachedKeyPrefix)) {
            return this.get(keys);
        }
        List<String> strList = new ArrayList<String>();
        for (Object key : keys) {
            strList.add(memcachedKeyPrefix + String.valueOf(key));
        }
        return this.get(strList);
    }

    /**
     * 重载方法
     * @param keys
     * @param <T>
     * @return
     */
    public <T> Map<String, T> getMulti(Collection keys) {
        return getMulti(keys, "");
    }

    /**
     * 批量获取
     * @param keys keys
     * @return valueMap
     */
    private <T> Map<String, T> get(Collection<String> keys) {
        Map<String, T> map = null;
        try {
            if (keys != null && isOpen && mc != null) {
                map = mc.get(keys);
            }
        } catch(Exception e) {
            log.error(e.getMessage(), e);
        }
        return map;
    }

    public void setIsOpen(boolean open) {
        isOpen = open;
    }

    public void setExpires(int expires) {
        this.expires = expires;
    }

    public void setMemcachedClient(MemcachedClient mc) {
        this.mc = mc;
    }


}

 

 

 

 



已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [xmemcached spring] 推荐:

Xmemcached使用之与Spring整合

- - 互联网 - ITeye博客
clerk-memcached.xml中代码如下:. . . 服务器列表,格式:ip:port. 主机映射:host1对应1号、host2对应2号... Session 分配器,有自带的,影响分布式. memcachedconf.properties中的代码如下.

xmemcached作者Dennis采访(转)

- - 企业架构 - ITeye博客
xmemcached是最近频繁出现在JavaEye新闻频道的热点词汇,它就是JavaEye的资深会员Dennis开发的基于java nio实现的高性能可扩展的memcached客户端. Dennis 在自己实现的一个nio框架  http://code.google.com/p/yanf4j/ 的基础上实现了xmemcached项目(目前1.1.3是基于yanf4j 0.7.0),xmemcached的序列化机制使用spymemcached的Transcoder并做了部分改造.

Spring详解

- - CSDN博客架构设计推荐文章
Spring是一个开源的控制反转(Inversion of Control ,IoC)和面向切面(AOP)的容器框架.它的主要目的是简化企业开发.. PersonDaoBean 是在应用内部创建及维护的. 所谓控制反转就是应用本身不负责依赖对象的创建及维护,依赖对象的创建及维护是由外部容器负责的.

Spring定时

- - 行业应用 - ITeye博客
spring的定时任务配置分为三个步骤:. . . . . .

简单Spring+hessian

- - Web前端 - ITeye博客
简单的Spring+hessian. dist\modules里面的 spring-webmvc.jar . lib\caucho 里面的hessian-3.1.3.jar. 里面有个接口interface:. 建立一个model层:(实现Serializable接口). 在WEB-INF下面创建一个remoting-servlet.xml:.

Spring MVC 和 Struts2

- - CSDN博客架构设计推荐文章
Web层面的框架学习了三个Struts1和2,SpringMVC,那他们之间肯定存在一个优劣和适用的环境,Struts1和2的异同点我已经做过对比《 Struts1和Struts2》,这篇将对比下Struts2和SpringMVC的异同,下面数据基本来源于网络,本人是搜集整理所得,供大家参考. 一个项目使用什么样的技术,决定的因素很多,我所能想到的有:对系统的性能、开发的效率、团队学习的成本、业务场景等,下面尽量从这几个方面入手,来分析比较下他们之间存在的优劣.

Spring AOP详解

- - Java - 编程语言 - ITeye博客
        最近项目中遇到了以下几点需求,仔细思考之后,觉得采用AOP来解决. 一方面是为了以更加灵活的方式来解决问题,另一方面是借此机会深入学习Spring AOP相关的内容. 例如,以下需求不用AOP肯定也能解决,至于是否牵强附会,仁者见仁智者见智. 1.对部分函数的调用进行日志记录,用于观察特定问题在运行过程中的函数调用情况.

spring roo 入门

- - 企业架构 - ITeye博客
Spring官网下载STS(如果没有STS). 创建Spring Roo基础项目. 根 据ROO的提示输入jpa setup再按ctrl+space,很遗憾这个快捷键已经被输入法切换占用,不能借助提示输入命令,但我们可以打开ROO命令向导,这里我们输入jpa 可以查到这条命令的用法,根据提示增加provider和database选项来完成命令.

Spring Rmi配置

- - 企业架构 - ITeye博客
现在远程调用一般用RPC,webservice或者Rmi,而目前用的比较多的是webservice和Rmi. webservice和rmi的最主要的区别,rmi的客户端和服务端都必须是java,webservice没有这个限制,webservice是在http协议上传递xml文本文件. 与语言和平台无关,rmi是在tcp协议上传递可序列化的java对象,只能用在java虚拟机上,绑定语言.

Spring+memcached整合

- - 行业应用 - ITeye博客
1)  下载memcached服务端memcached-1.2.6-win32-bin.zip,地址:http:. 2)  下载java版客户端 java_memcached-release_2.6.1.zip. 3)  解压缩memcached-1.2.6-win32-bin.zip到指定目录,例如:D:\memcached-1.2.6-win32 ,.