91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

[Spring cloud 一步步實現廣告系統] 13. 索引服務編碼實現

發布時間:2020-07-16 15:58:33 來源:網絡 閱讀:270 作者:zhangpan0614 欄目:編程語言

上一節我們分析了廣告索引的維護有2種,全量索引加載增量索引維護。因為廣告檢索是廣告系統中最為重要的環節,大家一定要認真理解我們索引設計的思路,接下來我們來編碼實現索引維護功能。

我們來定義一個接口,來接收所有index的增刪改查操作,接口定義一個范型,來接收2個參數,K代表我們索引的健值,V代表返回值。

/**
 * IIndexAware for 實現廣告索引的增刪改查
 *
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初</a>
 */
public interface IIndexAware<K, V> {

    /**
     * 通過key 獲取索引
     */
    V get(K key);
    /**
     * 添加索引
     * @param key
     * @param value
     */
    void add(K key, V value);
    /**
     * 更新索引
     */
    void update(K key, V value);
    /**
     * 刪除索引
     */
    void delete(K key, V value);
}

我們一定要知道,并不是所有的數據庫表都需要創建索引,比如User表我們在數據檢索的時候其實是不需要的,當然也就沒必要創建索引,并且,也不是表中的所有字段都需要索引,這個也是根據具體的業務來確定字段信息,比如我們接下來要編寫的推廣計劃索引中,推廣計劃名稱就可以不需要。下面,我們來實現我們的第一個正向索引

  • 首先創建操作推廣計劃的實體對象

    /**
    * AdPlanIndexObject for 推廣計劃索引對象
    * 這個索引對象我們沒有添加 推廣計劃名稱
    * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初</a>
    */
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public class AdPlanIndexObject {
    
    private Long planId;
    private Long userId;
    private Integer planStatus;
    private Date startDate;
    private Date endDate;
    
    /**
    * 根據實際字段來更新索引
    */
    public void update(AdPlanIndexObject newObject) {
    
        if (null != newObject.getPlanId()) {
            this.planId = newObject.getPlanId();
        }
        if (null != newObject.getUserId()) {
            this.userId = newObject.getUserId();
        }
        if (null != newObject.getPlanStatus()) {
            this.planStatus = newObject.getPlanStatus();
        }
        if (null != newObject.getStartDate()) {
            this.startDate = newObject.getStartDate();
        }
        if (null != newObject.getEndDate()) {
            this.endDate = newObject.getEndDate();
        }
    }
    }
  • 然后創建推廣計劃索引實現類,并實現IIndexAware接口。

    /**
    * AdPlanIndexAwareImpl for 推廣計劃索引實現類
    *
    * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初</a>
    */
    @Slf4j
    @Component
    public class AdPlanIndexAwareImpl implements IIndexAware<Long, AdPlanIndexObject> {
    
    private static Map<Long, AdPlanIndexObject> planIndexObjectMap;
    
    /**
     * 因為操作索引的過程中有可能對索引進行更新,為了防止多線程造成的線程不安全問題,我們不能使用hashmap,需要實現ConcurrentHashMap
     */
    static {
        planIndexObjectMap = new ConcurrentHashMap<>();
    }
    
    @Override
    public AdPlanIndexObject get(Long key) {
        return planIndexObjectMap.get(key);
    }
    
    @Override
    public void add(Long key, AdPlanIndexObject value) {
    
        log.info("AdPlanIndexAwareImpl before add::{}", planIndexObjectMap);
        planIndexObjectMap.put(key, value);
        log.info("AdPlanIndexAwareImpl after add::{}", planIndexObjectMap);
    }
    
    @Override
    public void update(Long key, AdPlanIndexObject value) {
    
        log.info("AdPlanIndexAwareImpl before update::{}", planIndexObjectMap);
                //查詢當前的索引信息,如果不存在,直接新增索引信息
        AdPlanIndexObject oldObj = planIndexObjectMap.get(key);
        if (null == oldObj) {
            planIndexObjectMap.put(key, value);
        } else {
            oldObj.update(value);
        }
    
        log.info("AdPlanIndexAwareImpl after update::{}", planIndexObjectMap);
    }
    
    @Override
    public void delete(Long key, AdPlanIndexObject value) {
    
        log.info("AdPlanIndexAwareImpl before delete::{}", planIndexObjectMap);
        planIndexObjectMap.remove(key);
        log.info("AdPlanIndexAwareImpl after delete::{}", planIndexObjectMap);
    }
    }

    至此,我們已經完成了推廣計劃的索引對象和索引操作的代碼編寫,大家可以參考上面的示例,依次完成推廣單元推廣創意地域興趣關鍵詞以及推廣創意和推廣單元的關聯索引,或者可直接從 Github傳送門 / Gitee傳送門 下載源碼。

