Solr+Tomcat+zookeeper部署实战

<env-entry>
       <env-entry-name>solr/home</env-entry-name>
       <env-entry-value>/opt/solr/solr-home</env-entry-value>
       <env-entry-type>Java.lang.String</env-entry-type>
 </env-entry>

<!-- 
<security-constraint>
    <web-resource-collection>
      <web-resource-name>Disable TRACE</web-resource-name>
      <url-pattern>/</url-pattern>
      <http-method>TRACE</http-method>
    </web-resource-collection>
    <auth-constraint/>
  </security-constraint>
  <security-constraint>
    <web-resource-collection>
      <web-resource-name>Enable everything but TRACE</web-resource-name>
      <url-pattern>/</url-pattern>
      <http-method-omission>TRACE</http-method-omission>
    </web-resource-collection>
  </security-constraint>
-->

 <!-- IK分词 -->
<fieldType name="text_ik" class="solr.TextField">
<analyzer type="index">
<tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="false"/>
</analyzer>
<analyzer type="query">
<tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="true"/>
</analyzer>
</fieldType>

<!-- IK分词 -->
<fieldType name="text_ik" class="solr.TextField">
<analyzer type="index">
<tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="false"/>
<filter class="top.pinyin.index.solr.PinyinTokenFilterFactory" pinyin="true" isFirstChar="true" minTermLenght="2" />
<filter class="com.shentong.search.analyzers.PinyinNGramTokenFilterFactory" minGram="2" maxGram="20" />
</analyzer>
<analyzer type="query">
<tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="true"/>
</analyzer>
</fieldType>

<fieldType name="text_ik" class="solr.TextField">
   <analyzer type="index">
      <tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="false"/>
      <filter class="top.pinyin.index.solr.PinyinTokenFilterFactory" pinyin="true" isFirstChar="true" minTermLenght="2"/>
      <filter class="com.shentong.search.analyzers.PinyinNGramTokenFilterFactory" minGram="2" maxGram="20"/>
      <filter class="solr.LowerCaseFilterFactory"/>
   </analyzer>
   <analyzer type="query">
      <tokenizer class="org.apache.lucene.analysis.ik.IKTokenizerFactory" useSmart="true"/
      <filter class="solr.SynonymFilterFactory" synonyms="synonyms.txt" ignoreCase="true" expand="true"/>
      <filter class="solr.LowerCaseFilterFactory"/>
   </analyzer>
</fieldType>

<field name="name" type="text_ik" multiValued="false" indexed="true" stored="true"/>
<field name="suggestion" type="text_suggest" indexed="true" stored="true" multiValued="true" /> 
<copyField source="name" dest="suggestion"/>

　　name为该suggest模块的名字；
　　lookUpImpl为查找器，默认为JaspellLookupFactory；
　　dictionaryImpl为字典实现；
　　field为要联想的字段；
　　suggestAnalyzerFieldType规定了进行联想操作所使用类型所对应的Analyzer（该字段必填）；
　　buildOnStartup表示是否在启动时建立索引。

[root@bogon bin]# bash /usr/local/zookeeper/zoo1/zookeeper-3.4.10/bin/zkCli.sh

<dependency>
<groupId>org.apache.solr</groupId>
      <artifactId>solr-solrj</artifactId>
      <version>6.6.0</version>
</dependency>

package com.demo.util.solr;
import java.io.IOException; 
import java.util.ArrayList; 
import java.util.Collection;
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.response.QueryResponse; 
import org.apache.solr.common.SolrDocument; 
import org.apache.solr.common.SolrDocumentList; 
import org.apache.solr.common.SolrInputDocument; 

