solrj的使用是一個java客戶端訪問solr它定義了jav

1、solrj的使 本頁描述的solrj 使用solrj的使 本頁描述的solrj 使用solrj/solr 是關(guān)于改變默認(rèn)請求writer二進(jìn)制solr- , 的使用場景別人需要）使用solrjFrom From/dist/solrj-server.setParser(new Fromslf4jk.rFromslf4jk.r 如果你使用的solr-solrj 1.4.1 且 slf4j-simple 1.5.6 ，你可能會獲得 你必須使用slf4j-simple 1.5 slf4j-servlet-solr-solr-HttpSolrServer apache 的 CommonsHttpSolr

2、Server 改變?yōu)?solr4.0 Common Http C HttpSolrServer apache 的 CommonsHttpSolrServer 改變?yōu)?solr4.0 Common Http C HttpSolrServer,StreamingUpdateSolrServer 改變?yōu)楦淖冞B接設(shè) Stringurl=HttpSolrServer server = new HttpSolrServer( url ); server.setMaxRetries(1); / defaults to 0. 1 notserver.setConnectionTimeout(5000);/5s

3、econdstoestablish/SettingtheXMLresponseparserisonlyrequiredfor/compatibilityandonlywhenonesideis1.4.1/ earr and the other side is 3.1 or later. by/Thefollowingsettingsareprovidedherefor/Theywillnotnormallyberequired,andshouldonlybeserver.setSoTimeout(1000); / socket read timeout Stringurl=HttpSolrSe

4、rveristhread-safeandifyouareusingthefollowing you*MUST*re-usethesameinstanceforallrequests. Ifinstan are created onthe fly, it can cause a connection leak. Theis to keep aic instance of HttpSolrServersolrserverurlandshare it for all requests.forSolrServerserver=newHttpSolrServer(url 應(yīng)用使用 應(yīng)用使用 Solr，這

5、是 HTTP工 說明：EmbeddedSolrServer只能在solrconfig.xml.用solrj 被設(shè)計為一個可擴展的框架，通過solrrequest 到solrserver 并返回一個solrresponse為簡單起見，最常 File home = new File( /path/to/solr/home ); File f = new File( home, solr.xml ); CoreContainercontainer=newCoreContainer(); container.load( /path/to/solr/home, f );EmbeddedSolrServe

6、rserver=newEmbeddedSolrServer(container, core name as defined in solr.xml );/ NotetthefollowingpropertycouldbesetthroughJVMlevel arguments tooCoreContainer.Initializerinitializer=new CoreContainer coreContainer = initializer.initialize(); server.setFollowRedirects(false); /defaultstodefaultsto/Serve

7、rsidemustsupportgzipordeflateforthistohaveany solr 添加數(shù)首先獲取一個server 用s創(chuàng)建一個dcouemntsolr 添加數(shù)首先獲取一個server 用s創(chuàng)建一個dcouemntUpdateRequestreq=newreq.setAction( UpdateMIT,false,false); req.add( docs );UpdateResponsersp=s(serverserver.add(docsdocs=new docs.add(doc1); docs.add(doc2doc2 = new SolrInputdoc2.addFi

8、eld( id, id2, 1.0f );doc2.addField(name,doc2,1.0f); doc2.addField( price, 20 );doc1 = new SolrInputdoc1.addField( id, id1, 1.0f );doc1.addField(name,doc1,1.0f); doc1.addField( price, 10 );server.deleteByQuery(*:*);/CAUTION:deletesSolrServerserver=newSolrServerserver=流的 流的 直接solr javabean“field注釋可以應(yīng)用

9、到一個字段或setter方法。如果字段名稱不 同于 bean 字段名稱給別名名稱中的注釋本身在類別字段顯示。publicclass Field Stringid;ListHttpSolrServerserver=newHttpSolrServer(); iter = newresultreturn result;publicresult=/ construct a newhereandsetittoresult return result;應(yīng)該有相應(yīng)的getter 方法（沒有注釋 說明重用solrserver應(yīng)該有相應(yīng)的getter 方法（沒有注釋 說明重用solrserver實例如果您使用此

10、功能（性能Solr SOLR最合適的方法是一個過程，以避免競爭條件時使用的提交和回滾。同時，在理 從數(shù)據(jù)數(shù)JDBC ResultSetaddresultset添加文件，SolrListbeans/addItemobjectstothelist Itemitem=newItem(); item.id = one;item.categories= newStringaaa,bbb,ccc; SolrServerserver=publicvoidsetCategory(String c) this.categories = c;importimport java.sql.ResultSet;impo

11、rtimport java.sql.ResultSet;import java.sql.SQLException; import java.sql.Types;import java.util.ArrayList; importimportpublicclassprivatefetchSize=privateprivateicHttpSolrServerpublicTest()throwssolrCore=newTakes an SQL ResultSet and adds thestosolr.Doesit in batchesof*paramAResultSetfromthereturnT

12、henumbersaddedtothrowsthrowsthrowspubliclongaddResultSet(ResultSetrs)throwsSQLException, SolrServerException, IOExceptionlong count = 0; innerCount=0;docs=new ResultSetMetaDatarsm=numColumns = rsm.getColumnCount(); StringcolNames=numColumns = rsm.getColumnCount(); StringcolNames=newStringnumColumns+

13、1;JDBCnumbersthecolumnsstartingat1,sothenormaljava ofstartingatzerowontfori=1;i(numColumns+1);colNamesi=Iftherearetyouwanttohandlemanually,themhereandtentryincolNamestonull.causethehenextsectiontot/if(rsm.getColumnName(i)=/colNamesi=/whiledoc=newAt this po, take care of manualassignments forwhich yo

14、u previously assigned the colNames entry to / doc.addField(solr_db_id, forj=1;j(numColumns+1);if(colNamesj!=ObjectswitchObjectswitchcasef=rs.getLong(j); casef = rs.getcasef=rs.getDate(j); casef=rs.getFloat(j); casef=rs.getDouble(j); casef=rs.getDate(j); casef = rs.getf=傳XML和二進(jìn)制格式的內(nèi)容。默認(rèn)的是XML，傳XML和二進(jìn)制

15、格式的內(nèi)容。默認(rèn)的是XML，使用下面的上傳使用二進(jìn)制格式。這是相 ndlername=/update/javabin server.setRequestWriter(new doc.addField(colNamesj, WhenwereachfetchSize,indexsandtheif(innerCount=innerCount = 0;Iftheouterloopendedbeforetheinnerloopreset,if(innerCount!=return數(shù)高級用solrjAPI來創(chuàng)建代替手工編碼的查詢。以下是一個faceted 數(shù)高級用solrjAPI來創(chuàng)建代替手工編碼的查詢。

16、以下是一個faceted SolrQueryquery=newSolrQuery(); query.setHighlight(true).setHighlightSnippets(1);/setother params as neededquery.setParam(hl.fl, SolrServer server = getSolrServer(); SolrQuerysolrQuery=new SolrQuery().QueryResponsersp=Listbeans=SolrServerserver=getSolrServer(); SolrQuery query = new Solr

17、Query(); query.setQuery( *:* );query.addSortField(price,SolrQuery.ORDER.asc); QueryResponse rsp = server.query( query );Listdocs=查詢負(fù)載平衡Groovy查詢負(fù)載平衡Groovy.slf4j, module=slf4j-jdk14, verimportStringurl=defserver=newHttpSolrServer(url); def doc = new SolrInputdoc.addField(id, 2) doc.addField(word_s, Cow) doc.addField(desc_t,FarmAnimal) iter = while(iter.hasNext()oc=Stringcontent=(String)String id = (String