安科网

Solr

lionelf

lionelf

2019-10-20

关注 关注

目录

solr

什么是Solr

直接使用sql搜索存在的问题

  • 大多数搜索引擎应用都必须具有某种搜索功能
  • 搜索功能往往是巨大的资源消耗
  • 它们由于沉重的数据库加载而拖垮你的应用的性能
  • 所有我们一般在做搜索的时候 会把它单独转移到一个外部的搜索服务器当中进行
  • Apache Solr是一个流行的开源搜索服务器

Apache Solr

  • Solr是一个开源搜索平台，用于构建搜索应用程序。
  • 是一个独立的企业级搜索应用服务器，它对外提供类似于Web-service的API接口
  • 它建立在Lucene(全文搜索引擎)之上。
  • Solr是企业级的，快速的和高度可扩展的。
  • 用户可以通过http请求，向搜索引擎服务器提交一定格式的XML文件，生成索引；也可以通过Http Get操作提出查找请求，并得到XML格式的返回结果。

为什么选择Solr ？

  • 第一点原因:来自SQL数据库在性能上缺乏亮点。基本上，你需要在你的查询中使用JOIN操作。
  • 第二点原因是文档的天然数据特性松散的文本文件，这种查询都是需要使用LIKE。然而joins和likes都是性能杀手，在目前的数据库引擎中是不方便的。
  • solr底层采用的是倒排索引。这种数据结构类似与美化过的词典

Solr 关键特性

1.基于标准的开放接口：Solr搜索服务器支持通过XML、JSON和HTTP查询和获取结果。
2.易管理：Solr可以通过HTML页面管理，Solr配置通过XML完成。
3.可伸缩性：能够有效地复制到另外一个Solr搜索服务器。
4.灵活的插件体系：新功能能够以插件的形式方便的添加到Solr服务器上。
5.强大的数据导入功能：数据库和其他结构化数据源现在都可以导入、映射和转化。

Solr安装

?

解压tomcat
    mkdir /usr/local/solr
    cd /usr/local/solr
    tar -zxvf apache-tomcat-8.5.32.tar.gz 
    mv apache-tomcat-8.5.32 tomcat
    有可能会存在tomcat在centos7中启动缓慢的现象
        安装：yum -y install rng-tools
        开启 rng-tools服务：service rngd start
        
解压solr
    tar -zxvf solr-4.10.3.tar
    
解压IK
    unzip IKAnalyzer.zip
    
复制solr.war到tomcat/webapp下
    cd /usr/local/solr/solr-4.10.3/example/webapps/
    cp solr.war /usr/local/solr/tomcat/webapps/
    
启动tomcat让solr.war自动解压
    /usr/local/solr/tomcat/bin
    ./startup.sh
    
关闭tomcat后才能删除solr.war包，否则会连带solr应用一起删除
    /usr/local/solr/tomcat/bin
    ./shutdown.sh
    
进入到webapps删除solr.war包
    cd /usr/local/solr/tomcat/webapps/
    rm -rf solr.war
    
将solr-4.10.3/example/lib/ext/目录下的所有jar包拷贝到/usr/local/solr/tomcat/webapps/solr/WEB-INF/lib目录中
    cd /usr/local/solr/solr-4.10.3/example/lib/ext
    cp *  /usr/local/solr/tomcat/webapps/solr/WEB-INF/lib
    
将solr-4.10.3/example/目录下的solr文件夹复制到/usr/local/solr/目录下，并且返回到/usr/local/solr目录下将solr重命名为solrhome
    cd /usr/local/solr/solr-4.10.3/example/
    cp -r solr /usr/local/solr/
    cd /usr/local/solr
    mv solr solrhome
    
配置tomcat/webapps/solr/WEB-INF/web.xml家的位置
    cd /usr/local/solr/tomcat/webapps/solr/WEB-INF/
    vim web.xml
    添加solrhome（/usr/local/solr/solrhome）
    <env-entry>
        <env-entry-name>solr/home</env-entry-name>
        <env-entry-value>/usr/local/solr/solrhome</env-entry-value>
        <env-entry-type>java.lang.String</env-entry-type>
    </env-entry>
启动tomcat
    /usr/local/solr/tomcat/bin/
    ./startup.sh

tomcat在linux中启动慢解决方式

中文分词器

