Spring cloud 查詢返回廣告創(chuàng)意實例代碼
更新時間：2019年08月14日 08:30:11 作者：zhangpan0614
在本篇文章里小編給大家整理的是關(guān)于Spring cloud 查詢返回廣告創(chuàng)意實例代碼，需要的朋友們可以跟著學(xué)習(xí)下。
根據(jù)三個維度繼續(xù)過濾
在上一節(jié)中我們實現(xiàn)了根據(jù)流量信息過濾的代碼，但是我們的條件有可能是多條件一起傳給我們的檢索服務(wù)的，本節(jié)我們繼續(xù)實現(xiàn)根據(jù)推廣單元的三個維度條件的過濾。
在SearchImpl類中添加過濾方法
public class SearchImpl implements ISearch {
@Override
public SearchResponse fetchAds(SearchRequest request) {
...
// 根據(jù)三個維度過濾
if (featureRelation == FeatureRelation.AND) {
filterKeywordFeature(adUnitIdSet, keywordFeature);
filterHobbyFeature(adUnitIdSet, hobbyFeatrue);
filterDistrictFeature(adUnitIdSet, districtFeature);
targetUnitIdSet = adUnitIdSet;
} else {
getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);
}
}
return null;
}
定義三個方法實現(xiàn)過濾
/**
* 獲取三個維度各自滿足時的廣告id
*/
private Set<Long> getOrRelationUnitIds(Set<Long> adUnitIdsSet,
KeywordFeature keywordFeature,
HobbyFeatrue hobbyFeatrue,
DistrictFeature districtFeature) {
if (CollectionUtils.isEmpty(adUnitIdsSet)) return Collections.EMPTY_SET;
// 我們在處理的時候，需要對副本進(jìn)行處理，大家可以考慮一下為什么需要這么做？
Set<Long> keywordUnitIdSet = new HashSet<>(adUnitIdsSet);
Set<Long> hobbyUnitIdSet = new HashSet<>(adUnitIdsSet);
Set<Long> districtUnitIdSet = new HashSet<>(adUnitIdsSet);
filterKeywordFeature(keywordUnitIdSet, keywordFeature);
filterHobbyFeature(hobbyUnitIdSet, hobbyFeatrue);
filterDistrictFeature(districtUnitIdSet, districtFeature);
// 返回它們的并集
return new HashSet<>(
CollectionUtils.union(
CollectionUtils.union(keywordUnitIdSet, hobbyUnitIdSet),
districtUnitIdSet
)
);
}
/**
* 根據(jù)傳遞的關(guān)鍵詞過濾
*/
private void filterKeywordFeature(Collection<Long> adUnitIds, KeywordFeature keywordFeature) {
if (CollectionUtils.isEmpty(adUnitIds)) return;
if (CollectionUtils.isNotEmpty(keywordFeature.getKeywords())) {
// 如果存在需要過濾的關(guān)鍵詞，查找索引實例對象進(jìn)行過濾處理
CollectionUtils.filter(
adUnitIds,
adUnitId -> IndexDataTableUtils.of(UnitKeywordIndexAwareImpl.class)
.match(adUnitId, keywordFeature.getKeywords())
);
}
}
/**
* 根據(jù)傳遞的興趣信息過濾
*/
private void filterHobbyFeature(Collection<Long> adUnitIds, HobbyFeatrue hobbyFeatrue) {
if (CollectionUtils.isEmpty(adUnitIds)) return;
// 如果存在需要過濾的興趣，查找索引實例對象進(jìn)行過濾處理
if (CollectionUtils.isNotEmpty(hobbyFeatrue.getHobbys())) {
CollectionUtils.filter(
adUnitIds,
adUnitId -> IndexDataTableUtils.of(UnitHobbyIndexAwareImpl.class)
.match(adUnitId, hobbyFeatrue.getHobbys())
);
}
}
/**
* 根據(jù)傳遞的地域信息過濾
*/
private void filterDistrictFeature(Collection<Long> adUnitIds, DistrictFeature districtFeature) {
if (CollectionUtils.isEmpty(adUnitIds)) return;
// 如果存在需要過濾的地域信息，查找索引實例對象進(jìn)行過濾處理
if (CollectionUtils.isNotEmpty(districtFeature.getProvinceAndCities())) {
CollectionUtils.filter(
adUnitIds,
adUnitId -> {
return IndexDataTableUtils.of(UnitDistrictIndexAwareImpl.class)
.match(adUnitId, districtFeature.getProvinceAndCities());
}
);
}
}
根據(jù)推廣單元id獲取推廣創(chuàng)意
我們知道，推廣單元和推廣創(chuàng)意的關(guān)系是多對多，從上文我們查詢到了推廣單元ids,接下來我們實現(xiàn)根據(jù)推廣單元id獲取推廣創(chuàng)意的代碼，let's code.
首先，我們需要在com.sxzhongf.ad.index.creative_relation_unit.CreativeRelationUnitIndexAwareImpl 關(guān)聯(lián)索引中查到推廣創(chuàng)意的ids
/**
* 通過推廣單元id獲取推廣創(chuàng)意id
*/
public List<Long> selectAdCreativeIds(List<AdUnitIndexObject> unitIndexObjects) {
if (CollectionUtils.isEmpty(unitIndexObjects)) return Collections.emptyList();
//獲取要返回的廣告創(chuàng)意ids
List<Long> result = new ArrayList<>();
for (AdUnitIndexObject unitIndexObject : unitIndexObjects) {
//根據(jù)推廣單元id獲取推廣創(chuàng)意
Set<Long> adCreativeIds = unitRelationCreativeMap.get(unitIndexObject.getUnitId());
if (CollectionUtils.isNotEmpty(adCreativeIds)) result.addAll(adCreativeIds);
}
return result;
}
然后得到了推廣創(chuàng)意的id list后，我們在創(chuàng)意索引實現(xiàn)類com.sxzhongf.ad.index.creative.CreativeIndexAwareImpl中定義根據(jù)ids查詢創(chuàng)意的方法。
/**
* 根據(jù)ids獲取創(chuàng)意list
*/
public List<CreativeIndexObject> findAllByIds(Collection<Long> ids) {
if (CollectionUtils.isEmpty(ids)) return Collections.emptyList();
List<CreativeIndexObject> result = new ArrayList<>();
for (Long id : ids) {
CreativeIndexObject object = get(id);
if (null != object)
result.add(object);
}
return result;
}
自此，我們已經(jīng)得到了想要的推廣單元和推廣創(chuàng)意，因為推廣單元包含了推廣計劃，所以我們想要的數(shù)據(jù)已經(jīng)全部可以獲取到了，接下來，我們還得過濾一次當(dāng)前我們查詢到的數(shù)據(jù)的狀態(tài)，因為有的數(shù)據(jù)，我們可能已經(jīng)進(jìn)行過邏輯刪除了，因此還需要判斷獲取的數(shù)據(jù)是否有效。在SearchImpl類中實現(xiàn)。
/**
* 根據(jù)狀態(tài)信息過濾數(shù)據(jù)
*/
private void filterAdUnitAndPlanStatus(List<AdUnitIndexObject> unitIndexObjects, CommonStatus status) {
if (CollectionUtils.isEmpty(unitIndexObjects)) return;
//同時判斷推廣單元和推廣計劃的狀態(tài)
CollectionUtils.filter(
unitIndexObjects,
unitIndexObject -> unitIndexObject.getUnitStatus().equals(status.getStatus()) &&
unitIndexObject.getAdPlanIndexObject().getPlanStatus().equals(status.getStatus())
);
}
在SearchImpl中我們實現(xiàn)廣告創(chuàng)意的查詢.
...
//獲取 推廣計劃 對象list
List<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).fetch(adUnitIdSet);
//根據(jù)狀態(tài)過濾數(shù)據(jù)
filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);
//獲取 推廣創(chuàng)意 id list
List<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class)
.selectAdCreativeIds(unitIndexObjects);
//根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意
List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
...
根據(jù)廣告位adslot 實現(xiàn)對創(chuàng)意數(shù)據(jù)的過濾
因為我們的廣告位是有不同的大小，不同的類型，因此，我們在獲取到所有符合我們查詢維度以及流量類型的條件后，還需要針對不同的廣告位來展示不同的廣告創(chuàng)意信息。
/**
* 根據(jù)廣告位類型以及參數(shù)獲取展示的合適廣告信息
*
* @param creativeIndexObjects 所有廣告創(chuàng)意
* @param width 廣告位width
* @param height 廣告位height
*/
private void filterCreativeByAdSlot(List<CreativeIndexObject> creativeIndexObjects,
Integer width,
Integer height,
List<Integer> type) {
if (CollectionUtils.isEmpty(creativeIndexObjects)) return;
CollectionUtils.filter(
creativeIndexObjects,
creative -> {
//審核狀態(tài)必須是通過
return creative.getAuditStatus().equals(CommonStatus.VALID.getStatus())
&& creative.getWidth().equals(width)
&& creative.getHeight().equals(height)
&& type.contains(creative.getType());
}
);
}
組建搜索返回對象
正常業(yè)務(wù)場景中，同一個廣告位可以展示多個廣告信息，也可以只展示一個廣告信息，這個需要根據(jù)具體的業(yè)務(wù)場景來做不同的處理，本次為了演示方便，會從返回的創(chuàng)意列表中隨機(jī)選擇一個創(chuàng)意廣告信息進(jìn)行展示，當(dāng)然大家也可以根據(jù)業(yè)務(wù)類型，設(shè)置不同的優(yōu)先級或者權(quán)重值來進(jìn)行廣告選擇。
/**
* 從創(chuàng)意列表中隨機(jī)獲取一條創(chuàng)意廣告返回出去
*
* @param creativeIndexObjects 創(chuàng)意廣告list
*/
private List<SearchResponse.Creative> buildCreativeResponse(List<CreativeIndexObject> creativeIndexObjects) {
if (CollectionUtils.isEmpty(creativeIndexObjects)) return Collections.EMPTY_LIST;
//隨機(jī)獲取一個廣告創(chuàng)意，也可以實現(xiàn)優(yōu)先級排序，也可以根據(jù)權(quán)重值等等，具體根據(jù)業(yè)務(wù)
CreativeIndexObject randomObject = creativeIndexObjects.get(
Math.abs(new Random().nextInt()) % creativeIndexObjects.size()
);
//List<SearchResponse.Creative> result = new ArrayList<>();
//result.add(SearchResponse.convert(randomObject));
return Collections.singletonList(
SearchResponse.convert(randomObject)
);
}
完整的請求過濾實現(xiàn)方法：
@Service
@Slf4j
public class SearchImpl implements ISearch {
@Override
public SearchResponse fetchAds(SearchRequest request) {
//獲取請求廣告位信息
List<AdSlot> adSlotList = request.getRequestInfo().getAdSlots();
//獲取三個Feature信息
KeywordFeature keywordFeature = request.getFeatureInfo().getKeywordFeature();
HobbyFeatrue hobbyFeatrue = request.getFeatureInfo().getHobbyFeatrue();
DistrictFeature districtFeature = request.getFeatureInfo().getDistrictFeature();
//Feature關(guān)系
FeatureRelation featureRelation = request.getFeatureInfo().getRelation();
//構(gòu)造響應(yīng)對象
SearchResponse response = new SearchResponse();
Map<String, List<SearchResponse.Creative>> adSlotRelationAds = response.getAdSlotRelationAds();
for (AdSlot adSlot : adSlotList) {
Set<Long> targetUnitIdSet;
//根據(jù)流量類型從緩存中獲取 初始 廣告信息
Set<Long> adUnitIdSet = IndexDataTableUtils.of(
AdUnitIndexAwareImpl.class
).match(adSlot.getPositionType());
// 根據(jù)三個維度過濾
if (featureRelation == FeatureRelation.AND) {
filterKeywordFeature(adUnitIdSet, keywordFeature);
filterHobbyFeature(adUnitIdSet, hobbyFeatrue);
filterDistrictFeature(adUnitIdSet, districtFeature);
targetUnitIdSet = adUnitIdSet;
} else {
targetUnitIdSet = getOrRelationUnitIds(adUnitIdSet, keywordFeature, hobbyFeatrue, districtFeature);
}
//獲取 推廣計劃 對象list
List<AdUnitIndexObject> unitIndexObjects = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class)
.fetch(targetUnitIdSet);
//根據(jù)狀態(tài)過濾數(shù)據(jù)
filterAdUnitAndPlanStatus(unitIndexObjects, CommonStatus.VALID);
//獲取 推廣創(chuàng)意 id list
List<Long> creativeIds = IndexDataTableUtils.of(CreativeRelationUnitIndexAwareImpl.class)
.selectAdCreativeIds(unitIndexObjects);
//根據(jù) 推廣創(chuàng)意ids獲取推廣創(chuàng)意
List<CreativeIndexObject> creativeIndexObjects = IndexDataTableUtils.of(CreativeIndexAwareImpl.class)
.fetch(creativeIds);
//根據(jù) 廣告位adslot 實現(xiàn)對創(chuàng)意數(shù)據(jù)的過濾
filterCreativeByAdSlot(creativeIndexObjects, adSlot.getWidth(), adSlot.getHeight(), adSlot.getType());
//一個廣告位可以展示多個廣告，也可以僅展示一個廣告，具體根據(jù)業(yè)務(wù)來定
adSlotRelationAds.put(
adSlot.getAdSlotCode(),
buildCreativeResponse(creativeIndexObjects)
);
}
return response;
}
...
檢索服務(wù)對外提供
暴露API接口
上文中，我們實現(xiàn)了檢索服務(wù)的核心邏輯，接下來，我們需要對外暴露我們的廣告檢索服務(wù)接口，在SearchController中提供：
@PostMapping("/fetchAd")
public SearchResponse fetchAdCreative(@RequestBody SearchRequest request) {
log.info("ad-serach: fetchAd ->{}", JSON.toJSONString(request));
return search.fetchAds(request);
}
實現(xiàn)API網(wǎng)關(guān)配置
zuul: routes: sponsor: #在路由中自定義服務(wù)路由名稱 path: /ad-sponsor/** serviceId: mscx-ad-sponsor #微服務(wù)name strip-prefix: false search: #在路由中自定義服務(wù)路由名稱 path: /ad-search/** serviceId: mscx-ad-search #微服務(wù)name strip-prefix: false prefix: /gateway/api strip-prefix: true #不對 prefix: /gateway/api 設(shè)置的路徑進(jìn)行截取，默認(rèn)轉(zhuǎn)發(fā)會截取掉配置的前綴
以上就是本次分享的全部知識點內(nèi)容，感謝大家對腳本之家的支持
您可能感興趣的文章:
相關(guān)文章
這篇文章主要為大家介紹了IntelliJ中高效重構(gòu)的10個快捷方式詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-01-01
超詳細(xì)講解SpringCloud?Commons公共抽象的用法
這篇文章主要介紹了超詳細(xì)講解SpringCloud?Commons公共抽象的用法，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-04-04
這篇文章主要為大家詳細(xì)介紹了SpringMVC圖片文件跨服務(wù)器上傳，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-08-08
實戰(zhàn)分布式醫(yī)療掛號系統(tǒng)之整合Swagger2到通用模塊
這篇文章主要為大家介紹了實戰(zhàn)分布式醫(yī)療掛號系統(tǒng)之整合Swagger2到通用模塊，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-04-04
Mybatis自定義TypeHandler解決特殊類型轉(zhuǎn)換問題詳解
這篇文章主要介紹了Mybatis自定義TypeHandler解決特殊類型轉(zhuǎn)換問題詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-11-11
這篇文章主要介紹了java對象拷貝詳解及實例的相關(guān)資料,需要的朋友可以參考下2017-04-04
Java創(chuàng)建非阻塞的HTTP服務(wù)器的實現(xiàn)
本文主要介紹了Java創(chuàng)建非阻塞的HTTP服務(wù)器的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-04-04
這篇文章主要為大家詳細(xì)介紹了spring事務(wù)與消息隊列,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-10-10
Java concurrency集合之LinkedBlockingDeque_動力節(jié)點Java學(xué)院整理
LinkedBlockingDeque是雙向鏈表實現(xiàn)的雙向并發(fā)阻塞隊列。該阻塞隊列同時支持FIFO和FILO兩種操作方式，即可以從隊列的頭和尾同時操作(插入/刪除)；并且，該阻塞隊列是支持線程安全。2017-06-06
SpringMVC中常用參數(shù)校驗類注解使用示例教程
這篇文章主要介紹了SpringMVC中常用參數(shù)校驗類注解使用示例教程，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-03-03