怎么关闭Elasticsearch服务
guoyiqin 回复了问题 • 5 人关注 • 4 个回复 • 9800 次浏览 • 2016-04-06 17:06
通过elasticsearch head插件,无法关闭服务器
owen 回复了问题 • 3 人关注 • 3 个回复 • 6142 次浏览 • 2016-03-30 15:37
java使用HTTP Rest client 客户端Jest连接操作es,功能很强大
kl 发表了文章 • 6 个评论 • 27372 次浏览 • 2016-03-28 23:30
在了解jest框架前,楼主一直尝试用官方的Elasticsearch java api连接es服务的,可是,不知何故,一直报如下的异常信息,谷歌了很久,都说是jvm版本不一致导致的问题,可我是本地测试的,jvm肯定是一致的,这个问题现在都木有解决,but,这怎么能阻止我探索es的脚步呢,so,让我发现了jest 这个框架
org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream Caused by: org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
我的测试代码是参考官方api实例的,官方api地址:Elasticsearch java api,代码如下:
Client client = new TransportClient().addTransportAddress(new InetSocketTransportAddress("127.0.0.1", 9300)); QueryBuilder queryBuilder = QueryBuilders.termQuery("content", "搜"); SearchResponse searchResponse = client.prepareSearch("indexdata").setTypes("fulltext") .setQuery(queryBuilder) .execute() .actionGet(); SearchHits hits = searchResponse.getHits(); System.out.println("查询到记录数:" + hits.getTotalHits()); SearchHit[] searchHists = hits.getHits(); for(SearchHit sh : searchHists){ System.out.println("content:"+sh.getSource().get("content")); } client.close();
如果有人知道怎么回事,告诉一下楼主吧,让楼主坑的明白,感激不尽了,我的es版本是2.2.0
进入正题
了解jest
jest是一个基于 HTTP Rest 的连接es服务的api工具集,功能强大,能够使用es java api的查询语句,项目是开源的,github地址:https://github.com/searchbox-io/Jest
我的测试用例
分词器:ik,分词器地址:https://github.com/medcl/elasticsearch-analysis-ik ,es的很多功能都是基于插件提供的,es版本升级都2.2.0后,安装插件的方式不一样了,如果你安装ik分词插件有问题,请点击右上角的qq联系博主
新建索引
curl -XPUT http://localhost:9200/indexdata
创建索引的mapping,指定分词器
curl -XPOST http://localhost:9200/indexdata/fulltext/_mapping
{
"fulltext": {
"_all": {
"analyzer": "ik_max_word",
"search_analyzer": "ik_max_word",
"term_vector": "no",
"store": "false"
},
"properties": {
"content": {
"type": "string",
"store": "no",
"term_vector": "with_positions_offsets",
"analyzer": "ik_max_word",
"search_analyzer": "ik_max_word",
"include_in_all": "true",
"boost": 8
},
"description": {
"type": "string",
"store": "no",
"term_vector": "with_positions_offsets",
"analyzer": "ik_max_word",
"search_analyzer": "ik_max_word",
"include_in_all": "true",
"boost": 8
},
"title": {
"type": "string",
"store": "no",
"term_vector": "with_positions_offsets",
"analyzer": "ik_max_word",
"search_analyzer": "ik_max_word",
"include_in_all": "true",
"boost": 8
},
"keyword": {
"type": "string",
"store": "no",
"term_vector": "with_positions_offsets",
"analyzer": "ik_max_word",
"search_analyzer": "ik_max_word",
"include_in_all": "true",
"boost": 8
}
}
}
}
mapping信息可以用head插件查看,如下
导入数据和查询,看代码吧
@RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = ElasticSearchTestApplication.class) public class JestTestApplicationTests { @Autowired private KlarticleDao klarticleDao; //得到JestClient实例 public JestClient getClient()throws Exception{ JestClientFactory factory = new JestClientFactory(); factory.setHttpClientConfig(new HttpClientConfig .Builder("http://127.0.0.1:9200") .multiThreaded(true) .build()); return factory.getObject(); } /** * 导入数据库数据到es * @throws Exception */ @Test public void contextLoads() throws Exception{ JestClient client=getClient(); Listlists=klarticleDao.findAll(); for(Klarticle k:lists){ Index index = new Index.Builder(k).index("indexdata").type("fulltext").id(k.getArcid()+"").build(); System.out.println("添加索引----》"+k.getTitle()); client.execute(index); } //批量新增的方式,效率更高 Bulk.Builder bulkBuilder = new Bulk.Builder(); for(Klarticle k:lists){ Index index = new Index.Builder(k).index("indexdata").type("fulltext").id(k.getArcid()+"").build(); bulkBuilder.addAction(index); } client.execute(bulkBuilder.build()); client.shutdownClient(); } //搜索测试 @Test public void JestSearchTest()throws Exception{ SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query(QueryBuilders.matchQuery("content", "搜索")); Search search = new Search.Builder(searchSourceBuilder.toString()) // multiple index or types can be added. .addIndex("indexdata") .build(); JestClient client =getClient(); SearchResult result= client.execute(search); // List> hits = result.getHits(Klarticle.class); Listarticles = result.getSourceAsObjectList(Klarticle.class); for(Klarticle k:articles){ System.out.println("------->:"+k.getTitle()); } } }下面是依赖的jar,maven项目<!--jest依赖--> <dependency> <groupId>io.searchbox</groupId> <artifactId>jest</artifactId> <version>2.0.0</version> </dependency> <!--jest 日志依赖--> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.6.1</version> </dependency> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>2.2.0</version> </dependency> </dependencies>
去我的博客查看原文:http://www.kailing.pub/article/index/arcid/84.html
大家聊一聊使用的什么版本的Elasticsearch,看看Elasticsearch版本变化
kl 发表了文章 • 4 个评论 • 7379 次浏览 • 2016-03-28 19:12
org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream
谷歌都说是服务和客户端的jvm不一致,我是本机环境测试的,所以,现在这个问题都还没解决,有遇到过的么,还是和版本有关系啊 ES处理大数据插入运行几个小时候出现性能问题
helloes 回复了问题 • 2 人关注 • 1 个回复 • 12138 次浏览 • 2016-03-28 17:09
拼音搜索+中文搜索
niweiyi1314 回复了问题 • 11 人关注 • 5 个回复 • 22950 次浏览 • 2018-04-26 14:08
从mysql同步数据到es方法大讨论
sunyizhen 回复了问题 • 5 人关注 • 3 个回复 • 13817 次浏览 • 2016-08-04 17:23
ElasticsearchTimeoutException问题
helloes 回复了问题 • 2 人关注 • 1 个回复 • 9744 次浏览 • 2016-03-24 02:10
如何使用自定义的 Similarity插件
smile_sunshine 回复了问题 • 2 人关注 • 2 个回复 • 6441 次浏览 • 2016-03-24 21:04
elasticsearch 如何计算 TP50 TP95 TP99 这样的值?
medcl 回复了问题 • 3 人关注 • 2 个回复 • 9022 次浏览 • 2016-03-24 10:38
使用spark向elasticsearch中写入数据异常
joe23_2006 回复了问题 • 6 人关注 • 6 个回复 • 21240 次浏览 • 2018-01-31 13:36
Elasticsearch 2.2 集群配置
Jea 回复了问题 • 6 人关注 • 9 个回复 • 5408 次浏览 • 2017-04-14 13:45
aggregation 统计用户一天之内登录次数大于n次的用户列表, 这个应该怎么写聚合json
ggchangan 回复了问题 • 4 人关注 • 2 个回复 • 6293 次浏览 • 2016-03-22 15:32
es多字段匹配 按字段匹配情况自定义得分
Jea 回复了问题 • 1 人关注 • 3 个回复 • 6316 次浏览 • 2016-03-24 08:01
elasticsearch 文件句柄问题
elastic 回复了问题 • 3 人关注 • 2 个回复 • 5288 次浏览 • 2016-03-24 10:31