IK Analyzer简介

  • IK Analyzer 是一个开源的，基亍 java 语言开发的轻量级的中文分词工具包。
  • 它是以开源项目Luence 为应用主体的，结合词典分词和文法分析算法的中文分词组件
  • IK 实现了简单的分词歧义排除算法，标志着 IK 分词器从单纯的词典分词向模拟语义分词衍化。
  • 作用: 有中文语义分析的效果, 对中文分词效果好.

IK Analyzer(配置)

把IKAnalyzer2012FF_u1.jar 添加到 solr 工程的 lib 目录下
    cd /usr/local/solr/IKAnalyzer/
    cp IKAnalyzer2012FF_u1.jar /usr/local/solr/tomcat/webapps/solr/WEB-INF/lib/
    
创建WEB-INF/classes文件夹
    cd /usr/local/solr/tomcat/webapps/solr/WEB-INF/
    mkdir classes
    
把扩展词典、停用词词典、配置文件放到 solr 工程的 WEB-INF/classes 目录下
    cd /usr/local/solr/tomcat/webapps/solr/WEB-INF/classes
    cp /usr/local/solr/IKAnalyzer/IKAnalyzer.cfg.xml ./
    cp /usr/local/solr/IKAnalyzer/ext_stopword.dic ./ 

将ext_stopword.dic文件名修改为stopword.dic
    mv ext_stopword.dic stopword.dic

修改IKAnalyzer.cfg.xml配置文件
    stopword.dic已经有了,ext.dic还没有
    cd /usr/local/solr/tomcat/webapps/solr/WEB-INF/classes
    vi IKAnalyzer.cfg.xml
    :wq
    <?xml version=1.0" encoding='UTF-8"?>
    <!DOCTYPE properties SYSTEM "http://java.sun.com/dtd/properties.dtd">
    <properties>
        <comment>IKAnalyzer扩展配置</comment>
        <--用户可以在这里配置自己的扩展字典-->
        <entry key="ext_dict">ext.dic;</entry>
        <--用户可以在这里配置自己的扩展停止词字典-->
        <entry key="ext_stopwords">stopword.dic</entry>
    </properties>

    创建ext.dic
        touch ext.dic

    stopword.dic-停止词典
        切分词的时候, 凡是出现在停止词典中的词都会被过滤掉.
    
    ext.dic-扩展词典
        凡是专有名词都会放到这里, 如果自然语义中不是一个词, 放到这里后solr
        切分词的时候就会切分成一个词.
    
配置分词器
    修改 Solrhome 的 schema.xml 文件
        cd /usr/local/solr/solrhome/collection1/conf
        vim schema.xml
            在最后添加
                <fieldType name="text_ik" class="solr.TextField">
                    <analyzer class="org.wltea.analyzer.lucene.IKAnalyzer"/>
                </fieldType>
    自定义域名使用自己创建的分词器
        <field name="content_ik" type="text_ik" indexed="true" stored="true"/>
    
配置完毕后重启tomcat

域

什么是域

  • 域相当于数据库的表字段，用户存放数据
  • 用户根据业务需要去定义相关的Field（域）

域的分类

field普通域
    大多数情况都可以用这个域来完成, 主要定义了域名和域的类型.
    
copyField复制域
    复制域中有source叫做源域, dest代表目标域, 
    在维护数据的时候, 源域中的内容会复制到目标域中一份, 
    从目标域中搜索, 就相当于从多个源域中搜索一样
    
dynamicField动态域
    solr中域名要先定义后使用, 没有定义就使用会报错, 
    起到模糊匹配的效果,可以模糊匹配没有定义过的域名，相当于通配符的作用
    
uniqueKey主键域
    在添加数据的时候必须有主键域, 没有会报错, 这个不用添加也不用修改, 就使用这个默认的域名id就可以.

域的常用属性

  • name：指定域的名称
  • type：指定域的类型
  • indexed：是否索引
  • stored：是否存储
  • required：是否必须
  • multiValued：是否多值

普通域

<fieldType name="text_ik" class="solr.TextField">
     <analyzer class="org.wltea.analyzer.lucene.IKAnalyzer"/>
</fieldType>


