dao層的方法新增

建立監聽器

package cn.e3mall.search.message;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.springframework.beans.factory.annotation.Autowired;

import cn.e3mall.common.pojo.SearchItem;
import cn.e3mall.search.mapper.ItemMapper;

/**
 * 監聽商品新增訊息，接收訊息後，將對應的商品資訊同步到索引庫
 *
 */
public class ItemAddMessageListener implements MessageListener {

	@Autowired
	private ItemMapper ItemMapper;

	@Autowired
	private SolrServer solrServer;

	@Override
	public void onMessage(Message message) {
		try {
			// 從訊息中取商品id
			TextMessage textMessage = (TextMessage) message;
			String text = textMessage.getText();
			Long itemId = new Long(text);
			//等待事務提交
			Thread.sleep(100);
			// 根據商品id查詢商品資訊
			SearchItem searchItem = ItemMapper.getItemById(itemId);
			// 建立一個文件物件
			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());
			// 把文件寫入索引庫
			solrServer.add(document);
			// 提交
			solrServer.commit();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
 

配置

業務層，

測試：

新增商品

搜尋商品