spring-boot-elasticsearch ES全文搜索引擎，基于Elasticsearch構(gòu)建網(wǎng)站日志處理系統(tǒng)，通過數(shù)據(jù)同步工具等一些列開源組件來快速構(gòu)建一個(gè)日志處理系統(tǒng)，項(xiàng)目雛形初步成型中。

開發(fā)環(huán)境

JDK1.8、Maven、Eclipse、SpringBoot1.5.9、elasticsearch2.4.6、Dubbo2.6.2、zookeeper3.4.13、Redis、kafka、Vue、Iview

接入方式

使用spring-boot中的spring-data-elasticsearch,可以使用兩種內(nèi)置客戶端接入

1、節(jié)點(diǎn)客戶端(node client)： 配置文件中設(shè)置為local:false,節(jié)點(diǎn)客戶端以無數(shù)據(jù)節(jié)點(diǎn)(node-master或node-client)身份加入集群，換言之，它自己不存儲(chǔ)任何數(shù)據(jù)，但是它知道數(shù)據(jù)在集群中的具體位置，并且能夠直接轉(zhuǎn)發(fā)請(qǐng)求到對(duì)應(yīng)的節(jié)點(diǎn)上。

2、傳輸客戶端(Transport client)： 配置文件中設(shè)置為local:true,這個(gè)更輕量的傳輸客戶端能夠發(fā)送請(qǐng)求到遠(yuǎn)程集群。它自己不加入集群，只是簡(jiǎn)單轉(zhuǎn)發(fā)請(qǐng)求給集群中的節(jié)點(diǎn)。 兩個(gè)Java客戶端都通過9300端口與集群交互，使用Elasticsearch傳輸協(xié)議(Elasticsearch Transport Protocol)。集群中的節(jié)點(diǎn)之間也通過9300端口進(jìn)行通信。如果此端口未開放，你的節(jié)點(diǎn)將不能組成集群。

項(xiàng)目結(jié)構(gòu)

├─src
│ ├─main
│ │ ├─java
│ │ │ └─com
│ │ │ └─itstyle
│ │ │ └─es
│ │ │ │ Application.java
│ │ │ │
│ │ │ ├─common
│ │ │ │ ├─constant
│ │ │ │ │ PageConstant.java
│ │ │ │ │
│ │ │ │ └─interceptor
│ │ │ │ MyAdapter.java
│ │ │ │
│ │ │ └─log
│ │ │ ├─controller
│ │ │ │ LogController.java
│ │ │ │
│ │ │ ├─entity
│ │ │ │ Pages.java
│ │ │ │ SysLogs.java
│ │ │ │
│ │ │ ├─repository
│ │ │ │ ElasticLogRepository.java
│ │ │ │
│ │ │ └─service
│ │ │ │ LogService.java
│ │ │ │
│ │ │ └─impl
│ │ │ LogServiceImpl.java
│ │ │
│ │ ├─resources
│ │ │ │ application-dev.properties
│ │ │ │ application-prod.properties
│ │ │ │ application-test.properties
│ │ │ │ application.yml
│ │ │ │
│ │ │ ├─static
│ │ │ │ ├─iview
│ │ │ │ │ │ iview.css
│ │ │ │ │ │ iview.min.js
│ │ │ │ │ │
│ │ │ │ │ └─fonts
│ │ │ │ │ ionicons.eot
│ │ │ │ │ ionicons.svg
│ │ │ │ │ ionicons.ttf
│ │ │ │ │ ionicons.woff
│ │ │ │ │
│ │ │ │ ├─jquery
│ │ │ │ │ jquery-3.2.1.min.js
│ │ │ │ │
│ │ │ │ └─vue
│ │ │ │ vue.min.js
│ │ │ │
│ │ │ └─templates
│ │ │ └─log
│ │ │ index.html
│ │ │
│ │ └─webapp
│ │ │ index.jsp
│ │ │
│ │ └─WEB-INF
│ │ web.xml
│ │
│ └─test
│ └─java
│ └─com
│ └─itstyle
│ └─es
│ └─test
│ Logs.java
│