<field name="content_ik" type="text_ik" indexed="true" stored="true"/>
<field name="item_goodsid" type="long" indexed="true" stored="true"/>
<field name="item_title" type="text_ik" indexed="true" stored="true"/>
<field name="item_price" type="double" indexed="true" stored="true"/>
<field name="item_image" type="string" indexed="false" stored="true" />
<field name="item_category" type="string" indexed="true" stored="true" />
<field name="item_seller" type="text_ik" indexed="true" stored="true" />
<field name="item_brand" type="string" indexed="true" stored="true" />
<field name="item_updatetime" type="date" indexed="true" stored="true" />

复制域

<field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_category" dest="item_keywords"/>
<copyField source="item_seller" dest="item_keywords"/>
<copyField source="item_brand" dest="item_keywords"/>

动态域

<dynamicField name="item_spec_*" type="string" indexed="true" stored="true" />

solrj

概述

  • solrJ是solr官方推出的客户端工具包, 将solrj的jar包放到我们项目中
  • 我们就可以调用solrj中的api来远程给solr服务器发送命令, solr服务器就可以完成对索引库的操作(添加修改删除查询)

操作步骤

创建一个普通的Java工程

添加soloJ相关Jar包

<!-- solr客户端 -->
<dependency>
    <groupId>org.apache.solr</groupId>
    <artifactId>solr-solrj</artifactId>
    <version>${solrj.version}</version>
</dependency>

操作

添加或者修改

?

//修改时, 会把以前的内容删除, 然后再添加
@Test
public void testIndexCreateAndUpdate() throws Exception {
    /**
    * 创建和solr服务器连接
    * http://192.168.1.88:8080/solr是连接的默认实例也就是collection1实例
     * http://192.168.1.88:8080/solr/collection2实例
    */
    SolrServer solrServer = new HttpSolrServer("http://192.168.1.88:8080/solr");
    //创建文档对象
    SolrInputDocument doc = new SolrInputDocument();
    doc.addField("id", "002");
    doc.addField("title", "后裔");
    doc.addField("price", "250");
    //添加或者修改
    solrServer.add(doc);
    //提交
    solrServer.commit();
    }
}
查询所有

?

@Test
public void testIndexSearch() throws Exception {
    SolrServer solrServer = new HttpSolrServer("http://192.168.1.88:8080/solr");
    //创建查询对象
    SolrQuery query = new SolrQuery();
    //设置查询条件
    query.setQuery("*:*");
    //查询并返回响应
    QueryResponse queryResponse = solrServer.query(query);
    //从响应中获取结果集
    SolrDocumentList results = queryResponse.getResults();
    System.out.println("count=" + results.getNumFound());
    for (SolrDocument result : results) {
        System.out.println("id=" + result.get("id"));
        System.out.println("title=" + result.get("title"));
    }
}
删除
@Test
public void testIndexDelete() throws Exception {
    SolrServer solrServer = new HttpSolrServer("http://192.168.1.88:8080/solr");
    //单个删除
    //solrServer.deleteById("001");
    //删除所有
    solrServer.deleteByQuery("*:*");
    //提交
    solrServer.commit();
}

Spring Data Solr

简介

  • Spring Data Solr就是为了方便Solr的开发所研制的一个框架
  • 其底层是对SolrJ（官方API）的封装

入门

（1）创建maven工程SpringSolrProject jar项目

（2）pom.xml中引入依赖

<properties>
    <spring.version>5.1.7.RELEASE</spring.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-beans</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aspects</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jms</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>${spring.version}</version>
    </dependency>


    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-solr</artifactId>
        <version>1.5.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>5.1.7.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
    </dependency>
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>servlet-api</artifactId>
        <version>2.5</version>
    </dependency>
</dependencies>

（3）在src/main/resources下创建applicationContext-solr.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
   xmlns:context="http://www.springframework.org/schema/context"
   xmlns:solr="http://www.springframework.org/schema/data/solr"
   xsi:schemaLocation="http://www.springframework.org/schema/data/solr
    http://www.springframework.org/schema/data/solr/spring-solr-1.0.xsd
    http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- solr服务器地址 -->
    <solr:solr-server id="solrServer" url="http://192.168.1.88:8080/solr" />

    <!-- solr模板，使用solr模板可对索引库进行CRUD的操作 -->
    <bean id="solrTemplate" class="org.springframework.data.solr.core.SolrTemplate">
        <constructor-arg ref="solrServer" />
    </bean>
</beans>

