我想编写一些与 ElasticSearch 的集成。为了进行测试，我想运行内存中的 ES。

我在文档中找到了一些信息，但没有示例如何编写此类测试。 Elasticsearch Reference [1.6] » Testing » Java Testing Framework » integration tests « unit tests

我也找到了下面的文章，但是没有数据了。 Easy JUnit testing with Elastic Search

我正在查看如何在内存中启动和运行 ES 以及如何通过 REST API 访问它的示例。

最佳答案

基于 the second link你提供的，我创建了这个抽象测试类:

@RunWith(SpringJUnit4ClassRunner.class)
public abstract class AbstractElasticsearchTest {

    private static final String HTTP_PORT = "9205";
    private static final String HTTP_TRANSPORT_PORT = "9305";
    private static final String ES_WORKING_DIR = "target/es";

    private static Node node;

    @BeforeClass
    public static void startElasticsearch() throws Exception {    
        removeOldDataDir(ES_WORKING_DIR + "/" + clusterName);

        Settings settings = Settings.builder()
                .put("path.home", ES_WORKING_DIR)
                .put("path.conf", ES_WORKING_DIR)
                .put("path.data", ES_WORKING_DIR)
                .put("path.work", ES_WORKING_DIR)
                .put("path.logs", ES_WORKING_DIR)
                .put("http.port", HTTP_PORT)
                .put("transport.tcp.port", HTTP_TRANSPORT_PORT)
                .put("index.number_of_shards", "1")
                .put("index.number_of_replicas", "0")
                .put("discovery.zen.ping.multicast.enabled", "false")
                .build();
        node = nodeBuilder().settings(settings).clusterName("monkeys.elasticsearch").client(false).node();
        node.start();
    }

    @AfterClass
    public static void stopElasticsearch() {
        node.close();
    }

    private static void removeOldDataDir(String datadir) throws Exception {
        File dataDir = new File(datadir);
        if (dataDir.exists()) {
            FileSystemUtils.deleteRecursively(dataDir);
        }
    }    
}

在生产代码中，我配置了一个 Elasticsearch 客户端，如下所示。集成测试扩展了上面定义的抽象类并将属性elasticsearch.port配置为9305，将elasticsearch.host配置为localhost.

@Configuration
public class ElasticsearchConfiguration {    
    @Bean(destroyMethod = "close")
    public Client elasticsearchClient(@Value("${elasticsearch.clusterName}") String clusterName,
                                      @Value("${elasticsearch.host}") String elasticsearchClusterHost,
                                      @Value("${elasticsearch.port}") Integer elasticsearchClusterPort) throws UnknownHostException {
        Settings settings = Settings.settingsBuilder().put("cluster.name", clusterName).build();
        InetSocketTransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName(elasticsearchClusterHost), elasticsearchClusterPort);
        return TransportClient.builder().settings(settings).build().addTransportAddress(transportAddress);
    }
}

就是这样。集成测试将运行配置为连接到在 AbstractElasticsearchTest.startElasticsearch() 中启动的节点的生产代码。

如果您想使用 elasticsearch REST api，请使用端口 9205。例如使用 Apache HttpComponents:

HttpClient httpClient = HttpClients.createDefault();
HttpPut httpPut = new HttpPut("http://localhost:9205/_template/" + templateName);
httpPut.setEntity(new FileEntity(new File("template.json")));
httpClient.execute(httpPut);

关于java - ElasticSearch in-memory 用于测试，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31400491/