전체 글

[Spring boot] WebSocket + STOMP

개요이전포스트에서 작업한거에서 추가로 STOMP를 적용하는것을 해보았습니다.STOMP (Simple Text Oriented Messaging Protocol)   - STOMP은 메시지 지향 미들웨어나 메시지 큐 시스템에서 사용되는 간단한 텍스트 기반의 프로토콜입니다.    - 주로 클라이언트와 서버 간의 메시지 전송 및 구독을 정의합니다.    - 메시지의 송수신을 위한 프레임(Frame)을 제공하며, CONNECT, SEND, SUBSCRIBE, UNSUBSCRIBE, ACK 등의 명령을 사용하여 클라이언트와 서버 간 통신을 정의합니다. WebSocket과 STOMP는 종종 함께 사용됩니다. WebSocket은 실시간 양방향 통신을 가능하게 하고, STOMP은 이를 이용하여 메시지를 보내고 받는..

[Spring boot] WebSocket 사용

개요 웹소켓(WebSocket)은 웹 애플리케이션에서 양방향 통신을 가능하게 하는 표준화된 프로토콜입니다. HTTP 프로토콜과 달리 웹소켓은 서버와 클라이언트 간에 지속적인 연결을 제공하여 실시간 데이터 전송이 가능합니다. 일반적으로 HTTP 요청은 클라이언트가 서버에게 요청을 보내고, 서버는 응답을 보내는 단방향 통신이었습니다. 그러나 웹소켓은 연결을 유지하면서 클라이언트와 서버 간에 양방향 통신이 가능해집니다. 웹소켓을 사용하면 실시간 채팅, 주식 시세 업데이트, 멀티플레이어 게임 등과 같은 애플리케이션에서 실시간 정보를 보내고 받을 수 있습니다. 이러한 특성으로 인해 웹소켓은 웹 기반의 실시간 응용 프로그램을 개발하는 데 매우 유용하게 활용됩니다. WebSocket 사용 build.gradle 파일..

[Apache Kafka] sink connector 오류 수정

sink connector를 설정 후 connect를 실행할때 아래와 같이 mysql driver를 못찾아서 에러가 발생했습니다. mysql connector 다운로드 사이트 에서 최신 mysql connector를 다운받습니다. os를 Platform Independent를 선택 후 zip버전을 다운로드 하고 압축을 풀면 mysql-connector-j-8.2.0.jar 파일이 존재합니다. 해당 jar파일을 kafka폴더\lib 폴더로 옮겨줍니다. 저는 D:\tools\kafka_2.13-3.6.0\libs 경로로 옮겨줬습니다. 그리고 다시 시작하면 에러가 해결된 것을 확인할 수 있습니다. 참고자료 https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc..

[Apache Kafka] topic 삭제 후 재생성시 producer 동작 안하는 현상

이전포스팅처럼 topic을 삭제 후 동일한 이름으로 topic을 다시 생성 시 producer가 동작을 안하는 현상이 있습니다. topic 정보를 확인해보면 topic의 고유 TopicId값을 확인할 수 있습니다. .\kafka-topics.bat --describe --bootstrap-server=localhost:9092 해당 TopicId값은 D:\tmp\kafka-logs\토픽명\partition.metadata 파일을 열어보면 topic_id값이 있는데 해당값이랑 일치해야 producer가 동작을 합니다. partition.metadata 파일의 topic_id값을 topic 정보에서 확인한 값과 일치시킨후 zookeeper, kafka를 다시 시작하면 producer가 정상적으로 동작하는것을..