`
zjnbshifox
  • 浏览: 312577 次
  • 性别: Icon_minigender_1
  • 来自: 宁波
社区版块
存档分类
最新评论

Solr客户端自定义开发

    博客分类:
  • Java
阅读更多

@Service
@Qualifier("searchService")
public class SearchService {
	@Value("${solr.url}")
	private String searchurl;
	@Value("${solr.q.fields}")
	private String qfields;
	@Value("${solr.s.fields}")
	private String sfields;
	@Value("${solr.h.fields}")
	private String hfields;
	/**
	 * 分页查询Position
	 * @param key 关键字
	 * @param page 分页
	 * @param pagesize 分页大小
	 * @return 分页信息
	 */
	public PageInfo<Position> query(String key, int page, int pagesize) {
		PageInfo<Position> ps = new PageInfo<Position>(page, pagesize);
		SolrServer server = new HttpSolrServer(searchurl);
		SolrQuery params = new SolrQuery();
		params.setQuery(setQueryFields(key, qfields));
		params.setStart(ps.getStart());
		params.setRows(ps.getPagesize());
		boolean ish = setHighlight(params,hfields);
		setSortFields(params, sfields);
		SolrDocumentList list = null;
		//第一个Map的键是文档的ID,第二个Map的键是高亮显示的字段名
		Map<String,Map<String,List<String>>> high= null;
		try {
			QueryResponse response = server.query(params);
			list = response.getResults();
			if(ish){
				high = response.getHighlighting();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		if(ish){
			
		}
		ps.setItems(mappingVo(list,high,ish));
		ps.setTotal((int) list.getNumFound());
		return ps;
	}
	/**
	 * 设置高亮字段
	 * @param params SolrQuery对象
	 * @param hfields2 高亮字段,以逗号分隔
	 * @return 是否需要高亮
	 */
	private boolean setHighlight(SolrQuery params, String hfields2) {		
		if(StringUtils.hasText(hfields2)){
			String[] arr = hfields2.split(",");
			for (String s : arr) {
				params.addHighlightField(s);
			}
			params.setHighlight(true);
			params.setHighlightSimplePre("<font color='red'><em>");
			params.setHighlightSimplePost("</em></font>");
			return true;
		}
		return false;
	}
	/**
	 * 将查询结果返回映射为Position对象列表
	 * @param list 返回的document列表
	 * @param high 高亮信息
	 * @param ish 是否需要高亮
	 * @return Position对象列表
	 */
	private List<Position> mappingVo(SolrDocumentList list,Map<String,Map<String,List<String>>> high,boolean ish) {
		List<Position> poses = new ArrayList<Position>();
		for (SolrDocument doc : list) {
			Position p = new Position();
			p.setPid(doc.getFieldValue("CP_ID").toString());
			if(ish && high.get(p.getPid()).containsKey("COMPANY_NAME")){
				p.setCompany(high.get(p.getPid()).get(("COMPANY_NAME")).toString());
			}else{
				p.setCompany(doc.getFieldValue("COMPANY_NAME").toString());
			}	
			p.setStamp((Date)doc.getFieldValue("ADD_AT"));
			poses.add(p);
		}
		return poses;
	}
	/**
	 * 设置排序字段
	 * @param params SolrQuery对象
	 * @param sfields2 排序字段,都是按降序排
	 */
	private void setSortFields(SolrQuery params, String sfields2) {
		String[] arr = sfields2.split(",");
		for (String s : arr) {
			params.addSortField(s, ORDER.desc);
		}

	}
	/**
	 * 定义查询字段
	 * @param key 关键字
	 * @param qfields2 以,分隔的字段列表,以或条件
	 * @return
	 */
	private String setQueryFields(String key, String qfields2) {
		StringBuilder sb = new StringBuilder();
		String[] arr = qfields2.split(",");
		for (String s : arr) {
			sb.append(s).append(":").append(key).append(" OR ");
		}
		String q = sb.toString();
		return q.substring(0, q.length() - 4);
	}
}

另外在浏览器中清除所有的索引可以这样
http://localhost:8080/solr/update?stream.body=%3Cdelete%3E%3Cquery%3E*:*%3C/query%3E%3C/delete%3E&commit=true

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.nbrc.gqh</groupId>
	<artifactId>search</artifactId>
	<packaging>war</packaging>
	<version>1.0.0-SNAPSHOT</version>
	<name>search Maven Webapp</name>
	<url>http://maven.apache.org</url>
	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>3.8.1</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-web</artifactId>
			<version>3.2.1.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>3.2.1.RELEASE</version>
		</dependency>
		<dependency>
			<groupId>org.apache.solr</groupId>
			<artifactId>solr-solrj</artifactId>
			<version>3.6.2</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<version>2.5</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>jstl</artifactId>
			<version>1.2</version>
		</dependency>
		<dependency>
			<groupId>taglibs</groupId>
			<artifactId>standard</artifactId>
			<version>1.1.2</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>jsp-api</artifactId>
			<version>2.0</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-core-lgpl</artifactId>
			<version>1.8.1</version>
		</dependency>
		<dependency>
			<groupId> org.codehaus.jackson</groupId>
			<artifactId>jackson-mapper-asl</artifactId>
			<version>1.9.5</version>
		</dependency>
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-mapper-lgpl</artifactId>
			<version>1.8.1</version>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpclient</artifactId>
			<version>4.2.1</version>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpmime</artifactId>
			<version>4.2.1</version>
		</dependency>
	</dependencies>
	<build>
		<finalName>search</finalName>
	</build>
</project>

分享到:
评论

相关推荐

    Java微服务架构l零从基础到精通高清视频教程全套 163课

    126 HBuilder 客户端-HBuilder 自定义代码块 127 HBuilder 客户端-打开新窗口 128 使用 API Gateway 统一服务接口-API Gateway 简介 129 使用 API Gateway 统一服务接口-创建频道服务 130使用 API Gateway 统一服务...

    Java微服务架构163课

    126 HBuilder 客户端-HBuilder 自定义代码块 127 HBuilder 客户端-打开新窗口 128 使用 API Gateway 统一服务接口-API Gateway 简介 129 使用 API Gateway 统一服务接口-创建频道服务 130使用 API Gateway 统一...

    java开源包1

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包11

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包2

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包3

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包6

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包5

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包10

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包4

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包8

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包7

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    java开源包9

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    JAVA上百实例源码以及开源项目

     Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 3...

    java开源包101

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    Java资源包01

    最大限度地减少时间和费用开发自定义的DSL(领域特定语言在Java)要求。 日志服务器 Apache Flume.tar Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就...

    JAVA上百实例源码以及开源项目源代码

    Tcp服务端与客户端的JAVA实例源代码 2个目标文件 摘要:Java源码,文件操作,TCP,服务器 Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多...

    单点登录源码

    Solr & Elasticsearch | 分布式全文搜索引擎 | [http://lucene.apache.org/solr/](http://lucene.apache.org/solr/) [https://www.elastic.co/](https://www.elastic.co/) Quartz | 作业调度框架 | ...

Global site tag (gtag.js) - Google Analytics