public class SolrCloudTest {
    private static CloudSolrClient cloudSolrClient;
    private static synchronized CloudSolrClient getCloudSolrClient(final String zkHost) { 
        if (cloudSolrClient == null) { 
            try { 
                cloudSolrClient = new CloudSolrClient(zkHost); 
            } catch (Exception e) { 
                e.printStackTrace(); 
            } 
        } 
        return cloudSolrClient; 
    }
    private static void addIndex(SolrClient solrClient) { 
        try { 
            SolrInputDocument doc1 = new SolrInputDocument(); 
            doc1.addField("id", "421245251215121452521251"); 
            doc1.addField("name", "张三"); 
            doc1.addField("age", 30); 
            doc1.addField("desc", "张三是个农民，勤劳致富，奔小康"); 
 
            SolrInputDocument doc2 = new SolrInputDocument(); 
            doc2.addField("id", "4224558524254245848524243"); 
            doc2.addField("name", "李四"); 
            doc2.addField("age", 45); 
            doc2.addField("desc", "李四是个企业家，白手起家，致富一方"); 

            SolrInputDocument doc3 = new SolrInputDocument(); 
            doc3.addField("id", "2224558524254245848524299"); 
            doc3.addField("name", "王五"); 
            doc3.addField("age", 60); 
            doc3.addField("desc", "王五好吃懒做，溜须拍马，跟着李四，也过着小康的日子"); 

            Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>(); 
            docs.add(doc1); 
            docs.add(doc2); 
            docs.add(doc3); 
            solrClient.add(docs); 
            solrClient.commit(); 
        } catch (SolrServerException e) { 
            System.out.println("Add docs Exception !!!"); 
            e.printStackTrace(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } catch (Exception e) { 
            System.out.println("Unknowned Exception!!!!!"); 
            e.printStackTrace(); 
        } 
    }

  public static void search(SolrClient solrClient, String String) { 
        SolrQuery query = new SolrQuery(); 
        query.setQuery(String); 
        try { 
            QueryResponse response = solrClient.query(query); 
            SolrDocumentList docs = response.getResults();
            System.out.println("文档个数：" + docs.getNumFound()); 
            System.out.println("查询时间：" + response.getQTime()); 
 
            for (SolrDocument doc : docs) { 
                String id = (String) doc.getFieldValue("id"); 
                String name = (String) doc.getFieldValue("name"); 
                Integer age = (Integer) doc.getFieldValue("age"); 
                String desc = (String) doc.getFieldValue("desc"); 
                System.out.println("id: " + id); 
                System.out.println("name: " + name); 
                System.out.println("age: " + age); 
                System.out.println("desc: " + desc); 
                System.out.println(); 
            } 
        } catch (SolrServerException e) { 
            e.printStackTrace(); 
        } catch (Exception e) { 
            System.out.println("Unknowned Exception!!!!"); 
            e.printStackTrace(); 
        } 
    }

    public static void deleteAllIndex(SolrClient solrClient) { 
        try { 
            solrClient.deleteByQuery("*:*");// delete everything! 
            solrClient.commit(); 
        } catch (SolrServerException e) { 
            e.printStackTrace(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } catch (Exception e) { 
            System.out.println("Unknowned Exception !!!!"); 
            e.printStackTrace(); 
        } 
    }

    public static void main(String[] args) throws IOException { 
         final String zkHost = "192.168.29.110:2181,192.168.29.120:2181,192.168.29.130:2181";
         final String defaultCollection = "collection1";   
         final int zkClientTimeout = 20000;   
         final int zkConnectTimeout = 1000;

         CloudSolrClient cloudSolrClient = getCloudSolrClient(zkHost);          
        System.out.println("The Cloud cloudSolrClient Instance has benn created!");             
        cloudSolrClient.setDefaultCollection(defaultCollection);   
        cloudSolrClient.setZkClientTimeout(zkClientTimeout);   
        cloudSolrClient.setZkConnectTimeout(zkConnectTimeout);                    
        cloudSolrClient.connect();   

        System.out.println("The cloud Server has been connected !!!!");  

   SolrCloudTest.addIndex(cloudSolrClient); 

  SolrCloudTest.search(cloudSolrClient, "name:李四");   

    SolrCloudTest.deleteAllIndex(cloudSolrClient);
    SolrCloudTest.search(cloudSolrClient, "name:李四");
        cloudSolrClient.close(); 
    }
}

　　dataSource：设置数据源
　　document：Solr的信息的基本单位，它是一组描述某些事物的数据集合
　　entity：对应数据表
　　pk：表主键
　　dataSource：指定使用哪个数据源
　　name：表名
　　query：查询sql
　　 deltaQuery：增量更新时使用的查询sql
　　 ${dih.last_index_time}：最后更新时间
　　field：表字段

[root@solr_1 ~]# vim /opt/solr/solr-home/conf/dataimport.properties