電子發燒友App
數據庫中的數據導入索引庫
導入solr索引庫需要先在Linux中安裝solr并且配置solr
這是在Linux中配置solr的詳細步驟地址
https://mp.csdn.net/postedit/80472436
模塊劃分
SearchItemServiceImpl.java代碼實現
/**
* 商品數據索引庫Service
*/
@Service
public class SearchItemServiceImpl implements SearchItemService {
@Autowired
private ItemMapper itemMapper;
@Autowired
private SolrServer solrServer;
/**
* 將刪商品數據導入索引庫
* @return
*/
@Override
public E3Result importItems（） {
try {
//查詢商品列表
List《SearchItem》 itemList = itemMapper.getItemList（）;
//導入到索引庫
for （SearchItem item ：itemList） {
//創建文檔對象
SolrInputDocument document=new SolrInputDocument（）;
//向文檔添加域
document.addField（“id”，item.getId（））;
document.addField（“item_title”，item.getTitle（））;
document.addField（“item_sell_point”，item.getSell_point（））;
document.addField（“item_price”，item.getPrice（））;
document.addField（“item_image”，item.getImage（））;
document.addField（“item_category_name”，item.getCategory_name（））;
//寫入索引庫
solrServer.add（document）;
}
//提交
solrServer.commit（）;
//返回成功
return E3Result.ok（）;
}catch （Exception e）{
e.printStackTrace（）;
return E3Result.build（500，“商品導入失敗！”）;
}
}
}
Controller代碼
然而我們在添加商品的時候solr庫沒有添加到該商品的索引，導致我們在搜索時搜索不到該商品的信息，想要同步只有每次添加一個商品，我們就只有去調用點擊后臺的一鍵導入solr庫才可以將該商品添加到solr庫中。這樣就感覺很麻煩而且效率非常的低，可用性較差。我們就可以使用activemq消息的方式來解決該方法實現自動同步的效果。每次添加一個商品發送一個消息在添加該商品的信息到solr庫中。
實現功能的代碼。
需要修改其中商品管理模塊的步驟
添加一個applicationConten-activemq.xml配置文件
2.修改添加實現類中的方法在插入商品信息到數據庫中的時候我們就發送一個消息
//發送一個商品添加信息
jmsTemplate.send（topicDestination， new MessageCreator（） {
@Override
public Message createMessage（Session session） throws JMSException {
//設置消息內容為商品id值需要轉換一下類型為字符串
TextMessage textMessage = session.createTextMessage（itemId+“”）;
return textMessage;
}
}）;
搜索模塊
添加一個監聽器監聽隨時監聽隨時接收消息
ItemAddMessageListener.java
添加applicationConten-activemq.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.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
http://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.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd”》
《！-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 --》
《bean id=“targetConnectionFactory” class=“org.apache.activemq.ActiveMQConnectionFactory”》
《property name=“brokerURL” value=“tcp://192.168.25.128:61616” /》
《/bean》
《！-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --》
《bean id=“connectionFactory”
class=“org.springframework.jms.connection.SingleConnectionFactory”》
《！-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory --》
《property name=“targetConnectionFactory” ref=“targetConnectionFactory” /》
《/bean》
《！--這個是隊列目的地，點對點的 --》
《bean id=“queueDestination” class=“org.apache.activemq.command.ActiveMQQueue”》
《constructor-arg》
《value》spring-queue《/value》
《/constructor-arg》
《/bean》
《！--這個是主題目的地，一對多的 --》
《bean id=“topicDestination” class=“org.apache.activemq.command.ActiveMQTopic”》
《constructor-arg value=“itemAddTopic” /》
《/bean》
《！-- 接收消息 --》
《！-- 配置監聽器 --》
《bean id=“myMessageListener” class=“com.e3mall.search.activemq.listener.MyMessageListener” /》
《！-- 消息監聽容器 --》
《bean class=“org.springframework.jms.listener.DefaultMessageListenerContainer”》
《property name=“connectionFactory” ref=“connectionFactory” /》
《property name=“destination” ref=“queueDestination” /》
《property name=“messageListener” ref=“myMessageListener” /》
《/bean》
《！-- 配置監聽器 --》
《bean id=“itemAddMessageListener” class=“com.e3mall.search.activemq.listener.ItemAddMessageListener” /》
《！-- 消息監聽容器監聽商品添加消息同步索引庫 --》
《bean class=“org.springframework.jms.listener.DefaultMessageListenerContainer”》
《property name=“connectionFactory” ref=“connectionFactory” /》
《！--設置我需要的發送消息方式--》
《property name=“destination” ref=“topicDestination” /》
《property name=“messageListener” ref=“itemAddMessageListener” /》
《/bean》
《/beans》
applicationContent-service.xml發布服務
將數據庫中的數據導入Solr索引庫
在大部分應用中，主要還是使用的是數據庫中的數據，因此，這一步還是非常重要的。
現在目錄結構如圖所示：
在solr后臺管理界面中
dataimport 負責將數據庫中數據導入到索引庫中，不過在導入之前，還需要一些相關配置。
1、需要的jar包
還需要mysql的驅動包
將這3個jar包 放入 E：\solr\solrhome\collection1\lib 下
2.在solrconfig.xml中最后面添加一個requesthandler節點
《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 是指關于要導入的數據庫的配置信息。
2、在E：\solr\solrhome\collection1\conf 下創建
data-config.xml 文件
《？xml version=“1.0” encoding=“UTF-8” ？》
《dataConfig》
《dataSource type=“JdbcDataSource”
driver=“com.mysql.jdbc.Driver”
url=“jdbc:mysql://localhost:3306/lucene”
user=“root”
password=“root”/》
《document》
《entity name=“product” query=“SELECT pid，name，catalog_name，price，description，picture FROM products ”》
《field column=“pid” name=“id”/》
《field column=“name” name=“product_name”/》
《field column=“catalog_name” name=“product_catalog_name”/》
《field column=“price” name=“product_price”/》
《field column=“description” name=“product_description”/》
《field column=“picture” name=“product_picture”/》
《/entity》
《/document》
《/dataConfig》
數據庫和賬戶密碼根據自己的實際情況來寫
可以看出，可以在
query=“SELECT pid，name，catalog_name，price，description，picture FROM products ”
指定自己索引庫中要存的索引，
《field column=“pid” name=“id”/》
《field column=“name” name=“product_name”/》
可以配置索引中的域名 和 數據庫字段的映射關系 ，其中column為字段名，name為域名。
3、在schema.xml中配置自定義域
首先要配置好ik分詞器，不會的可以參考下面這篇文章
solr的安裝與使用（二）
然后在后面增加自定義域
《field name=“product_name” type=“text_ik” indexed=“true” stored=“true”/》
《field name=“product_price” type=“float” indexed=“true” stored=“true”/》
《field name=“product_description” type=“text_ik” indexed=“true” stored=“false” /》
《field name=“product_picture” type=“string” indexed=“false” stored=“true” /》
《field name=“product_catalog_name” type=“string” indexed=“true” stored=“true” /》
《field name=“product_keywords” type=“text_ik” indexed=“true” stored=“false” multiValued=“true”/》
《copyField source=“product_name” dest=“product_keywords”/》
《copyField source=“product_description” dest=“product_keywords”/》
這里面name 和 data-config.xml中的 name一致。type使用ik分詞器定義的type
type=“text_ik”
4、重啟tomcat
選中collection1 點擊dataimport
5、點擊執行，就可以將數據中數據導入索引庫了。
工商網監
評論