增加 spring boot memcached 用例

spring-boot/spring-boot-memcached/src/main/java/com/heibaiying/springboot/SpringBootMemcachedApplication.java

@@ -0,0 +1,14 @@
+package com.heibaiying.springboot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringBootMemcachedApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringBootMemcachedApplication.class, args);
+    }
+
+}
+

spring-boot/spring-boot-memcached/src/main/java/com/heibaiying/springboot/bean/Programmer.java

@@ -0,0 +1,26 @@
+package com.heibaiying.springboot.bean;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author : heibaiying
+ * @description :
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Programmer implements Serializable {
+
+    private String name;
+
+    private int age;
+
+    private float salary;
+
+    private Date birthday;
+}

spring-boot/spring-boot-memcached/src/main/java/com/heibaiying/springboot/config/MemcacheConfig.java

@@ -0,0 +1,68 @@
+package com.heibaiying.springboot.config;
+
+import net.rubyeye.xmemcached.MemcachedClient;
+import net.rubyeye.xmemcached.XMemcachedClientBuilder;
+import net.rubyeye.xmemcached.command.TextCommandFactory;
+import net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator;
+import net.rubyeye.xmemcached.transcoders.SerializingTranscoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author : heibaiying
+ */
+@Configuration
+public class MemcacheConfig {
+
+    /*
+     * Memcached 单机版本简单配置
+     */
+    @Bean
+    public MemcachedClient memcachedClient() {
+        XMemcachedClientBuilder builder = new XMemcachedClientBuilder("192.168.0.108:11211");
+        MemcachedClient memcachedClient = null;
+        try {
+            memcachedClient = builder.build();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return memcachedClient;
+    }
+
+    /*
+     * Memcached 集群版本配置
+     */
+
+    /*@Bean*/
+    public MemcachedClient memcachedClientForCluster() {
+
+        List<InetSocketAddress> addressList = new ArrayList<>();
+        addressList.add(new InetSocketAddress("192.168.0.108", 11211));
+        addressList.add(new InetSocketAddress("192.168.0.108", 11212));
+        // 赋予权重
+        int[] weights = {1, 2};
+        XMemcachedClientBuilder builder = new XMemcachedClientBuilder(addressList, weights);
+        // 设置连接池大小
+        builder.setConnectionPoolSize(10);
+        // 协议工厂
+        builder.setCommandFactory(new TextCommandFactory());
+        // 分布策略，一致性哈希KetamaMemcachedSessionLocator或者ArraySessionLocator(默认)
+        builder.setSessionLocator(new KetamaMemcachedSessionLocator());
+        // 设置序列化器
+        builder.setTranscoder(new SerializingTranscoder());
+        MemcachedClient memcachedClient = null;
+        try {
+            memcachedClient = builder.build();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return memcachedClient;
+    }
+
+
+}