搜索学习Solr全文搜索服务器的基本使用（一）——SolrJ的使用

作为一般的Lucene使用者&＃xff0c;我们直接用Lucene虽然可以实现很多自己想要的自定义功能&＃xff0c;但是对于一般的项目&＃xff0c;为了方便开发和维护&＃xff0c;我们通常会使用现成的搜索服务器。现在常用的有Solr和ElasticSearch。
对于Solr服务器如何搭建&＃xff0c;Solr服务器的搭建&＃xff0c;之前已经整理过&＃xff0c;这次&＃xff0c;我将使用SolrJ来调用Solr服务器。

在Solr中配置Core

在managed-schema中&＃xff0c;主要的配置为&＃xff1a;

blogId













依赖

org.apache.solrsolr-solrj6.5.1



SolrServer.Java

package top.yuyufeng.learn.lucene.solr;import org.apache.solr.client.solrj.impl.HttpSolrClient;/*** &＃64;author yuyufeng* &＃64;date 2017/12/6*/
public class SolrServer {private static HttpSolrClient server &＃61; null;private final static String solrServerUrl &＃61; "http://127.0.0.1:8983/solr/blog";public static HttpSolrClient getServer() {if (server &＃61;&＃61; null) {server &＃61; new HttpSolrClient(solrServerUrl);server.setDefaultMaxConnectionsPerHost(1000);server.setMaxTotalConnections(10000);//最大连接数server.setConnectionTimeout(60000);//设置连接超时时间&＃xff08;单位毫秒&＃xff09; 1000server.setSoTimeout(60000); 设置读数据超时时间(单位毫秒) 1000server.setFollowRedirects(false);//遵循从定向server.setAllowCompression(true);//允许压缩}return server;}public static void main(String[] args) {HttpSolrClient client &＃61; getServer();System.out.println(client);}
}


BlogCore.java

package top.yuyufeng.learn.lucene.solr.core;import org.apache.solr.client.solrj.beans.Field;import java.util.Date;/*** &＃64;author yuyufeng* &＃64;date 2017/12/6*/
public class BlogCore {&＃64;Fieldprivate String blogId;&＃64;Fieldprivate String blogTitle;&＃64;Fieldprivate String blogContent;&＃64;Fieldprivate Date createTime;&＃64;Fieldprivate String keywords;public String getBlogId() {return blogId;}public void setBlogId(String blogId) {this.blogId &＃61; blogId;}public String getBlogTitle() {return blogTitle;}public void setBlogTitle(String blogTitle) {this.blogTitle &＃61; blogTitle;}public String getBlogContent() {return blogContent;}public void setBlogContent(String blogContent) {this.blogContent &＃61; blogContent;}public Date getCreateTime() {return createTime;}public void setCreateTime(Date createTime) {this.createTime &＃61; createTime;}public String getKeywords() {return keywords;}public void setKeywords(String keywords) {this.keywords &＃61; keywords;}&＃64;Overridepublic String toString() {return "BlogCore{" &＃43;"blogId&＃61;&＃39;" &＃43; blogId &＃43; &＃39;\&＃39;&＃39; &＃43;", blogTitle&＃61;&＃39;" &＃43; blogTitle &＃43; &＃39;\&＃39;&＃39; &＃43;", blogContent&＃61;&＃39;" &＃43; blogContent &＃43; &＃39;\&＃39;&＃39; &＃43;", createTime&＃61;" &＃43; createTime &＃43;", keywords&＃61;&＃39;" &＃43; keywords &＃43; &＃39;\&＃39;&＃39; &＃43;&＃39;}&＃39;;}
}


BlogSolrDao.java

package top.yuyufeng.learn.lucene.solr.dao;import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.client.solrj.response.UpdateResponse;
import top.yuyufeng.learn.lucene.solr.SolrServer;
import top.yuyufeng.learn.lucene.solr.core.BlogCore;import java.awt.print.Pageable;
import java.util.List;
import java.util.Map;/*** &＃64;author yuyufeng* &＃64;date 2017/12/6*/
public class BlogSolrDao{HttpSolrClient server;public BlogSolrDao() {server &＃61; SolrServer.getServer();}/*** 按Bean 添加/修改 索引** &＃64;throws Exception*/public int addIndex(BlogCore entity) throws Exception {server.addBean(entity);UpdateResponse updateResponse &＃61; server.commit();return updateResponse.getStatus();}/*** 按Bean 添加/修改 索引** &＃64;throws Exception*/public int addIndexList(List entitys) throws Exception {server.addBeans(entitys);UpdateResponse updateResponse &＃61; server.commit();return updateResponse.getStatus();}/*** 删除索引 按查询** &＃64;throws Exception*/public int deleteAll() throws Exception {String query &＃61; "*:*";server.deleteByQuery(query);server.commit();UpdateResponse updateResponse &＃61; server.commit();return updateResponse.getStatus();}/*** 删除索引 按id** &＃64;throws Exception*/public int deleteByQuery(Long id) throws Exception {server.deleteById(id &＃43; "");server.commit();UpdateResponse updateResponse &＃61; server.commit();return updateResponse.getStatus();}//查询所有public List query() throws Exception {SolrQuery query &＃61; new SolrQuery();query.setQuery("*:*");query.setStart(0);//开始记录数query.setRows(10000);//总条数QueryResponse queryResponse &＃61; server.query(query);List results &＃61; queryResponse.getBeans(BlogCore.class);return results;}//搜索keywordspublic List queryByKeyWords(String keywords) throws Exception {SolrQuery query &＃61; new SolrQuery();query.set("q", "keywords:" &＃43; keywords);//*通配多个字符
// query.set("sort", "product_price desc");//&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;高亮设置&＃61;&＃61;&＃61;//开启高亮query.setHighlight(true);//高亮域query.addHighlightField("blogContent");query.addHighlightField("blogTitle");//前缀query.setHighlightSimplePre("");//后缀query.setHighlightSimplePost("");//query.setHighlightSnippets(1);//结果分片数&＃xff0c;默认为1//query.setHighlightFragsize(1000);//每个分片的最大长度&＃xff0c;默认为100query.setStart(0);//开始记录数query.setRows(100);//总条数QueryResponse queryResponse &＃61; server.query(query);long sum &＃61; queryResponse.getResults().getNumFound();List results &＃61; queryResponse.getBeans(BlogCore.class);//输出高亮Map>> highlighting &＃61; queryResponse.getHighlighting();for (BlogCore result : results) {Map> map &＃61; highlighting.get(result.getBlogId()&＃43;"");List list &＃61; map.get("blogTitle");if (list !&＃61; null && list.size() > 0) {result.setBlogTitle(list.get(0));}list &＃61; map.get("blogContent");if (list !&＃61; null && list.size() > 0) {result.setBlogContent(list.get(0));}}return results;}
}


SolrTest.java

package top.yuyufeng.learn.lucene.solr;import org.junit.Test;
import top.yuyufeng.learn.lucene.solr.core.BlogCore;
import top.yuyufeng.learn.lucene.solr.dao.BlogSolrDao;import java.util.Date;
import java.util.List;/*** &＃64;author yuyufeng* &＃64;date 2017/12/6*/
public class SolrTest {&＃64;Testpublic void testIndex() throws Exception {BlogSolrDao blogSolrDao &＃61; new BlogSolrDao();BlogCore blog &＃61; new BlogCore();blog.setBlogId("2");blog.setBlogTitle("达摩院超越业界龙头");blog.setBlogContent("达摩院一定也必须要超越英特尔&＃xff0c;必须超越微软&＃xff0c;必须超越IBM&＃xff0c;因为我们生于二十一世纪&＃xff0c;我们是有机会后发优势的。");blog.setCreateTime(new Date());blogSolrDao.addIndex(blog);}&＃64;Testpublic void testFindAll() throws Exception {BlogSolrDao blogSolrDao &＃61; new BlogSolrDao();List list &＃61; blogSolrDao.query();for (BlogCore blogCore : list) {System.out.println(blogCore);}}&＃64;Testpublic void testSearch() throws Exception {BlogSolrDao blogSolrDao &＃61; new BlogSolrDao();List list &＃61; blogSolrDao.queryByKeyWords("达摩院");for (BlogCore blogCore : list) {System.out.println(blogCore);}}
}


运行结果&＃xff1a;

启动Solr服务器后&＃xff0c;我建立了一些索引&＃xff0c;然后我执行Search方法

BlogCore{blogId&＃61;&＃39;2&＃39;, blogTitle&＃61;&＃39;达摩院超越业界龙头&＃39;, blogContent&＃61;&＃39;达摩院一定也必须要超越英特尔&＃xff0c;必须超越微软&＃xff0c;必须超越IBM&＃xff0c;因为我们生于二十一世纪&＃xff0c;我们是有机会后发优势的。&＃39;, createTime&＃61;Wed Dec 06 13:38:12 CST 2017, keywords&＃61;&＃39;null&＃39;}
BlogCore{blogId&＃61;&＃39;1&＃39;, blogTitle&＃61;&＃39;马云表达愿景&＃39;, blogContent&＃61;&＃39;10月11日杭州云栖大会上&＃xff0c;马云表达了对新建成的阿里巴巴全球研究院—阿里巴巴达摩院的愿景&＃xff0c;希望达摩院二十年内成为世界第一大经济体&＃xff0c;服务世界二十亿人&＃xff0c;创造一亿个工作岗位。&＃39;, createTime&＃61;Wed Dec 06 12:03:56 CST 2017, keywords&＃61;&＃39;null&＃39;}