Solr空间搜寻之周边酒店搜索

Solr空间搜索之周边酒店搜索
<?xml version="1.0" encoding="UTF-8" ?><solr persistent="false"> <cores adminPath="/admin/cores"> <core name="core0" instanceDir="core0" />  </cores></solr>?? 2.3 在D:\hotel_solr新建core0\conf目录

?? 2.4 在D:\hotel_solr\core0\conf目录下，新建schema.xml文件,内容如下:

&lt;?xml version="1.0" ?&gt;&lt;schema name="example core zero" version="1.1"&gt;  &lt;types&gt;   &lt;fieldType name="string" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="boolean" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="integer" omitNorms="true"/&gt;         &lt;fieldType name="int" precisionStep="0" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="float" precisionStep="0" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="long" precisionStep="0" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="double" precisionStep="0" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="tint" precisionStep="8" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="tfloat" precisionStep="8" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="tlong" precisionStep="8" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="tdouble" precisionStep="8" omitNorms="true" positionIncrementGap="0"/&gt;         &lt;fieldType name="sint" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="slong" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="sfloat" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="sdouble" sortMissingLast="true" omitNorms="true"/&gt;         &lt;fieldType name="date" omitNorms="true" precisionStep="0" positionIncrementGap="0"/&gt;         &lt;fieldType name="tdate" omitNorms="true" precisionStep="6" positionIncrementGap="0"/&gt;         &lt;fieldtype name="ignored" stored="false" indexed="false" subFieldSuffix="_d"/&gt;         &lt;fieldType name="text" positionIncrementGap="100"&gt;               &lt;analyzer type="index"&gt;                 &lt;tokenizer type="integer" indexed="true" stored="true" required="true"/&gt;  &lt;field name="crawl_hotel_id"    type="string"   indexed="true"  stored="true"  multiValued="false" required="true"/&gt;   &lt;field name="name"    type="text"   indexed="true"  stored="true"  multiValued="false" required="true"/&gt;   &lt;field name="address"    type="text"   indexed="true"  stored="true"  multiValued="false" required="true"/&gt;   &lt;field name="search_kw" type="text" indexed="true" multiValued="true" stored="false" /&gt;   &lt;field name="latlng" type="location" indexed="true" /&gt;  &lt;dynamicField name="*_d" type="double" indexed="true" stored="true"/&gt; &lt;/fields&gt; &lt;copyField source="name" dest="search_kw" /&gt; &lt;copyField source="address" dest="search_kw" /&gt; &lt;uniqueKey&gt;hotel_id&lt;/uniqueKey&gt; &lt;defaultSearchField&gt;search_kw&lt;/defaultSearchField&gt; &lt;solrQueryParser defaultOperator="AND"/&gt;&lt;/schema&gt;

??? 2.5 在D:\hotel_solr\core0\conf目录下，新建solrconfig.xml文件,内容如下:

&lt;?xml version="1.0" encoding="UTF-8" ?&gt;&lt;config&gt;  &lt;luceneMatchVersion&gt;LUCENE_36&lt;/luceneMatchVersion&gt;  &lt;directoryFactory name="DirectoryFactory" /&gt;  &lt;requestDispatcher handleSelect="true" &gt;    &lt;requestParsers enableRemoteStreaming="false" multipartUploadLimitInKB="2048" /&gt;  &lt;/requestDispatcher&gt;  &lt;requestHandler name="standard" default="true" /&gt;  &lt;requestHandler name="/update" /&gt;  &lt;requestHandler name="/admin/" /&gt;  &lt;admin&gt;    &lt;defaultQuery&gt;*:*&lt;/defaultQuery&gt;  &lt;/admin&gt;&lt;/config&gt;

??? 到这里为止Solr的索引配置完成.

3 配置tomcat

?? 3.1 让tomcat支持HTTP GET UTF-8编码的支持, 打开D:\apache-tomcat-7.0.16\conf\server.xml，修成如下地方:

&lt;Connector port="8080" protocol="HTTP/1.1"                connectionTimeout="20000"                redirectPort="8443" URIEncoding="UTF-8"/&gt;

?? 3.2 配置solr的war包

???????? 在D:\apache-tomcat-7.0.16\conf\Catalina\localhost新建solr.xml,内容如下:

&lt;Context docBase="F:/apache-solr-3.6.2.war" debug="0" crossContext="true" &gt;    &lt;Environment name="solr/home" type="java.lang.String" value="D:/hotel_solr" override="true" /&gt;  &lt;/Context&gt;

?? 3.3 启动tomcat, 在浏览器中输入:http://localhost:8080/solr/?? 如果出现Admin core0 表示正常。
?5 把数据库中的酒店数据添加到Solr索引库中

??? 使用Solrj客户端进行索引构建和查询,MAVEN依赖包：

&lt;dependency&gt;      &lt;groupId&gt;junit&lt;/groupId&gt;      &lt;artifactId&gt;junit&lt;/artifactId&gt;      &lt;version&gt;3.8.1&lt;/version&gt;      &lt;scope&gt;test&lt;/scope&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;org.apache.solr&lt;/groupId&gt;    &lt;artifactId&gt;solr-solrj&lt;/artifactId&gt;    &lt;version&gt;3.6.0&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;mysql&lt;/groupId&gt;    &lt;artifactId&gt;mysql-connector-java&lt;/artifactId&gt;    &lt;version&gt;5.1.19&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;commons-lang&lt;/groupId&gt;    &lt;artifactId&gt;commons-lang&lt;/artifactId&gt;    &lt;version&gt;2.6&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;org.apache.httpcomponents&lt;/groupId&gt;    &lt;artifactId&gt;httpclient&lt;/artifactId&gt;    &lt;version&gt;4.1.3&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;org.apache.httpcomponents&lt;/groupId&gt;    &lt;artifactId&gt;httpclient-cache&lt;/artifactId&gt;    &lt;version&gt;4.1.3&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;org.apache.httpcomponents&lt;/groupId&gt;    &lt;artifactId&gt;httpmime&lt;/artifactId&gt;    &lt;version&gt;4.1.3&lt;/version&gt;    &lt;/dependency&gt;    &lt;dependency&gt;    &lt;groupId&gt;org.slf4j&lt;/groupId&gt;    &lt;artifactId&gt;slf4j-simple&lt;/artifactId&gt;    &lt;version&gt;1.6.4&lt;/version&gt;    &lt;/dependency&gt;

??? Java代码:

import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.HashMap;import java.util.Map;import org.apache.commons.lang.StringUtils;import org.apache.solr.client.solrj.SolrRequest.METHOD;import org.apache.solr.client.solrj.impl.HttpSolrServer;import org.apache.solr.client.solrj.response.QueryResponse;import org.apache.solr.common.SolrDocumentList;import org.apache.solr.common.SolrInputDocument;import org.apache.solr.common.params.MapSolrParams;public class App {/** * 初始化索引数据 * @param solrServer * @throws Exception */public static void buildIndex(String solrServer) throws Exception {Connection connect = null;Statement statement = null;ResultSet resultSet = null;HttpSolrServer server = null;try {Class.forName("com.mysql.jdbc.Driver");connect = DriverManager.getConnection("jdbc:mysql://localhost/hotel_analysis?"+ "user=root&password=11111");statement = connect.createStatement();resultSet = statement.executeQuery("select hotel_id,crawl_hotel_id,hotel_name,hotel_address,hotel_location from crawl_hotel");server = new HttpSolrServer(solrServer);int count = 0;int eachCommit = 100;//从数据库中获取酒店数据while (resultSet.next()) {Integer hotel_id = resultSet.getInt(1);String crawl_hotel_id = resultSet.getString(2);String hotel_name = resultSet.getString(3);String hotel_address = resultSet.getString(4);String hotel_location = resultSet.getString(5);if (StringUtils.isBlank(hotel_location)) {continue;}count++;//添加酒店数据到Solr索引中SolrInputDocument doc = new SolrInputDocument();doc.addField("hotel_id", hotel_id);doc.addField("crawl_hotel_id", crawl_hotel_id);doc.addField("name", hotel_name);doc.addField("address", hotel_address);doc.addField("latlng", hotel_location);server.add(doc);//100条commit一次if (count % eachCommit == 0) {server.commit();count = 0;}}if (count &gt; 0) {server.commit();count = 0;}} finally {if (null != resultSet) {try {resultSet.close();} catch (SQLException ex) {}}if (null != statement) {try {statement.close();} catch (SQLException ex) {}}if (null != connect) {try {connect.close();} catch (SQLException ex) {}}}}public static void main(String[] args) throws Exception {String URL = "http://localhost:8080/solr/core0";//构建索引到Solr库buildIndex(URL);        //索引周边查询//queryTest(URL);}/** * 测试索引查询 * http://localhost:8080/solr/core0/select?q=*%3A*&fq=%7B%21geofilt%7D&pt=31.26552%2C121.460815&sfield=latlng&d=2&sort=geodist%28%29+asc&fl=*%2Cscore&start=0&rows=10 * @param solrServer * @throws Exception */public static void queryTest(String solrServer) throws Exception {HttpSolrServer server = new HttpSolrServer(solrServer);Map&lt;String,String&gt; params = new HashMap&lt;String,String&gt;(); params.put("q", "*:*");params.put("fq", "{!geofilt}");//距离过滤函数params.put("pt", "31.26552,121.460815");//当前经纬度params.put("sfield", "latlng");//经纬度的字段params.put("d", "2");//就近2公里的所有酒店params.put("sort", "geodist() asc");//根据距离排序params.put("fl", "*,score");params.put("start", "0");//记录开始位置params.put("rows", "10");//查询的行数QueryResponse resp = server.query(new MapSolrParams(params), METHOD.POST);SolrDocumentList docs = resp.getResults();for(int i=0;i&lt;docs.size();i++){System.out.println(docs.get(i));}}}

6 查询展示：

???
Solr空间搜寻之周边酒店搜索
?

查询结果页:

Solr空间搜寻之周边酒店搜索
?

Solr空间搜寻之周边酒店搜索

热点推荐