SSM整合elasticsearch的详细配置

SSM（Spring + SpringMVC + MyBatis）框架整合 Elasticsearch 可以实现高效的全文搜索功能。以下是详细配置步骤：

1. 引入 Elasticsearch 依赖

在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.3.1</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.3.1</version>
</dependency>

2. 配置 Elasticsearch 连接

在 Spring 的配置文件（比如 applicationContext.xml）中添加以下配置：

<!-- 配置 Elasticsearch 连接 -->
<bean id="restHighLevelClient" class="org.elasticsearch.client.RestHighLevelClient">
    <constructor-arg name="builder">
        <bean class="org.elasticsearch.client.RestClient">
            <constructor-arg name="builder">
                <bean class="org.elasticsearch.client.RestClientBuilder">
                    <constructor-arg name="hosts">
                        <list>
                            <bean class="org.apache.http.HttpHost">
                                <constructor-arg name="hostname" value="localhost" />
                                <constructor-arg name="port" value="9200" />
                                <constructor-arg name="scheme" value="http" />
                            </bean>
                        </list>
                    </constructor-arg>
                </bean>
            </constructor-arg>
        </bean>
    </constructor-arg>
</bean>

其中，`HttpHost` 的参数可以根据实际情况进行修改。

3. 编写 Elasticsearch 操作工具类

@Component
public class ElasticsearchUtils {

    @Autowired
    private RestHighLevelClient restHighLevelClient;

    /**
     * 创建索引
     *
     * @param indexName 索引名称
     * @throws IOException
     */
    public void createIndex(String indexName) throws IOException {
        CreateIndexRequest request = new CreateIndexRequest(indexName);
        restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
    }

    /**
     * 删除索引
     *
     * @param indexName 索引名称
     * @throws IOException
     */
    public void deleteIndex(String indexName) throws IOException {
        DeleteIndexRequest request = new DeleteIndexRequest(indexName);
        restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
    }

    /**
     * 添加文档
     *
     * @param indexName 索引名称
     * @param id 文档 ID
     * @param source 文档内容
     * @throws IOException
     */
    public void addDocument(String indexName, String id, Map<String, Object> source) throws IOException {
        IndexRequest request = new IndexRequest(indexName).id(id).source(source);
        restHighLevelClient.index(request, RequestOptions.DEFAULT);
    }

    /**
     * 删除文档
     *
     * @param indexName 索引名称
     * @param id 文档 ID
     * @throws IOException
     */
    public void deleteDocument(String indexName, String id) throws IOException {
        DeleteRequest request = new DeleteRequest(indexName).id(id);
        restHighLevelClient.delete(request, RequestOptions.DEFAULT);
    }

    /**
     * 更新文档
     *
     * @param indexName 索引名称
     * @param id 文档 ID
     * @param source 更新内容
     * @throws IOException
     */
    public void updateDocument(String indexName, String id, Map<String, Object> source) throws IOException {
        UpdateRequest request = new UpdateRequest(indexName, id).doc(source);
        restHighLevelClient.update(request, RequestOptions.DEFAULT);
    }

    /**
     * 查询文档
     *
     * @param indexName 索引名称
     * @param query 查询条件
     * @return 查询结果
     * @throws IOException
     */
    public List<Map<String, Object>> searchDocuments(String indexName, QueryBuilder query) throws IOException {
        SearchRequest request = new SearchRequest(indexName);
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder().query(query);
        request.source(sourceBuilder);
        SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
        SearchHit[] hits = response.getHits().getHits();
        List<Map<String, Object>> result = new ArrayList<>();
        for (SearchHit hit : hits) {
            result.add(hit.getSourceAsMap());
        }
        return result;
    }
}

该工具类包含了 Elasticsearch 的基本操作，包括创建/删除索引、添加/删除/更新文档、查询文档等。

4. 编写 Elasticsearch 操作接口

public interface ElasticsearchService {
    void createIndex(String indexName) throws IOException;
    void deleteIndex(String indexName) throws IOException;
    void addDocument(String indexName, String id, Map<String, Object> source) throws IOException;
    void deleteDocument(String indexName, String id) throws IOException;
    void updateDocument(String indexName, String id, Map<String, Object> source) throws IOException;
    List<Map<String, Object>> searchDocuments(String indexName, QueryBuilder query) throws IOException;
}

5. 实现 Elasticsearch 操作接口

@Service
public class ElasticsearchServiceImpl implements ElasticsearchService {

    @Autowired
    private ElasticsearchUtils elasticsearchUtils;

    @Override
    public void createIndex(String indexName) throws IOException {
        elasticsearchUtils.createIndex(indexName);
    }

    @Override
    public void deleteIndex(String indexName) throws IOException {
        elasticsearchUtils.deleteIndex(indexName);
    }

    @Override
    public void addDocument(String indexName, String id, Map<String, Object> source) throws IOException {
        elasticsearchUtils.addDocument(indexName, id, source);
    }

    @Override
    public void deleteDocument(String indexName, String id) throws IOException {
        elasticsearchUtils.deleteDocument(indexName, id);
    }

    @Override
    public void updateDocument(String indexName, String id, Map<String, Object> source) throws IOException {
        elasticsearchUtils.updateDocument(indexName, id, source);
    }

    @Override
    public List<Map<String, Object>> searchDocuments(String indexName, QueryBuilder query) throws IOException {
        return elasticsearchUtils.searchDocuments(indexName, query);
    }
}

6. 使用 Elasticsearch

可以在任何需要使用 Elasticsearch 的地方注入 `ElasticsearchService` 接口，并调用相应的方法即可实现 Elasticsearch 相关操作。例如：

@Autowired
private ElasticsearchService elasticsearchService;

public void testElasticsearch() throws IOException {
    // 创建索引
    elasticsearchService.createIndex("test_index");

    // 添加文档
    Map<String, Object> source = new HashMap<>();
    source.put("title", "test title");
    source.put("content", "test content");
    elasticsearchService.addDocument("test_index", "1", source);

    // 查询文档
    QueryBuilder query = QueryBuilders.termQuery("title", "test");
    List<Map<String, Object>> result = elasticsearchService.searchDocuments("test_index", query);
    System.out.println(result);

    // 删除文档
    elasticsearchService.deleteDocument("test_index", "1");

    // 删除索引
    elasticsearchService.deleteIndex("test_index");
}

以上就是 SSM 框架整合 Elasticsearch 的详细配置步骤。