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>
下面是具體使用Solr4j的工具類
?
package
x.y.z;
import
java.io.IOException;
import
java.util.ArrayList;
import
java.util.LinkedList;
import
java.util.List;
import
java.util.Map;
import
my.VirtualProxy;
import
org.apache.log4j.Logger;
import
org.apache.solr.client.solrj.SolrQuery;
import
org.apache.solr.client.solrj.SolrServer;
import
org.apache.solr.client.solrj.SolrServerException;
import
org.apache.solr.client.solrj.impl.HttpSolrServer;
import
org.apache.solr.client.solrj.response.FacetField;
import
org.apache.solr.client.solrj.response.FacetField.Count;
import
org.apache.solr.client.solrj.response.QueryResponse;
import
org.apache.solr.common.SolrDocument;
import
org.apache.solr.common.SolrDocumentList;
import
org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.stereotype.Repository;
import
org.springframework.stereotype.Service;
import
org.springframework.util.StringUtils;
import
x.y.z.framework.search.vo.Content;
import
x.y.z.framework.search.vo.Search;
//
@Repository & @Autowired is use spring annotations
@Repository
public
class
SearchDAOImpl
implements
SearchDAO
{
private
static
Logger logger = Logger.getLogger(SearchDAOImpl.
class
);
//
@Autowired
private
HttpSolrServer solrServer;
@Override
public
void
init()
{
//
TODO Auto-generated method stub
String SearchService_Url = "http://localhost:8983/solr"
;
this
.solrServer =
new
HttpSolrServer(SearchService_Url);
try
{
solrServer.ping();
}
catch
(Exception e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public
void
init(String url)
{
//
TODO Auto-generated method stub
this
.solrServer =
new
HttpSolrServer(url);
try
{
solrServer.ping();
}
catch
(Exception e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
@Override
public
boolean
ping()
{
//
TODO Auto-generated method stub
try
{
if
(
this
.solrServer !=
null
)
{
this
.solrServer.ping();
return
true
;
}
else
{
logger.debug(
"Manipulate null object.SolrServer must init."
);
return
false
;
}
}
catch
(Exception e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
return
false
;
}
}
@Override
public
void
addIndex(Content add)
{
//
TODO Auto-generated method stub
}
@Override
public
void
deleteIndex(Content delete)
{
//
TODO Auto-generated method stub
}
@Override
public
void
changeIndex(Content old_index, Content new_index)
{
//
TODO Auto-generated method stub
}
@Override
public
Search query(String query,
int
start,
int
rows,String SortField,
boolean
Highlight)
{
//
TODO Auto-generated method stub
if
(
this
.solrServer !=
null
)
{
SolrQuery solrQuery
=
new
SolrQuery();
solrQuery.setQuery(query);
//
start the query and show the rows number
solrQuery.setStart(start);
solrQuery.setRows(rows);
//
Sequence
//
Sequence for the asscet time and Weights for the sort result
//
the seq must not a null value
solrQuery.addSortField(SortField, SolrQuery.ORDER.asc);
//
high light
solrQuery.setHighlight(
true
);
solrQuery.addHighlightField(
"name"
);
solrQuery.addHighlightField(
"id"
);
solrQuery.addHighlightField(
"title"
);
solrQuery.addHighlightField(
"features"
);
solrQuery.addHighlightField(
"content"
);
solrQuery.setHighlightSimplePre(
"<font color='red'>"
);
solrQuery.setHighlightSimplePost(
"</font>"
);
solrQuery.setHighlightSnippets(
1);
//
結果分片數，默認為1
solrQuery.setHighlightFragsize(1000);
//
每個分片的最大長度，默認為100
solrQuery.setFacet(
true
).setFacetMinCount(1).setFacetLimit(5).addFacetField("id").addFacetField("inStock"
);
solrQuery.setFacet(
true
).setFacetMinCount(1).setFacetLimit(5).addFacetField("content").addFacetField("inStock"
);
QueryResponse queryResponse
=
null
;
try
{
queryResponse
=
solrServer.query(solrQuery);
SolrDocumentList solrDocumentList
=
queryResponse.getResults();
return
new
Search(queryResponse,solrDocumentList);
}
catch
(SolrServerException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
else
{
logger.debug(
"The Search Server is null value."
);
}
return
null
;
}
@Override
public
void
close()
{
//
TODO Auto-generated method stub
if
(
this
.solrServer !=
null
)
{
this
.solrServer.shutdown();
}
else
{
logger.debug(
"Manipulate null object.SolrServer must init."
);
}
}
@Override
public
List<Content>
queryAll()
{
//
TODO Auto-generated method stub
List<Content> list =
new
ArrayList<Content>
();
if
(
this
.solrServer !=
null
)
{
SolrQuery solrQuery
=
new
SolrQuery();
//
String query = "GB";
String query = "*:*"
;
solrQuery.setQuery(query);
//
add the
Integer start = 0
;
Integer rows
= 20
;
solrQuery.setStart(start);
solrQuery.setRows(rows);
//
Sequence
//
Sequence for the asscet time and Weights for the sort result
//
the seq must not a null value
//
solrQuery.addSortField("name", SolrQuery.ORDER.asc);
solrQuery.addSortField("id"
, SolrQuery.ORDER.asc);
//
high light
solrQuery.setHighlight(
true
);
solrQuery.addHighlightField(
"name"
);
solrQuery.addHighlightField(
"id"
);
solrQuery.addHighlightField(
"title"
);
solrQuery.addHighlightField(
"features"
);
solrQuery.addHighlightField(
"content"
);
solrQuery.setParam(
"hl.fl", "content"
);
solrQuery.setHighlightSimplePre(
"<font color=\"red\">"
);
solrQuery.setHighlightSimplePost(
"</font>"
);
solrQuery.setFacet(
true
).setFacetMinCount(1).setFacetLimit(5).addFacetField("id"
);
solrQuery.setFacet(
true
).setFacetMinCount(1).setFacetLimit(5).addFacetField("content"
);
solrQuery.setFacet(
true
).setFacetMinCount(1).setFacetLimit(5).addFacetField("features"
);
try
{
QueryResponse queryResponse
=
solrServer.query(solrQuery);
SolrDocumentList docs
=
queryResponse.getResults();
System.out.println(
"doc number found :" +
docs.getNumFound());
System.out.println(
"doc max score :" +
docs.getMaxScore());
for
(SolrDocument doc : docs)
{
String name
= (String) doc.getFieldValue("name"
);
String id
= (String) doc.getFieldValue("id"
);
ArrayList features
= (ArrayList)doc.getFieldValue("features"
);
//
to add the list value must use the temp object
Content vo =
new
Content();
//
Set the vo object
vo.setId(id);
vo.setName(name);
vo.setFeatures(features);
list.add(vo);
//
Print the list value
System.out.println("id :" +
id);
System.out.println(
"name :" +
name);
if
(features !=
null
)
{
for
(Object feature : features.toArray())
{
System.out.println(
"feature :" +
feature.toString());
}
}
}
}
catch
(SolrServerException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
else
{
logger.debug(
"The Search Server is null value."
);
}
return
list;
}
@Override
public
int
queryTotal(String query)
{
//
TODO Auto-generated method stub
if
(
this
.solrServer !=
null
)
{
SolrQuery solrQuery
=
new
SolrQuery();
solrQuery.setQuery(query);
QueryResponse queryResponse;
try
{
queryResponse
=
solrServer.query(solrQuery);
return
queryResponse.getResults().size();
}
catch
(SolrServerException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
return
0
;
}
/*
* (non-Javadoc)
* @Warning it will clear ALL the index
* @see com.cfp.framework.search.dao.SearchDAO#clearAll()
*/
@Override
public
void
clearAll()
{
//
TODO Auto-generated method stub
try
{
solrServer.deleteByQuery(
"*:*"
);
solrServer.commit();
}
catch
(SolrServerException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
catch
(IOException e)
{
//
TODO Auto-generated catch block
e.printStackTrace();
}
}
}
?
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