按照上述代碼展示,我們已經實現了所有的索引操作的定義,但是實際情況中,我們需要使用這些服務的時候,需要在每一個Service中@Autowired注入,我們那么多的索引操作類,還不包含后續還有可能需要新增的索引維度,工作量實在是太大,而且不方便維護,作為一個合格的程序員來說,這是非常不友好的,也許會讓后續的開發人員罵娘。

為了防止后續被罵,我們來編寫一個索引緩存工具類com.sxzhongf.ad.index.IndexDataTableUtils,通過這個索引緩存工具類來實現一次注入,解決后顧之憂。要實現這個工具類,我們需要實現2個接口:org.springframework.context.ApplicationContextAwareorg.springframework.core.PriorityOrdered

  • org.springframework.context.ApplicationContextAware, 統一通過實現該接口的類,來操作Spring容器以及其中的Bean實例。
    在Spring中,以Aware為后綴結束的類,大家可以簡單的理解為應用程序想要XXX,比如ApplicationContextAware代表應用程序想要ApplicationContext,BeanFactoryAware 表示應用程序想要BeanFactory...等等
  • org.springframework.core.PriorityOrdered組件加載順序,也可以使用org.springframework.core.Ordered
    以下代碼為我們的工具類:
package com.sxzhongf.ad.index;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.core.PriorityOrdered;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * IndexDataTableUtils for 所有索引服務需要緩存的Java Bean
 *
 * 使用方式:
 * 獲取{@link com.sxzhongf.ad.index.creative.CreativeIndexAwareImpl}索引服務類
 * 如下:
 * {@code
 *   IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
 * }
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初</a>
 */
@Component
public class IndexDataTableUtils implements ApplicationContextAware, PriorityOrdered {

    //注入ApplicationContext
    private static ApplicationContext applicationContext;

    /**
     * 定義用于保存所有Index的Map
     * Class標示我們的索引類
     */
    private static final Map<Class, Object> dataTableMap = new ConcurrentHashMap<>();

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        IndexDataTableUtils.applicationContext = applicationContext;
    }

    /**
     * 獲取索引服務緩存
     */
    public static <T> T of(Class<T> klass) {
        T instance = (T) dataTableMap.get(klass);
        //如果獲取到索引bean,直接返回當前bean
        if (null != instance) {
            return instance;
        }
        //首次獲取索引bean為空,寫入Map
        dataTableMap.put(klass, bean(klass));
        return (T) dataTableMap.get(klass);
    }

    /**
     * 獲取Spring 容器中的Bean對象
     */
    private static <T> T bean(String beanName) {
        return (T) applicationContext.getBean(beanName);
    }

    /**
     * 獲取Spring 容器中的Bean對象
     */
    private static <T> T bean(Class klass) {
        return (T) applicationContext.getBean(klass);
    }

    @Override
    public int getOrder() {
        return PriorityOrdered.HIGHEST_PRECEDENCE;
    }
}
向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

汤原县| 微山县| 子长县| 浪卡子县| 环江| 萨迦县| 南川市| 闸北区| 靖州| 水富县| 乳山市| 垣曲县| 丹寨县| 含山县| 麦盖提县| 云梦县| 商洛市| 老河口市| 乐都县| 绩溪县| 县级市| 翁牛特旗| 威信县| 若尔盖县| 新平| 澳门| 安康市| 思茅市| 开阳县| 镇远县| 万载县| 涟源市| 庐江县| 屏山县| 梧州市| 慈利县| 万年县| 黔东| 襄城县| 抚远县| 江津市|