知识点
相关文章
更多最近更新
更多solrj的使用 ---转
2019-03-27 01:12|来源: 网路
CommonsHttpSolrServer
CommonsHttpSolrServer 使用HTTPClient 和solr服务器进行通信。
- String url = "http://localhost:8983/solr";
- SolrServer server = new CommonsHttpSolrServer( url );
Setting XMLResponseParser
sorlr J 目前使用二进制的格式作为默认的格式。对于solr1.2的用户通过显示的设置才能使用XML格式。
- server.setParser(new XMLResponseParser());
server.setParser(new XMLResponseParser());
Changing other Connection Settings
CommonsHttpSorlrServer 允许设置链接属性。
- String url = "http://localhost:8983/solr"
- CommonsHttpSolrServer server = new CommonsHttpSolrServer( url );
- server.setSoTimeout(1000); // socket read timeout
- server.setConnectionTimeout(100);
- server.setDefaultMaxConnectionsPerHost(100);
- server.setMaxTotalConnections(100);
- server.setFollowRedirects(false); // defaults to false
- // allowCompression defaults to false.
- // Server side must support gzip or deflate for this to have any effect.
- server.setAllowCompression(true);
- server.setMaxRetries(1); // defaults to 0. > 1 not recommended.
String url = "http://localhost:8983/solr" CommonsHttpSolrServer server = new CommonsHttpSolrServer( url ); server.setSoTimeout(1000); // socket read timeout server.setConnectionTimeout(100); server.setDefaultMaxConnectionsPerHost(100); server.setMaxTotalConnections(100); server.setFollowRedirects(false); // defaults to false // allowCompression defaults to false. // Server side must support gzip or deflate for this to have any effect. server.setAllowCompression(true); server.setMaxRetries(1); // defaults to 0. > 1 not recommended.
EmbeddedSolrServer
EmbeddedSorrServer提供和CommonsHttpSorlrServer相同的接口,它不需要http连接。
- SolrCore core = SolrCore.getSolrCore();
- SolrServer server = new EmbeddedSolrServer( core );
- ...
SolrCore core = SolrCore.getSolrCore(); SolrServer server = new EmbeddedSolrServer( core ); ...
如果你想要使用 Multicore 特性,那么你可以这样使用:
- File home = new File( getSolrHome() );
- File f = new File( home, "solr.xml" );
- multicore.load( getSolrHome(), f );
- EmbeddedSolrServer server = new EmbeddedSolrServer( multicore, "core name as defined in solr.xml" );
File home = new File( getSolrHome() ); File f = new File( home, "solr.xml" ); multicore.load( getSolrHome(), f ); EmbeddedSolrServer server = new EmbeddedSolrServer( multicore, "core name as defined in solr.xml" );
如果你在你的项目中内嵌solr服务,这将是一个不错的选择。无论你能否使用http,它都提供相同的接口。
用法
solrj 被设计成一个可扩展的框架,用以向solr服务器提交请求,并接收回应。
我们已经将最通用的一些命令封装在了solrServer类中了。
Adding Data to Solr
- 首先需要获得一个server的实例,
- SolrServer server = getSolrServer();
SolrServer server = getSolrServer();
- 如果,你使用的是一个远程的solrServer的话呢,你或许会这样来实现getSolrServer()这个方法:
- public SolrServer getSolrServer(){
- //the instance can be reused
- return new CommonsHttpSolrServer();
- }
public SolrServer getSolrServer(){
//the instance can be reused
return new CommonsHttpSolrServer();
}
- 如果,你使用的是一个本地的solrServer的话,你或许会这样来实现getSolrServer()方法:
- public SolrServer getSolrServer(){
- //the instance can be reused
- return new EmbeddedSolrServer();
- }
public SolrServer getSolrServer(){ //the instance can be reused return new EmbeddedSolrServer(); }
- 如果,你在添加数据之前,想清空现有的索引,那么你可以这么做:
- server.deleteByQuery( "*:*" );// delete everything!
server.deleteByQuery( "*:*" );// delete everything!
- 构造一个document
- SolrInputDocument doc1 = new SolrInputDocument();
- doc1.addField( "id", "id1", 1.0f );
- doc1.addField( "name", "doc1", 1.0f );
- doc1.addField( "price", 10 );
SolrInputDocument doc1 = new SolrInputDocument(); doc1.addField( "id", "id1", 1.0f ); doc1.addField( "name", "doc1", 1.0f ); doc1.addField( "price", 10 );
- 构造另外一个文档,每个文档都能够被独自地提交给solr,但是,批量提交是更高效的。每一个对SolrServer的请求都是http请求,当然对于EmbeddedSolrServer来说,是不一样的。
- SolrInputDocument doc2 = new SolrInputDocument();
- doc2.addField( "id", "id2", 1.0f );
- doc2.addField( "name", "doc2", 1.0f );
- doc2.addField( "price", 20 );
SolrInputDocument doc2 = new SolrInputDocument(); doc2.addField( "id", "id2", 1.0f ); doc2.addField( "name", "doc2", 1.0f ); doc2.addField( "price", 20 );
- 构造一个文档的集合
- Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
- docs.add( doc1 );
- docs.add( doc2 );
Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>(); docs.add( doc1 ); docs.add( doc2 );
- 将documents提交给solr
- server.add( docs );
server.add( docs );
- 提交一个commit
- server.commit();
server.commit();
- 在添加完documents后,立即做一个commit,你可以这样来写你的程序:
- UpdateRequest req = new UpdateRequest();
- req.setAction( UpdateRequest.ACTION.COMMIT, false, false );
- req.add( docs );
- UpdateResponse rsp = req.process( server );
UpdateRequest req = new UpdateRequest(); req.setAction( UpdateRequest.ACTION.COMMIT, false, false ); req.add( docs ); UpdateResponse rsp = req.process( server );
Directly adding POJOs to Solr
- 使用 java 注释创建java bean。@Field ,可以被用在域上,或者是setter方法上。如果一个域的名称跟bean的名称是不一样的,那么在java注释中填写别名,具体的,可以参照下面的域categories
- import org.apache.solr.client.solrj.beans.Field;
- public class Item {
- @Field
- String id;
- @Field("cat")
- String[] categories;
- @Field
- List<String> features;
- }
import org.apache.solr.client.solrj.beans.Field; public class Item { @Field String id; @Field("cat") String[] categories; @Field List<String> features; }
- java注释也可以使用在setter方法上,如下面的例子:
- @Field("cat")
- public void setCategory(String[] c){
- this.categories = c;
- }
@Field("cat") public void setCategory(String[] c){ this.categories = c; }
这里应该要有一个相对的,get方法(没有加java注释的)来读取属性
- Get an instance of server
- SolrServer server = getSolrServer();
SolrServer server = getSolrServer();
- 创建bean实例
- Item item = new Item();
- item.id = "one";
- item.categories = new String[] { "aaa", "bbb", "ccc" };
Item item = new Item(); item.id = "one"; item.categories = new String[] { "aaa", "bbb", "ccc" };
- 添加给solr
- server.addBean(item);
server.addBean(item);
- 将多个bean提交给solr
- List<Item> beans ;
- //add Item objects to the list
- server.addBeans(beans);
List<Item> beans ; //add Item objects to the list server.addBeans(beans);
注意: 你可以重复使用SolrServer,这样可以提高性能。
Reading Data from Solr
- 获取solrserver的实例
- SolrServer server = getSolrServer();
SolrServer server = getSolrServer();
- 构造 SolrQuery
- SolrQuery query = new SolrQuery();
- query.setQuery( "*:*" );
- query.addSortField( "price", SolrQuery.ORDER.asc );
SolrQuery query = new SolrQuery(); query.setQuery( "*:*" ); query.addSortField( "price", SolrQuery.ORDER.asc );
- 向服务器发出查询请求
- QueryResponse rsp = server.query( query );
QueryResponse rsp = server.query( query );
- 获取结果。
- SolrDocumentList docs = rsp.getResults();
SolrDocumentList docs = rsp.getResults();
- 想要以javabean的方式获取结果,那么这个javabean必须像之前的例子一样有java注释。
- List<Item> beans = rsp.getBeans(Item.class);
List<Item> beans = rsp.getBeans(Item.class);
高级用法
solrJ 提供了一组API,来帮助我们创建查询,下面是一个faceted query的例子。
- SolrServer server = getSolrServer();
- SolrQuery solrQuery = new SolrQuery().
- setQuery("ipod").
- setFacet(true).
- setFacetMinCount(1).
- setFacetLimit(8).
- addFacetField("category").
- addFacetField("inStock");
- QueryResponse rsp = server.query(solrQuery);
所有的 setter/add 方法都是返回它自己本身的实例,所以就像你所看到的一样,上面的用法是链式的。
转自:http://www.cnblogs.com/cy163/archive/2009/09/19/1570049
相关问答
更多-
索引db通过SolrJ(index db via SolrJ)[2022-08-12]
如果您只需要能够打开与Solr服务器的连接以进行索引(并且不需要将配置文件与SolrJ项目实际集成),那么这很简单。 首先,您需要打开SolrJ连接,这样做是这样的: HttpSolrServer solrServer = new HttpSolrServer("http://localhost:8983/solr"); 另一个选择是利用Spring Data Solr的solr模式,并使Solr服务器bean执行以下操作:solrj RealTime得到(solrj RealTime get)[2023-07-14]
由于RealTime Get是使用备用requestHandler实现的,因此您只需要在SolrQuery上使用setRequestHandler()方法,将"/get"作为处理程序名称。 有关完整示例,请参阅Solr源中此SolrExampleTests.java文件中的testRealTimeGet()方法。 这是该文件的片段: SolrQuery q = new SolrQuery(); q.setRequestHandler("/get"); q.set("id", "DOCID"); ...在Eclipse上运行SolrJ(Running SolrJ on Eclipse)[2023-09-20]
好的,这意味着另类: A)你正在从错误的类中“运行 - - >> Java应用程序”。 打开包含main的类,右键单击它并选择“Run as Java Application” B)你的main方法有一个错误的签名(因此不是一个有效的主方法) - Ok so that means in alternative: A) your're doing "run as -->> Java application" from the wrong class. Open then class that contains ...您可以在SolrQuery类上使用addFilterQuery()方法 。 只需按原样传递过滤器查询(“ x:[10 TO 100] AND y:[20 TO 300] ”) You can use the addFilterQuery() method on the SolrQuery class. Just pass the filter query as is ("x:[10 TO 100] AND y:[20 TO 300]")这是一个在java中的错误,bug代码在这里: http : //bugs.java.com/bugdatabase/view_bug.do?bug_id=8168069 非常感谢mjiderhamn(在GitHub上) 。 他是优秀的classloader-leak-prevention库的开发者,现在已经包含了一个针对此问题的预防器 (版本2.1.0)。 It's a bug in java, the bug ticket is here: http://bugs.java.com/bugdatabas ...import org.apache.solr.client.solrj.impl.CloudSolrServer; import org.apache.solr.common.SolrInputDocument; CloudSolrServer server = new CloudSolrServer("localhost:9983"); server.setDefaultCollection("collection1"); SolrInputDocument doc = new SolrInputDoc ...Solrj查询响应(Solrj query Response)[2022-04-10]
谢谢Perikli,但它已经整理好了。 代码如下: SolrServer solrServer = new HttpSolrServer("http://localhost:8983/solr"); QueryResponse qResponse = solrServer.query(queryForFecthing); 实际上在创建QueryResponse对象时得到异常,即qResponse ,我认为这是因为我作为参数传递的查询(即上面是' queryForFecthing ')。 但这是错误的假设 ...您可以通过以下方式指定所有参 query.setParam("spellcheck", "true"); query.setParam("spellcheck.q", query); You can specify all parameters via: query.setParam("spellcheck", "true"); query.setParam("spellcheck.q", query);使用SolrJ索引文档(Indexing document with SolrJ)[2023-01-07]
您需要在文档索引过程完成后提交。 因此,如果您重新启动solr,它将执行自动提交。 如果你不想重启Solr。 你可以试试 重新加载核心(请参阅下面的URL,根据您更改URL名称) http://127.0.0.1:8080/solr/admin/cores?action=RELOAD&core=core1 要么 使用solr.commit(); 在你的代码中 You need to commit after document indexing process is done. so if you resta ...Solr / Solrj分页(Solr/Solrj pagination)[2022-06-13]
在服务器上执行查询之前,客户端不会知道你在服务器端设置了什么,对吧? 所以他们全都是空的并不奇怪。 要实现分页,您需要客户端的两个参数 - 页码和每页的项目数量。 一旦你得到了这两个,你可以在客户端构建你的SolrQuery,如下所示: SolrQuery query = new SolrQuery(searchTerm); query.setStart((pageNum - 1) * numItemsPerPage); query.setRows(numItemsPerPage); // execute ...