Java开发：如何实现搜索引擎和全文检索功能

import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.queryparser.classic.QueryParser;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.RAMDirectory;

public class LuceneExample {
    public static void main(String[] args) throws Exception {
        // 创建索引存储目录
        Directory directory = new RAMDirectory();
        
        // 创建索引写入器
        IndexWriter indexWriter = new IndexWriter(directory, new StandardAnalyzer());
        
        // 创建文档并添加到索引中
        Document doc1 = new Document();
        doc1.add(new Field("content", "Java开发", Field.Store.YES, Field.Index.ANALYZED));
        indexWriter.addDocument(doc1);
        
        Document doc2 = new Document();
        doc2.add(new Field("content", "搜索引擎", Field.Store.YES, Field.Index.ANALYZED));
        indexWriter.addDocument(doc2);
        
        indexWriter.close();
        
        // 搜索文档
        DirectoryReader reader = DirectoryReader.open(directory);
        IndexSearcher searcher = new IndexSearcher(reader);
        
        QueryParser parser = new QueryParser("content", new StandardAnalyzer());
        Query query = parser.parse("Java");
        
        TopDocs topDocs = searcher.search(query, 10);
        
        for (ScoreDoc scoreDoc : topDocs.scoreDocs) {
            Document document = searcher.doc(scoreDoc.doc);
            System.out.println("搜索结果: " + document.get("content"));
        }
    }
}

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class ElasticsearchExample {
    public static void main(String[] args) throws IOException {
        // 创建Elasticsearch客户端
        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder("localhost:9200"));
        
        // 构建搜索请求
        SearchRequest searchRequest = new SearchRequest("index_name");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchQuery("content", "Java"));
        searchSourceBuilder.size(10);
        searchSourceBuilder.timeout(TimeValue.timeValueSeconds(5));
        searchRequest.source(searchSourceBuilder);
        
        // 执行搜索请求，并处理搜索结果
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        
        for (SearchHit hit : searchResponse.getHits().getHits()) {
            System.out.println("搜索结果: " + hit.getSourceAsString());
        }
        
        // 关闭Elasticsearch客户端
        client.close();
    }
}