Spring Boot 2 (八):Spring Boot 集成 Memcached详解编程语言

Spring Boot 2 (八):Spring Boot 集成 Memcached

一、Memcached 介绍

Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态、数据库驱动网站的速度。Memcached基于一个存储键/值对的hashmap。其守护进程(daemon )是用C写的,但是客户端可以用任何语言来编写,并通过memcached协议与守护进程通信。

因为 Spring Boot 没有针对 Memcached 提供对应的组建包,因此需要我们自己来集成。官方推出的 Java 客户端 Spymemcached 是一个比较好的选择之一。

Spymemcached 介绍:

Spymemcached 最早由 Dustin Sallings 开发,Dustin 后来和别人一起创办了 Couchbase (原NorthScale),职位为首席架构师。2014 加入 Google。

Spymemcached 是一个采用 Java 开发的异步、单线程的 Memcached 客户端, 使用 NIO 实现。Spymemcached 是 Memcached 的一个流行的 Java client 库,性能表现出色,广泛应用于 Java + Memcached 项目中。

二、依赖配置

1,添加依赖

pomx 包中添加 spymemcached 的引用:

<dependency> 
  <groupId>net.spy</groupId> 
  <artifactId>spymemcached</artifactId> 
  <version>2.12.2</version> 
</dependency>

2,添加配置

memcache.ip=192.168.0.161 
memcache.port=11211

分别配置 memcache 的 Ip 地址和 端口。

3,设置配置对象

创建 MemcacheSource 接收配置信息:

@Component 
@ConfigurationProperties(prefix = "memcache") 
public class MemcacheSource { 
 
    private String ip; 
 
    private int port; 
 
    public String getIp() { 
        return ip; 
    } 
 
    public void setIp(String ip) { 
        this.ip = ip; 
    } 
 
    public int getPort() { 
        return port; 
    } 
 
    public void setPort(int port) { 
        this.port = port; 
    } 
}

@ConfigurationProperties(prefix = "memcache") 的意思会以 memcache.* 为开通将对应的配置文件加载到属性中。

三、启动初始化 MemcachedClient

利用 CommandLineRunner 在项目启动的时候配置好 MemcachedClient 。

@Component 
public class MemcachedRunner implements CommandLineRunner { 
    protected Logger logger =  LoggerFactory.getLogger(this.getClass()); 
 
    @Resource 
    private  MemcacheSource memcacheSource; 
 
    private MemcachedClient client = null; 
 
    @Override 
    public void run(String... args) throws Exception { 
        try { 
            client = new MemcachedClient(new InetSocketAddress(memcacheSource.getIp(),memcacheSource.getPort())); 
        } catch (IOException e) { 
            logger.error("inint MemcachedClient failed ",e); 
        } 
    } 
 
    public MemcachedClient getClient() { 
        return client; 
    } 
 
}

四、测试使用

@RunWith(SpringRunner.class) 
@SpringBootTest 
public class RepositoryTests { 
 
  @Resource 
    private MemcachedRunner memcachedRunner; 
 
  @Test 
  public void testSetGet()  { 
    MemcachedClient memcachedClient = memcachedRunner.getClient(); 
    memcachedClient.set("testkey",1000,"666666"); 
    System.out.println("***********  "+memcachedClient.get("testkey").toString()); 
  } 
 
}

使用中先测试插入一个 key 为 testkey ,1000 为过期时间单位为 毫秒,最后的 “666666” 为 key 对应的值。

执行测试用例 testSetGet ,控制台输出内容:

***********  666666

表明测试成功。

 

原创文章,作者:Maggie-Hunter,如若转载,请注明出处:https://blog.ytso.com/tech/pnotes/16640.html

(0)
上一篇 2021年7月19日 19:29
下一篇 2021年7月19日 19:29

相关推荐

发表回复

登录后才能评论