Commit 092f98d7 by zhiwei

修改为新版去重

parent f67a184e
...@@ -3,7 +3,7 @@ ...@@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.zhiwei</groupId> <groupId>com.zhiwei</groupId>
<artifactId>weibohotcrawler</artifactId> <artifactId>weibohotcrawler</artifactId>
<version>0.0.7-SNAPSHOT</version> <version>0.0.8-SNAPSHOT</version>
<name>weibohotcrawler</name> <name>weibohotcrawler</name>
<description>微博热搜1小时榜单,社会、热点采集程序</description> <description>微博热搜1小时榜单,社会、热点采集程序</description>
...@@ -35,11 +35,11 @@ ...@@ -35,11 +35,11 @@
<scope>provided</scope> <scope>provided</scope>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.zhiwei.middleware</groupId> <groupId>com.zhiwei.middleware</groupId>
<artifactId>cleaner-unified-urlfilterNew</artifactId> <artifactId>cleaner-unified-filter</artifactId>
<version>0.0.6-SNAPSHOT</version> <version>1.0.1.RELEASE</version>
<scope>provided</scope>
</dependency> </dependency>
</dependencies> </dependencies>
<!-- 打包管理 --> <!-- 打包管理 -->
<build> <build>
......
...@@ -12,18 +12,16 @@ public class Config { ...@@ -12,18 +12,16 @@ public class Config {
conf = new Properties(); conf = new Properties();
conf.load(is); conf.load(is);
is.close(); is.close();
rsidUrl = conf.getProperty("zookeeper"); zookeeper = conf.getProperty("zookeeper");
rsidGroup = conf.getProperty("group"); group = conf.getProperty("group");
redisWeiboKey = conf.getProperty("rsidType");
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
public static String rsidUrl; public static String zookeeper;
public static String rsidGroup; public static String group;
public static String redisWeiboKey;
......
...@@ -18,7 +18,7 @@ import com.zhiwei.weibobusiness.weibo4j.model.StatusWapper; ...@@ -18,7 +18,7 @@ import com.zhiwei.weibobusiness.weibo4j.model.StatusWapper;
import com.zhiwei.weibobusiness.weibo4j.model.WeiboException; import com.zhiwei.weibobusiness.weibo4j.model.WeiboException;
import com.zhiwei.weibocrawler.httpclient.HttpClientDemo; import com.zhiwei.weibocrawler.httpclient.HttpClientDemo;
import com.zhiwei.weibocrawler.rsidClient.DataQueue; import com.zhiwei.weibocrawler.rsidClient.DataQueue;
import com.zhiwei.weibocrawler.rsidClient.RsidClientDAO; import com.zhiwei.weibocrawler.rsidClient.RsidRedisClient;
/** /**
* *
...@@ -117,7 +117,7 @@ public class WeiboCrawlerAnalysis { ...@@ -117,7 +117,7 @@ public class WeiboCrawlerAnalysis {
if(!midsList.isEmpty()){ if(!midsList.isEmpty()){
for(String mid : midsList){ for(String mid : midsList){
boolean f = RsidClientDAO.isWeiboExit(mid); boolean f = RsidRedisClient.isNotDuplicated(mid);
if (!f) { if (!f) {
DataQueue.offer(mid); DataQueue.offer(mid);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment