Spring-cloud-一步步实现广告系统-17-根据流量类型查询广告

36次阅读

共计 5339 个字符，预计需要花费 14 分钟才能阅读完成。

广告检索服务

功能介绍

媒体方（手机 APP 打开的展示广告，走在路上看到的大屏幕广告等等）

请求数据对象实现

从上图我们可以看出，在媒体方向我们的广告检索系统发起请求的时候，请求中会有很多的请求参数信息，他们分为了三个部分，我们来编码封装这几个参数对象信息以及我们请求本身的信息。Let’s code.

  • 创建广告检索请求接口

/**
 * ISearch for 请求接口,
 * 根据广告请求对象，获取广告响应信息
 *
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初 </a>
 */
@FunctionalInterface
public interface ISearch {

    /**
     * 根据请求返回广告结果
     */
    SearchResponse fetchAds(SearchRequest request);
}
  • 创建 SearchRequest, 包含三部分：mediaId,RequestInfo,FeatureInfo 
@Data
@NoArgsConstructor
@AllArgsConstructor
public class SearchRequest {

    // 媒体方请求标示
    private String mediaId;
    // 请求基本信息
    private RequestInfo requestInfo;
    // 匹配信息
    private FeatureInfo featureInfo;


    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public static class RequestInfo {
        private String requestId;

        private List<AdSlot> adSlots;
        private App app;
        private Geo geo;
        private Device device;
    }

    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    public static class FeatureInfo {

        private KeywordFeature keywordFeature;
        private DistrictFeature districtFeature;
        private HobbyFeatrue hobbyFeatrue;

        private FeatureRelation relation = FeatureRelation.AND;
    }
}

其他的对象大家可以去 github 传送门 & gitee 传送门 下载源码。

检索响应对象定义
/**
 * SearchResponse for 检索 API 响应对象
 *
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初 </a>
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class SearchResponse {

    // 一个广告位，可以展示多个广告
    //Map key 为广告位 AdSlot#adSlotCode
    public Map<String, List<Creative>> adSlotRelationAds = new HashMap<>();

    @Data
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Creative {

        private Long adId;
        private String adUrl;
        private Integer width;
        private Integer height;
        private Integer type;
        private Integer materialType;

        // 展示监控 url
        private List<String> showMonitorUrl = Arrays.asList("www.life-runner.com", "www.babydy.cn");
        // 点击监控 url
        private List<String> clickMonitorUrl = Arrays.asList("www.life-runner.com", "www.babydy.cn");
    }

    /**
     * 我们的检索服务针对的是内存中的索引检索，那么我们就需要一个转换方法
     */
    public static Creative convert(CreativeIndexObject object) {return Creative.builder()
                       .adId(object.getAdId())
                       .adUrl(object.getAdUrl())
                       .width(object.getWidth())
                       .height(object.getHeight())
                       .type(object.getType())
                       .materialType(object.getMaterialType())
                       .build();}
}
根据流量类型广告过滤

流量类型本身属于推广单元下的类目，有很多种类 贴片广告 , 开屏广告 等等，这些类型需要同步到媒体方，媒体方会根据不同的流量类型发起不同的广告请求，我们需要先定义一个流量类型的信息类。

public class AdUnitConstants {
    public static class PositionType{
        //App 启动时展示的、展示时间短暂的全屏化广告形式。private static final int KAIPING = 1;
        // 电影开始之前的广告
        private static final int TIEPIAN = 2;
        // 电影播放中途广告
        private static final int TIEPIAN_MIDDLE = 4;
        // 暂停视频时候播放的广告
        private static final int TIEPIAN_PAUSE = 8;
        // 视频播放完
        private static final int TIEPIAN_POST = 16;
    }
}

从上述类型的数字，我们可以看出是 2 的倍数，这是为了使用位运算提升性能。

在 com.sxzhongf.ad.index.adunit.AdUnitIndexObject 中，我们添加类型校验方法：

public static boolean isAdSlotType(int adSlotType, int positionType) {switch (adSlotType) {
            case AdUnitConstants.PositionType.KAIPING:
                return isKaiPing(positionType);
            case AdUnitConstants.PositionType.TIEPIAN:
                return isTiePian(positionType);
            case AdUnitConstants.PositionType.TIEPIAN_MIDDLE:
                return isTiePianMiddle(positionType);
            case AdUnitConstants.PositionType.TIEPIAN_PAUSE:
                return isTiePianPause(positionType);
            case AdUnitConstants.PositionType.TIEPIAN_POST:
                return isTiePianPost(positionType);
            default:
                return false;
        }
    }

    /**
     * 与运算，低位取等，高位补零。* 如果 > 0，则为开屏
     */
    private static boolean isKaiPing(int positionType) {return (positionType & AdUnitConstants.PositionType.KAIPING) > 0;
    }
    private static boolean isTiePianMiddle(int positionType) {return (positionType & AdUnitConstants.PositionType.TIEPIAN_MIDDLE) > 0;
    }

    private static boolean isTiePianPause(int positionType) {return (positionType & AdUnitConstants.PositionType.TIEPIAN_PAUSE) > 0;
    }

    private static boolean isTiePianPost(int positionType) {return (positionType & AdUnitConstants.PositionType.TIEPIAN_POST) > 0;
    }

    private static boolean isTiePian(int positionType) {return (positionType & AdUnitConstants.PositionType.TIEPIAN) > 0;
    }

无所如何，我们都是需要根据 positionType 进行数据查询过滤，我们在之前的 com.sxzhongf.ad.index.adunit.AdUnitIndexAwareImpl 中添加 2 个方法来实现过滤:

/**
     * 过滤当前是否存在满足 positionType 的 UnitIds
     */
    public Set<Long> match(Integer positionType) {Set<Long> adUnitIds = new HashSet<>();
        objectMap.forEach((k, v) -> {if (AdUnitIndexObject.isAdSlotType(positionType, v.getPositionType())) {adUnitIds.add(k);
            }
        });
        return adUnitIds;
    }

    /**
     * 根据 UnitIds 查询 AdUnit list
     */
    public List<AdUnitIndexObject> fetch(Collection<Long> adUnitIds) {if (CollectionUtils.isEmpty(adUnitIds)) {return Collections.EMPTY_LIST;}
        List<AdUnitIndexObject> result = new ArrayList<>();
        adUnitIds.forEach(id -> {AdUnitIndexObject object = get(id);
            if (null == object) {log.error("AdUnitIndexObject does not found:{}", id);
                return;
            }
            result.add(object);
        });

        return result;
    }
  • 实现 Search 服务接口

上述我们准备了一系列的查询方法，都是为了根据流量类型查询广告单元信息，我们现在开始实现我们的查询接口，查询接口中，我们可以获取到媒体方的请求对象信息，它带有一系列查询所需要的过滤参数：

/**
 * SearchImpl for 实现 search 服务
 *
 * @author <a href="mailto:magicianisaac@gmail.com">Isaac.Zhang | 若初 </a>
 */
@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 关系
        FeatureRelation featureRelation = request.getFeatureInfo().getRelation();


        // 构造响应对象
        SearchResponse response = new SearchResponse();
        Map<String, List<SearchResponse.Creative>> adSlotRelationAds = response.getAdSlotRelationAds();

        for (AdSlot adSlot : adSlotList) {
            Set<Long> targetUnitIdSet;
            // 根据流量类型从缓存中获取 初始 广告信息
            Set<Long> adUnitIdSet = IndexDataTableUtils.of(AdUnitIndexAwareImpl.class).match(adSlot.getPositionType());
        }
        return null;
    }
}

正文完
spring springboot springcloud
发表至：无分类
2019-08-13
 0