solr java客户端build索引
package com.duitang.views.test;import java.io.IOException;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.CommonsHttpSolrServer;
import org.apache.solr.client.solrj.impl.XMLResponseParser;
import org.apache.solr.client.solrj.response.UpdateResponse;
public class SolrTest {
public static void main(String[] args) throws IOException, SolrServerException {
CommonsHttpSolrServer solrServer = new CommonsHttpSolrServer("http://127.0.0.1:7100/solr/blog/");
solrServer.setSoTimeout(1000);
solrServer.setConnectionTimeout(100);
solrServer.setDefaultMaxConnectionsPerHost(100);
solrServer.setMaxTotalConnections(100);
solrServer.setAllowCompression(true);
solrServer.setParser(new XMLResponseParser());
for(long i=0;i<1000;i++){
BlogDO obj = new BlogDO();
obj.setId(i);
obj.setMsg("hello world");
UpdateResponse response = solrServer.addBean(obj);
System.out.println(response.getStatus());
}
solrServer.commit();
}
}
public class BlogDO {
@Field
private Long id;
@Field("sender_id")
private Long senderId;
@Field
private String msg;
@Field("add_datetime")
private Date addDatetime;
@Field
private Date last_replied_datetime;
@Field
private Integer buyable;
}
页:
[1]