1-1 课程导学

什么是广告系统？

2-1 广告系统概览

2-2 广告系统架构

2-3 准备工作与系统目录结构

2-3 准备工作与系统目录结构

第3章 广告系统骨架开发

3-1 Maven基础知识

3-2 Maven 相关特性

3-3 广告系统主工程

...建立项目结构...

Maven有三种类型的仓库：

本地仓库：工程里依赖的jar包，maven会主动下载到本地目录的.m2。

中央仓库：由maven社区提供，包含有大量的常用库。

远程仓库：对开发者提供的，开发者把自己编写的包放在这个仓库，工程就可以指定远程仓库去下载。

3-4 单节点 Eureka Server 的开发

3-5 Eureka Server 的部署

分别启动单节点和多节点的Eureka Server

单节点配置文件：

多节点(三个节点的Eureka server)：

由于父工程会管理所有子工程，因此在父工程打包：

启动第一个服务：

类似的，分别启动server2和3。

3-6 微服务架构及网关组件介绍

三种类型的过滤器可以分别用来实现不同的功能。

Pre filters：请求被路由之前调用，可以利用这种过滤器实现身份认证、在集群中选择请求的微服务记录调试信息等等。

Routing filters：这种过滤器将请求路由到微服务，即用于构造发送给微服务的请求。使用Apache的HttpClient或者Netflix的Ribbon请求微服务。

Post filters：这种过滤器在路由到微服务以后执行，可以为响应添加Http的header、收集统计信息和指标、将响应从微服务发送给客户端等等。

Error filters：当请求发生了错误去执行的过滤器。

Custom filters：自定义的过滤器。例如我们可以定义一种静态类型的过滤器，直接在Zuul中响应，而不在微服务中响应。如果请求的是一个静态文件，可以不需要经过路由到微服务，直接在Custom filters返回给客户端。

3-7 网关启动程序的开发

3-8 自定义网关过滤器的开发

实现两个自定义过滤器完成一个访问日志的功能。

PreRequestFilter.java

import com.netflix.zuul.ZuulFilter;

import com.netflix.zuul.context.RequestContext;

import com.netflix.zuul.exception.ZuulException;

import lombok.extern.slf4j.Slf4j;

import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;

import org.springframework.stereotype.Component;

@Slf4j

@Componentpublic class PreRequestFilter extendsZuulFilter {

@OverridepublicString filterType() {returnFilterConstants.PRE_TYPE;

}

@Overridepublic intfilterOrder() {return 0;

}

@Overridepublic booleanshouldFilter() {return true;

}

@Overridepublic Object run() throwsZuulException {

RequestContext ctx=RequestContext.getCurrentContext();

ctx.set("startTime", System.currentTimeMillis());return null;

}

}

AccessLogFilter.java

importcom.netflix.zuul.ZuulFilter;importcom.netflix.zuul.context.RequestContext;importcom.netflix.zuul.exception.ZuulException;importlombok.extern.slf4j.Slf4j;importorg.springframework.cloud.netflix.zuul.filters.support.FilterConstants;importorg.springframework.stereotype.Component;importjavax.servlet.http.HttpServletRequest;

@Slf4j

@Componentpublic class AccessLogFilter extendsZuulFilter {

@OverridepublicString filterType() {returnFilterConstants.POST_TYPE;

}

@Overridepublic intfilterOrder() {return FilterConstants.SEND_RESPONSE_FILTER_ORDER - 1;

}

@Overridepublic booleanshouldFilter() {return true;

}

@Overridepublic Object run() throwsZuulException {

RequestContext context=RequestContext.getCurrentContext();

HttpServletRequest request=context.getRequest();

Long startTime= (Long) context.get("startTime");

String uri=request.getRequestURI();long duration = System.currentTimeMillis() -startTime;

log.info("uri: " + uri + ", duration: " + duration / 100 + "ms");return null;

}

}

第4章 微服务通用模块开发

4-1 关于通用模块功能的介绍

4-2 统一响应处理的开发

