base on 🚀Apache RocketMQ build in Rust🦀. Faster, safer, and with lower memory usage. # rocketmq-rust  [](https://crates.io/crates/rocketmq-rust) [](https://docs.rs/rocketmq-rust) [](https://github.com/mxsm/rocketmq-rust/actions) [![CodeCov][codecov-image]][codecov-url]     Welcome to [Apache Rocketmq](https://github.com/apache/rocketmq) Rust implementation. **RocketMQ-Rust(Rust library)** is a reimplementation of the Apache RocketMQ message middleware in the Rust language. This project aims to provide Rust developers with a high-performance and reliable message queue service, making full use of the features of the Rust language.  ### RocketMQ-Rust Features - **Rust Language Advantages:** Leveraging the benefits of Rust, such as memory safety, zero-cost abstractions, and high concurrency performance, RocketMQ-Rust offers an efficient and reliable message middleware. - **Asynchronous and Non-blocking Design:** RocketMQ-Rust takes full advantage of Rust's asynchronous programming capabilities, adopting a non-blocking design that supports high-concurrency message processing. - **Ecosystem Integration:** As part of the Rust ecosystem, RocketMQ-Rust integrates well with other libraries and frameworks within the Rust ecosystem, providing flexible integration options for developers. - **Cross-platform Support:** RocketMQ-Rust supports multiple platforms, including Linux, Windows, macOS, making it convenient for use in different environments. ## Roadmap ### **🔊Note**: ***[Rocketmq-rust](https://github.com/mxsm/rocketmq-rust)*** is implemented based on ***[Apache Rocketmq release-5.3.1📌](https://github.com/apache/rocketmq/tree/release-5.3.1)***, with subsequent feature enhancements to follow the updates of the version🚩.  🔊Release a new version every three months to fix issues. If there are major updates or new features, additional releases will be scheduled🍻. | 🔖Version | 🚩Release time | 🚧Remark | |-----------|----------------|------------| | 🔖v0.1.0 | 🚩2024-01-28 | Released🎉 | | 🔖v0.2.0 | 🚩2024-06-05 | Released🎉 | | 🔖v0.3.0 | 🚩2024-11-17 | Released🎉 | | 🔖v0.4.0 | 🚩2025-02-17 | 🚧 | | 🔖v0.5.0 | 🚩2025-05-17 | 🚧 | | 🔖v0.6.0 | 🚩2025-08-17 | 🚧 | | 🔖v0.7.0 | 🚩2025-11-17 | 🚧 | | 🔖v0.8.0 | 🚩2026-02-17 | 🚧 | | 🔖v0.9.0 | 🚩2026-05-17 | 🚧 | | 🔖.... | 🚩.... | 🚧... | ## Getting Started ### Requirements 1. rust toolchain MSRV is 1.75.(stable,nightly) ### Run name server **Run the following command to see usage：** - **windows platform** ```cmd cargo run --bin rocketmq-namesrv-rust -- --help RocketMQ Name server(Rust) Usage: rocketmq-namesrv-rust.exe [OPTIONS] Options: -p, --port <PORT> rocketmq name server port [default: 9876] -i, --ip <IP> rocketmq name server ip [default: 127.0.0.1] -h, --help Print help -V, --version Print version ``` - **Linux platform** ```shell $ cargo run --bin rocketmq-namesrv-rust -- --help RocketMQ Name server(Rust) Usage: rocketmq-namesrv-rust [OPTIONS] Options: -p, --port <PORT> rocketmq name server port [default: 9876] -i, --ip <IP> rocketmq name server ip [default: 127.0.0.1] -h, --help Print help -V, --version Print version ``` Run the following command to start the name server ```shell cargo run --bin rocketmq-namesrv-rust ``` ### Run Borker **Run the following command to see usage：** - **windows platform** ```shell cargo run --bin rocketmq-broker-rust -- --help RocketMQ Broker Server(Rust) Usage: rocketmq-broker-rust.exe [OPTIONS] Options: -c, --config-file <FILE> Broker config properties file -m, --print-important-config Print important config item -n, --namesrv-addr <IP> Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876] -p, --print-config-item Print all config item -h, --help Print help -V, --version Print version ``` - **Linux platform** ```shell $ cargo run --bin rocketmq-broker-rust -- --help RocketMQ Broker Server(Rust) Usage: rocketmq-broker-rust [OPTIONS] Options: -c, --config-file <FILE> Broker config properties file -m, --print-important-config Print important config item -n, --namesrv-addr <IP> Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876] -p, --print-config-item Print all config item -h, --help Print help -V, --version Print version ``` Run the following command to start the name server ```shell cargo run --bin rocketmq-broker-rust ``` ## Client how to send message First, start the RocketMQ NameServer and Broker services. - [**Send a single message**](https://github.com/mxsm/rocketmq-rust/blob/main/rocketmq-client/README.md#Send-a-single-message) - [**Send batch messages**](https://github.com/mxsm/rocketmq-rust/blob/main/rocketmq-client/README.md#Send-batch-messages) - [**Send RPC messages**](https://github.com/mxsm/rocketmq-rust/blob/main/rocketmq-client/README.md#Send-RPC-messages) [**For more examples, you can check here**](https://github.com/mxsm/rocketmq-rust/tree/main/rocketmq-client/examples) ## Modules The existing RocketMQ has the following functional modules: - [**Name Server**](https://github.com/mxsm/rocketmq-rust/tree/main/rocketmq-namesrv) - [**Broker**](https://github.com/mxsm/rocketmq-rust/tree/main/rocketmq-broker) - [**Store (Local Storage)**](https://github.com/mxsm/rocketmq-rust/tree/main/rocketmq-store) - **Controller (High Availability)** - [**Client (SDK)**](https://github.com/mxsm/rocketmq-rust/tree/main/rocketmq-client) - **Proxy** - **Tiered Store (Tiered Storage Module)** The specific functions of each module can be referred to in the [official RocketMQ documentation](https://github.com/apache/rocketmq/tree/develop/docs). The Rust implementation will be carried out sequentially in the following order. ## Contributing Contributions to code, issue reporting, and suggestions are welcome. The development of RocketMQ-Rust relies on the support of developers. Let's collaborate to advance Rust in the message middleware domain.  <a href="https://github.com/mxsm/rocketmq-rust/graphs/contributors"> <img src="https://contrib.rocks/image?repo=mxsm/rocketmq-rust&anon=1" /> </a> [](https://api.star-history.com/svg?repos=mxsm/rocketmq-rust&type=Date) ## License RocketMQ-Rust is licensed under the [Apache License 2.0](https://github.com/mxsm/rocketmq-rust/blob/main/LICENSE-APACHE) and [MIT license](https://github.com/mxsm/rocketmq-rust/blob/main/LICENSE-MIT) [codecov-image]: https://codecov.io/gh/mxsm/rocketmq-rust/branch/main/graph/badge.svg [codecov-url]: https://codecov.io/gh/mxsm/rocketmq-rust ", Assign "at most 3 tags" to the expected json: {"id":"12176","tags":[]} "only from the tags list I provide: [{"id":77,"name":"3d"},{"id":89,"name":"agent"},{"id":17,"name":"ai"},{"id":54,"name":"algorithm"},{"id":24,"name":"api"},{"id":44,"name":"authentication"},{"id":3,"name":"aws"},{"id":27,"name":"backend"},{"id":60,"name":"benchmark"},{"id":72,"name":"best-practices"},{"id":39,"name":"bitcoin"},{"id":37,"name":"blockchain"},{"id":1,"name":"blog"},{"id":45,"name":"bundler"},{"id":58,"name":"cache"},{"id":21,"name":"chat"},{"id":49,"name":"cicd"},{"id":4,"name":"cli"},{"id":64,"name":"cloud-native"},{"id":48,"name":"cms"},{"id":61,"name":"compiler"},{"id":68,"name":"containerization"},{"id":92,"name":"crm"},{"id":34,"name":"data"},{"id":47,"name":"database"},{"id":8,"name":"declarative-gui "},{"id":9,"name":"deploy-tool"},{"id":53,"name":"desktop-app"},{"id":6,"name":"dev-exp-lib"},{"id":59,"name":"dev-tool"},{"id":13,"name":"ecommerce"},{"id":26,"name":"editor"},{"id":66,"name":"emulator"},{"id":62,"name":"filesystem"},{"id":80,"name":"finance"},{"id":15,"name":"firmware"},{"id":73,"name":"for-fun"},{"id":2,"name":"framework"},{"id":11,"name":"frontend"},{"id":22,"name":"game"},{"id":81,"name":"game-engine "},{"id":23,"name":"graphql"},{"id":84,"name":"gui"},{"id":91,"name":"http"},{"id":5,"name":"http-client"},{"id":51,"name":"iac"},{"id":30,"name":"ide"},{"id":78,"name":"iot"},{"id":40,"name":"json"},{"id":83,"name":"julian"},{"id":38,"name":"k8s"},{"id":31,"name":"language"},{"id":10,"name":"learning-resource"},{"id":33,"name":"lib"},{"id":41,"name":"linter"},{"id":28,"name":"lms"},{"id":16,"name":"logging"},{"id":76,"name":"low-code"},{"id":90,"name":"message-queue"},{"id":42,"name":"mobile-app"},{"id":18,"name":"monitoring"},{"id":36,"name":"networking"},{"id":7,"name":"node-version"},{"id":55,"name":"nosql"},{"id":57,"name":"observability"},{"id":46,"name":"orm"},{"id":52,"name":"os"},{"id":14,"name":"parser"},{"id":74,"name":"react"},{"id":82,"name":"real-time"},{"id":56,"name":"robot"},{"id":65,"name":"runtime"},{"id":32,"name":"sdk"},{"id":71,"name":"search"},{"id":63,"name":"secrets"},{"id":25,"name":"security"},{"id":85,"name":"server"},{"id":86,"name":"serverless"},{"id":70,"name":"storage"},{"id":75,"name":"system-design"},{"id":79,"name":"terminal"},{"id":29,"name":"testing"},{"id":12,"name":"ui"},{"id":50,"name":"ux"},{"id":88,"name":"video"},{"id":20,"name":"web-app"},{"id":35,"name":"web-server"},{"id":43,"name":"webassembly"},{"id":69,"name":"workflow"},{"id":87,"name":"yaml"}]" returns me the "expected json"