服务器之家

服务器之家 > 正文

java中Memcached的使用实例(包括与Spring整合)

时间:2021-10-03 14:23     来源/作者:十禾。

一、什么是memcached?

memcached是danga.com开发的分布式内存对象缓存系统,所谓分布式,意味着它不是本地的,而是基于网络连接完成服务。memcached把一些数据通过key=value数据存储到内存中,这样访问更加方便快捷。

但是随之而来的问题是如果memcached关闭或者memcached的服务器关闭那么所保存的内容也就没有了。

二、安装memcached服务端

我是在win下做的实验。

首先下载win下的memcached,解压到指定目录。

memcached.exe -d install 安装memcached服务

然后通过memcached start memcached就启动了。

常用命令:

-p 监听的端口

-l 连接的ip地址, 默认是本机

-d start 启动memcached服务

-d restart 重起memcached服务

-d stop|shutdown 关闭正在运行的memcached服务

-d install 安装memcached服务

-d uninstall 卸载memcached服务

-u 以的身份运行 (仅在以root运行的时候有效)

-m 最大内存使用,单位mb。默认64mb

-m 内存耗尽时返回错误,而不是删除项

-c 最大同时连接数,默认是1024

-f 块大小增长因子,默认是1.25

-n 最小分配空间,key+value+flags默认是48

-h 显示帮助

三、java下使用memcached(java客户端程序)

目前常用客户端有三种,我使用的是java_memcached-release_2.6.6,该系列是最早推出也应用最为广泛的客户端。

所需全部的jar:

commons-pool-1.5.6.jar

java_memcached-release_2.6.6.jar

slf4j-api-1.6.1.jar

slf4j-simple-1.6.1.jar

1、基本使用:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
@test
    public  void show(){
        memcachedclient client=new memcachedclient();
        //使用的服务器,由于是在本地测试,只有一个服务器地址。默认端口是11211
        //格式为 服务器ip:端口号
        string [] addr={"127.0.0.1:11211"};
        /**
         * 设置权重,与设定的服务器一一对应
         */
        integer[] weight={3};
        //建立通信的连接池
        sockiopool pool=sockiopool.getinstance();
        //设置连接池可用cache服务器列表,服务器构成形式:ip地址+端口号
        pool.setservers(addr);
        //设置连接池可用cache服务器的权重,和server数组的位置一一对应
        pool.setweights(weight);
        //设置初始连接数
        pool.setinitconn(5);
        //设置最小连接数
        pool.setminconn(5);
        //设置最大连接数
        pool.setmaxconn(200);
        //设置可用连接的最长等待时间
        pool.setmaxidle(1000*30*30);
        //设置连接池维护线程的睡眠时间,设置为0,维护线程不启动
        pool.setmaintsleep(30);
        //设置nagle算法,设置为false,因为通讯数据量比较大要求相应及时
        pool.setnagle(false);
        //设置socket读取等待超时时间
        pool.setsocketto(30);
        //设置连接等待超时值
        pool.setsocketconnectto(0);
        //设置完参数后,启动pool
        pool.initialize();
        client.set("value","ok");
        string value= (string) client.get("value");
         //设置定时时间2s后消失
        client.set("value1","ok2",new date(2000));
        string value2= (string) client.get("value1");
        system.out.println(value);
        system.out.println(value2);
    }

2、spring整合memcached

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
<bean class="org.springframework.beans.factory.config.propertyplaceholderconfigurer">
        <property name="locations">
            <list>
                <value>classpath:property/memcached.properties</value>
            </list>
        </property>
    </bean>
    <!--spring整合memched-->
    <bean id="memcachedpool" class="com.danga.memcached.sockiopool" factory-method="getinstance"
          init-method="initialize"   destroy-method="shutdown">
        <property name="servers">
            <list>
                <value>${memcached.server}</value>
            </list>
        </property>
        <property name="maxconn" value="${memcached.maxconn}"></property>
        <property name="maintsleep" value="${memcached.manisleep}"></property>
        <property name="nagle" value="${memcached.nagle}"></property>
        <property name="socketto" value="${memcached.socketto}"></property>
    </bean>

