<dependencies>

<!-- Spring Data Elasticsearch 依赖 -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-elasticsearch</artifactId>

</dependency>

<!-- Spring Boot 测试依赖 -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

</dependencies>

spring:

data:

elasticsearch:

cluster-name: elasticsearch # ES集群名称，默认为elasticsearch

cluster-nodes: localhost:9300 # ES节点地址，9300为传输端口，若使用默认配置可不修改

# 或者使用以下配置方式，适用于REST API连接

# uri: http://localhost:9200

import org.springframework.data.annotation.Id;

import org.springframework.data.elasticsearch.annotations.Document;

import org.springframework.data.elasticsearch.annotations.Field;

import org.springframework.data.elasticsearch.annotations.FieldType;

@Document(indexName = "blog", type = "_doc", shards = 1, replicas = 0)

public class Blog {

@Id

private String id;

@Field(type = FieldType.Text)

private String title;

@Field(type = FieldType.Text)

private String content;

// 省略getter和setter方法

}

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

import java.util.List;

public interface BlogRepository extends ElasticsearchRepository<Blog, String> {

List<Blog> findByTitleContaining(String keyword);

}

import org.springframework.stereotype.Service;

import java.util.List;

import java.util.Optional;

@Service

public class BlogService {

private final BlogRepository blogRepository;

public BlogService(BlogRepository blogRepository) {

this.blogRepository = blogRepository;

}

public Blog saveBlog(Blog blog) {

return blogRepository.save(blog);

}

public Optional<Blog> findBlogById(String id) {

return blogRepository.findById(id);

}

public List<Blog> searchBlogs(String keyword) {

return blogRepository.findByTitleContaining(keyword);

}

public void deleteBlogById(String id) {

blogRepository.deleteById(id);

}

}

import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

import java.util.Optional;

import static org.junit.jupiter.api.Assertions.*;

@SpringBootTest

public class BlogServiceTest {

@Autowired

private BlogService blogService;

@Test

public void testSaveAndFindBlog() {

Blog blog = new Blog();

blog.setTitle("Spring Boot集成ES测试文章");

blog.setContent("这是一篇用于测试的文章内容");

Blog savedBlog = blogService.saveBlog(blog);

assertNotNull(savedBlog.getId());

Optional<Blog> retrievedBlog = blogService.findBlogById(savedBlog.getId());

assertTrue(retrievedBlog.isPresent());

assertEquals("Spring Boot集成ES测试文章", retrievedBlog.get().getTitle());

}

@Test

public void testSearchBlogs() {

Blog blog1 = new Blog();

blog1.setTitle("Spring Boot入门教程");

blog1.setContent("详细介绍Spring Boot入门知识");

blogService.saveBlog(blog1);

Blog blog2 = new Blog();

blog2.setTitle("Elasticsearch实战");

blog2.setContent("分享Elasticsearch的实战经验");

blogService.saveBlog(blog2);

List<Blog> searchResults = blogService.searchBlogs("Spring Boot");

assertEquals(1, searchResults.size());

assertEquals("Spring Boot入门教程", searchResults.get(0).getTitle());

}

}

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;

import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;

@Configuration

@EnableElasticsearchRepositories(basePackages = "com.example.demo.repository")

public class ElasticsearchConfig {

@Bean

public ElasticsearchTemplate elasticsearchTemplate() {

return new ElasticsearchTemplate(elasticsearchClient());

}

// 省略elasticsearchClient方法的定义，根据实际连接方式编写

}