全文检索及ES学习笔记

上一篇学习了lucene原理及简单的使用.这次基于lucene上学习一下ES的使用.

之前在linux上部署过ES(之前的文章有部署流程),然后今天启动发现启动不起来,报错
No factory method found for class org.apache.logging.log4j.core.appender.RollingFileAppender

于是搜了一下,ES启动报错No factory method found for class org.apache.logging.log4j.core.appender.RollingFileAppender

是因为之前以root的身份进入log文件导致文件权限变成了root权限
将文件权限修改一下即可
执行命令: chown yyy[我的用户名] xxx.log
修改完后启动正常了.

ES集群:

创建es-clutser文件夹,在内部复制三个ES服务.
然后分别修改每个ES服务中elasticsearch-cluster\node*\config\elasticsearch.yml配置文件:

node1节点&＃xff1a;

#节点1的配置信息&＃xff1a;
#集群名称&＃xff0c;保证唯一
cluster.name: my-elasticsearch
#节点名称&＃xff0c;必须不一样
node.name: node-1
#必须为本机的ip地址
network.host: 127.0.0.1
#服务端口号&＃xff0c;在同一机器下必须不一样
http.port: 9200
#集群间通信端口号&＃xff0c;在同一机器下必须不一样
transport.tcp.port: 9300
#设置集群自动发现机器ip集合
discovery.zen.ping.unicast.hosts: [“127.0.0.1:9300”,“127.0.0.1:9301”,“127.0.0.1:9302”]

node2节点&＃xff1a;

#节点2的配置信息&＃xff1a;
#集群名称&＃xff0c;保证唯一
cluster.name: my-elasticsearch
#节点名称&＃xff0c;必须不一样
node.name: node-2
#必须为本机的ip地址
network.host: 127.0.0.1
#服务端口号&＃xff0c;在同一机器下必须不一样
http.port: 9201
#集群间通信端口号&＃xff0c;在同一机器下必须不一样
transport.tcp.port: 9301
#设置集群自动发现机器ip集合
discovery.zen.ping.unicast.hosts: [“127.0.0.1:9300”,“127.0.0.1:9301”,“127.0.0.1:9302”]

node3节点&＃xff1a;

#节点3的配置信息&＃xff1a;
#集群名称&＃xff0c;保证唯一
cluster.name: my-elasticsearch
#节点名称&＃xff0c;必须不一样
node.name: node-3
#必须为本机的ip地址
network.host: 127.0.0.1
#服务端口号&＃xff0c;在同一机器下必须不一样
http.port: 9202
#集群间通信端口号&＃xff0c;在同一机器下必须不一样
transport.tcp.port: 9302
#设置集群自动发现机器ip集合
discovery.zen.ping.unicast.hosts: [“127.0.0.1:9300”,“127.0.0.1:9301”,“127.0.0.1:9302”]

然后依次启动各个节点服务器.

ES使用(通过SpringDataES):

环境搭建
:
xml配置:

entity:

package com.ceeemall.es.entity;import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;&＃64;Document(indexName &＃61; "test",type&＃61;"article") //索引库名称 类型名称
public class Article {&＃64;Id //主键标识&＃64;Field(type &＃61; FieldType.Long,store &＃61; true) //type 数据类型 store 是否存储private long id;&＃64;Field(type &＃61; FieldType.text,store &＃61; true,analyzer &＃61; "ik_max_word")private String title;&＃64;Field(type &＃61; FieldType.text,store &＃61; true,analyzer &＃61; "ik_max_word") //analyzer 分词器 使用ikprivate String content;public long getId() {return id;}public void setId(long id) {this.id &＃61; id;}public String getTitle() {return title;}public void setTitle(String title) {this.title &＃61; title;}public String getContent() {return content;}public void setContent(String content) {this.content &＃61; content;}
}

操作:
索引库的操作:

package com.ceeemall.es;import com.ceeemall.es.entity.Article;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;&＃64;RunWith(SpringJUnit4ClassRunner.class)
&＃64;ContextConfiguration("classpath:applicationContext.xml")
public class SpEsTest {&＃64;Autowiredprivate ElasticsearchTemplate template;&＃64;Testpublic void creatIndex(){//初始化spring容器//ApplicationContext applicationContext &＃61; new ClassPathXmlApplicationContext("classpath:applicationContext.xml");//从容器中获取ElasticsearchTemplate对象// ElasticsearchTemplate template &＃61; applicationContext.getBean(ElasticsearchTemplate.class);//通过template对象创建索引库,指定entity可以基于entity创建索引库template.createIndex(Article.class);}//删除索引库&＃64;Testpublic void deleteIndex(){template.deleteIndex("test");}//设置mapping&＃64;Testpublic void putMapping(){template.putMapping(Article.class);}}

文档的操作:

定义dao:

package com.ceeemall.es.dao;import com.ceeemall.es.entity.Article;
import org.springframework.data.elasticsearch.repository.ElasticsearchCrudRepository;public interface ArticleDao extends ElasticsearchCrudRepository {}

添加文档:

//添加文档&＃64;Testpublic void addDocument(){Article article &＃61; new Article();article.setId(1);article.setTitle("你好,我是title");article.setContent("你好,我是content");//添加文档articleDao.save(article);}


添加成功:

删改就不说了,就是delete和save方法.

查询:
通过id查询:

&＃64;Testpublic void findById(){//返回optional对象Optional