solr索引文件
package com.gotop.solrproj.importdata;import java.io.File;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrRequest.METHOD;
import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.apache.solr.client.solrj.request.AbstractUpdateRequest;
import org.apache.solr.client.solrj.request.ContentStreamUpdateRequest;
public> public static void main(String[] args) throws Exception {
String zkHost = "192.168.137.200:2181,192.168.137.201:2181";
SolrClient server = new CloudSolrClient(zkHost);
addDocs(server);
server.close();
}
public static void addDocs(SolrClient server) throws Exception {
ContentStreamUpdateRequest req = new ContentStreamUpdateRequest("/update/extract");
req.setMethod(METHOD.POST);
File file = new File("D:/java文档/Javaweb项目开发手册.docx");
req.addFile(file, "application/msword");
req.setParam("literal.id", "00007");
req.setParam("literal.stream_size", String.valueOf(file.length()));
req.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
server.request(req,"mycollection");
}
}
页:
[1]