本文主要是介绍使用solrj操作solr索引库，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
solr库搭建参考我的博客:https://blog.csdn.net/tomcatAndOracle/article/details/80306018
(solrj)初次使用solr的开发人员总是很郁闷，不知道如何去操作solr索引库，以为只能用《五分钟solr4.5教程（搭建、运行）》中讲到的用xml文件的形式提交数据到索引库，其实没有那么麻烦，solr配套有好多的客户端用于操作索引库，下面我们来讲如何用solrj去操作solr索引库。
一、认识solrj
solrj是solr的java客户端，用于访问solr索引库。它提供了添加、删除、查询、优化等功能。
二、下载
百度、google以下solrj下载，你会发现根本就没有，那么我们该到哪儿下载呢？其实，它是集成到solr压缩包里的，解压文件后，有个目录/dist/solrj-lib，里面就存放了solrj所用到的jar，你把这些jar都添加到你的classpath就ok。
如果你是使用Maven来构建项目，添加以下代码到你的pom.xml配置文件中：
<dependency> <artifactId>solr-solrj</artifactId> <groupId>org.apache.solr</groupId> <version>1.4.0</version> <type>jar</type> <scope>compile</scope> </dependency>
<dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-simple</artifactId> <version>1.5.6</version> </dependency>
三、创建SolrServer
1、HttpSolrServer
solrj是采用http请求的方式去访问solr索引库的，首先我们得先创建一个HttpSolrServer，如下：
String url = "http://localhost:8983/solr";//8983是web服务器的端口号，需要根据情况进行调整 SolrServer server = new HttpSolrServer( url );
以上使用默认的方式创建server，你也可以配置其他的连接参数：
2、EmbeddedSolrServer
EmbeddedSolrServer提供了和HttpSolrServer一样的接口，区别是EmbeddedSolrServer没有通过http连接。
//Note that the following property could be set through JVM level arguments too System.setProperty("solr.solr.home", "d:/solr_home/solr"); //此处配置solr home，根据自己的情况修改 CoreContainer.Initializer initializer = new CoreContainer.Initializer(); CoreContainer coreContainer = initializer.initialize(); EmbeddedSolrServer server = new EmbeddedSolrServer(coreContainer, "");
当然实际中可能不止一个core，那么采用如下方式：
File home = new File( "d:/solr_home/solr" );//此处配置solr home，根据自己的情况修改 File f = new File( home, "solr.xml" ); CoreContainer container = new CoreContainer(); container.load( "d:/solr_home/solr", f ); EmbeddedSolrServer server = new EmbeddedSolrServer( container, "core name as defined in solr.xml" );//双引号配置你的core名字 ...
在嵌入式的应用中使用solr，推荐使用EmbeddedSolrServer。
注意：EmbeddedSolrServer使用有个前提条件，需要在solrconfig.xml配置相对应的RequestHandler，如：/update对应更新操作。
四：solrj的使用
创建好server以后，我们就可以开始solrj操作索引库了！！
首先创建一个server，最好的方式是采用单例模式，不要重复去创建。
SolrServer server = new HttpSolrServer("http://HOST:8983/solr/");
1、添加文档到索引库
//创建一个文档
SolrInputDocument doc1 = new SolrInputDocument(); doc1.addField( "id", "id1", 1.0f ); doc1.addField( "name", "doc1", 1.0f ); doc1.addField( "price", 10 );
//再创建一个文档
SolrInputDocument doc2 = new SolrInputDocument(); doc2.addField( "id", "id2", 1.0f ); doc2.addField( "name", "doc2", 1.0f ); doc2.addField( "price", 20 );
//创建一个collection，把以上两个文档添加进去
Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>(); docs.add( doc1 ); docs.add( doc2 );
//把文档添加到server中
server.add( docs );
//提交文档
server.commit();//此处只是提交到索引中，不会出现在搜索结果中；如果想立马搜索，请使用commit(boolean waitFlush, boolean waitSearcher)方法
如果你想添加到server后想快速提交（commit），可以采用如下方式：
UpdateRequest req = new UpdateRequest(); req.setAction( UpdateRequest.ACTION.COMMIT, false, false ); req.add( docs ); UpdateResponse rsp = req.process( server );
2、添加pojo到索引库
除了通过文档的形式提交以外，solrj还可以通过pojo的方式提交。使用注解@Field映射到schema.xml中定义的字段中
创建一个javaBean：
import org.apache.solr.client.solrj.beans.Field; public class Item { @Field String id; @Field("cat")//自定义字段名 String[] categories; @Field List<String> features; public void setId(String id) { this.id = id; } public void getId() { return this.id; } //其他get、set方法}
创建JavaBean的实例：
Item item = new Item(); item.id = "one"; item.categories = new String[] { "aaa", "bbb", "ccc" };
添加到server中：
server.addBean(item);
提交到索引：
server.commit();
还可以同时添加多个javaBean：
List<Item> beans ; //add Item objects to the list server.addBeans(beans);
3、删除索引
server.deleteById(String id); 或者 deleteById(List<String> ids);
4、更新索引
solr索引库不同于数据库，没有更新的功能。如果想更新，先通过id删除对应的文档，再添加新的文档。
5、查询索引
SolrQuery query = new SolrQuery(); query.setQuery( "*:*" ); query.addSortField( "price", SolrQuery.ORDER.asc ); QueryResponse rsp = server.query( query );
//文档方式读取
SolrDocumentList docs = rsp.getResults();//实际项目中如果业务比较复杂，采用这种方式显得比较灵活
//使用javaBean的方式读取
List<Item> beans = rsp.getBeans(Item.class);
6、高级使用
SolrServer server = getSolrServer(); SolrQuery solrQuery = new SolrQuery() . setQuery("ipod") . setFacet(true) . setFacetMinCount(1) . setFacetLimit(8) . addFacetField("category") . addFacetField("inStock"); QueryResponse rsp = server.query(solrQuery);
7、高亮显示
SolrQuery query = new SolrQuery(); query.setQuery("foo"); query.setHighlight(true).setHighlightSnippets(1); //set other params as needed query.setParam("hl.fl", "content"); QueryResponse queryResponse = getSolrServer().query(query);
处理高亮显示结果：
Iterator<SolrDocument> iter = queryResponse.getResults().iterator(); while (iter.hasNext()) { SolrDocument resultDoc = iter.next(); String content = (String) resultDoc.getFieldValue("content"); String id = (String) resultDoc.getFieldValue("id"); //id is the uniqueKey field if (queryResponse.getHighlighting().get(id) != null) { List<String> highlightSnippets = queryResponse.getHighlighting().get(id).get("content"); } }
这篇关于使用solrj操作solr索引库的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
