Solr

 1 import org.apache.solr.client.solrj.SolrQuery;
 2         import org.apache.solr.client.solrj.SolrServerException;
 3         import org.apache.solr.client.solrj.impl.HttpSolrServer;
 4         import org.apache.solr.client.solrj.response.QueryResponse;
 5         import org.apache.solr.client.solrj.response.UpdateResponse;
 6         import org.apache.solr.common.SolrDocument;
 7         import org.apache.solr.common.SolrDocumentList;
 8         import org.apache.solr.common.SolrInputDocument;
 9         import org.junit.Before;
10         import org.junit.Test;
11 
12         import java.io.IOException;
13         import java.util.ArrayList;
14         import java.util.List;
15 
16 /**
17  * Created by Edward on 2016/7/27.
18  */
19 public class MyTest {
20 
21     private static final String URL = "http://node1:8080/solr/collection1/";
22     private HttpSolrServer httpSolrServer;
23 
24     @Before
25     public void init(){
26         httpSolrServer = new HttpSolrServer(URL);
27 
28     }
29 
30     @Test
31     public void add() throws IOException, SolrServerException {
32         SolrInputDocument doc1 = new SolrInputDocument();
33         doc1.addField("id","1");
34         doc1.addField("title","了解hadoop概念");
35         doc1.addField("content","了解hadoop概念，这个是内容");
36         SolrInputDocument doc2 = new SolrInputDocument();
37         doc2.addField("id","2");
38         doc2.addField("title","学习查看hadoop文档");
39         doc2.addField("content","学习查看hadoop文档，这个是内容");
40         SolrInputDocument doc3 = new SolrInputDocument();
41         doc3.addField("id","3");
42         doc3.addField("title","搭建hadoop环境");
43         doc3.addField("content","搭建hadoop环境，这个是内容");
44         List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
45         docs.add(doc1);
46         docs.add(doc2);
47         docs.add(doc3);
48 
49         UpdateResponse response = httpSolrServer.add(docs);
50 
51         System.out.println("Query Time：" + response.getQTime());
52         System.out.println("Elapsed Time：" + response.getElapsedTime());
53         System.out.println("Status：" + response.getStatus());
54 
55         httpSolrServer.commit();
56     }
57 
58     @Test
59     public void query() throws SolrServerException {
60         SolrQuery solrQuery = new SolrQuery();
61         solrQuery.setQuery("hadoop");
62 
63         QueryResponse response = httpSolrServer.query(solrQuery);
64         SolrDocumentList list = response.getResults();
65 
66         for(int i=0; i<list.size(); i++){
67             SolrDocument doc = list.get(i);
68             System.out.println(doc.get("id"));
69             System.out.println(doc.get("title"));
70             System.out.println(doc.get("content"));
71         }
72     }
73 }