반응형

스트림

    리액티브 스트림의 이해

    리액티브 스트림은 총 4개의 인터페이스로 구성되어 있다. ㅁ 발행자(Publisher) - 데이터의 소스를 가지고 있으며 Subscriber의 요청이 오면 데이터를 발행한다. 구독자는 발행자에 대한 구독을 추가할 수 있다. Subscribe 메소드를 통해서 구독자를 추가할수 있다.123public interface Publisher { public void subscribe(Subscriber

    스프링 부트와 RabbitMQ를 사용한 리액티브 마이크로 서비스

    publisher와 subscriber가 외부의 메시지 큐(RabbitMQ)와 연결되어 있는 애플리케이션을 만들어보자. Rabbitmq 설치 - 자세한 설치법은 검색을 해서 찾아보면 간단하게 나온다. - 하단의 내용은 local docker가 설치되어 있을때 docker-compose.yml을 작성할때 붙혀넣으면 된다. rabbitmq: image: rabbitmq:management ports: - "5672:5672” // 연결 포트 - "15672:15672” // 관리자 페이지 포트 (localhost:15672) Maven 의존성 추가1234 org.springframework.boot spring-boot-starter-amqpColored by Color Scriptercs Sender 클래..

    Java8 스트림(stream) 연산

    리덕션 연산 Stream의 reduce 메소드는 2개의 인자를 받아 인자와 같은 값을 리턴하는 (T,T) -> T 메소드이다. 첫 번째 인자는 누적되는 값이 되고, str2는 foreach처럼 순서대로 요소가 들어오는 방식이다. public static void main(String args[]) { List list = Arrays.asList(new String[] {"a", "b", "c"}); Stream stream = list.stream(); Optional opt = stream.reduce((str1, str2) -> str1 + str2); opt.ifPresent(System.out::println); } =>> 리턴 값 "abc" 또 다른 형태의 reduce 메소드 위에서 소개한 r..

    Java8 스트림(Stream) API

    Java8의 람다식, 인터페이스의 변화에 이어서 더 좋은 기능이 바로 스트림이다. 스트림(Stream) 정의 - 스트림이란 리눅스에서 사용되는 파이프 라인 처럼 한번에 한 개 씩 만들어지는 연속적인 데이터 항목들의 모임이다. Ex) ps -ef | grep pnp | grep -v drop 조금 더 자세히 설명하면, 집계 연산을 지원하는 요소의 순서(a sequence of elements from a source that supports aggregate operations) 라고 소개 되어 있다. - Stream은 정의된 엘리먼트의 속성에 따라서 처리할 수 있는 인터페이스를 제공하지만 실제 엘리먼트들을 저장하지 않고 계산하는 데만 쓰인다. - 스트림은 컬렉션, 배열, I/O 리소스 등에서 제공받은 데..

    스트림(Stream)_입출력 스트림

    스트림(stream)- 네트워크 프로그램의 가장 큰 비중은 입출력(I/O) 출력스트림1. java.io.OutputStream제공메소드public abstract void write(int b) throws IOExceptionpublic void write(byte[] data) throws IOExceptionpublic void write(byte[] data, int offset, int length) throws IOExceptionpublic void flush() throws IOException // 버퍼가 아직 가득 차지 않은 상황에서 강제로 버퍼의 내용을 전송public void close() throws IOException //스트림 사용이 끝나면 해당스트림을 닫는다. - Outpu..

반응형