zoukankan      html  css  js  c++  java
  • java客户端提交数据到memcached方法memcached+java+client个人总结 东师理想

    尊重作者辛勤劳动,转载请注明!

    (2013-3-22续)本人新用simple-spring-memcached配置在spring-mvc中,感觉非常方便,有兴趣的朋友可以去看看

    (2013-4-9续)本人信用spring-aop + memcached配置memcached的更新操作,存取list<bean>,更实际使用,点击这里

    (2013-4-10续 本人实现了不用数据库临时表的方法,见 利用Spring AOP 更新memcached 缓存策略的实现(二))

    2013-4-28续 spring配置xmemcached及使用

    终于把nginx+memcached+tomcat集群windows下布置完成,但是遇到java客户端提交数据到memcached的问题,上网看了好多人的帖子,发现了3种方法

    1. 三种API比较
    1)      memcached client for java

    较早推出的memcached JAVA客户端API,应用广泛,运行比较稳定。


    2)      spymemcached

    A simple, asynchronous, single-threaded memcached client written in java. 支持异步,单线程的memcached客户端,用到了java1.5版本的concurrent和nio,存取速度会高于前者,但是稳定性不好,测试中常报timeOut等相关异常。


    3)      xmemcached

    XMemcached 同样是基于java nio的客户端,java nio相比于传统阻塞io模型来说,有效率高(特别在高并发下)和资源耗费相对较少的优点。传统阻塞IO为了提高效率,需要创建一定数量的连接形成连接池,而nio仅需要一个连接即可(当然,nio也是可以做池化处理),相对来说减少了线程创建和切换的开销,这一点在高并发下特别明显。因此 XMemcached与Spymemcached在性能都非常优秀,在某些方面(存储的数据比较小的情况下)Xmemcached比 Spymemcached的表现更为优秀,具体可以看这个Java Memcached Clients Benchmark。


    2.  建议

    由于memcached client for java发布了新版本,性能上有所提高,并且运行稳定,所以建议使用memcached client for java。

    XMemcached 也使用得比较广泛,而且有较详细的中文API文档,具有如下特点:高性能、支持完整的协议、支持客户端分布、允许设置节点权重、动态增删节点、支持 JMX、与Spring框架和Hibernate-memcached的集成、客户端连接池、可扩展性好等。

    我使用的是建议方法memcached client for java,

    Memcached-Java-Client官网jar包的下载地址:

    https://github.com/gwhalin/Memcached-Java-Client/downloads

    Memcached-Java-Client的说明文档:

    https://github.com/gwhalin/Memcached-Java-Client

    具体实现步骤为:

    1.将jar包引入项目中,我引入了4个commons-pool-1.5.6.jar,java_memcached-release_2.6.2.jar,slf4j-api-1.6.1.jar,slf4j-simple-1.6.1.jar

    2.写测试代码:

    import java.util.Date;
    
    import com.danga.MemCached.MemCachedClient;
    import com.danga.MemCached.SockIOPool;
    
    
    /**
    * 使用memcached的缓存实用类.
    * 
    * @author 原作者:铁木箱子  完善:周枫
    *
    */
    public class MemCached
    {
        // 创建全局的唯一实例
        protected static MemCachedClient mcc = new MemCachedClient();
        
        protected static MemCached memCached = new MemCached();
        
        // 设置与缓存服务器的连接池
        static {
            // 服务器列表和其权重,个人memcached地址和端口号
            String[] servers = {"192.168.88.137:11211"};
            Integer[] weights = {3};
    
            // 获取socke连接池的实例对象
            SockIOPool pool = SockIOPool.getInstance();
    
            // 设置服务器信息
            pool.setServers( servers );
            pool.setWeights( weights );
    
            // 设置初始连接数、最小和最大连接数以及最大处理时间
            pool.setInitConn( 5 );
            pool.setMinConn( 5 );
            pool.setMaxConn( 250 );
            pool.setMaxIdle( 1000 * 60 * 60 * 6 );
    
            // 设置主线程的睡眠时间
            pool.setMaintSleep( 30 );
    
            // 设置TCP的参数,连接超时等
            pool.setNagle( false );
            pool.setSocketTO( 3000 );
            pool.setSocketConnectTO( 0 );
    
            // 初始化连接池
            pool.initialize();
    
           
        }
        
        /**
         * 保护型构造方法,不允许实例化!
         *
         */
        protected MemCached()
        {
            
        }
        
        /**
         * 获取唯一实例.
         * @return
         */
        public static MemCached getInstance()
        {
            return memCached;
        }
        
        /**
         * 添加一个指定的值到缓存中.
         * @param key
         * @param value
         * @return
         */
        public boolean add(String key, Object value)
        {
            return mcc.add(key, value);
        }
        
        public boolean add(String key, Object value, Date expiry)
        {
            return mcc.add(key, value, expiry);
        }
        
        /**
         * 替换一个指定的值到缓存中.
         * @param key
         * @param value
         * @return
         */
        public boolean replace(String key, Object value)
        {
            return mcc.replace(key, value);
        }
        
        public boolean replace(String key, Object value, Date expiry)
        {
            return mcc.replace(key, value, expiry);
        }
        
        /**
         * 删除一个指定的值到缓存中.
         * @param key
         * @param value
         * @return
         */
        public boolean delete(String key)
        {
        	return mcc.delete(key);
        }
        
        
        /**
         * 根据指定的关键字获取对象.
         * @param key
         * @return
         */
        public Object get(String key)
        {
            return mcc.get(key);
        }
        
        public static void main(String[] args)
        {
            MemCached cache = MemCached.getInstance();
            //cache.add("zf", 18);
            //cache.replace("zf", 19);
            cache.delete("zf");
            System.out.println("zf get value : " + cache.get("zf"));
        }
    }
    

    3.测试阶段

    1)取消cache.add("zf",18)注释,将cache.replace("zf", 19);和cache.delete("zf");注释掉,增加zf到memcached中

    2)将cache.add("zf",18);cache.replace("zf", 19);和cache.delete("zf");注释,输出结果为刚才添加的内容,表示该值已经存入memcached中

    3) 将cache.delete("zf");取消注释,再运行,控制台输出 zf get value : null,该值已删除

    其他测试方法:

    使用telnet命令语句查看:

    1)cmd中输入telnet 192.168.88.137 11211(自己memcached地址及端口号)

    2)输入命令stats,查看 STAT curr_items 数量,增加、修改、删除此数量随之变化

    具体memcached输入stats命令解释如下:(转载:http://www.cnblogs.com/suger/archive/2011/09/06/2168319.html

    STAT pid 1552

    STAT uptime 3792

    STAT time 1262517674

    STAT version 1.2.6

    STAT pointer_size 32

    STAT curr_items 1

    STAT total_items 2

    STAT bytes 593

    STAT curr_connections 2

    STAT total_connections 28

    STAT connection_structures 9

    STAT cmd_get 3

    STAT cmd_set 2

    STAT get_hits 2

    STAT get_misses 1

    STAT evictions 0

    STAT bytes_read 1284

    STAT bytes_written 5362

    STAT limit_maxbytes 67108864

    STAT threads 1

    END

    这里显示了很多状态信息,下边详细解释每个状态项:

    1.  pid: memcached服务进程的进程ID

    2.  uptime: memcached服务从启动到当前所经过的时间,单位是秒。

    3.  time: memcached服务器所在主机当前系统的时间,单位是秒。

    4.  version: memcached组件的版本。这里是我当前使用的1.2.6。

    5.  pointer_size:服务器所在主机操作系统的指针大小,一般为32或64.

    6.  curr_items:表示当前缓存中存放的所有缓存对象的数量。不包括目前已经从缓存中删除的对象。

    7.  total_items:表示从memcached服务启动到当前时间,系统存储过的所有对象的数量,包括目前已经从缓存中删除的对象。

    8.  bytes:表示系统存储缓存对象所使用的存储空间,单位为字节。

    9.  curr_connections:表示当前系统打开的连接数。

    10. total_connections:表示从memcached服务启动到当前时间,系统打开过的连接的总数。

    11. connection_structures:表示从memcached服务启动到当前时间,被服务器分配的连接结构的数量,这个解释是协议文档给的,具体什么意思,我目前还没搞明白。

    12. cmd_get:累积获取数据的数量,这里是3,因为我测试过3次,第一次因为没有序列化对象,所以获取数据失败,是null,后边有2次是我用不同对象测试了2次。

    13. cmd_set:累积保存数据的树立数量,这里是2.虽然我存储了3次,但是第一次因为没有序列化,所以没有保存到缓存,也就没有记录。

    14. get_hits:表示获取数据成功的次数。

    15. get_misses:表示获取数据失败的次数。

    16. evictions:为了给新的数据项目释放空间,从缓存移除的缓存对象的数目。比如超过缓存大小时根据LRU算法移除的对象,以及过期的对象。

    17. bytes_read:memcached服务器从网络读取的总的字节数。

    18. bytes_written:memcached服务器发送到网络的总的字节数。

    19. limit_maxbytes:memcached服务缓存允许使用的最大字节数。这里为67108864字节,也就是是64M.与我们启动memcached服务设置的大小一致。

    20. threads:被请求的工作线程的总数量。这个解释是协议文档给的,具体什么意思,我目前还没搞明白。

  • 相关阅读:
    一个随机数生成函数
    HTTP Post请求过程详解
    md5加密算法c语言版
    android popupwindow 自定义视图
    android 获取顶部状态栏的高度
    android 显示和隐藏输入框
    android tablayout + recycleview 简单使用
    jetpack paging使用
    android 自定义控件 属性配置
    vueLazyload 图片懒加载
  • 原文地址:https://www.cnblogs.com/cczhoufeng/p/2344220.html
Copyright © 2011-2022 走看看