Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
messageflow
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
虞诚毅
messageflow
Commits
34436537
Commit
34436537
authored
Mar 08, 2019
by
303514581@qq.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
2019/3/8 正式版事件采集过滤规则添加
parent
5b3f996b
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
12 additions
and
11 deletions
+12
-11
src/main/java/com/zhiwei/messageflow/ES4RedisRunner.java
+2
-2
src/main/java/com/zhiwei/messageflow/ES4RedisStart.java
+2
-1
src/main/java/com/zhiwei/messageflow/config/ESConfig.java
+4
-4
src/main/resources/es.properties
+4
-4
No files found.
src/main/java/com/zhiwei/messageflow/ES4RedisRunner.java
View file @
34436537
...
@@ -35,8 +35,8 @@ public class ES4RedisRunner implements ApplicationRunner {
...
@@ -35,8 +35,8 @@ public class ES4RedisRunner implements ApplicationRunner {
// gs.getDataByeRedis("", "", 0, 0, 0);
// gs.getDataByeRedis("", "", 0, 0, 0);
ESGetCommonId
esGetCommonId
=
ApplicationContextProvider
.
getBean
(
"ESGetCommonId"
,
ESGetCommonId
.
class
);
ESGetCommonId
esGetCommonId
=
ApplicationContextProvider
.
getBean
(
"ESGetCommonId"
,
ESGetCommonId
.
class
);
esGetCommonId
.
getCommonId
();
esGetCommonId
.
getCommonId
();
esGetCommonId
.
getbackupStartId
();
//
esGetCommonId.getbackupStartId();
//
esGetCommonId.getStartId();
esGetCommonId
.
getStartId
();
// 启动时更新事件等待采集列表中的前十个任务状态为采集完毕
// 启动时更新事件等待采集列表中的前十个任务状态为采集完毕
boolean
isSuccess
=
esGetCommonId
.
updateTopTenCollection
();
boolean
isSuccess
=
esGetCommonId
.
updateTopTenCollection
();
...
...
src/main/java/com/zhiwei/messageflow/ES4RedisStart.java
View file @
34436537
...
@@ -38,7 +38,8 @@ public class ES4RedisStart {
...
@@ -38,7 +38,8 @@ public class ES4RedisStart {
private
Map
<
String
,
Boolean
>
PROJECTMAP
=
new
HashMap
<>();
private
Map
<
String
,
Boolean
>
PROJECTMAP
=
new
HashMap
<>();
private
static
final
int
PROJECTCOUNT
=
10
;
// private static final int PROJECTCOUNT = 10;
private
static
final
int
PROJECTCOUNT
=
40
;
/**
/**
* 启动线程
* 启动线程
...
...
src/main/java/com/zhiwei/messageflow/config/ESConfig.java
View file @
34436537
...
@@ -29,16 +29,16 @@ public class ESConfig {
...
@@ -29,16 +29,16 @@ public class ESConfig {
public
static
String
weiboMarkType
;
public
static
String
weiboMarkType
;
/** Es IP **/
/** Es IP **/
//
public static final String ESIP = "1.119.44.201";
public
static
final
String
ESIP
=
"1.119.44.201"
;
// public static final String ESIP = "202.107.192.94";
// public static final String ESIP = "202.107.192.94";
public
static
final
String
ESIP
=
"192.168.0.120"
;
//
public static final String ESIP = "192.168.0.120";
/** Es PORT **/
/** Es PORT **/
public
static
final
int
ESPORT
=
9200
;
public
static
final
int
ESPORT
=
9200
;
/** Es 9300PORT **/
/** Es 9300PORT **/
public
static
final
int
ESTCPPORT
=
9300
;
public
static
final
int
ESTCPPORT
=
9300
;
/** Es cluster.name **/
/** Es cluster.name **/
//
public static final String CLUSTERNAME = "Media-University";
public
static
final
String
CLUSTERNAME
=
"Media-University"
;
public
static
final
String
CLUSTERNAME
=
"my-test-es"
;
//
public static final String CLUSTERNAME = "my-test-es";
public
static
String
getIp
()
{
public
static
String
getIp
()
{
...
...
src/main/resources/es.properties
View file @
34436537
#es.ip=192.168.1.75
#es.ip=192.168.1.75
#
es.ip=1.119.44.201
es.ip
=
1.119.44.201
#es.ip=202.107.192.94
#es.ip=202.107.192.94
es.ip
=
192.168.0.120
#
es.ip=192.168.0.120
#es.ip=192.168.0.234
#es.ip=192.168.0.234
#es.ip=115.231.214.234
#es.ip=115.231.214.234
#es.ip=192.168.0.11
#es.ip=192.168.0.11
es.esPort
=
9300
es.esPort
=
9300
#
es.clusterName=Media-University
es.clusterName
=
Media-University
es.clusterName
=
my-test-es
#
es.clusterName=my-test-es
#es.clusterName=elasticsearch
#es.clusterName=elasticsearch
#es.clusterName=MyEsCluster
#es.clusterName=MyEsCluster
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment