Solr的原理及在項目中的使用實例.

前面已經講過 如果安裝及配置Solr服務器了, 那么現在我們就來正式在代碼中使用Solr.
1,這里Solr主要是怎么使用的呢? 

當我們在前台頁面搜索商品名稱關鍵詞時, 我們這時是在Solr庫中去查找相應的商品信息, 然后將搜索關鍵詞高亮.

2,那么Solr庫中的商品信息又是如何添加的呢? 

當我們在給商品上架的時候, 將商品信息update 到mysql數據庫中的bbs_product表中, 然后同樣的將相應的信息 添加到Solr庫中.

接下來就看代碼的具體實現吧: 

 

一, 商品上架

我們在這里點擊上架按鈕: 
list.jsp:

<div style="margin-top:15px;"><input class="del-button" type="button" value="刪除" onclick="optDelete();"/><input class="add" type="button" value="上架" onclick="isShow('${name}', '${brandId }', '${isShow }' ,'${pagination.pageNo }')"/><input class="del-button" type="button" value="下架" onclick="isHide();"/></div>

點擊上架觸發isShow事件:

<script type="text/javascript">
//上架
function isShow(name,brandId,isShow,pageNo){
    //請至少選擇一個
    var size = $("input[name='ids']:checked").size();
    if(size == 0){
        alert("請至少選擇一個");
        return;
    }
    //你確定上架嗎
    if(!confirm("你確定上架嗎")){
        return;
    }
    //提交 Form表單
    $("#jvForm").attr("action","/product/isShow.do?name="+ name +"&brandId="+brandId+"&isShow="+isShow+"&pageNo="+pageNo);
    $("#jvForm").attr("method","post");
    $("#jvForm").submit();
    
}
</script>

接着到Controller層:
ProductController.java:

//添加頁面
    @RequestMapping("/isShow.do")
    public String isShow(Long[] ids, Model model){
        productService.isShow(ids);
        return "forward:/product/list.do";
    }

接着看Service層:
ProdcutServiceImpl.java:

//上架