（4）创建 cn.fmjava.pojo 包 引入 Item实体类

import lombok.Data;
import org.apache.solr.client.solrj.beans.Field;
import org.springframework.data.solr.core.mapping.Dynamic;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import java.util.Map;

@Data
public class Item implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 商品id，同时也是商品编号
     */
    @Field
    private Long id;

    /**
     * 商品标题
     */
    @Field("item_title")
    private String title;

    /**
     * 商品卖点
     */
    private String sellPoint;

    /**
     * 商品价格，单位为：元
     */
    @Field("item_price")
    private BigDecimal price;

    private Integer stockCount;

    /**
     * 库存数量
     */
    private Integer num;

    /**
     * 商品条形码
     */
    private String barcode;

    /**
     * 商品图片
     */
    @Field("item_image")
    private String image;

    /**
     * 所属类目，叶子类目
     */
    private Long categoryid;

    /**
     * 商品状态，1-正常，2-下架，3-删除
     */
    private String status;

    /**
     * 创建时间
     */
    private Date createTime;

    /**
     * 更新时间
     */
    @Field("item_updatetime")
    private Date updateTime;

    private String itemSn;

    private BigDecimal costPirce;

    private BigDecimal marketPrice;

    private String isDefault;

    @Field("item_goodsid")
    private Long goodsId;

    private String sellerId;

    private String cartThumbnail;

    @Field("item_category")
    private String category;

    @Field("item_brand")
    private String brand;

    private String spec;

    @Field("item_seller")
    private String seller;

    @Dynamic
    @Field("item_spec_*")
    private Map<String,String> specMap;

    public Map<String, String> getSpecMap() {
        return specMap;
    }

    public void setSpecMap(Map<String, String> specMap) {
        this.specMap = specMap;
    }

}

（5）配置业务域

修改solrhome的schema.xml 文件 设置业务系统 Field
<field name="item_goodsid" type="long" indexed="true" stored="true"/>
<field name="item_title" type="text_ik" indexed="true" stored="true"/>
<field name="item_price" type="double" indexed="true" stored="true"/>
<field name="item_image" type="string" indexed="false" stored="true" />
<field name="item_category" type="string" indexed="true" stored="true" />
<field name="item_seller" type="text_ik" indexed="true" stored="true" />
<field name="item_brand" type="string" indexed="true" stored="true" />
<field name="item_updatetime" type="date" indexed="true" stored="true" />
复制域的作用在于将某一个Field中的数据复制到另一个域中
<field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_category" dest="item_keywords"/>
<copyField source="item_seller" dest="item_keywords"/>
<copyField source="item_brand" dest="item_keywords"/>
动态扩充字段时，我们需要使用动态域
<dynamicField name="item_spec_*" type="string" indexed="true" stored="true" />

?

配置
cd /usr/local/solr/solrhome/collection1/conf
vim schema.xml
<field name="item_goodsid" type="long" indexed="true" stored="true"/>
    <field name="item_title" type="text_ik" indexed="true" stored="true"/>
    <field name="item_price" type="double" indexed="true" stored="true"/>
    <field name="item_image" type="string" indexed="false" stored="true" />
    <field name="item_category" type="string" indexed="true" stored="true" />
    <field name="item_seller" type="text_ik" indexed="true" stored="true" />
    <field name="item_brand" type="string" indexed="true" stored="true" />
<field name="item_updatetime" type="date" indexed="true" stored="true" />

<field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_category" dest="item_keywords"/>
<copyField source="item_seller" dest="item_keywords"/>
<copyField source="item_brand" dest="item_keywords"/>

<dynamicField name="item_spec_*" type="string" indexed="true" stored="true" />

?

重启tomcat
/usr/local/solr/tomcat/bin/shutdown.sh
/usr/local/solr/tomcat/bin/startup.sh

（6）在实体类字段上添加@Field注解

public class Item implements Serializable {
    /**
     * 商品id，同时也是商品编号
     */
    @Field
    private Long id;

    /**
     * 商品标题
     */
    @Field("item_title")
    private String title;

    /**
     * 商品卖点
     */
    private String sellPoint;

    /**
     * 商品价格，单位为：元
     */
    @Field("item_price")
    private BigDecimal price;

    private Integer stockCount;

    /**
     * 库存数量
     */
    private Integer num;

