Skip to content

Commit a72d15f

Browse files
JavaCodeMingJavaCodeMing
committed
新增SpringBoot整合Elasticsearch案例
1 parent 56fa086 commit a72d15f

25 files changed

+1235
-0
lines changed

‎Spring-Boot-Elasticsearch/pom.xml

+83
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,83 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
<parent>
6+
<groupId>org.springframework.boot</groupId>
7+
<artifactId>spring-boot-starter-parent</artifactId>
8+
<version>2.2.6.RELEASE</version>
9+
<relativePath/> <!-- lookup parent from repository -->
10+
</parent>
11+
<groupId>com.example</groupId>
12+
<artifactId>elasticsearch</artifactId>
13+
<version>0.0.1-SNAPSHOT</version>
14+
<name>Spring-Boot-Elasticsearch</name>
15+
<description>Demo project for Spring Boot</description>
16+
17+
<properties>
18+
<java.version>1.8</java.version>
19+
<elasticsearch.version>7.6.0</elasticsearch.version>
20+
<fastjson.version>1.2.68</fastjson.version>
21+
<commons-lang3.version>3.10</commons-lang3.version>
22+
</properties>
23+
24+
<dependencies>
25+
<dependency>
26+
<groupId>org.springframework.boot</groupId>
27+
<artifactId>spring-boot-starter-web</artifactId>
28+
</dependency>
29+
<dependency>
30+
<groupId>org.springframework.boot</groupId>
31+
<artifactId>spring-boot-starter-thymeleaf</artifactId>
32+
</dependency>
33+
<!-- Java Low Level REST Client -->
34+
<dependency>
35+
<groupId>org.elasticsearch.client</groupId>
36+
<artifactId>elasticsearch-rest-client</artifactId>
37+
<version>${elasticsearch.version}</version>
38+
</dependency>
39+
<!-- Java High Level REST Client -->
40+
<dependency>
41+
<groupId>org.elasticsearch.client</groupId>
42+
<artifactId>elasticsearch-rest-high-level-client</artifactId>
43+
<version>${elasticsearch.version}</version>
44+
</dependency>
45+
<dependency>
46+
<groupId>com.alibaba</groupId>
47+
<artifactId>fastjson</artifactId>
48+
<version>${fastjson.version}</version>
49+
</dependency>
50+
<!-- Commons-Lang3工具包 -->
51+
<dependency>
52+
<groupId>org.apache.commons</groupId>
53+
<artifactId>commons-lang3</artifactId>
54+
<version>${commons-lang3.version}</version>
55+
</dependency>
56+
<dependency>
57+
<groupId>org.projectlombok</groupId>
58+
<artifactId>lombok</artifactId>
59+
<optional>true</optional>
60+
</dependency>
61+
<dependency>
62+
<groupId>org.springframework.boot</groupId>
63+
<artifactId>spring-boot-starter-test</artifactId>
64+
<scope>test</scope>
65+
<exclusions>
66+
<exclusion>
67+
<groupId>org.junit.vintage</groupId>
68+
<artifactId>junit-vintage-engine</artifactId>
69+
</exclusion>
70+
</exclusions>
71+
</dependency>
72+
</dependencies>
73+
74+
<build>
75+
<plugins>
76+
<plugin>
77+
<groupId>org.springframework.boot</groupId>
78+
<artifactId>spring-boot-maven-plugin</artifactId>
79+
</plugin>
80+
</plugins>
81+
</build>
82+
83+
</project>

‎Spring-Boot-Elasticsearch/src/main/java/com/example/elasticsearch/SpringBootElasticsearchApplication.java

+13
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.example.elasticsearch;
2+
3+
import org.springframework.boot.SpringApplication;
4+
import org.springframework.boot.autoconfigure.SpringBootApplication;
5+
6+
@SpringBootApplication
7+
public class SpringBootElasticsearchApplication {
8+
9+
public static void main(String[] args) {
10+
SpringApplication.run(SpringBootElasticsearchApplication.class, args);
11+
}
12+
13+
}

‎Spring-Boot-Elasticsearch/src/main/java/com/example/elasticsearch/config/ExceptionAdvice.java

