WebMaster

fs 파일 시스템에 접근하는 모듈 파일/폴더 생성, 삭제, 읽기, 쓰기 가능 웹 브라우저에서는 제한적이었으나 노드는 권한을 가지고 있음 파일 읽기 예제(결과의 버퍼는 뒤에서 설명함) fs Promise 콜백 방식 대신 프로미스 방식으로 사용 가능 require(‘fs’).promises 사용하기 훨씬 더 편해서 프로미스 방식을 추천함 fs 파일 만들기 fs.writeFile을 사용하게 되면, file을 쓸 수 있다. 동기 메서드와 비동기 메서드 노드는 대부분의 내장 모듈 메서드를 비동기 방식으로 처리 비동기는 코드의 순서와 실행 순서가 일치하지 않는 것을 의미 일부는 동기 방식으로 사용 가능 위 코드의 콜백 함수는 비동기로 동작하기 때문에 어떤 것을 먼저 출력할지 예측할 수 없다(운영체제만 실행 순서를 ..

여러 개의 Reactive 스타일로 받는 Flux @Slf4j @SpringBootApplication public class Chapter14Application { @RestController public static class MyController { @GetMapping("/event/{id}") public Mono event(@PathVariable long id) { return Mono.just(new Event(id, "event " + id));//특정 오브젝트를 컬렉션으로 다뤄 리액티브 스타일로 다루고 싶다면 어떻게 할까? } @GetMapping("/events") public Flux events() { return Flux.just(new Event(1L, "event1"), ..

@SpringBootApplication public class Chapter13Application { public static void main(String[] args) { //Tomcat을 기본으로 사용하는 것이 아닌, netty가 실행이된다. //비동기 non-blocking 에 사용되는 서버인 netty가 기본적으로 실행되는 것을 확인 할 수 있다. SpringApplication.run(Chapter13Application.class, args); } } dependency를 추가할 때는 spring-web과 spring-webflux를 같이 import 하지 말자(webflux에 web을 포함하고 있음) 기본적으로 spring-webflux의 dependency만 있다면, 서버는 톰캣이 아..

이전에 사용했던 AsyncRestTemplate의 getForEntity 메서드 같은 경우, Http 요청을 모두 받기 때문에 Http Header, 상태 코드 모두 돌아오기 때문에 좋지 않다. Mono @GetMapping("/rest") public Mono rest(int idx) { //Mono를 사용하면, 어떤 오브젝트든 받아서 반환할 수 있다. //Mono를 컨테이너(컬렉션)이라고, 생각하면 된다 -> 컨테이너 = Optional, List 등과 같이 컨테이너로 데이터를 감싸면 여러 기능을 쓸 수 있다. //Mono m = Mono.just("Hello");//일반 String 메서드와 달리 Mono로 감싸게 되면, 많은 기능을 쓸 수 있는것을 볼 수 있다 return Mono.just("He..

CompletableFuture : 비동기 작업을 간단하게 완료하는 작업을 할 수 있다. public static void main(String[] args) throws ExecutionException, InterruptedException { //CompletableFuture cf = CompletableFuture.completedFuture(1); //비동기 작업을 간단하게 완료하는 작업을 할 수 있다. CompletableFuture cf = new CompletableFuture(); //값을 넘기지 않았기 때문에 무한정 대기 //cf.complete(2);//값을 넣어준다 cf.completeExceptionally(new RuntimeException()); //예외가 발생했다는것을 알..

Refectoring: CallBack 지옥에서 벗어나는 코드 Version 1 코드를 자세히 보면, 결과를 리턴으로 받는 것이 아닌 콜백 형식으로 받게 되니, Callback 지옥이 발생하게 된다. 에러를 처리해주는 코드가 매번 중복되는 문제도 계속 발생한다. @SpringBootApplication public class Chapter10Application { @RestController public static class MyController { public static final String URL1 = "http://localhost:8081/service1?req={req}"; public static final String URL2 = "http://localhost:8081/servic..

Thread Pool Hell(스레드 풀 지옥) LinkedIn의 Thread Pool 2~4시 사이에 요청이 급격히 많아졌고, 그에 따라 Latency도 급격히 증가한 것을 볼 수 있다 Thread요청이 급격히 늘어나 Queue에 대기하고 있던 요청들도 늘게 되어, Latency가 길어진 것을 볼 수 있다. 왜 이렇게 Latency가 늘어났을까? 최신 BackEnd 구조를 보면, 외부 API 호출을 통한 요청으로 서로 간 통신을 한다 외부 API 호출을 통한 요청은 I/O 요청으로 Blocking 처리가 되고, 스레드가 Blocking 상태가 되어 놀고 있기 때문에 Latancy가 증가한 것이다. 스레드를 늘리는것은 근본적인 해결이 될 수 없다(스레드 개수를 늘리는 것은 한정되어 있으며, 오히려 잦은 ..

JAVA에서의 비동기 작업(Future) JVM의 Future란? JVM 1.5에서 나왔다, 비동기적인 연산,작업에 대한 결과를 가지고 있는 인터페이스 public static void main(String[] args) throws InterruptedException { ExecutorService es = Executors.newCachedThreadPool(); Thread.sleep(2000); System.out.println("Hello"); //2초 후 해당 결과가 실행되고 Exit 실행 System.out.println("Exit"); } 2초 뒤에 Hello가 출력되고, Exit가 출력된다 동기적 실행이 된다. 비동기적 실행 public static void main(String[] a..

@Slf4j public class SchedulerEx { public static void main(String[] args) { //모두 main 쓰레드에서 동작한다 Publisher pub = sub -> { sub.onSubscribe(new Subscription() { @Override public void request(long n) { sub.onNext(1); sub.onNext(2); sub.onNext(3); sub.onNext(4); sub.onNext(5); sub.onComplete(); } @Override public void cancel() { } }); }; pub.subscribe(new Subscriber() { @Override public void onSubscr..

중위 호출 연쇄: 테스트 프레임워크의 should 코틀린 테스트 DSL에서 중위 호출을 어떻게 활용하는지 살펴보자 s should startwith("kot") //DSL 단언문 표현 infix fun T.should(matcher: Matcher) = matcher.test(this) //should 함수 구현 s에 들어있는 값이"kot"로 시작하지 않으면 단언문 실패 should 함수 앞에 infix 변경자를 붙여 중위 호출 함수를 정의한다. should 함수는 Matcher 인스턴스를 요구하며, Matcher는 값에 대한 단언문을 표현하는 제네릭 인터페이스다. startwith는 Matcher를 구현하며, 문자열 시작을 검사한다. interface Matcher{ fun test(value:T) }..