    /**
     * 商品条形码
     */
    private String barcode;

    /**
     * 商品图片
     */
    @Field("item_image")
    private String image;

    /**
     * 所属类目，叶子类目
     */
    private Long categoryid;

    /**
     * 商品状态，1-正常，2-下架，3-删除
     */
    private String status;

    /**
     * 创建时间
     */
    private Date createTime;

    /**
     * 更新时间
     */
    private Date updateTime;

    private String itemSn;

    private BigDecimal costPirce;

    private BigDecimal marketPrice;

    private String isDefault;

    @Field("item_goodsid")
    private Long goodsId;

    private String sellerId;

    private String cartThumbnail;

    @Field("item_category")
    private String category;

    @Field("item_brand")
    private String brand;

    private String spec;

    @Field("item_seller")
    private String seller;

    private static final long serialVersionUID = 1L;
}

（7）创建测试类

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext-solr.xml")
public class TestIndexManager {
    @Autowired
    private SolrTemplate solrTemplate;
    //添加更新
    @Test
    public void testIndexCreatAndUpdate() {
        List<Item> itemList = new ArrayList<Item>();
        for(long i= 1; i < 100; i++) {
            Item item = new Item();
            item.setId(i);
            item.setTitle("鲁班" + i);
            item.setCategory("射手");
            item.setPrice(new BigDecimal("100"+i));
            item.setBrand("王者");
            itemList.add(item);
        }
        //保存
        //solrTemplate.saveBean(itemList);
        solrTemplate.saveBeans(itemList);
        //提交
        solrTemplate.commit();
    }

    //删除
    @Test
    public void testIndexDelte() {
        //根据主键域id删除
        //solrTemplate.deleteById("1");

        //创建查询对象
        Query query = new SimpleQuery("*:*");
        //根据查询条件删除
        solrTemplate.delete(query);
        //提交
        solrTemplate.commit();
    }

    //查询
    @Test
    public void testSearch() {
        //创建查询对象
        //Query query = new SimpleQuery("*:*");
        //创建查询对象
        Query query = new SimpleQuery();
        //创建查询条件对象, 注意这里的Criteria对象和mybatis中的那个不是同一个, 只是同名而已
        Criteria criteria = new Criteria("item_title").contains("鲁班");
        //查询对象中放入查询条件
        query.addCriteria(criteria);
        //从第几条开始查询
        query.setOffset(11);
        //设置每页查询多少条数据
        query.setRows(20);
        //查询并返回结果
        ScoredPage<Item> items = solrTemplate.queryForPage(query, Item.class);
        //总页数
        int totalPages = items.getTotalPages();
        //查询到的总记录数
        long totalElements = items.getTotalElements();
        //查询到的数据集合
        List<Item> content = items.getContent();
        //每页有多少条数据
        int numberOfElements = items.getNumberOfElements();
        System.out.println("==========");
        System.out.println(content);
    }
}

库存数据批量导入

作用

  • 查询库存数据库中所有的数据
  • 把数据导入到索引库当中
  • 只需要要用一次, 当索引库当中的数据出现损坏或文件丢失时, 再次调用

创建solr-util（jar） ,引入依赖dao项目

?

<dependencies>
    <dependency>
        <groupId>com.itxk</groupId>
        <artifactId>dao</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
</dependencies>

在common工程当中引入pom依赖

<!-- solr -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-solr</artifactId>
    <version>1.5.5.RELEASE</version>
</dependency>

在solr-util项目src/main/resource/spring文件夹下创建

spring/applicationContext-solr.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:solr="http://www.springframework.org/schema/data/solr"
xsi:schemaLocation="http://www.springframework.org/schema/data/solr 
    http://www.springframework.org/schema/data/solr/spring-solr-1.0.xsd
    http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context.xsd">

    <!-- solr服务器地址 -->
    <solr:solr-server id="solrServer" url="http://192.168.1.88:8080/solr" />

    <!-- solr模板，使用solr模板可对索引库进行CRUD的操作 -->
    <bean id="solrTemplate" class="org.springframework.data.solr.core.SolrTemplate">
        <constructor-arg ref="solrServer" />
    </bean>
</beans>

spring/applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <context:component-scan base-package="com.fmjava.core.util"></context:component-scan>

</beans>

把pojo/item添加@Field