　　　　 @Autowired
	private SolrServer solrServer;
    public void isShow(Long[] ids){
        Product product = new Product();
        product.setIsShow(true);
        for (Long id : ids) {
            //上下架狀態
            product.setId(id);
            productDao.updateByPrimaryKeySelective(product);
            
            //TODO 保存商品信息到Solr服務器
            SolrInputDocument doc = new SolrInputDocument();
            //ID
            doc.setField("id", id);
            //名稱
            Product p = productDao.selectByPrimaryKey(id);
            doc.setField("name_ik", p.getName());
            //圖片URL
            doc.setField("url", p.getImgUrls()[0]);
            //品牌 ID
            doc.setField("brandId", p.getBrandId());
            //價格 sql查詢語句: select price from bbs_sku where product_id = ? order by price asc limit 1
            SkuQuery skuQuery = new SkuQuery();
            skuQuery.createCriteria().andProductIdEqualTo(id);
            skuQuery.setOrderByClause("price asc");
            skuQuery.setPageNo(1);
            skuQuery.setPageSize(1);
            List<Sku> skus = skuDao.selectByExample(skuQuery);
            doc.setField("price", skus.get(0).getPrice());
            //...時間等 剩下的省略
            
            try {
                solrServer.add(doc);
                solrServer.commit();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            //TODO 靜態化
        }
    }

這里使用SolrInputDocument 來保存商品信息, 其中doc.setField("name_ik", p.getName());的name_ik 是我們在solr 配置文件配置的IK 分詞器的字段, doc.setField("url", p.getImgUrls()[0]); 這里我們也只是取第一張圖片的url用來展示.
這里我們還用到了skuQuery, 因為一個商品中不同的顏色不同的尺碼都可能有不同的價格, 我們在這里 是取到同一個productId下價格最小的來給顯示~
然后再就是將我們已經設置好的SolrInputDocument 通過SolrServer 來提交到Solr服務器. SolrServer是已經在spring中注冊好了的, 在這里直接注入即可使用.
spring來管理Solr:

到了這里上架的功能就做好了, 這也是給后面Solr查詢做好鋪墊.

二, 前台使用Solr查詢
到了這里就開始查看前台頁面了, 前台頁面是扒的網上的, 具體業務邏輯是自己修改的, 頁面如下:

這里需要特殊說明一下, 我們配置的全局攔截器變成了: / , 而且過濾掉靜態資源, 配置如下:
首先是babasport-portal project下的web.xml文件:

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
    
    <!-- Post過濾器 -->
    <filter>
        <filter-name>encoding</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>UTF-8</param-value>
        </init-param>
    </filter>
    
    <filter-mapping>
        <filter-name>encoding</filter-name>
        <url-pattern>/</url-pattern>
    </filter-mapping>
    
    <!-- 前端控制器 -->
    <servlet>
        <servlet-name>portal</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <!-- 默認讀取的是 WEB-INF/console-servlet.xml -->
            <param-value>classpath:springmvc-portal.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    
    <servlet-mapping>
        <servlet-name>portal</servlet-name>
        <!-- 
            /*: 攔截視圖請求: .jsp  .js  .css  幾乎不用,配置靜態資源過濾
            /: 攔截所有,不攔截.jsp 文件, 但是同樣攔截.js .css  如果使用也需要配置靜態資源過濾(前台系統使用)
            *.do:攔截所有以.do請求, 后台開發應用*.do
         -->
        <url-pattern>/</url-pattern>
    </servlet-mapping>
</web-app>

第二個就是babasport-portal project下的spring配置文件中設置過濾掉靜態資源:

<!-- 過濾靜態資源 -->
    <mvc:resources location="/js/" mapping="/js/*.*"/>
    <mvc:resources location="/css/" mapping="/css/*.*"/>
    <mvc:resources location="/images/" mapping="/images/*.*"/>

這樣就就可以直接訪問了.

當我們輸入2016 點擊查詢后會出現什么? 我把已經做好的頁面展示一下: 


那么就進入到實際的開發當中: 
當我們在搜索框輸入2016 且點擊 搜索時: 


然后到Controller層去找到search方法:

@Autowired
    private SearchService searchService;
    
    //去首頁
    @RequestMapping(value="/")
    public String index(){
        return "index";
    }
    
    //搜索
    @RequestMapping(value="/search")
    public String search(Integer pageNo, String keyword, String price, Long brandId,  Model model){
        //品牌結果集  Redis中
        List<Brand> brands = searchService.selectBrandListFromRedis();
        model.addAttribute("brands", brands);
        
        //map 裝已經選擇的條件
        Map<String, String> map = new HashMap<String, String>();
        if(null != brandId){
            for (Brand brand : brands) {
                if(brandId.equals(brand.getId())){
                    map.put("品牌", brand.getName());
                    break;
                }
            }
        }
        //價格 0-99 1600以上
        if(null != price){
            String[] split = price.split("-");
            //如果切割后的長度等於2 就說明這是一個價格區間
            if(split.length == 2){
                map.put("價格", price);
            }else {
                map.put("價格", price + "以上");
            }
        }
        model.addAttribute("map", map);
        
        Pagination pagination = searchService.selectPaginationFromSolr(pageNo, keyword, price, brandId);
        model.addAttribute("pagination", pagination);
        model.addAttribute("keyword", keyword);
        model.addAttribute("price", price);
        model.addAttribute("brandId", brandId);
        
        return "search";
    }

提示: 這里使用到了SolrService, 相信看我以前博文的朋友都知道這個地方還需要配置dubbo, 就是服務提供方和適用方, 這里為了簡便直接略過, 實際開發中是必須要配置的, 否則就調用不了SolrService中的方法了.
這個controller 中往search.jsp中put了很多東西, 具體這些東西什么用我們可以先不管, 我們先看下search.jsp頁面.
而且這個controller中查詢brand 是從redis中查詢出來的, 我們會在下面講到這個.

<c:if test="${fn:length(map) != 0 }">
            <div class="sl-b-selected J_brandSelected">
                <span class="crumbs-arrow">已選條件：</span>
                    <c:forEach items="${map }" var="m">
                        <a title="依琦蓮（yiqilian）"  href="javascript:;" class="crumb-select-item">
                            <b>${m.key }：</b><em>${m.value }</em><i></i>
                        </a>
                    </c:forEach>
            </div>
            </c:if>

上面這個地方就是為何要在controller設置map值了, 這個是顯示已選擇的過濾條件.

 

<c:if test="${empty brandId }">
<div class="J_selectorLine s-brand">
    <div class="sl-wrap">
        <div class="sl-key"><strong>品牌：</strong></div>
        <div class="sl-value">
            <div class="sl-v-list">
                <ul class="J_valueList v-fixed">
                <c:forEach items="${brands }" var="brand">
                    <li id="brand-38118" data-initial="j" style="display:block;">
                        <a href="javascript:;" onclick="fqBrand('${brand.id }')" title="${brand.name }"><i></i>${brand.name }</a>
                    </li>
                </c:forEach>
                </ul>
            </div>
        </div>
    </div>
</div>
</c:if>
<c:if test="${empty price }">
<div id="J_selectorPrice" class="J_selectorLine s-line">
    <div class="sl-wrap">
        <div class="sl-key"><span>價格：</span></div>
        <div class="sl-value">
            <div class="sl-v-list">
                <ul class="J_valueList">
                    <li>
                        <a href="javascript:;" onclick="fqPrice('0-99')"><i></i>0-99</a>
                    </li>
                    <li>
                        <a href="javascript:;" onclick="fqPrice('100-299')"><i></i>100-299</a>
                    </li>
                    <li>
                        <a href="javascript:;" onclick="fqPrice('300-599')"><i></i>300-599</a>
                    </li>
                    <li>
                        <a href="javascript:;" onclick="fqPrice('600-999')"><i></i>600-999</a>
                    </li>
                    <li>
                        <a href="javascript:;" onclick="fqPrice('1000-1599')"><i></i>1000-1599</a>
                    </li>
                    <li>
                        <a href="javascript:;" onclick="fqPrice('1600')"><i></i>1600以上</a>
                    </li>
                </ul>
            </div>
        </div>
    </div>
</div>
</c:if>

接下來我們來看下對應的js方法:

<script type="text/javascript">
    var price = '${price}';
    var brandId = '${brandId}';
    //過濾品牌id
    function fqBrand(id){
        if('' != price){
            window.location.href="/search?keyword="+ ${keyword} + "&brandId="+ id+"&price="+price;
        }else{
            window.location.href="/search?keyword="+ ${keyword} + "&brandId="+ id;
        }
    }
    
    //過濾價格
    function fqPrice(id){
        if('' != brandId){
            window.location.href = "/search?keyword=${keyword}" + "&brandId=" + brandId + "&price=" + id;
        }else{
            window.location.href = "/search?keyword=${keyword}" + "&price=" + id;
        }
    }
</script>

這個就可以實現 添加 過濾條件的選項了.


三, 使用Redis 取出商品品牌列表
首先 當我們在后台添加或者修改品牌時, 我們應該同樣將這個品牌添加到Redis中, 格式類似於: {"brandId":"brandName"}
controller層:(當我們在后台添加或者修改品牌)

@Autowired
    private Jedis jedis;
    //修改
    public void updateBrandById(Brand brand){
        //保存或修改 時修改Redis中的品牌, hmset適合批量添加品牌
        /*Map<String, String> map = new HashMap<String,String>();
        map.put(String.valueOf(brand.getId()), brand.getName());
        jedis.hmset("brand", map);*/
        jedis.hset("brand", String.valueOf(brand.getId()), brand.getName());
        brandDao.updateBrandById(brand);
    }

redis中有了品牌列表后, 然后就是查詢了: 

@Autowired
    private Jedis jedis;
    //查詢Redis中的品牌結果集
    public List<Brand> selectBrandListFromRedis(){
        List<Brand> brands = new ArrayList<Brand>();
        Map<String, String> hgetAll = jedis.hgetAll("brand");
        Set<Entry<String, String>> entrySet = hgetAll.entrySet();
        for (Entry<String, String> entry : entrySet) {
            Brand brand = new Brand();
            brand.setId(Long.parseLong(entry.getKey()));
            brand.setName(entry.getValue());
            brands.add(brand);
        }
        
        return brands;
    }

到了這里redis查詢brand就完成了, 那么繼續看下關於solr 是如何加入過濾條件的吧: 

@Autowired
    private SolrServer solrServer;
    //查詢商品信息從Solr
    public Pagination selectPaginationFromSolr(Integer pageNo, String keyword, String price, Long brandId){
        ProductQuery productQuery = new ProductQuery();
        //當前頁
        productQuery.setPageNo(Pagination.cpn(pageNo));
        //每頁數
        productQuery.setPageSize(8);
        
        SolrQuery solrQuery = new SolrQuery();
        //關鍵詞 商品名稱
        solrQuery.set("q", "name_ik:"+keyword);
        //回顯數據
        StringBuilder params = new StringBuilder();
        params.append("keyword=").append(keyword);
        
        //排序
        solrQuery.addSort("price", ORDER.asc);
        
        //高亮
        //1,設置, 打開高亮的開關
        solrQuery.setHighlight(true);
        //2, 設置高亮字段
        solrQuery.addHighlightField("name_ik");
        //3, 設置關鍵字高亮的樣式 <span style='color:red'>2016</span>
        //設置前綴和后綴
        solrQuery.setHighlightSimplePre("<span style='color:red'>");
        solrQuery.setHighlightSimplePost("</span>");
        
        //過濾條件 品牌
        if(null != brandId){
            solrQuery.addFilterQuery("brandId:"+brandId);
            params.append("&brandId=").append(brandId);
        }
        //過濾價格 0-99  1600
        if(null != price){
            String[] split = price.split("-");
            //如果切割后的長度等於2 就說明這是一個價格區間
            if(split.length == 2){
                solrQuery.addFilterQuery("price:["+split[0]+" TO "+split[1]+"]");
            }else {
                solrQuery.addFilterQuery("price:["+split[0]+" TO *]");
            }
            params.append("&price=").append(price);
        }
        
        //分頁  limit 開始行,每頁數
        solrQuery.setStart(productQuery.getStartRow());
        solrQuery.setRows(productQuery.getPageSize());
        
        QueryResponse response = null;
        try {
            response = solrServer.query(solrQuery);
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        //分析這個Map
        //第一層Map: Key String == ID : Value: Map
        //第二層Map: Key String == name_ik : Value: List
        //獲取到List: String 0,1,2....
        Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
        
        
        List<Product> products = new ArrayList<Product>();
        //結果集
        SolrDocumentList docs = response.getResults();
        //總條數
        long numFound = docs.getNumFound();
        for (SolrDocument doc : docs) {
            Product product = new Product();
            //商品的ID
            String id = (String)doc.get("id");
            product.setId(Long.parseLong(id));
            
            //取第二層Map
            Map<String, List<String>> map = highlighting.get(id);
            //取List集合
            List<String> list = map.get("name_ik");
            
            //商品名稱
            //String name = (String)doc.get("name_ik");
            //product.setName(name);
            product.setName(list.get(0)); //list.get(0) 中的name是已經設置為高亮的
            
            //圖片
            String url = (String)doc.get("url");
            product.setImgUrl(url);
            //價格 這里的價格本身是保存在bbs_sku表中的, 而我們在這里將price屬性直接添加到了Product中
            //因為我們在做上架的時候, 查詢的是bbs_sku中price最小的值 然后保存到solr中的, 所以這里我們就直接將price屬性添加到product中了
            //這里的價格只有一個值
            //Float price = (Float)doc.get("price");
            product.setPrice((Float)doc.get("price"));
            //品牌ID
            //Integer brandId = (Integer)doc.get("brandId");
            product.setBrandId(Long.parseLong(String.valueOf((Integer)doc.get("brandId"))));
            products.add(product);
        }
        
        Pagination pagination = new Pagination(
                    productQuery.getPageNo(),
                    productQuery.getPageSize(),
                    (int)numFound,
                    products
                );
        //頁面展示
        String url = "/search";
        pagination.pageView(url, params.toString());
        
        return pagination;
    }

這個就是本博文的重中之重了, code上面都加了注釋, 相信還是比較容易理解的.

 

 

[項目構建 六]babasport Redis使用實例.