properties配置文件:

?
1
2
3
4
5
6
7
8
9
10
11
12
#服务器地址
memcached.server=127.0.0.1:11211
#初始连接数目
memcached.initconn=20
#每个服务器建立最大连接数
memcached.maxconn=50
#自查线程周期工作,其每次休眠时间
memcached.manisleep=3000
#是否使用nagle算法(socket参数,如果是true,写数据不缓冲,直接发送)
memcached.nagle=false
#socket阻塞读取数据的超时时间
memcached.socketto=3000

测试:

?
1
2
3
4
5
6
7
8
9
10
11
@runwith(springjunit4classrunner.class)//表示整合junit进行测试
@contextconfiguration(locations ={"classpath:applicationcontext.xml"})
public class springtest {
    @test
    public void test1(){
        memcachedclient memcachedclient=new memcachedclient();
        memcachedclient.set("username","luck");
        string value= (string) memcachedclient.get("username");
        system.out.println(value);
    }
}

四、个人学习中遇到的问题:

我们通过客户端添加与获得数据,那么这个客户端如何与pool联系的,通过别人的博客找到答案。

客户端是通过pool的name关联到某个pool上的。

客户端与pool都没有指定名称的时候,默认是创建名称为“default”的pool,客户端与它关联。

如果pool设置了名字,那么客户也要指定名称。

memcached结合java基本操作

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
//创建memcachedclient    连接memcached服务器端
        memcachedclient mclient = new memcachedclient(new inetsocketaddress("127.0.0.1", 11211));
        system.out.println("连接memcached成功..........");
        //存储数据,key-ruo,value-888,时间是1000秒
        future future = mclient.set("ruo", 1000, "888");
        system.out.println("查看ruo的存储状态:"+future.get()+",存储的值:"+mclient.get("ruo"));
        //添加数据,如果key已经存储,则不会更新之前的value,返回not_stored
        future f1 = mclient.add("ruo", 1000, "999");
        system.out.println("查看添加ruo的存储状态:"+f1.get()+",添加后key:ruo的值是"+mclient.get("ruo"));
        //替换replace
        future f2 = mclient.replace("ruo", 1000, "999");
        system.out.println("查看替换ruo的存储状态:"+f2.get()+",替换后key:ruo的值是"+mclient.get("ruo"));
        //追加数据append,用来向已存在的key,追加数据
        future f3 = mclient.append("ruo","666");
        system.out.println("查看替换ruo的存储状态:"+f3.get()+",替换后key:ruo的值是"+mclient.get("ruo"));
        //prepend,用来向已存在的key对应的value前,追加数据
        future f4 = mclient.prepend("ruo", "555");
        system.out.println("查看替换ruo的存储状态:"+f4.get()+",替换后key:ruo的值是"+mclient.get("ruo"));
        //清空数据库
        mclient.flush();
        //关闭连接
        mclient.shutdown();

运行结果

2018-10-30 11:23:07.350 info net.spy.memcached.memcachedconnection: connection state changed for sun.nio.ch.selectionkeyimpl@38a22ea7
查看ruo的存储状态:true,存储的值:888
查看添加ruo的存储状态:false,添加后key:ruo的值是888
查看替换ruo的存储状态:true,替换后key:ruo的值是999
查看替换ruo的存储状态:true,替换后key:ruo的值是999666
查看替换ruo的存储状态:true,替换后key:ruo的值是555999666
2018-10-30 11:23:07.368 info net.spy.memcached.memcachedconnection: shut down memcached client

以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。

原文链接:https://www.cnblogs.com/GregZQ/p/8365276.html

标签:

相关文章

热门资讯

yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
2021年耽改剧名单 2021要播出的59部耽改剧列表
2021年耽改剧名单 2021要播出的59部耽改剧列表 2021-03-05
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
返回顶部