@Data
public class Item implements Serializable {
    private static final long serialVersionUID = 1L;
    
    /**
     * 商品id，同时也是商品编号
     */
    @Field
    private Long id;

    /**
     * 商品标题
     */
    @Field("item_title")
    private String title;

    /**
     * 商品卖点
     */
    private String sellPoint;

    /**
     * 商品价格，单位为：元
     */
    @Field("item_price")
    private BigDecimal price;

    private Integer stockCount;

    /**
     * 库存数量
     */
    private Integer num;

    /**
     * 商品条形码
     */
    private String barcode;

    /**
     * 商品图片
     */
    @Field("item_image")
    private String image;

    /**
     * 所属类目，叶子类目
     */
    private Long categoryid;

    /**
     * 商品状态，1-正常，2-下架，3-删除
     */
    private String status;

    /**
     * 创建时间
     */
    private Date createTime;

    /**
     * 更新时间
     */
    @Field("item_updatetime")
    private Date updateTime;

    private String itemSn;

    private BigDecimal costPirce;

    private BigDecimal marketPrice;

    private String isDefault;

    @Field("item_goodsid")
    private Long goodsId;

    private String sellerId;

    private String cartThumbnail;

    @Field("item_category")
    private String category;

    @Field("item_brand")
    private String brand;

    private String spec;

    @Field("item_seller")
    private String seller;

    @Dynamic
    @Field("item_spec_*")
    private Map<String,String> specMap;

    public Map<String, String> getSpecMap() {
        return specMap;
    }

    public void setSpecMap(Map<String, String> specMap) {
        this.specMap = specMap;
    }
}

创建类SolrUtil ,实现商品数据的查询(已审核商品)

@Component
public class DataImportToSolr {

    @Autowired
    private SolrTemplate solrTemplate;
    @Autowired
    private ItemDao itemDao;
    public void importItemDataToSolr() {
        ItemQuery query = new ItemQuery();
        ItemQuery.Criteria criteria = query.createCriteria();
        criteria.andStatusEqualTo("1");
        List<Item> items = itemDao.selectByExample(query);
        if (items != null) {
            for (Item item : items) {
                //获取规格json格式字符串
                String specJsonStr = item.getSpec();
                Map map = JSON.parseObject(specJsonStr, Map.class);
                item.setSpecMap(map);
            }
            //保存
            solrTemplate.saveBeans(items);
            //提交
            solrTemplate.commit();
        }
    }

    public static void main(String[] args) {
        ApplicationContext contexnt =
                new ClassPathXmlApplicationContext("classpath*:spring/applicationContext*.xml");
        DataImportToSolr bean = (DataImportToSolr)contexnt.getBean("dataImportToSolr");
        bean.importItemDataToSolr();
    }
}

solr ul

lionelf

lionelf

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

docker 安装solr8.6.2 配置中文分词器的方法

docker run --name blog-solr -d -p 8983:8983 solr // blog-solr这个可用自行命名。docker exec -it --user=solr blog-solr bin/solr create_core

spylyt 2020-09-11

Apache Solr velocity模板注入RCE漏洞

lionelf 2020-07-28

【solr】使用-取反时注意，-是表示排除，不能单独做条件用

1、solr的-表示取反、排除意思，比如说我要name不为a的数据，我们正常理解写法是-name:a，这是不对的，正确写法是

upxiaofeng 2020-06-11

solr与.net系列课程(五)solrnet的使用

最近因项目比较忙,所以这篇文章出的比较晚,离上一篇文章已经有半个月的时间了,这节课我们来学下一下solr的.net客户端solrnet. 上一篇文章讲述了C#是如何请求和接受solr的数据的,请求链接是自己拼接的,接受数据是使用数据契约,solrnet就是

TyCoding 2020-05-03

关于Solr服务搭建

Solr 是Apache下的一个顶级开源项目，采用Java开发，它是基于Lucene的全文搜索服务器。Solr提供了比Lucene更为丰富的查询语言，同时实现了可配置、可扩展，并对索引、搜索性能进行了优化。Solr根据xml文档添加、删除、更新索引 。So

upxiaofeng 2020-04-30

【solr】添加分词器ik-analyzer-solr

项目在此基础上：solr7.2.1+tomcat8.5.37+jdk8安装配置。下载的jar包复制到。添加分词字段类型

