Easysearch、Elasticsearch 还是 Opensearch,是个问题

java代码连接es集群报错

Elasticsearch | 作者 PhoebM | 发布于2018年03月04日 | 阅读数:5192

QQ图片20180304143622.png

es都是6.1.2的版本,安装了x-pack不过禁用了安全检查(kibana和head都是直接登录的)
 控制台错误,下面是代码:
java.lang.IllegalStateException: Unsupported transport.type [netty4]

at org.elasticsearch.common.network.NetworkModule.getTransportSupplier(NetworkModule.java:212)
at org.elasticsearch.client.transport.TransportClient.buildTemplate(TransportClient.java:179)
at org.elasticsearch.client.transport.TransportClient.<init>(TransportClient.java:273)
at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:128)
at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:114)
at org.elasticsearch.transport.client.PreBuiltTransportClient.<init>(PreBuiltTransportClient.java:104)
at com.dmsdbj.bebavior.service.impl.ElasticClientOrIndexImp.getClient(ElasticClientOrIndexImp.java:33)
at testTransDataToEs.addData(testTransDataToEs.java:29)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:263)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:69)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:48)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:231)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:60)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:229)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:50)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:222)
at org.junit.runners.ParentRunner.run(ParentRunner.java:292)
at org.junit.runner.JUnitCore.run(JUnitCore.java:157)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:237)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
  @Test
public void addData() {
TestClass testClass = new TestClass();
ElasticClientOrIndex elasticClientOrIndex = new ElasticClientOrIndexImp();
testClass.setUserId("1");
testClass.setUserName("mjx");
String json = JSON.toJSON(testClass).toString();
TransportClient client ;
client = elasticClientOrIndex.getClient();
IndexResponse response = client.prepareIndex("test","test1",testClass.getUserId()).setSource(json).execute().actionGet();
System.out.println(response);
}
第二行代码报错,集群名字没有错吧,您看一下上面的图片,我感觉是没有错的:
  Settings settings = Settings.builder().put("cluster.name", "user-action-data").build();// 设置集群名称
TransportClient client = new PreBuiltTransportClient(settings);
已邀请:

laoyang360 - 《一本书讲透Elasticsearch》作者,Elastic认证工程师 [死磕Elasitcsearch]知识星球地址:http://t.cn/RmwM3N9;微信公众号:铭毅天下; 博客:https://elastic.blog.csdn.net

赞同来自:

集群名称的确认:
GET /_cluster/health,不过head插件中间显示的也是集群名称,确认你的集群名称是正确的。
 

要回复问题请先登录注册