+74
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
package com.example.elasticsearch.config;
2+
3+
import com.example.elasticsearch.domain.ResponseBean;
4+
import com.example.elasticsearch.exception.CustomException;
5+
import com.example.elasticsearch.exception.SystemException;
6+
import org.springframework.http.HttpStatus;
7+
import org.springframework.web.bind.annotation.ExceptionHandler;
8+
import org.springframework.web.bind.annotation.ResponseStatus;
9+
import org.springframework.web.bind.annotation.RestControllerAdvice;
10+
import org.springframework.web.servlet.NoHandlerFoundException;
11+
12+
import javax.servlet.http.HttpServletRequest;
13+
14+
/**
15+
* @author dengzhiming
16+
* @date 2020/5/1 14:48
17+
*/
18+
@RestControllerAdvice
19+
public class ExceptionAdvice {
20+
/**
21+
* 捕捉自定义异常
22+
* @return ResponseBean
23+
*/
24+
@ResponseStatus(HttpStatus.BAD_REQUEST)
25+
@ExceptionHandler(CustomException.class)
26+
public ResponseBean handle(CustomException e) {
27+
return new ResponseBean(HttpStatus.BAD_REQUEST.value(), e.getMessage(), null);
28+
}
29+
30+
/**
31+
* 捕捉系统异常
32+
* @return ResponseBean
33+
*/
34+
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
35+
@ExceptionHandler(SystemException.class)
36+
public ResponseBean handle(SystemException e) {
37+
return new ResponseBean(HttpStatus.INTERNAL_SERVER_ERROR.value(), e.getMessage(), null);
38+
}
39+
40+
/**
41+
* 捕捉404异常
42+
* @return ResponseBean
43+
*/
44+
@ResponseStatus(HttpStatus.NOT_FOUND)
45+
@ExceptionHandler(NoHandlerFoundException.class)
46+
public ResponseBean handle(NoHandlerFoundException e) {
47+
return new ResponseBean(HttpStatus.NOT_FOUND.value(), e.getMessage(), null);
48+
}
49+
50+
/**
51+
* 捕捉其他所有异常
52+
* @param request 请求对象
53+
* @param ex 异常
54+
* @return ResponseBean
55+
*/
56+
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
57+
@ExceptionHandler(Exception.class)
58+
public ResponseBean globalException(HttpServletRequest request, Throwable ex) {
59+
return new ResponseBean(this.getStatus(request).value(), ex.toString() + ": " + ex.getMessage(), null);
60+
}
61+
62+
/**
63+
* 获取状态码
64+
* @param request 请求对象
65+
* @return HttpStatus
66+
*/
67+
private HttpStatus getStatus(HttpServletRequest request) {
68+
Integer statusCode = (Integer) request.getAttribute("javax.servlet.error.status_code");
69+
if (statusCode == null) {
70+
return HttpStatus.INTERNAL_SERVER_ERROR;
71+
}
72+
return HttpStatus.valueOf(statusCode);
73+
}
74+
}

‎Spring-Boot-Elasticsearch/src/main/java/com/example/elasticsearch/config/RestClientConfig.java

+47
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
package com.example.elasticsearch.config;
2+
3+
import org.apache.http.Header;
4+
import org.apache.http.HttpHost;
5+
import org.apache.http.message.BasicHeader;
6+
import org.elasticsearch.client.RestClient;
7+
import org.elasticsearch.client.RestClientBuilder;
8+
import org.elasticsearch.client.RestHighLevelClient;
9+
import org.springframework.beans.factory.annotation.Value;
10+
import org.springframework.context.annotation.Bean;
11+
import org.springframework.context.annotation.Configuration;
12+
13+
@Configuration
14+
public class RestClientConfig {
15+
@Value("${elasticsearch.hostname}")
16+
private String hostname;
17+
@Value("${elasticsearch.port}")
18+
private int port;
19+
20+
/**
21+
* LowLevelRestConfig
22+
*
23+
* @return org.elasticsearch.client.RestClient
24+
*/
25+
@Bean
26+
public RestClient restClient() {
27+
// 如果有多个从节点可以持续在内部new多个HttpHost，参数1是IP，参数2是端口，参数3是通信协议
28+
RestClientBuilder clientBuilder = RestClient.builder(new HttpHost(hostname, port, "http"));
29+
// 设置Header编码
30+
Header[] defaultHeaders = {new BasicHeader("content-type", "application/json")};
31+
clientBuilder.setDefaultHeaders(defaultHeaders);
32+
// 添加其他配置，这些配置都是可选的，详情配置可看https://blog.csdn.net/jacksonary/article/details/82729556
33+
return clientBuilder.build();
34+
}
35+
36+
/**
37+
* HighLevelRestConfig
38+
*
39+
* @return org.elasticsearch.client.RestClient
40+
*/
41+
@Bean
42+
public RestHighLevelClient restHighLevelClient() {
43+
// 如果有多个从节点可以持续在内部new多个HttpHost，参数1是IP，参数2是端口，参数3是通信协议
44+
return new RestHighLevelClient(RestClient.builder(new HttpHost(hostname, port, "http")));
45+
}
46+
47+
}

‎Spring-Boot-Elasticsearch/src/main/java/com/example/elasticsearch/config/WebMvcConfig.java

+24
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
package com.example.elasticsearch.config;
2+
3+
import org.springframework.context.annotation.Configuration;
4+
import org.springframework.core.Ordered;
5+
import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;
6+
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
7+
8+
/**
9+
* @author dengzhiming
10+
* @date 2020/5/1 14:49
11+
*/
12+
@Configuration
13+
public class WebMvcConfig implements WebMvcConfigurer {
14+
/**
15+
* 设置首页
16+
*
17+
* @param registry 注册器
18+
*/
19+
@Override
20+
public void addViewControllers(ViewControllerRegistry registry) {
21+
registry.addViewController("/").setViewName("forward:/index.shtml");
22+
registry.setOrder(Ordered.HIGHEST_PRECEDENCE);
23+
}
24+
}

0 commit comments

Comments
 (0)