DISCLAIMER: The codebase is very much a work in progress and feature incomplete. DO NOT USE IN PRODUCTION
ZeroMQ is a high-performance asynchronous messaging library that provides many popular messaging patterns for many transport types. They look and feel like Berkeley style sockets, but are fault tolerant and easier to use. This project aims to provide a native rust alternative to the reference implementation, and leverage Rust's async ecosystem.
A basic ZMTP implementation is working, but is not yet fully compliant to the spec. Integration tests against the reference implementation are also missing. External APIs are still subject to change - there are no semver or stability guarantees at the moment.
We plan to support most of the basic ZMQ sockets. The current list is as follows:
- TCP
- IPC (unix only)
We plan to support most of the basic ZMQ messaging patterns. The current list is as follows:
- Request/Response (REQ, REP, DEALER, ROUTER)
- Publish/Subscribe (PUB, SUB)
- Pipeline (PUSH, PULL)
See the examples for some ways to get up and running quickly. You can also generate the documentation by doing cargo doc --open
on the source code.
The project currently supports both tokio
and async-std
, controllable via feature flags. tokio
is used by default. See the section about feature flags for more info.
Feature flags provide a way to customize the functionality provided by this library. Refer to the cargo guide for more info.
Features:
- (default)
tokio-runtime
: Usetokio
as your async runtime. async-std-runtime
: Useasync-std
as your async runtime.- (default)
all-transport
: Enable all the*-transport
flags ipc-transport
: Enable IPC as a transport mechanismtcp-transport
: Enable TCP as a transport mechanism
Contributions are welcome! See our issue tracker for a list of the things we need help with.
You can ask quesions in our Discord channel - https://discord.gg/pFXSqWtjQT