快捷導(dǎo)航

SpringBoot 集成 Memcached的方法示例

更新時(shí)間：2019年05月13日 09:15:51 作者：Java_老男孩

這篇文章主要介紹了SpringBoot 集成 Memcached的方法示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

Memcached 介紹

Memcached 是一個(gè)高性能的分布式內(nèi)存對(duì)象緩存系統(tǒng)，用于動(dòng)態(tài)Web應(yīng)用以減輕數(shù)據(jù)庫(kù)負(fù)載。它通過(guò)在內(nèi)存中緩存數(shù)據(jù)和對(duì)象來(lái)減少讀取數(shù)據(jù)庫(kù)的次數(shù)，從而提高動(dòng)態(tài)、數(shù)據(jù)庫(kù)驅(qū)動(dòng)網(wǎng)站的速度。Memcached基于一個(gè)存儲(chǔ)鍵/值對(duì)的hashmap。其守護(hù)進(jìn)程（daemon ）是用C寫(xiě)的，但是客戶端可以用任何語(yǔ)言來(lái)編寫(xiě)，并通過(guò)memcached協(xié)議與守護(hù)進(jìn)程通信。

因?yàn)?Spring Boot 沒(méi)有針對(duì) Memcached 提供對(duì)應(yīng)的組建包，因此需要我們自己來(lái)集成。官方推出的 Java 客戶端 Spymemcached 是一個(gè)比較好的選擇之一。

Spymemcached 介紹

Spymemcached 最早由 Dustin Sallings 開(kāi)發(fā)，Dustin 后來(lái)和別人一起創(chuàng)辦了 Couchbase (原NorthScale)，職位為首席架構(gòu)師。2014 加入 Google。

Spymemcached 是一個(gè)采用 Java 開(kāi)發(fā)的異步、單線程的 Memcached 客戶端，使用 NIO 實(shí)現(xiàn)。Spymemcached 是 Memcached 的一個(gè)流行的 Java client 庫(kù)，性能表現(xiàn)出色，廣泛應(yīng)用于 Java + Memcached 項(xiàng)目中。

依賴配置

添加依賴

pomx 包中添加 spymemcached 的引用

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

添加配置

memcache.ip=192.168.0.161
memcache.port=11211

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

設(shè)置配置對(duì)象

創(chuàng)建 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") 的意思會(huì)以 memcache.* 為開(kāi)通將對(duì)應(yīng)的配置文件加載到屬性中。

啟動(dòng)初始化 MemcachedClient

我們使用上一節(jié)的內(nèi)容Spring Boot 2 (七)：Spring Boot 如何解決項(xiàng)目啟動(dòng)時(shí)初始化資源 ,利用 CommandLineRunner 在項(xiàng)目啟動(dòng)的時(shí)候配置好 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;
 }

}

測(cè)試使用

@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());
 }

}

使用中先測(cè)試插入一個(gè) key 為 testkey ，1000 為過(guò)期時(shí)間單位為毫秒，最后的 “666666” 為 key 對(duì)應(yīng)的值。

執(zhí)行測(cè)試用例 testSetGet ，控制臺(tái)輸出內(nèi)容：