本地环境(windows)安装elasticsearch及kibana。
添加elasticsearch依赖
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-data-elasticsearch
<artifactId>
</dependency>
修改application.yml文件，在spring节点下添加Elasticsearch相关配置。
data:
elasticsearch:
repositories:
enabled:true
cluster-nodes:127.0.0.1:9300 # es的连接地址及端口号
cluster-name:elasticsearch # es集群的名称
添加domain文档对象
不需要中文分词的字段设置成@Field(type = FieldType.Keyword)类型，需要中文分词的设置成@Field(analyzer = "ikmaxword",type = FieldType.Text)类型。
/**
- 搜索中的商品信息
- Created by macro on 2018/6/19.
*/
@Document(indexName ="pms", type ="product",shards =1,replicas =0)
public class EsProduct implements Serializable{
private static final long serialVersionUID =-1L;
@Id
private Long id;
@Field(type =FieldType.Keyword)
private String productSn;
private Long brandId;
@Field(type =FieldType.Keyword)
private String brandName;
private Long productCategoryId;
@Field(type =FieldType.Keyword)
private String productCategoryName;
private String pic;
@Field(analyzer ="ik_max_word",type =FieldType.Text)
private String name;
@Field(analyzer ="ik_max_word",type =FieldType.Text)
private String subTitle;
@Field(analyzer ="ik_max_word",type =FieldType.Text)
private String keywords;
private BigDecimal price;
private Integer sale;
private Integer newStatus;
private Integer recommandStatus;
private Integer stock;
private Integer promotionType;
private Integer sort;
@Field(type =FieldType.Nested)
private List<EsProductAttributeValue> attrValueList;
//省略了所有getter和setter方法
}
添加EsProductRepository接口用于操作Elasticsearch
继承ElasticsearchRepository接口，这样就拥有了一些基本的Elasticsearch数据操作方法，同时定义了一个衍生查询方法。
/**
- 商品ES操作类
- Created by macro on 2018/6/19.
/
public interface EsProductRepository extends ElasticsearchRepository<EsProduct,Long>{
/*- 搜索查询
- @param name 商品名称
- @param subTitle 商品标题
- @param keywords 商品关键字
- @param page 分页信息
- @return
*/
Page<EsProduct> findByNameOrSubTitleOrKeywords( String name, String subTitle, String keywords,Pageable page);
}
添加xxxService接口
/**
- 商品搜索管理Service
- Created by macro on 2018/6/19.
/
public interface EsProductService{
/* - 从数据库中导入所有商品到ES
/
int importAll();
/* - 根据id删除商品
/
void delete( Long id);
/* - 根据id创建商品
/
EsProduct create( Long id);
/* - 批量删除商品
/
void delete(List<Long> ids);
/* - 根据关键字搜索名称或者副标题
*/
Page<EsProduct> search(String keyword,Integer pageNum,Integer pageSize);
}
添加Service接口的实现类xxxServiceImpl
/**
- 商品搜索管理Service实现类
- Created by macro on 2018/6/19.
*/
@Service
public class EsProductServiceImpl implements EsProductService{
private static final Logger LOGGER = LoggerFactory.getLogger(EsProductServiceImpl.class);
@Autowired
private EsProductDao productDao;
@Autowired
private EsProductRepository productRepository;
@Override
public int importAll(){
List<EsProduct> esProductList = productDao. getAllEsProductList(null);
Iterable<EsProduct> esProductIterable = productRepository.saveAll(esProductList);
Iterator<EsProduct> iterator = esProductIterable.iterator();
int result =0;
while(iterator.hasNext()){
result++;
iterator.next();
}
return result;
}
@Override
public void delete(Long id){
productRepository.deleteById(id);
}
@Override
public EsProduct create(Long id){
EsProduct result =null;
List<EsProduct> esProductList = productDao.getAllEsProductList(id);
if(esProductList.size()>0){
EsProduct esProduct = esProductList.get(0);
result = productRepository.save(esProduct);
}
return result;
}
@Override
public void delete(List<Long> ids){
if(!CollectionUtils.isEmpty(ids)){
List<EsProduct> esProductList = new ArrayList<>();
for(Long id : ids){
EsProduct esProduct =new EsProduct();
esProduct.setId(id);
esProductList.add(esProduct);
}
productRepository.deleteAll(
esProductList
);
}
}
@Override
public Page<EsProduct> search(String keyword,Integer pageNum,Integer pageSize){
Pageable pageable =PageRequest.of(pageNum, pageSize);
return productRepository.findByNameOrSubTitleOrKeywords(keyword, keyword, keyword, pageable);
}
}
添加Controller定义接口
/**
- 搜索商品管理Controller
- Created by macro on 2018/6/19.
*/
@Controller @Api(tags ="EsProductController", description ="搜索商品管理")
@RequestMapping("/esProduct")
public class EsProductController{
@Autowired
private EsProductService esProductService;
@ApiOperation(value = "导入所有数据库中商品到ES")
@RequestMapping(value ="/importAll", method =RequestMethod.POST)
@ResponseBody
public CommonResult<Integer> importAllList(){
int count = esProductService.importAll();
return CommonResult.success(count);
}
@ApiOperation(value ="根据id删除商品")
@RequestMapping(value ="/delete/{id}", method =RequestMethod.GET)
@ResponseBody
public CommonResult< Object> delete(@PathVariable Long id){
esProductService.delete(id);
return CommonResult.success(null);
}
@ApiOperation(value = "根据id批量删除商品")
@RequestMapping(value ="/delete/batch", method =RequestMethod.POST)
@ResponseBody
public CommonResult<Object> delete(@RequestParam("ids") List<Long> ids){
esProductService.delete(ids);
return CommonResult.success(null);
}
@ApiOperation(value ="根据id创建商品")
@RequestMapping(value ="/create/{id}", method =RequestMethod.POST)
@ResponseBody
public CommonResult<EsProduct> create(@PathVariable Long id){
EsProduct esProduct = esProductService.create(id);
if(esProduct !=null){
return CommonResult.success(esProduct);
}else{
return CommonResult.failed();
}
}
@ApiOperation(value ="简单搜索")
@RequestMapping(value ="/search/simple", method =RequestMethod.GET)
@ResponseBody
public CommonResult<CommonPage<EsProduct>> search(@RequestParam(required =false) String keyword,@RequestParam(required =false, defaultValue ="0") Integer pageNum,@RequestParam(required =false, defaultValue="5") Integer pageSize){
Page<EsProduct> esProductPage = esProductService.search(keyword, pageNum, pageSize);
return CommonResult.success(CommonPage.restPage(esProductPage));
}
}
常用注解
@Document
//标示映射到Elasticsearch文档上的领域对象
public @interface Document{
//索引库名次，mysql中数据库的概念
String indexName();
//文档类型，mysql中表的概念
String type() default "";
//默认分片数
short shards() default 5;
//默认副本数量
short replicas() default 1;
}
@Id
//表示是文档的id，文档可以认为是mysql中表行的概念
public @interface Id{}
@Field
public @interface Field{
//文档中字段的类型
FieldType type() default FieldType.Auto;
//是否建立倒排索引
boolean index() default true;
//是否进行存储
boolean store() default false;
//分词器名次
String analyzer() default "";
}
//为文档自动指定元数据类型
public enum FieldType{
Text,//会进行分词并建了索引的字符类型
Integer,
Long,
Date,
Float,
Double,
Boolean,
Object,
Auto,//自动判断字段类型
Nested,//嵌套对象类型
Ip,
Attachment,
Keyword //不会进行分词建立索引的类型
}
参考项目：https://github.com/macrozheng/mall-learning/tree/master/mall-tiny-06
