728x90 반응형 스프링부트16 스프링 클라우드 데이터 플로우(SCDF)를 활용한 무중단 서비스 구축: 소스, 프로세서, 싱크 어플리케이션 스트림 통합 및 배포 (3) 이제 SCDF 서버로 다시 돌아와서 지금까지 만들었던 어플리케이션을 스트림 구조를 활용하여 무중단 서비스를 만들어 봅시다. add applications 클릭 1. 하나의 어플리케이션 등록 클릭 2. name , type , URI 설정 -. type에는 source, processor, sink 에 맞게 골라 주세요 -. URI에는 메이븐 리파지토리에 올린 본인의 jar를 추가해 주는데 다음과 같은 형식으로 올리면 됩니다. maven://그룹아이디:네임:버전 위와 같이 source, processor, sink를 올려주면 본인이 올린 어플리케이션들을 확인 할 수 있습니다. 이제 Streams 탭을 클릭하고 create streams를 클릭합니다. 우리가 만든 어플리케이션을 왼쪽에서 찾아 드래그 하여 담.. 2023. 6. 12. 스프링 클라우드 데이터 플로우 (SCDF)를 이용한 로컬 서버 구축 및 어플리케이션 통합 - 실습 가이드와 네이버 개발자 리소스 (1) 여러가지 문서들을 찾아 보면서 네이버 개발자분의 정리가 잘되어있어 참고하였습니다. 스프링 클라우드 데이터 플로우에 대한 이해를 높이기 위해 먼저 살펴보면 좋을 것 같아 참조합니다. 참조 : https://deview.kr/data/deview/session/attach/[135]SCDF%EB%A1%9C+%ED%95%98%EB%A3%A8+N%EB%A7%8C%EA%B3%A1+%EC%9D%B4%EC%83%81+VIBE+%EB%A9%94%ED%83%80+%EB%8D%B0%EC%9D%B4%ED%84%B0+%EC%8B%A4%EC%8B%9C%EA%B0%84%EC%9C%BC%EB%A1%9C+%EC%A0%81%EC%9E%AC%ED%95%98%EA%B8%B0!+-+%EB%B0%B0%ED%8F%AC%EC%9A%A9%20(1.. 2023. 6. 9. 스프링 클라우드 데이터 플로우 (SCDF)를 활용한 실시간 대용량 데이터 처리 프로젝트 소개와 경험 공유 안녕하세요 한동안 정신없이 바빴던 네띠와 레디스를 사용한 사내 프로젝트를 마무리하고 새로운 프로젝트를 시작하려 합니다. 네띠와 레디스에 대해 배운점은 차근차근 업데이트 할 예정이고 오늘은 새로운 프로젝트의 주요기술인 스프링 클라우드 데이터 플로우(SCDF)에 대해 알아보겠습니다. 사내에서 레거시 대용량 데이터를 관리하는 부분에 해당 기술을 적용하려 하는데요 해당 기술을 찾아보면서 제가 알게된 내용들을 공유해드리려 합니다. 공식 문서를 찾아보면 Spring Cloud Data Flow는 구성 가능한 데이터 마이크로서비스를 위한 클라우드 네이티브 프로그래밍 및 운영 모델입니다. 데이터 수집, 실시간 분석 및 데이터 가져오기/내보내기와 같은 일반적인 사용 사례를 위한 데이터 파이프라인을 만들고 오케스트레이션할.. 2023. 6. 8. Stomp를 활용한 실시간 채팅 프로그램 구현: 웹소켓 최적화 및 효율적인 메시징 전송 (4) 이번에는 Websocket의 프로세스를 좀더 고도화 하고 메시징에 좀 더 최적화된 방식을 구현하기 위해 Stomp를 적용해 보겠습니다. Stomp란? stomp는 메시징 전송을 효율적으로 하기 위해 나온 프로토콜이며 기본적으로 pub/sub 구조로 되어있습니다. 메시지를 발송하고 처리하는 부분이 명확하여 개발하는 입장에서 명확하게 인지하고 개발 할 수 있는 이점이 있습니다. 또한 통신 메시지의 헤더에 값을 세팅할 수 있어 헤더값을 기반으로 통신 시 인증처리를 구현하는 것도 가능합니다. pub는 publisher(집배원)으로 볼 수 있으며 sub는 subscriber(구독자)로써 여러명이 될 수 있습니다. - 채팅방 만들기 : pub/sub를 위한 topic 생성 - 채팅방 입장 : topic 구독 - 채.. 2023. 2. 24. Java 스프링부트 채팅 프로그램 확장하기: 여러 채팅방 구현, 컨트롤러 설정 및 테스트 방법 (2) 1편 : https://rhgustmfrh.tistory.com/14 Java 스프링부트를 이용한 채팅 프로그램 구축하기: 웹소켓 활용, 설정 및 테스트 방법 (1) 오늘을 자바 스프링부트 채팅 프로그램 만들기 실습을 진행 하겠습니다. 먼저 spring.io 에서 진행하고자 할 스프링부트 프로젝트를 만들어봅니다. 해당 실습은 자바 17버전과 gradle로 진행 하겠습 rhgustmfrh.tistory.com 2편에서는 채팅방을 여러개 만들어 채팅을 할 수 있게 구현 해 보겠습니다. 클라이언트들은 개별 웹소켓 세션을 가지게 되고 채팅방에 세션 정보를 mapping 시켜 두면 특정 방으로 메시지를 보낼 수 있습니다. 여러 채팅방을 구현하기 위한 구조는 다음과 같이 구현 하였습니다. 1. 채팅 메시지를 구현합.. 2023. 2. 20. Java 스프링부트를 이용한 채팅 프로그램 구축하기: 웹소켓 활용, 설정 및 테스트 방법 (1) 오늘을 자바 스프링부트 채팅 프로그램 만들기 실습을 진행 하겠습니다. 먼저 spring.io 에서 진행하고자 할 스프링부트 프로젝트를 만들어봅니다. 해당 실습은 자바 17버전과 gradle로 진행 하겠습니다. dependencies - Spring Web - WebSocket - Lombok GENERATE를 클릭하고 intellij에서 프로젝트 임포트 해주세요~ 해당 프로젝트의 구조입니다. chatEx 패키지의 main 파일과 config handler 패키지의 handler 파일을 볼 수 있습니다. 클라이언트가 작성한 메시지를 받아 처리해줄 handler입니다. 받은 메시지를 console log에 payload에 담아 출력하고 환영 메시지를 보내줍니다. 다음은 config 파일입니다. websock.. 2023. 2. 20. 이전 1 2 다음 728x90 반응형