CommonResponseDataAdvice.java

importcom.imooc.ad.annotation.IgnoreResponseAdvice;importcom.imooc.ad.vo.CommonResponse;importorg.springframework.core.MethodParameter;importorg.springframework.http.MediaType;importorg.springframework.http.converter.HttpMessageConverter;importorg.springframework.http.server.ServerHttpRequest;importorg.springframework.http.server.ServerHttpResponse;importorg.springframework.lang.Nullable;importorg.springframework.web.bind.annotation.RestControllerAdvice;importorg.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice;

@RestControllerAdvicepublic class CommonResponseDataAdvice implements ResponseBodyAdvice{

@Override

@SuppressWarnings("all")public booleansupports(MethodParameter methodParameter,

Class extends HttpMessageConverter>>aClass) {if(methodParameter.getDeclaringClass().isAnnotationPresent(

IgnoreResponseAdvice.class)) {return false;

}if(methodParameter.getMethod().isAnnotationPresent(

IgnoreResponseAdvice.class)) {return false;

}return true;

}

@Nullable

@Override

@SuppressWarnings("all")publicObject beforeBodyWrite(@Nullable Object o,

MethodParameter methodParameter,

MediaType mediaType,

Class extends HttpMessageConverter>>aClass,

ServerHttpRequest serverHttpRequest,

ServerHttpResponse serverHttpResponse) {

CommonResponse response = new CommonResponse<>(0, "");if (null ==o) {returnresponse;

}else if (o instanceofCommonResponse) {

response= (CommonResponse) o;

}else{

response.setData(o);

}returnresponse;

}

}

4-3 统一异常处理的开发

自定义AdException类。

GlobalExceptionAdvice.java

importcom.imooc.ad.exception.AdException;importcom.imooc.ad.vo.CommonResponse;importorg.springframework.web.bind.annotation.ExceptionHandler;importorg.springframework.web.bind.annotation.RestControllerAdvice;importjavax.servlet.http.HttpServletRequest;

@RestControllerAdvicepublic classGlobalExceptionAdvice {

@ExceptionHandler(value= AdException.class)public CommonResponsehandlerAdException(HttpServletRequest req,

AdException ex) {

CommonResponse response = new CommonResponse<>(-1,"business error");

response.setData(ex.getMessage());returnresponse;

}

}

4-4 统一配置的开发

定义http消息转换器(将Java对象转换为http的输出流)。

WebConfiguration.java

importorg.springframework.context.annotation.Configuration;importorg.springframework.http.converter.HttpMessageConverter;importorg.springframework.http.converter.json.MappingJackson2HttpMessageConverter;importorg.springframework.web.servlet.config.annotation.WebMvcConfigurer;importjava.util.List;

@Configurationpublic class WebConfiguration implementsWebMvcConfigurer {

@Overridepublic void configureMessageConverters(List>converters) {

converters.clear();

converters.add(newMappingJackson2HttpMessageConverter());

}

}

第5章 广告投放系统的开发

5-1 Spring IOC和MVC基础知识

5-2 SpringBoot 常用功能特性介绍

启动的方法还有两种：

定时任务：

5-3 广告投放系统数据表设计

第7章 广告检索系统 - 广告数据索引的设计与实现

7-1 广告数据索引设计介绍

7-2 广告数据索引维护介绍

7-3 推广计划索引对象定义与服务实现

IndexAware.java

packagecom.imooc.ad.index;public interface IndexAware{

V get(K key);voidadd(K key, V value);voidupdate(K key, V value);voiddelete(K key, V value);

}

索引对象 AdPlanObject.java

packagecom.imooc.ad.index.adplan;importlombok.AllArgsConstructor;importlombok.Data;importlombok.NoArgsConstructor;importjava.util.Date;

@Data

@NoArgsConstructor

@AllArgsConstructorpublic classAdPlanObject {privateLong planId;privateLong userId;privateInteger planStatus;privateDate startDate;privateDate endDate;public voidupdate(AdPlanObject 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();

}

}

}