在弹性搜索中创建TransportClient时,在ThreadPool中限制线程数 [英] limit number of thread in ThreadPool while creating TransportClient in elasticsearch
本文介绍了在弹性搜索中创建TransportClient时,在ThreadPool中限制线程数的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
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 ();
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屋!
查看全文