lionelf 2020-04-20

Solr7-4的学习与使用

17年的时候有学习使用过lucene和solr，但是后来也遗忘了，最近公司有个项目需要使用到全文检索，正好也顺便跟着学习一下，使用的版本是Solr7.4的，solr解压之后的目录结构:各文件夹里面的内容：。solr从5版本之后不再需要tomcat，使用内置

TyCoding 2020-04-08

01 CentOS7中安装和启动solr

solr是一个企业级搜索应用服务器，以lucence为基础。本文将讲解如何在centos7中安装solr。# 确保solr-4.10.3.tgz、apache-tomcat-8.5.38.zip是在当前目录下。稍等片刻，war包便会被解压。重启tomcat

TyCoding 2020-03-26

solr replication原理探究

无论是垂直搜索，还是通用搜索引擎，对外提供搜索服务其压力都比较大，经常有垂直电商在做活动的时候服务器宕机。对面访问压力比较大的情况，一般的应对方法就是+。Solr提供了两种解决方案来对应访问压力。其一是Replication，其一是SolrCloud。Re

wenchanter 2020-03-26

ant编译solr源码生成eclipse项目，解决一直resolve，一直[ivy:retrieve]的问题

咋不说这个问题用相应方法解决即可/微笑？最终通过自己一通乱搞，终于“Build Successful”，具体哪一步起了作用实在不敢说，尝试的方法是在太多了，只把正确的记录下来好了，自己整理一下思路，能够帮到有同样问题的人更好啦~

roygbip 2020-02-16

2020.2.3学习进度总结

感受：重新安装了十多次android studio都没有成功，今天你在同学的远程桌面的帮助下，将android studio完全彻底删除之后又安装了看三次，最后还是没成功，有点崩溃了，但是不会放弃，明天要问一问老师，希望老师能帮我解决这个问题。

wsxsxz 2020-02-03

Solr请求概念和配置详解

　　Solr最常见的请求类型是在Solr索引中查找相关文档的查询。除此之外，Solr还可以处理许多不同类型的请求。所有的请求基本上都是通过请求处理器提交给Solr。例如，通过搜索组件执行主查询，其中分面、搜索结果高亮和拼写检查都有各自的搜索组件。要让查询请

lionelf 2020-02-03

lucene&amp;solr全文检索_7solr后台界面的介绍

Logging：solr的运行日志，如果出现问题会告诉你什么问题。Core Admin:solr core 的管理界面。solr core是solr 的一个独立运行实例单位，他可以对外提供索引和搜索服务，一个solr工程可以运行多个solrcore，一个c

lionelf 2020-02-03

lucene&amp;solr全文检索_3查询索引

创建完索引之后，我们需要查询。// 第一步：创建一个java工程，并导入jar包。// 2）指定一个分析器，对文档内容进行分析。Directory directory =FSDirectory.open;//创建document

TyCoding 2020-02-01

Lucene、Solr、ElasticSearch、hibernate-search四部曲

直到昨天，在工作中刚刚得知Lucene、Solr。本质区别在于：1、Lucene是搜索库，不是独立的应用程序，而Solr是。此外Hibernate Search能够根据需要进行同步或异步的索引更新。Lucene的目的是为软件开发人员提供一个简单易用的工具包

heniancheng 2020-01-31

lunrjs - A bit like Solr, but much smaller and not as bright.

Lunr.js is a small, full-text search library for use in the browser. It indexes JSON documents and provides a simple search inte

lionelf 2020-01-30

一、linux系统安装配置solr8

第五步：配家、配置apache-tomcat-8.0.47→webApp→solr→WEB_INF下的web.xml

wsxsxz 2020-01-17

详细solr集成搭建

numShards=2 ---------------------- 4个solr分成两个区name=collection1　 ---------------------- name为collection1shard=shard1　　　------

TyCoding 2020-01-10

solr 7.7.0 添加多个core（三）

复制new_core里的所有文件到new_core1中

TyCoding 2020-01-09

solr7.7.0 添加core （二）

1 接上篇 solr 环境搭建(一)，在schema.xml下面有一个感叹号！主要是修改contrib目录，dist目录的相对位置。instanceDir文件夹里会自动生成一个core.properties文件。以后再次需要创建solrCore核心的时候，

wsxsxz 2020-01-09
lionelf

lionelf

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号