ThreeDotsLabs/watermill

어떤 프로젝트인가요?

핵심 기능

• 01다양한 메시지 브로커에서 사용할 수 있는 공통 Publisher 및 Subscriber 인터페이스
• 02핸들러가 새 메시지나 오류를 반환하는 핸들러 기반 모델
• 03재시도와 처리 흐름 같은 동작을 구성할 수 있는 미들웨어
• 04Kafka, RabbitMQ, NATS JetStream, Redis Streams, Google Cloud Pub/Sub, AWS SNS/SQS 및 SQL 데이터베이스 지원
• 05로컬 개발과 테스트를 위한 인메모리 GoChannel

활용 사례

• 컴포넌트 간 메시지를 주고받는 이벤트 기반 서비스 구축
• Go에서 이벤트 소싱 또는 CQRS 읽기 모델 구현
• 사가를 사용해 장기 실행 워크플로 조정
• 애플리케이션 로직을 다시 작성하지 않고 메시지 브로커 전환

빠른 시작

1. 1

   Watermill 라이브러리 모듈을 설치하세요

   go get github.com/ThreeDotsLabs/watermill
2. 2

   공식 사이트의 Quickstart 가이드를 따라 첫 앱을 작성하세요

사용 전 알아둘 점

• !Go 라이브러리이므로 Go로 애플리케이션을 개발할 때만 유용합니다.
• !Kafka나 RabbitMQ와 같은 각 Pub/Sub 백엔드는 별도의 모듈로 제공되므로 직접 추가해야 합니다.
• !벤치마크 수치는 대략적인 추정치이며 설정에 따라 크게 달라집니다.

토픽

자주 묻는 질문

watermill은(는) 무엇인가요?

Kafka, RabbitMQ, NATS, SQL 등에서 통일된 Publisher/Subscriber 인터페이스를 제공해 이벤트 기반 애플리케이션을 구축할 수 있는 Go 라이브러리입니다. Watermill은 메시지 스트림을 다루기 위한 Go 라이브러리입니다. 이벤트 기반 애플리케이션과 이벤트 소싱, CQRS, 사가, 메시지를 통한 RPC 같은 패턴을 대상으로 합니다. 핵심 추상화는 메시지를 받아 새 메시지나 오류를 반환하는 핸들러이며, 미들웨어가 다음 처리 과정을 결정합니다.

watermill은(는) 무료로 사용할 수 있나요? 라이선스는 무엇인가요?

watermill은(는) MIT 라이선스의 오픈소스입니다. 상업용 제품에 사용하기 전에 라이선스 조건을 확인하세요.

watermill은(는) 아직 유지보수되고 있나요?

6개월 이내 업데이트. watermill의 마지막 커밋은 2026년 8월 25일입니다.

watermill은(는) 어디에 사용할 수 있나요?

컴포넌트 간 메시지를 주고받는 이벤트 기반 서비스 구축 Go에서 이벤트 소싱 또는 CQRS 읽기 모델 구현 사가를 사용해 장기 실행 워크플로 조정 애플리케이션 로직을 다시 작성하지 않고 메시지 브로커 전환

watermill는 어떻게 설치하나요?

Watermill 라이브러리 모듈을 설치하세요: go get github.com/ThreeDotsLabs/watermill 공식 사이트의 Quickstart 가이드를 따라 첫 앱을 작성하세요

watermill은(는) 어디서 받을 수 있나요?

소스 코드와 설치 방법은 GitHub에 있습니다: https://github.com/ThreeDotsLabs/watermill