redis

houko · houko · commit 4e1a95382e7a · 2016-11-19T11:25:53.000+08:00
diff --git a/redis/src/main/java/info/xiaomo/redis/RedisMain.java b/redis/src/main/java/info/xiaomo/redis/RedisMain.java
@@ -8,10 +8,8 @@
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.cache.RedisCacheManager;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 /**
  * 把今天最好的表现当作明天最新的起点．．～
@@ -31,6 +29,7 @@
 @EnableAutoConfiguration
 @ComponentScan("info.xiaomo")
 @EnableCaching
+@EnableScheduling
 public class RedisMain {
     public static void main(String[] args) throws Exception {
         SpringApplication.run(RedisMain.class, args);
@@ -41,11 +40,11 @@ public CacheManager cacheManager(RedisTemplate redisTemplate) {
         return new RedisCacheManager(redisTemplate);
     }
 
-    @Bean
-    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
-        final StringRedisTemplate template = new StringRedisTemplate(factory);
-        template.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class)); //请注意这里
-        return template;
-    }
+//    @Bean
+//    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
+//        final StringRedisTemplate template = new StringRedisTemplate(factory);
+//        template.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class)); //请注意这里
+//        return template;
+//    }
 
 }
diff --git a/redis/src/main/java/info/xiaomo/redis/job/TaskJob.java b/redis/src/main/java/info/xiaomo/redis/job/TaskJob.java
@@ -0,0 +1,44 @@
+package info.xiaomo.redis.job;
+
+import com.alibaba.fastjson.JSON;
+import info.xiaomo.redis.model.CityInfo;
+import info.xiaomo.redis.service.CityService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Random;
+
+@Component
+public class TaskJob {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(TaskJob.class);
+    private static final List<String> list = Arrays.asList("北京市", "上海市", "天津市", "重庆市", "河北省", "山西省", "内蒙古自治区", "辽宁省",
+            "吉林省", "黑龙江", "江苏省", "浙江省", "安徽省", "福建省", "江西省", "山东省", "河南省", "湖北省", "湖南省", "广东省", "广西自治区", "海南省", "四川省",
+            "贵州省", "云南省", "西藏自治区", "陕西省", "甘肃省", "青海省", "宁夏自治区", "新疆自治区", "香港特别行政区", "澳门特别行政区", "台湾省");
+    private final CityService cityService;
+
+    @Autowired
+    public TaskJob(CityService cityService) {
+        this.cityService = cityService;
+    }
+
+    /**
+     * Job
+     */
+    @Scheduled(fixedDelay = 500)
+    public void retrieveCountry() {
+        int index = new Random().nextInt(list.size());
+        String city = find(index);
+        CityInfo info = cityService.getCity(index, city);
+        LOGGER.debug("{}", JSON.toJSONString(info));
+    }
+
+    private String find(int index) {
+        return list.get(index);
+    }
+}
diff --git a/redis/src/main/java/info/xiaomo/redis/model/CityInfo.java b/redis/src/main/java/info/xiaomo/redis/model/CityInfo.java
@@ -0,0 +1,32 @@
+package info.xiaomo.redis.model;
+
+import java.io.Serializable;
+
+public class CityInfo implements Serializable{
+	private static final long serialVersionUID = 2845294956907027149L;
+	
+	private int id;
+	private String city;
+	
+	public CityInfo() {
+		
+	}
+	
+	public CityInfo(int id, String city) {
+		this.id = id;
+		this.city = city;
+	}
+	
+	public int getId() {
+		return id;
+	}
+	public void setId(int id) {
+		this.id = id;
+	}
+	public String getCity() {
+		return city;
+	}
+	public void setCity(String city) {
+		this.city = city;
+	}
+}
diff --git a/redis/src/main/java/info/xiaomo/redis/service/CityService.java b/redis/src/main/java/info/xiaomo/redis/service/CityService.java
@@ -0,0 +1,16 @@
+package info.xiaomo.redis.service;
+
+import info.xiaomo.redis.model.CityInfo;
+import org.springframework.cache.annotation.CacheConfig;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Component;
+
+@Component
+@CacheConfig(cacheNames="CityService")
+public class CityService {
+
+	@Cacheable
+	public CityInfo getCity(int id, String city) {
+		return new CityInfo(id, city);
+	}
+}
