solr入门之搭建具有安全控制和权限管理功能的SolrCloud集群

标签：

9.配置客户端,使用solrj来操作solrcloud(摸索阶段)

================================================================

================

3.在solr启动配置中增加zk的acl配置信息
3.1在solr_8001/data中的solr.xml中增加如下内容

3.2 在solr_8001/solr.in.sh中底部增加如下内容:

这里是设置了一个操作zookeeper的权限用户admin 密码也是admin

================

==========================

===================

============

使用的Java代码如下:

package com.mx.solr.zk.client.servlet.utils;

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.impl.CloudSolrClient;

public class SolrClientUitls {

    private static SolrClient client = null;
    public static SolrClient getClient(){
        if(client ==null){
            String zkUrl = "192.168.119.20:2181,192.168.119.21:2181";
            CloudSolrClient cloudSolrClient = new  CloudSolrClient(zkUrl);
            cloudSolrClient.setDefaultCollection("meixin_suggest");
            cloudSolrClient.connect();
            client = cloudSolrClient;
        }
        return client;
    }
}

package com.mx.solr.zk.client.servlet;

import java.io.IOException;
import java.util.Properties;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.apache.solr.client.solrj.request.QueryRequest;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;

import com.mx.solr.zk.client.servlet.utils.SolrClientUitls;



/**
 * Servlet implementation class ClientServlet
 */
@WebServlet("/ClientServlet")
public class ClientServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;

    /**
     * @see HttpServlet#HttpServlet()
     */
    public ClientServlet() {
        super();
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
            SolrClient client = SolrClientUitls.getClient();
            SolrQuery q  = new SolrQuery();
            q.set("q", "*:*");
            QueryRequest req = new QueryRequest(q);
            req.setBasicAuthCredentials("root", "songqinghu");
            QueryResponse res;
            try {
                res = req.process(client);
                long numFound = res.getResults().getNumFound();
                System.out.println("the query numfound is :"+ numFound);
                SolrDocumentList docs = res.getResults();
                for (SolrDocument doc : docs) {
                    System.out.println("suggestId :"+doc.getFieldValue("suggestId").toString());
                    System.out.println("word :"+doc.getFieldValue("word").toString());
                }
            } catch (SolrServerException e) {
                e.printStackTrace();
            }
           // cloudSolrClient.close();
    }

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }

}

运行结果如下:

如果使用maven启动的话,只需要在下图的位置设置变量即可:

到现在为止,一个具有安全控制功能的SolrCloud集合就搭建完成了,当然你在搭建的过程中可能会遇到很多问题,如果需要一起讨论,请加博主QQ群.

488252920

solr入门之搭建具有安全控制和权限管理功能的SolrCloud集群

标签：

原文地址：http://blog.csdn.net/sqh201030412/article/details/51396427