分布式搜索SolrCloud简介

[root@localhost solr-5.0.0]# bin/solr start -c -z 192.168.140.133:2181,192.168.140.134:2181,192.168.140.135:2181
Waiting to see Solr listening on port 8983 [\]  
Started Solr server on port 8983 (pid=9219). Happy searching!
# -c 以SolrCloud模式启动 -z ZooKeeper链接               

[root@localhost solr-5.0.0]# bin/solr create -c commenta_admin -d data_driven_schema_configs -shards 3 -replicationFactor 2
Connecting to ZooKeeper at 192.168.140.133:2181,192.168.140.134:2181,192.168.140.135:2181
Uploading /home/tianduoduo/solr/solr-5.0.0/server/solr/configsets/data_driven_schema_configs/conf for config commenta_admin to ZooKeeper at 192.168.140.133:2181,192.168.140.134:2181,192.168.140.135:2181

Creating new collection 'commenta_admin' using command:
http://192.168.140.135:8983/solr/admin/collections?action=CREATE&name=commenta_admin&numShards=3&replicationFactor=2&maxShardsPerNode=2&collection.configName=commenta_admin

{
  "responseHeader":{
    "status":0,
    "QTime":11866},
  "success":{"":{
      "responseHeader":{
        "status":0,
        "QTime":11423},
      "core":"commenta_admin_shard3_replica1"}}}
# -c Collection名字 -d 加载配置文件 -shards 分片数量 -replicationFactor 复制数量

创建完成后，我们可以在Solr的Admin管理界面上查看：

192.168.140.133
commenta_admin_shard1_replica1
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog
commenta_admin_shard2_replica2
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog

192.168.140.134
commenta_admin_shard1_replica2
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog
commenta_admin_shard3_replica1
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog

192.168.140.135
commenta_admin_shard2_replica1
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog
commenta_admin_shard3_replica2
├── core.properties
└── data
    ├── index
    │   ├── segments_1
    │   └── write.lock
    └── tlog

@Test
public void testqueryCommodityData(){
	List<CommentaCommodity> list = commentaSolrCloudService.queryCommodityData(1, 5);
	System.out.println(JSON.toJSONString(list));
}

CommoditySolrRepository
public interface CommoditySolrRepository{
	Page findCommodities(String value, Pageable page);
}

CommoditySolrRepositoryImpl
public class CommoditySolrRepositoryImpl implements CommoditySolrRepository{
	private SolrOperations solrTemplate;
	public CommoditySolrRepositoryImpl() {
		super();
	}
	public CommoditySolrRepositoryImpl(SolrOperations solrTemplate) {
		super();
		this.solrTemplate = solrTemplate;
	}
	@Override
	public Page findCommodities(String value, Pageable page) {
		return solrTemplate.queryForPage(new SimpleQuery(new SimpleStringCriteria("name:" + "*" + value+ "*" )).setPageRequest(page),
				CommentaCommodity.class);
	}
}

@Test
public void testfindCommodities(){
	String value = "联想";
	PageRequest page = new PageRequest(1, 100); //page从0开始	
	Page<CommentaCommodity> resultPage = commoditySolrRepository.findCommodities(value, page);
	System.out.println(JSON.toJSONString(resultPage.getContent()));
		
}

DerivedCommoditySolrRepository 
public interface DerivedCommoditySolrRepository extends SolrCrudRepository {
	@Query(CommentaCommodity.TYPE + ":0")
	Page findByTypeUsingAnnotatedQuery(Pageable page); #分页查找
	@Highlight
	HighlightPage findByNameIn(Collection name, Pageable page);#分页高亮查找
	@Query(value = "count:[ 1 TO 10 ]")
	@Facet(fields = { "name" }, limit = 20)
	FacetPage findByNameAndFacetOnCount(String name, Pageable page);#分组聚类数据
	Page findByNameOrType(@Boost(2) String name, String type, Pageable page);#设置权重
	
}

@Test
public void testAnnotationQuery(){
        DerivedCommoditySolrRepository repo= new SolrRepositoryFactory(solrTemplate).getRepository(DerivedCommoditySolrRepository.class,new CommoditySolrRepositoryImpl(solrTemplate));
        Page resultPage = repo.findByTypeUsingAnnotatedQuery(new PageRequest(0, 10));
        System.out.println(JSON.toJSONString(resultPage.getTotalElements()));
}

        /**
	 * 通过Solr API提供的Facet机制提供一种类似于分组查找的效果。
	 * @see Solr Facet介绍
	 * 目前Facet机制提供了很多可选参数，如：
	 *  1.facet.field  分组的字段(必须是索引字段)
	 *  2.facet.prefix 表示Facet字段前缀
	 *  3.facet.limit Facet字段返回条数
	 *  4.facet.offict 开始条数,偏移量,它与facet.limit配合使用可以达到分页的效果
	 *  5.facet.mincount Facet字段最小count,默认为0
	 *  6.facet.missing 如果为on或true,那么将统计那些Facet字段值为null的记录
	 *  7.facet.method 取值为enum或fc,默认为fc, fc表示Field Cache
	 *  8.facet.enum.cache.minDf 当facet.method=enum时,参数起作用,文档内出现某个关键字的最少次数
	 * @param fileds
	 */
	public List qyeryDataByFacetParam(String queryStr,String... fields){
		SolrQuery solrQuery = new SolrQuery();
		List list = new ArrayList();
		try {
			solrQuery.setFacet(true);//设置facet=on
			solrQuery.addFacetField(fields);
			solrQuery.setFacetLimit(DEFAULT_FACET_LIMIT);
			if(StringUtils.isEmpty(queryStr)){
				solrQuery.setQuery("*:*");
			}else{
				solrQuery.setQuery(queryStr);
			}
			QueryResponse response = cloudSolrClient.query(solrQuery);
			List facets = response.getFacetFields();//返回的facet列表
			for (FacetField facetField : facets) {
				List count_list = facetField.getValues();
				for (Count count_info : count_list) {
					list.add(new FacetInfo(count_info.getName(), count_info.getCount()));
				}
			}
			return list;
		} catch (Exception e) {
			logger.error(e.getMessage(), e);
			return null;
		}
	}

        /**
	 * 自定义打分规则查询数据
	 * @param pageNo
	 * @param pageSize
	 * @param bfValue
	 * @param queryStr
	 * @return
	 */
	public List queryCommodityDataByBoost(String bfValue, Integer pageNo, Integer pageSize, String queryStr){
		SolrQuery solrQuery = new SolrQuery();
		if(pageNo.intValue() == DEFAULT_LIMIT && pageSize.intValue() == DEFAULT_LIMIT){
			solrQuery.setQuery(queryStr);
			solrQuery.setStart(0);
			solrQuery.setRows(Integer.MAX_VALUE);
		}else {
			int start = (pageNo - 1) * pageSize;
			solrQuery.setQuery(queryStr);
			solrQuery.setStart(start);
			solrQuery.setRows(pageSize);
		}
		solrQuery.set("defType","edismax");
		solrQuery.set("pf", "name^100");
		solrQuery.set("bf", bfValue); 
		try {
			QueryResponse queryResponse = cloudSolrClient.query(solrQuery);
			return queryResponse.getBeans(CommentaCommodity.class);
		} catch (Exception e) {
			logger.error(e.getMessage(), e);
			return null;
		}
		
	}

System.out.println(JSON.toJSONString(commentaSolrCloudService.queryCommodityDataByBoost("sum(recip(_version_,3.16e-11,1,1),div(1000,count))^100", 1, 10,"id:79* AND name:*联想*")));