整合

依賴

    <dependency>
            <groupId>com.googlecode.xmemcached</groupId>
            <artifactId>xmemcached</artifactId>
            <version>2.4.5</version>
        </dependency>

配置

application.yml配置如下

memcached:
  //memcached服務(wù)器節(jié)點
  servers: 192.168.139.145:2222 192.168.139.145:6666
  //nio連接池的數(shù)量
  poolSize: 10
  //是否啟用url  encode機制
  sanitizeKeys: false

構(gòu)建一個config bean坪郭，對應(yīng)配置文件內(nèi)容

@Component
@ConfigurationProperties(prefix = "memcached")
public class XMemcachedProperties {

    private String servers;
    private Integer poolSize;
    private Boolean  santizeKeys;
    //省略getter-setter
}

構(gòu)造MemcachedClient

• 構(gòu)造MemcachedClient Bean之前啤它，需要先構(gòu)造MemcachedClientBuilder

    @Autowired
    private XMemcachedProperties properties;

    //構(gòu)建builder
    @Bean
    public MemcachedClientBuilder getXMBuilder(){
        MemcachedClientBuilder memcachedClientBuilder = null;
         try {
            String server =properties.getServers();
            memcachedClientBuilder= new XMemcachedClientBuilder(server);

            memcachedClientBuilder.setFailureMode(false);
            memcachedClientBuilder.setSanitizeKeys(properties.getSantizeKeys());
            memcachedClientBuilder.setConnectionPoolSize(properties.getPoolSize());
            memcachedClientBuilder.setCommandFactory(new BinaryCommandFactory());
            memcachedClientBuilder.setOpTimeout(3000);
            memcachedClientBuilder.setSessionLocator(new KetamaMemcachedSessionLocator());
            return  memcachedClientBuilder;
         }catch (Exception e){
            e.printStackTrace();
         }
         return null;
    }

• 構(gòu)造MemcachedClient

    @Bean
    public MemcachedClient getXMClient(MemcachedClientBuilder builder){
        MemcachedClient client = null;
        try {
            client = builder.build();
            return client;
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }

測試

• 編寫一個Service，注入MemcachedClient ，調(diào)用set/get命令

@Service
public class ShowService {

    @Autowired
    private MemcachedClient memcachedClient;


    public void showAdd(String key,String value){
        try {
            memcachedClient.set(key,3600,value);
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    public String showQuery(String key){
        try {
            return  memcachedClient.get(key);
        }catch (Exception e){
            e.printStackTrace();
        }
        return "";
    }

}

• 編寫junit

@RunWith(SpringRunner.class)
@SpringBootTest
public class DemoApplicationTests {

    @Autowired
    private ShowService showService;

    @Test
    public void contextLoads() {

        String key = "k1";
        String value= "k1value";

        String key2 = "k2";
        String value2= "k2value";
        showService.showAdd(key,value);
        showService.showAdd(key2,value2);
        System.out.println(showService.showQuery(key));
        System.out.println(showService.showQuery(key2));
    }

}