Solr实战

本文的示例代码参考SolrPractice

目录

环境

  • Solr
brew install solr

brew services start solr

brew services list

docker run --name solr -p 8983:8983 -d solr

solr create -c core-practice
  • MySQL驱动
wget http://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.46.tar.gz

tar xf mysql-connector-java-5.1.46.tar.gz

cp mysql-connector-java-5.1.46/mysql-connector-java-5.1.46-bin.jar /usr/local/Cellar/solr/$(solr -v)/libexec/dist
  • solrconfig.xml
vim /usr/local/Cellar/solr/$(solr -v)/server/solr/core-practice/conf/solrconfig.xml
# 添加以下配置

<lib dir="${solr.install.dir}/libexec/dist/" regex="mysql-connector-java-5.1.46-bin.jar" />
<lib dir="${solr.install.dir}/libexec/dist/" regex="solr-dataimporthandler-.*\.jar" />

<requestHandler name="/dataimport" class="org.apache.solr.handler.dataimport.DataImportHandler">
    <lst name="defaults">
        <str name="config">data-config.xml</str>
    </lst>
</requestHandler>
  • data-config.xml
vim /usr/local/Cellar/solr/$(solr -v)/server/solr/core-practice/conf/data-config.xml
<dataConfig>
    <dataSource type="JdbcDataSource" 
                driver="com.mysql.jdbc.Driver"
                url="jdbc:mysql://120.55.98.237:3306/zhg" 
                user="root" 
                password="***"/>
    <document>
        <entity
            name="article"  
            pk="id"
            query="select * from article"
            deltaImportQuery="SELECT * from article WHERE id='${dih.delta.id}'"
            deltaQuery="SELECT id FROM article WHERE updated_at > '${dih.last_index_time}'"
            >
                <field column="id" name="id"/>
                <field column="title" name="title"/>
                <field column="content" name="content"/>
                <field column="updated_at" name="updated_at"/>
            </entity>
    </document>
</dataConfig>
  • managed-schema
vim /usr/local/Cellar/solr/$(solr -v)/server/solr/core-practice/conf/managed-schema
# 添加以下配置

<field name="title" type="string" indexed="true" stored="false" />
<field name="content" type="string" indexed="true" stored="false" />
<field name="updated_at" type="pdate" indexed="true" stored="false" />
brew services restart solr
  • 全量导入数据
curl http://localhost:8983/solr/core-practice/dataimport?command=full-import
  • 增量导入数据
curl http://localhost:8983/solr/core-practice/dataimport?command=delta-import
  • 查询导入数据
curl http://localhost:8983/solr/core-practice/select?q=*:* | json

这里使用nodejs的json工具格式化数据: npm i -g json、

Startup

spring init -dweb,data-solr --build gradle SolrPractice
# cd SolrPractice
mv src/main/resources/application.properties src/main/resources/application.yml
vim src/main/resources/application.yml
spring:
  data:
    solr:
      host: http://127.0.0.1:8983/solr/
vim src/main/java/com/example/SolrPractice/ArticleController.java
package com.example.SolrPractice;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/articles")
public class ArticleController {
    @GetMapping
    public String getArticles() {
        return "getArticles";
    }
}
  • 测试
./gradlew bootrun

curl localhost:8080/articles # 返回"getArticles"

Model

vim src/main/java/com/example/SolrPractice/Article.java
package com.example.SolrPractice;

import org.apache.solr.client.solrj.beans.Field;
import org.springframework.data.annotation.Id;
import org.springframework.data.solr.core.mapping.SolrDocument;

@SolrDocument(solrCoreName = "core-practice")
public class Article {

    @Id
    @Field
    private int id;
    @Field
    private String title;
    @Field
    private String content;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }
}

Repository

vim src/main/java/com/example/SolrPractice/ArticleRepository.java
package com.example.SolrPractice;

import org.springframework.data.solr.repository.SolrCrudRepository;

import java.util.List;

public interface ArticleRepository extends SolrCrudRepository<Article, Long> {
    List<Article> findAllByContentContains(String query);
}

Controller

vim src/main/java/com/example/SolrPractice/ArticleController.java
package com.example.SolrPractice;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/articles")
public class ArticleController {
    @Autowired
    private ArticleRepository articleRepository;

    @GetMapping
    public List<Article> getArticles(@RequestParam String query) {
        return articleRepository.findAllByContentContains(query);
    }
}
  • 测试
curl localhost:8080/articles?query=5000 | json
curl localhost:8080/articles?query=%e6%88%aa%e8%87%b3%e7%9b%ae%e5%89%8d | json

上述query=截至目前 urlencode编解码可以参考UrlEncode编码/UrlDecode解码- 站长工具

中文分词

solr_practice_01.png
cp /usr/local/Cellar/solr/$(solr -v)/libexec/contrib/analysis-extras/lucene-libs/lucene-analyzers-smartcn* /usr/local/Cellar/solr/$(solr -v)/server/solr-webapp/webapp/WEB-INF/lib/
vim /usr/local/Cellar/solr/$(solr -v)/server/solr/core-practice/conf/managed-schema
# 添加以下配置

<fieldType name="text_smartcn" class="solr.TextField" positionIncrementGap="0">
    <analyzer type="index">
        <tokenizer class="org.apache.lucene.analysis.cn.smart.HMMChineseTokenizerFactory"/>
    </analyzer>
    <analyzer type="query">
        <tokenizer class="org.apache.lucene.analysis.cn.smart.HMMChineseTokenizerFactory"/>
    </analyzer>
</fieldType>

# 修改之前配置

<field name="content" type="text_smartcn" indexed="true" stored="false" multiValued="true"/>
brew services restart solr
solr_practice_02.png

参考

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 两年前用过solr5.1版本的,当时只是简单入个门,拿来在项目里建个全文索引,然后再query,其他什么也没做,还...
    Coselding阅读 8,278评论 3 22
  • 1 准备工作及相关介绍 solr和lucene的版本是同步更新的,最新版本是6.5.0。本案例使用4.10.3 j...
    阿太哥阅读 6,885评论 1 5
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,324评论 19 139
  • 一.简介 Solr是一个独立的企业级搜索应用服务器,它对外提供类似于Web-service的API接口。用户可以通...
    泰安青年阅读 9,059评论 0 37
  •   Solr是一个高性能,采用Java5开发,基于Lucene的全文搜索服务器。同时对其进行了扩展,提供了比Luc...
    缱绻离愁阅读 4,886评论 0 0