在弹性搜索中创建TransportClient时，在ThreadPool中限制线程数 [英] limit number of thread in ThreadPool while creating TransportClient in elasticsearch

问题描述

我正在弹性搜索中创建一个TransportClient实例。以下是相同的代码。问题是我试图降低传播客户端启动的线程池产生的线程数。但是我使用弹性搜索的设置总是用12个线程来初始化线程池。请让我知道如何配置相同的信息来获取所需的线程。

  public static TransportClient getTransportClient（String ip，int port） {
 
 ImmutableSettings.Builder settings = ImmutableSettings 
 .settingsBuilder（）; 
 settings.put（cluster.name，elasticsearch）; 
 settings.put（threadpool.bulk.type，fixed）; 
 settings.put（threadpool.bulk.size，5）; 
 settings.put（threadpool.bulk.queue_size，5）; 
 settings.put（threadpool.index.type，fixed）; 
 settings.put（threadpool.index.size，5）; 
 settings.put（threadpool.index.queue_size，10）; 
 settings.put（threadpool.search.type，fixed）; 
 settings.put（threadpool.search.size，5）; 
 settings.put（threadpool.search.queue_size，5）; 
 
 settings.build（）; 
 
 TransportClient instance = new TransportClient（settings）
 .addTransportAddress（new InetSocketTransportAddress（ip，port））; 
 
返回实例; 
} 
  

解决方案

尝试

 设置设置= ImmutableSettings.settingsBuilder（）
 .put（transport.netty.workerCount，NUM_THREADS）
 .build （）; 
  

信用于JanuZ，取自

I'm creating a TransportClient instance in elasticsearch. Below is the code for the same. The issue is I'm trying to lower the number of threads spawned with the threadpool that TransportClient initiates. But what ever settings I use my elasticsearch always initialing the threadpool with 12 threads. Please let me know how to configure the same to get the desirable threads.

public static TransportClient getTransportClient(String ip, int port) {

    ImmutableSettings.Builder settings = ImmutableSettings
            .settingsBuilder();
    settings.put("cluster.name", "elasticsearch");
    settings.put("threadpool.bulk.type",  "fixed");
    settings.put("threadpool.bulk.size" ,5);
    settings.put("threadpool.bulk.queue_size", 5);
    settings.put("threadpool.index.type" , "fixed");
    settings.put("threadpool.index.size" , 5);
    settings.put("threadpool.index.queue_size" , 10);
    settings.put("threadpool.search.type",  "fixed");
    settings.put("threadpool.search.size" ,5);
    settings.put("threadpool.search.queue_size", 5);

    settings.build();

    TransportClient instance = new TransportClient(settings)
            .addTransportAddress(new InetSocketTransportAddress(ip, port));

    return instance;
}

解决方案

Try

Settings settings = ImmutableSettings.settingsBuilder()
                    .put("transport.netty.workerCount",NUM_THREADS)
                    .build();

Credit to JanuZ, taken from http://www.lucidelectricdreams.com/2013/11/reducing-number-of-threads-created-by.html

这篇关于在弹性搜索中创建TransportClient时，在ThreadPool中限制线程数的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！