spring boot 는 차단기 의 3 가지 방식 과 비동기 적 인 사 고 를 실현 합 니 다.
16859 단어 springboot차단기비동기 실행
실제 항목 에서 우 리 는 항상 출력 요구 파라미터,응답 결과,방법 소모 시간,통 일 된 권한 검사 등 이 필요 합 니 다.
본 고 는 먼저 HTTP 요청 에서 흔히 볼 수 있 는 세 가지 차단 실현 을 소개 하고 그 중의 차 이 를 비교 하고 자 한다.
(1)Aspect 기반 차단기
(2)Handler Interceptor 기반 차단기
(3)Response Body Advice 기반 차단기
추천 읽 기:
통일 로그 프레임 워 크:https://github.com/houbb/auto-log
springboot 입문 사례
여러분 의 학습 을 편리 하 게 하기 위해 서,우 리 는 먼저 가장 기본 적 인 spring boot 예 에서 말 합 니 다.
maven 도입
필요 한 jar 가방 을 도입 합 니 다.
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.9.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjrt</artifactId>
<version>1.8.10</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.10</version>
</dependency>
</dependencies>
<!-- Package as an executable jar -->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>가장 간단 한 시작 클래스 를 실현 합 니 다.
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
프 리 젠 테 이 션 의 편 의 를 위해 서 우 리 는 먼저 간단 한 contrller 를 실현 합 니 다.
@RestController
public class IndexController {
@RequestMapping("/index")
public AsyncResp index() {
AsyncResp asyncResp = new AsyncResp();
asyncResp.setResult("ok");
asyncResp.setRespCode("00");
asyncResp.setRespDesc(" ");
System.out.println("IndexController#index：" + asyncResp);
return asyncResp;
}
}
public class AsyncResp {
private String respCode;
private String respDesc;
private String result;
// getter & setter & toString()
}
Aspect 기반
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.stereotype.Component;
import java.util.Arrays;
/**
*
* @author binbin.hou
* @since 1.0.0
*/
@Aspect
@Component
@EnableAspectJAutoProxy
public class AspectLogInterceptor {
/**
*
* @since 1.0.0
*/
private static final Logger LOG = LoggerFactory.getLogger(AspectLogInterceptor.class);
/**
* controller public
*/
@Pointcut("execution(public * com.github.houbb.springboot.learn.aspect.controller..*(..))")
public void pointCut() {
//
}
/**
*
*
* @param point point
* @return result
* @throws Throwable if any
*/
@Around("pointCut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
try {
//1. MDC
//
String signatureShortStr = point.getSignature().toShortString();
//2.
Object[] args = point.getArgs();
LOG.info("{} : {}", signatureShortStr, Arrays.toString(args));
//3.
Object result = point.proceed();
LOG.info("{} : {}", signatureShortStr, result);
return result;
} finally {
// mdc
}
}
}개인 적 으로 아주 좋아 하 는 방식 입 니 다.
주요 용도:
(1)로그 의 출 참/입 참
(2)TraceId 통일 설정
(3)방법의 호출 시간 통계
HandlerInterceptor 기반
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.DispatcherType;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* @author binbin.hou
* @since 1.0.0
*/
@Component
public class LogHandlerInterceptor implements HandlerInterceptor {
private Logger logger = LoggerFactory.getLogger(LogHandlerInterceptor.class);
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
// 、
logger.info("LogHandlerInterceptor#preHandle ：{}", request.getRequestURI());
if (request.getDispatcherType().equals(DispatcherType.ASYNC)) {
return true;
}
return true;
}
@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
logger.info("LogHandlerInterceptor#postHandle ");
}
@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
}
}
import com.github.houbb.springboot.learn.aspect.aspect.LogHandlerInterceptor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
/**
* spring mvc
* @since 1.0.0
*/
@Configuration
public class SpringMvcConfig extends WebMvcConfigurerAdapter {
@Autowired
private LogHandlerInterceptor logHandlerInterceptor;
@Override
public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(logHandlerInterceptor)
.addPathPatterns("/**")
.excludePathPatterns("/version");
super.addInterceptors(registry);
}
}단점 은 주로 컨트롤 러 층 에 쓰 인 다 는 것 이다.
Response Body Advice 기반
이 인 터 페 이 스 는 beforeBody Write 방법 이 있 습 니 다.매개 변수 body 는 응답 대상 response 의 응답 체 입 니 다.그러면 우 리 는 이 방법 으로 응답 체 를 통일 적 으로 조작 할 수 있 습 니 다.
예 를 들 어 암호 화,서명 등 이다.
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.MethodParameter;
import org.springframework.http.MediaType;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice;
import javax.servlet.http.HttpServletRequest;
/**
* @author binbin.hou
* @since 1.0.0
*/
@ControllerAdvice
public class MyResponseBodyAdvice implements ResponseBodyAdvice<Object> {
/**
*
* @since 1.0.0
*/
private static final Logger LOG = LoggerFactory.getLogger(MyResponseBodyAdvice.class);
@Override
public boolean supports(MethodParameter methodParameter, Class aClass) {
// false, beforeBodyWrite
return true;
}
@Override
public Object beforeBodyWrite(Object resp, MethodParameter methodParameter, MediaType mediaType, Class<? extends HttpMessageConverter<?>> aClass, ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse) {
String uri = serverHttpRequest.getURI().getPath();
LOG.info("MyResponseBodyAdvice#beforeBodyWrite ：{}", uri);
ServletServerHttpRequest servletServerHttpRequest = (ServletServerHttpRequest) serverHttpRequest;
HttpServletRequest servletRequest = servletServerHttpRequest.getServletRequest();
//
//
LOG.info("MyResponseBodyAdvice#beforeBodyWrite ：{}", resp);
return resp;
}
}응용 프로그램 시작,페이지 접근:
http://localhost:18080/index
페이지 응답:
{"respCode":"00","respDesc":"성공","result":"ok"}
백 엔 드 로그:
c.g.h.s.l.a.a.LogHandlerInterceptor : LogHandlerInterceptor\#preHandle 요청 주소:/index
c.g.h.s.l.a.aspect.AspectLogInterceptor : IndexController.index()인자:[]
IndexController\#index:AsyncResp{respCode='00',respDesc='성공',result='ok'}
c.g.h.s.l.a.aspect.AspectLogInterceptor : IndexController.index()결과:AsyncResp{respCode='00',respDesc='성공',result='ok'}
c.g.h.s.l.a.aspect.MyResponseBodyAdvice : MyResponseBodyAdvice\#beforeBodyWrite 요청 주소:/index
c.g.h.s.l.a.aspect.MyResponseBodyAdvice : MyResponseBodyAdvice\#beforeBodyWrite 응답 결과:AsyncResp{respCode='00',respDesc='성공',result='ok'}
c.g.h.s.l.a.a.LogHandlerInterceptor : LogHandlerInterceptor\#post Handle 호출
여기 서 집행 하 는 선후 순서 도 비교적 명확 하 므 로 여 기 는 더 이상 군말 하지 않 겠 다.
비동기 실행
물론 위의 내용 만 있다 면 이 문장의 중점 은 아니다.
이 어 비동기 집행 이 도입 되면 어떻게 될 지 살 펴 보 자.
비동기 스 레 드 풀 정의
springboot 에서 비동기 스 레 드 풀 을 정의 하 는 것 은 매우 간단 합 니 다.
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.AsyncTaskExecutor;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
*
*
* @author binbin.hou
*/
@Configuration
@EnableAsync
public class SpringAsyncConfig {
@Bean(name = "asyncPoolTaskExecutor")
public AsyncTaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setMaxPoolSize(10);
executor.setQueueCapacity(10);
executor.setCorePoolSize(10);
executor.setWaitForTasksToCompleteOnShutdown(true);
return executor;
}
}
@RestController
public class MyAsyncController extends BaseAsyncController<String> {
@Override
protected String process(HttpServletRequest request) {
return "ok";
}
@RequestMapping("/async")
public AsyncResp hello(HttpServletRequest request) {
AsyncResp resp = super.execute(request);
System.out.println("Controller#async ：" + resp);
return resp;
}
}
@RestController
public abstract class BaseAsyncController<T> {
protected abstract T process(HttpServletRequest request);
@Autowired
private AsyncTaskExecutor taskExecutor;
protected AsyncResp execute(HttpServletRequest request) {
//
AsyncResp resp = new AsyncResp();
try {
taskExecutor.execute(new Runnable() {
@Override
public void run() {
try {
T result = process(request);
resp.setRespCode("00");
resp.setRespDesc(" ");
resp.setResult(result.toString());
} catch (Exception exception) {
resp.setRespCode("98");
resp.setRespDesc(" ");
}
}
});
} catch (TaskRejectedException e) {
resp.setRespCode("99");
resp.setRespDesc(" ");
}
return resp;
}
}(1)메 인 스 레 드 는 AsyncResp 를 만 들 고 되 돌아 오 는 데 사용 합 니 다.
(2)스 레 드 탱크 이 보 는 구체 적 인 하위 클래스 방법 을 실행 하고 해당 하 는 값 을 설정 합 니 다.
사고 하 다.
다음은 여러분 에 게 한 가지 질문 을 드 리 겠 습 니 다.
만약 우리 가 요청 한다 면http://localhost:18080/async:
(1)페이지 에서 얻 은 반환 값 은 무엇 입 니까?
(2)Aspect 로그 출력의 반환 값 은?
(3)Response Body Advice 로그 출력의 반환 값 은 무엇 입 니까?
너 는 여기에서 잠시 멈 추고 너의 답안 을 기록 할 수 있다.
테스트
우리 페이지 요청http://localhost:18080/async.
페이지 응답 은 다음 과 같 습 니 다:
{"respCode":"00","respDesc":"성공","result":"ok"}
백 엔 드 로그:
c.g.h.s.l.a.a.LogHandlerInterceptor : LogHandlerInterceptor\#preHandle 요청 주소:/async
c.g.h.s.l.a.aspect.AspectLogInterceptor : MyAsyncController.hello(..)인자:[org.apache.catalina.connector.RequestFacade@7e931750]
Controller\#async 결과:AsyncResp{respCode='null',respDesc='null',result='null'}
c.g.h.s.l.a.aspect.AspectLogInterceptor : MyAsyncController.hello(..)결과:AsyncResp{respCode='null',respDesc='null',result='null'}
c.g.h.s.l.a.aspect.MyResponseBodyAdvice : MyResponseBodyAdvice\#beforeBodyWrite 요청 주소:/async
c.g.h.s.l.a.aspect.MyResponseBodyAdvice : MyResponseBodyAdvice\#beforeBodyWrite 응답 결과:AsyncResp{respCode='00',respDesc='성공',result='ok'}
c.g.h.s.l.a.a.LogHandlerInterceptor : LogHandlerInterceptor\#post Handle 호출
비교 해 보면 우리 위의 문제 의 답 을 발견 할 수 있다.
(1)페이지 에서 얻 은 반환 값 은 무엇 입 니까?
{"respCode":"00","respDesc":"성공","result":"ok"}
비동기 실행 이 완 료 된 결 과 를 얻 을 수 있 습 니 다.
(2)Aspect 로그 출력의 반환 값 은?
AsyncResp{respCode='null', respDesc='null', result='null'}
비동기 결 과 를 가 져 올 수 없습니다.
(3)Response Body Advice 로그 출력의 반환 값 은 무엇 입 니까?
AsyncResp{respCode='00',respDesc='성공',result='ok'}
비동기 실행 이 완 료 된 결 과 를 얻 을 수 있 습 니 다.
반성
spring 이 페이지 에 대한 응답 은 우리 가 생각 하 는 것 과 다 를 수 있 습 니 다.동기 화 결 과 를 직접 얻 는 것 이 아 닙 니 다.
여기까지 쓰 고 보 니 자신 이 뮤 직 비디오 에 대한 이 해 는 표면 에 만 머 물 렀 고 전체 절 차 를 진정 으로 이해 하지 못 했다.
Aspect 의 형식 은 많은 프레임 워 크 에서 사용 되 지만 비동기 적 인 실행 결 과 를 얻 지 못 해 문제 가 있 음 을 발견 할 수 있 습 니 다.
spring boot 구현 차단기 의 3 가지 방식 과 비동기 실행 에 대한 사 고 를 소개 합 니 다.더 많은 spring boot 차단기 내용 은 이전 글 을 검색 하거나 아래 의 관련 글 을 계속 찾 아 보 세 요.앞으로 도 많은 응원 부 탁 드 리 겠 습 니 다!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Kotlin Springboot -- 파트 14 사용 사례 REST로 전환하여 POST로 JSON으로 전환前回 前回 前回 記事 の は は で で で で で で を 使っ 使っ 使っ て て て て て リクエスト を を 受け取り 、 reqeustbody で 、 その リクエスト の ボディ ボディ を を 受け取り 、 関数 内部 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
