微服务开发与实战Day08 - Elasticsearch

在本章中，我们将介绍Elasticsearch及其在微服务架构中的应用。Elasticsearch是一个基于Lucene的搜索引擎，它提供了全文搜索能力，这对于需要复杂搜索功能的应用程序是一个非常有用的工具。

安装Elasticsearch

在开始之前，我们需要在本地机器上安装Elasticsearch。可以通过以下命令在Docker中运行Elasticsearch容器：

docker run -d --name elasticsearch -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" elasticsearch:7.10.0

使用Elasticsearch

在Java中，我们可以使用Elasticsearch的客户端库，例如Jest或者Spring Data Elasticsearch来与Elasticsearch进行交互。

使用Jest

首先，添加Jest依赖到demo-microservice-search-service模块的build.gradle文件中：

dependencies {
    implementation 'io.searchbox:jest:5.3.3'
}

然后，配置JestClient并使用它来索引和搜索数据：

@Service
public class ElasticsearchService {
 
    @Autowired
    private JestClient jestClient;
 
    public void indexItem(Item item) {
        Index index = new Index.Builder(item)
                .index("demo_items")
                .type("item")
                .build();
 
        try {
            jestClient.execute(index);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    public List<Item> searchItems(String query) {
        Search search = new Search.Builder(query)
                .addIndex("demo_items")
                .addType("item")
                .build();
 
        try {
            SearchResult result = jestClient.execute(search);
            return result.getSourceAsObjectList(Item.class);
        } catch (IOException e) {
            e.printStackTrace();
        }
 
        return Collections.emptyList();
    }
}

使用Spring Data Elasticsearch

首先，添加Spring Data Elasticsearch依赖到demo-microservice-search-service模块的build.gradle文件中：

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-elasticsearch'
}

然后，配置ElasticsearchRepository并使用它来进行数据操作：

@Repository
public interface ItemRepository extends ElasticsearchRepository<Item, String> {
    List<Item> findByNameContaining(String name);
}

在application.properties中配置Elasticsearch的连接信息：

spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=localhost:9300

这样，我们就可以在ItemService中使用ItemRepository来进行搜索操作：

@Service
public class ItemService {
 
    @Autowired
    private ItemRepository itemRepository;
 
    public List<Item> searchItems(String query) {
        return itemRepos