글

라벨이 Reactor인 게시물 표시

Spring Boot Admin Server, Client config 설정하기

-
이미지
 Spring Boot로 많은 프로젝트를 진행하게 됩니다. 많은 모니터링 도구가 있지만, Spring Boot 어플리케이션을 쉽게 모니터링 할 수 있는 방법을 소개하려고 합니다.   코드 중심으로 살펴보겠습니다. 1. 어드민 서버 구축 1-1. 디펜던시 추가 dependencies { // https://mvnrepository.com/artifact/de.codecentric/spring-boot-admin-starter-server implementation 'de.codecentric:spring-boot-admin-starter-server:2.5.4' } 1-2. 어드민 서버 설정 활성화 @SpringBootApplication @EnableAdminServer public class ServerApplication { public static void main (String[] args) { SpringApplication. run (ServerApplication. class, args) ; } } EnableAdminServer를 하면 됩니다. 2. 클라이언트 서버 설정  예제는 book-client, member-client 2가지 클라이언트, member-client가 2개의 인스턴스 실행으로 작성했습니다.  2-1 디펜던시 추가 dependencies { // https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web implementation 'org.springframework.boot:spring-boot-starter-web:2.5.4' // https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-actuator implementation 'org.spring...
댓글 쓰기
자세한 내용 보기

Spring boot Webflux에서 block 찾기

-
이미지
Webflux로 개발하는 경우 block가 있으면 성능이 현저하게 낮아 집니다. 따라서 개발 후에 개발한 코드에 Block을 발생 시키는 코드가 있는지 확인하는 것은 중요합니다. 이것을 도와 주는 라이브러리가 Blockhound 입니다. 1. 의존성 추가 testImplementation( 'org.springframework.boot:spring-boot-starter-test' ) testImplementation 'io.projectreactor:reactor-test' testImplementation 'io.projectreactor.tools:blockhound:1.0.6.RELEASE' testImplementation 'io.projectreactor.tools:blockhound-junit-platform:1.0.6.RELEASE' Blockhound를 사용하면 Block을 발생시키는 곳에서 에러를 발생시킵니다. 따라서 운영 환경에서는 사용을 피해야 합니다. 테스트 환경에서 사용하는 것을 추천 드립니다. 2. 샘플 라우터 작성 @Configuration public class BlockingRouter { @Bean public RouterFunction<ServerResponse> blockRouter () { return RouterFunctions. route (RequestPredicates. GET ( "/nonBlock" ).and(RequestPredicates. accept (MediaType. APPLICATION_JSON )) , request -> { return ServerResponse. ok ().body(Mono. just ( "nonblock response" ) , String. class ) ; }).andRoute(RequestPredicates. GET ...
댓글 쓰기
자세한 내용 보기

Spring boot webflux + mysql

-
스프링 부트의 webflux의 rest api 예제 입니다. 샘플 코드 https://github.com/withccm/spring-webflux-study/tree/feature/webflux-mysql-sample 북 테이블 CREATE TABLE `book` ( `id` int ( 11 ) NOT NULL AUTO_INCREMENT , `bookname` varchar ( 200 ) DEFAULT NULL , PRIMARY KEY (`id`) ) ; 1. 의존성 추가 implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc' runtimeOnly 'mysql:mysql-connector-java' implementation 'dev.miku:r2dbc-mysql' 2. spring data r2dbc bean 등록 @Configuration @EnableTransactionManagement @EnableR2dbcRepositories public class DataSourceR2DBCConfig extends AbstractR2dbcConfiguration { @Bean @Primary public ConnectionFactory connectionFactory () { ConnectionFactoryOptions options = ConnectionFactoryOptions. builder () .option(ConnectionFactoryOptions. DRIVER , "pool" ) .option(ConnectionFactoryOptions. PROTOCOL , "mysql" ) .option(ConnectionFactoryOptions. HOST , "localhost" ...
댓글 쓰기
자세한 내용 보기