添加商品數(shù)據(jù)

Spring容器

由Spring容器，來管理SolrServer
將SolrServer注入Spring容器

添加配置文件
applicationContext-solr.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsdhttp://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsdhttp://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd"><!-- 單機(jī)版solr的連接 --><bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer"><constructor-arg name="baseURL" value="http://192.168.25.154:8080/solr/collection1"/></bean><!-- 集群版solr連接 --><!-- <bean id="cloudSolrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer"><constructor-arg name="zkHost" value="192.168.25.154:2181,192.168.25.154:2182,192.168.25.154:2183"></constructor-arg><property name="defaultCollection" value="collection2"/></bean> --></beans>

ServerImpl

業(yè)務(wù)邏輯

1、查詢所有商品數(shù)據(jù)
2、創(chuàng)建一個(gè)SolrServer對(duì)象
3、為每個(gè)商品創(chuàng)建一個(gè)SolrInputDocument對(duì)象
4、為文檔添加域
5、向索引庫中添加文檔
6、返回TaotaoResult

@Service public class SearchItemServiceImpl implements SearchItemService {@Autowiredprivate SearchItemMapper searchItemMapper;@Autowiredprivate SolrServer solrServer;@Overridepublic TaotaoResult importItemsToIndex() {try {//1、先查詢所有商品數(shù)據(jù)List<SearchItem> itemList = searchItemMapper.getItemList();//2、遍歷商品數(shù)據(jù)添加到索引庫for (SearchItem searchItem : itemList) {//創(chuàng)建文檔對(duì)象SolrInputDocument document = new SolrInputDocument();//向文檔中添加域document.addField("id", searchItem.getId());document.addField("item_title", searchItem.getTitle());document.addField("item_sell_point", searchItem.getSell_point());document.addField("item_price", searchItem.getPrice());document.addField("item_image", searchItem.getImage());document.addField("item_category_name", searchItem.getCategory_name());document.addField("item_desc", searchItem.getItem_desc());//把文檔寫入索引庫solrServer.add(document);}//3、提交solrServer.commit();} catch (Exception e) {e.printStackTrace();return TaotaoResult.build(500, "數(shù)據(jù)導(dǎo)入失敗");}//4、返回添加成功return TaotaoResult.ok();}}

如果，采用Dubbo分布式服務(wù)
需要發(fā)布服務(wù)

<!-- 聲明需要暴露的服務(wù)接口 --> <dubbo:service interface="com.taotao.search.service.SearchItemService" ref="searchItemServiceImpl" timeout="300000"/>

調(diào)用的模塊，引用服務(wù)

<!-- 引用dubbo服務(wù) --> <dubbo:reference interface="com.taotao.search.service.SearchItemService" id="searchItemService" />

總結(jié)

以上是生活随笔為你收集整理的SolrJ添加商品数据的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。