微博热搜推送添加缓存机制，避免推送重复的数据

src/main/java/com/zhiwei/searchhotcrawler/dao/WeiboHotSearchDAO.java

@@ -9,6 +9,7 @@ import com.mongodb.DBCursor;
 import com.mongodb.DBObject;
 import com.mongodb.WriteConcern;
 import com.zhiwei.searchhotcrawler.bean.WeiboHotSearch;
+import com.zhiwei.searchhotcrawler.cache.CacheManager;
 import com.zhiwei.searchhotcrawler.config.Config;
 import com.zhiwei.searchhotcrawler.dbtemplate.MongoDBTemplate;
 import com.zhiwei.zhiweiTools.tools.ZhiWeiTools;
@@ -87,18 +88,17 @@ public class WeiboHotSearchDAO extends MongoDBTemplate{
 		DBObject query = new BasicDBObject();
 		query.put("time", new BasicDBObject("$gte", date));
 		query.put("changeCount", 0);	
-		List<String> nameList = new ArrayList<String>();
+		
 		try {
 			DBCursor cur = this.getReadColl().find(query);
 			while(cur.hasNext()){
 				DBObject doc = cur.next();
 				String name = doc.get("name").toString();
-				if(!nameList.contains(name)){
-					nameList.add(name);
+				if(CacheManager.getCacheByKey(name)==null){
+					CacheManager.putCache(name, doc, 48*60*60*1000);
 					list.add(doc);
 				}
 			}
-			nameList.clear();
 			cur.close();
 		} catch (Exception e) {
 			return null;

src/main/java/com/zhiwei/searchhotcrawler/run/HotSearchRun.java

@@ -4,6 +4,7 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
+import com.zhiwei.searchhotcrawler.cache.CacheListener;
 import com.zhiwei.searchhotcrawler.timer.SendWeiboHotSearchRun;
 import com.zhiwei.searchhotcrawler.timer.SendZhihuHotSearchRun;
 import com.zhiwei.searchhotcrawler.timer.WeiboHotSearchRun;
@@ -15,17 +16,18 @@ public class HotSearchRun {
 	private ScheduledExecutorService scheduExec;
 
     public HotSearchRun() {
-        this.scheduExec = Executors.newScheduledThreadPool(4);
+        this.scheduExec = Executors.newScheduledThreadPool(1);
     }     
 
     public void showTimer() {
         scheduExec.scheduleAtFixedRate(new WeiboHotSearchRun(), 1000, 60 * 1000, TimeUnit.MILLISECONDS);
         scheduExec.scheduleAtFixedRate(new ZhihuHotSearchRun(), 1000, 60 * 1000 , TimeUnit.MILLISECONDS);
         scheduExec.scheduleAtFixedRate(new SendZhihuHotSearchRun(), 1000, 60 * 60 * 1000 , TimeUnit.MILLISECONDS);
-        scheduExec.scheduleAtFixedRate(new SendWeiboHotSearchRun(), 1000, 60 * 60 * 1000 , TimeUnit.MILLISECONDS);
+        scheduExec.scheduleAtFixedRate(new SendWeiboHotSearchRun(), 1000,  60*60 * 1000 , TimeUnit.MILLISECONDS);
     }
     
     public static void main(String[] args) {
 		new HotSearchRun().showTimer();
+		new CacheListener().startListen();
 	}
 }

src/main/java/com/zhiwei/searchhotcrawler/timer/SendWeiboHotSearchRun.java

@@ -16,6 +16,7 @@ import com.zhiwei.zhiweiTools.timeParse.TimeParse;
 
 public class SendWeiboHotSearchRun extends Thread{
 	private WeiboHotSearchDAO weiboHotSearchDAO = new WeiboHotSearchDAO();
+	
 	@Override
 	public void run() {
 		List<DBObject> list = weiboHotSearchDAO.getWeiboHotOneHour();