Watermill 一个用来构建事件驱动应用程序的Go库

Watermill

Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case.

Goals

Easy to understand.Universal - event-driven architecture, messaging, stream processing, CQRS - use it for whatever you need.Fast (see Benchmarks).Flexible with middlewares, plugins and Pub/Sub configurations.Resilient - using proven technologies and passing stress tests (see Stability).

Getting Started

Pick what you like the best or see in order:

Follow the Getting Started guide.See examples below.Read the full documentation: https://watermill.io/

Examples

Basic Your first app - start here!Realtime feedRouterMetricsCQRS with protobuf Pub/Subs usageThese examples are part of the Getting started guide and show usage of a single Pub/Sub at a time. Real-world examples Receiving webhooksSending webhooksSynchronizing DatabasesPersistent Event LogTransactional Events Complete projects NATS example with live code reloadingRabbitMQ, webhooks and Kafka integration

Background

Building distributed and scalable services is rarely as easy as some may suggest. There is a lot of hidden knowledge that comes with writing such systems. Just like you don't need to know the whole TCP stack to create a HTTP REST server, you shouldn't need to study all of this knowledge to start with building message-driven applications.

Watermill's goal is to make communication with messages as easy to use as HTTP routers. It provides the tools needed to begin working with event-driven architecture and allows you to learn the details on the go.

At the heart of Watermill there is one simple interface:

func(*Message) ([]*Message, error)

Your handler receives a message and decides whether to publish new message(s) or return an error. What happens next is up to the middlewares you've chosen.

You can find more about our motivations in our Introducing Watermill blog post.

Pub/Subs

All publishers and subscribers have to implement an interface:

type Publisher interface { Publish(topic string, messages ...*Message) error Close() error}type Subscriber interface { Subscribe(ctx context.Context, topic string) (<-chan *Message, error) Close() error}

Supported Pub/Subs:

AMQP Pub/Sub (github.com/ThreeDotsLabs/watermill-amqp)Google Cloud Pub/Sub (github.com/ThreeDotsLabs/watermill-googlecloud)HTTP Pub/Sub (github.com/ThreeDotsLabs/watermill-http)io.Reader/io.Writer Pub/Sub (github.com/ThreeDotsLabs/watermill-io)Kafka Pub/Sub (github.com/ThreeDotsLabs/watermill-kafka)NATS Pub/Sub (github.com/ThreeDotsLabs/watermill-nats)SQL Pub/Sub (github.com/ThreeDotsLabs/watermill-sql)

All Pub/Subs implementation documentation can be found in the documentation.

Contributing

Please check our contributing guide.

Stability

Watermill v1.0.0 has been released and is production-ready. The public API is stable and will not change without changing the major version.

To ensure that all Pub/Subs are stable and safe to use in production, we created a set of tests that need to pass for each of the implementations before merging to master. All tests are also executed in stress mode - that means that we are running all the tests 20x in parallel.

All tests are run with the race condition detector enabled (-race flag in tests).

Benchmarks

Initial tools for benchmarking Pub/Subs can be found in watermill-benchmark.

All benchmarks are being done on a single 16 CPU VM instance, running one binary and dependencies in Docker Compose.

These numbers are meant to serve as a rough estimate of how fast messages can be processed by different Pub/Subs. Keep in mind that the results can be vastly different, depending on the setup and configuration (both much lower and higher).

Here's the short version for message size of 16 bytes.

Support

If you didn't find the answer to your question in the documentation, feel free to ask us directly!

Please join us on the #watermill channel on the Gophers slack: You can get an invite here.

Every bit of feedback is very welcome and appreciated. Please submit it using the survey.

Why the name?

It processes streams!

License

MIT License

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。