上一章讲了怎么使用solr admin向solrserver加入索引，Solr 是一个独立的企业级搜索应用server。它对外提供类似于 Web-service 的 API 接口。

用户能够通过 http请求，向搜索引擎server提交一定格式的 XML 文件，生成索引。也能够通过 Http
Get 操作提出查找请求，并得到XML 格式的返回结果。

所以我们能够使用httpClient作为client向solrserver加入索引。可是幸运的是，solr为我们提供专门的clientjar包。solrj，我们能够使用该jar包向solrserver提交索引。

首先我们导入相关的包，相关的jar包能够通过下载的solr的压缩包中获取，当中包含：

1.dist/solrj-lib

2.dist/solr-solrj-*.jar

把这些jar包导入到classpath中，我们就能够開始使用solrj了。

HttpSolrServer

		String url = "http://localhost:8080/solr";

		HttpSolrServer server = new HttpSolrServer(url);

		server.setMaxRetries(1); // defaults to 0. > 1 not recommended.

		server.setConnectionTimeout(5000); // 5 seconds to establish TCP

		// Setting the XML response parser is only required for cross

		// version compatibility and only when one side is 1.4.1 or

		// earlier and the other side is 3.1 or later.

		server.setParser(new XMLResponseParser()); // binary parser is used by

													// default

		// The following settings are provided here for completeness.

		// They will not normally be required, and should only be used

		// after consulting javadocs to know whether they are truly required.

		server.setSoTimeout(1000); // socket read timeout

		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);

 // Note that the following property could be set through JVM level arguments too

  System.setProperty("solr.solr.home", "/home/shalinsmangar/work/oss/branch-1.3/example/solr");

  CoreContainer.Initializer initializer = new CoreContainer.Initializer();

  CoreContainer coreContainer = initializer.initialize();

  EmbeddedSolrServer server = new EmbeddedSolrServer(coreContainer, "");

    File home = new File( "/path/to/solr/home" );

    File f = new File( home, "solr.xml" );

    CoreContainer container = new CoreContainer();

    container.load( "/path/to/solr/home", f );

    EmbeddedSolrServer server = new EmbeddedSolrServer( container, "core name as defined in solr.xml" );

连接成功后。我们能够使用server进行数据的提交。

		 SolrInputDocument doc1 = new SolrInputDocument();

		 doc1.addField( "id", "333333333333333", 1.0f );

		 doc1.addField( "name", "3333333333333333333", 1.0f );

		 doc1.addField( "price", 10 );

		 server.add(doc1);

		 server.commit();

提交成功后。能够通过solr admin查看索引是否添加了，可是最简单的方式就是调用查询方法，查询一下。

		SolrQuery solrQuery = new SolrQuery();

		solrQuery.setQuery("q=3333333333333333333");

		QueryResponse queryResponse= server.query(solrQuery);

		System.out.println(queryResponse.getResults().get(0).getFieldValue("name"));

向solr服务加入pojo的数据

首先我们须要新建一个java bean。

public class Item {

	@Field

    private String id;

    @Field

    private String category;

    @Field

    private List<String> features;

	public String getId() {

		return id;

	}

	public void setId(String id) {

		this.id = id;

	}

	public String getCategory() {

		return category;

	}

	public void setCategory(String category) {

		this.category = category;

	}

	public List<String> getFeatures() {

		return features;

	}

	public void setFeatures(List<String> features) {

		this.features = features;

	}

}

向solr加入数据。

		Item item = new Item();

		item.setId("201404300001");

		item.setCategory("category");

		item.setFeatures(Arrays.asList("feature1","feature2","feature3"));

		server.addBean(item);

		server.commit();

搜索一下，验证是否加入成功。

		SolrQuery solrQuery = new SolrQuery();

		solrQuery.setQuery("q=feature1");

		QueryResponse queryResponse= server.query(solrQuery);

		List<Item> items = queryResponse.getBeans(Item.class);

		System.out.println(items.get(0).getCategory());