Spring Boot：使用Memcached緩存

時間 2020-05-09

標籤 spring boot 使用 memcached 緩存欄目 Spring 简体版

原文原文鏈接

綜合概述

Memcached是一個自由開源的，高性能，分佈式內存對象緩存系統。Memcached基於內存的key-value存儲，用來存儲小塊的任意數據，這些數據能夠是數據庫調用、API調用或者是頁面渲染的結果。經過Memcached緩存數據庫查詢結果，能夠有效地減小數據庫訪問次數，進而提升動態Web應用的速度。雖然Memcached的守護進程是用C寫的，可是客戶端能夠用任何語言來編寫，並經過Memcached協議與守護進程進行通訊。html

由於Spring Boot暫時尚未提供 Memcached相關的支持包，所以須要咱們經過集成第三方提供的Memcached客戶端來實現。Spymemcached是官方推出的一個Memcached Java客戶端，使用NIO實現，異步、單線程，在性能上表現出色，普遍應用於Java + Memcached項目中。java

實現案例

接下來，咱們就用一個簡單的案例來講明在Spring Boot中如何使用Memcached緩存技術。git

首先，須要安裝Memcached，教程不少，這裏再也不贅述。能夠參考：Memcached安裝教程。web

生成項目模板

爲方便咱們初始化項目，Spring Boot給咱們提供一個項目模板生成網站。spring

1. 打開瀏覽器，訪問：https://start.spring.io/數據庫

2. 根據頁面提示，選擇構建工具，開發語言，項目信息等。apache

3. 點擊 Generate the project，生成項目模板，生成以後會將壓縮包下載到本地。api

4. 使用IDE導入項目，我這裏使用Eclipse，經過導入Maven項目的方式導入。瀏覽器

添加相關依賴

清理掉不須要的測試類及測試依賴，添加 Maven 相關依賴，這裏須要添加上web、swagger和spymemcached的依賴，Swagger是爲了方便接口測試。緩存

對於spymemcached的支持，其實只要以下這個依賴包就能夠了。

<!-- spymemcached -->
<dependency>
  <groupId>net.spy</groupId>
  <artifactId>spymemcached</artifactId>
  <version>2.12.3</version>
</dependency>

完整的POM文件內容以下。

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.louis.springboot</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!-- web -->
        <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
        <!-- swagger -->
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger2</artifactId>
            <version>2.9.2</version>
        </dependency>
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger-ui</artifactId>
            <version>2.9.2</version>
        </dependency>
        <!-- spymemcached -->
        <dependency>
          <groupId>net.spy</groupId>
          <artifactId>spymemcached</artifactId>
          <version>2.12.3</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

添加相關配置

1.添加swagger 配置

添加一個swagger 配置類，在工程下新建 config 包並添加一個 SwaggerConfig 配置類，除了常規配置外，加了一個令牌屬性，能夠在接口調用的時候傳遞令牌。

SwaggerConfig.java

package com.louis.springboot.demo.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import springfox.documentation.builders.ApiInfoBuilder; import springfox.documentation.builders.PathSelectors; import springfox.documentation.builders.RequestHandlerSelectors; import springfox.documentation.service.ApiInfo; import springfox.documentation.spi.DocumentationType; import springfox.documentation.spring.web.plugins.Docket; import springfox.documentation.swagger2.annotations.EnableSwagger2; @Configuration @EnableSwagger2 public class SwaggerConfig { @Bean public Docket createRestApi(){ return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()) .select() .apis(RequestHandlerSelectors.any()) .paths(PathSelectors.any()).build(); } private ApiInfo apiInfo(){ return new ApiInfoBuilder() .title("Swagger API Doc") .description("This is a restful api document of Swagger.") .version("1.0") .build(); } }

2.在配置文件添加memcache的主機端口信息

application.properties

memcache.ip=127.0.0.1 memcache.port=11211

3.添加一個MemcacheConfig配置類，讀取主機端口並構造一個MemcachedClient。

MemcacheConfig.java

package com.louis.springboot.demo.config; import java.io.IOException; import java.net.InetSocketAddress; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import net.spy.memcached.MemcachedClient; @Configuration public class MemcacheConfig { @Value("${memcache.ip}") private String ip; @Value("${memcache.port}") private int port; @Bean public MemcachedClient getClient() { MemcachedClient memcachedClient = null; try { memcachedClient = new MemcachedClient(new InetSocketAddress(ip, port)); } catch (IOException e) { e.printStackTrace(); } return memcachedClient; } }

編寫業務接口

編寫一個業務控制器，經過MemcachedClient實現對緩存的設置和讀取。

MemcacheController.java

package com.louis.springboot.demo.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import net.spy.memcached.MemcachedClient; import net.spy.memcached.internal.OperationFuture; @RestController public class MemcacheController { @Autowired private MemcachedClient memcachedClient; @GetMapping("/memcache") public String memcache() throws InterruptedException { // 放入緩存, 以下參數key爲name，值爲louis，過時時間爲5000，單位爲毫秒
        OperationFuture<Boolean> flag = memcachedClient.set("name", 5000, "louis"); // 取出緩存
        Object value = memcachedClient.get("name"); System.out.println(value); // 多線程睡眠5秒,讓
        Thread.sleep(5000); value = memcachedClient.get("name"); System.out.println(value); return "success"; } }