base on Eclipse iceoryx2™ - true zero-copy inter-process-communication in pure Rust <!-- markdownlint-disable --> [](https://github.com/eclipse-iceoryx/iceoryx2/actions/workflows/build-test.yml?query=branch%3Amain++) [](https://cirrus-ci.com/github/eclipse-iceoryx/iceoryx2/main) [](https://codecov.io/gh/eclipse-iceoryx/iceoryx2?branch=main) [](benchmarks/README.md) [](CHANGELOG.md) [](https://crates.io/crates/iceoryx2) [](examples/) [](FAQ.md) [](https://gitter.im/eclipse/iceoryx) [](https://opensource.org/licenses/Apache-2.0) [](ROADMAP.md) <p align="center"> <img src="https://github.com/eclipse-iceoryx/iceoryx2/assets/56729169/3230a125-19e5-4e98-a752-da026a086782" width="50%"> </p> <!-- markdownlint-enable --> # iceoryx2 - Zero-Copy Lock-Free IPC Purely Written In Rust 1. [Introduction](#introduction) 2. [Documentation](#documentation) 3. [Performance](#performance) 4. [Getting Started](#getting-started) 1. [Publish Subscribe](#publish-subscribe) 2. [Events](#events) 3. [Custom Configuration](#custom-configuration) 5. [Supported Platforms](#supported-platforms) 6. [Language Bindings](#language-bindings) 7. [Commercial Support](#commercial-support) 8. [Thanks To All Contributors](#thanks-to-all-contributors) ## Introduction Welcome to iceoryx2, the efficient, and ultra-low latency inter-process communication middleware. This library is designed to provide you with fast and reliable zero-copy and lock-free inter-process communication mechanisms. So if you want to communicate efficiently between multiple processes or applications iceoryx2 is for you. With iceoryx2, you can: * Send huge amounts of data using a publish/subscribe, request/response (planned), pipeline (planned) or blackboard pattern (planned), making it ideal for scenarios where large datasets need to be shared. * Exchange signals through events, enabling quick and reliable signaling between processes. iceoryx2 is based on a service-oriented architecture (SOA) and facilitates seamless inter-process communication (IPC). It is all about providing a seamless experience for inter-process communication, featuring versatile messaging patterns. Whether you're diving into publish-subscribe, events, or the promise of upcoming features like request-response, pipelines, and blackboard, iceoryx2 has you covered. One of the features of iceoryx2 is its consistently low transmission latency regardless of payload size, ensuring a predictable and reliable communication experience. iceoryx2's origins can be traced back to [iceoryx](https://github.com/eclipse-iceoryx/iceoryx). By overcoming past technical debts and refining the architecture, iceoryx2 enables the modularity we've always desired. In the near future, iceoryx2 is poised to support at least the same feature set and platforms as [iceoryx](https://github.com/eclipse-iceoryx/iceoryx), ensuring a seamless transition and offering enhanced capabilities for your inter-process communication needs. So, if you're looking for lightning-fast, cross-platform communication that doesn't compromise on performance or modularity, iceoryx2 is your answer. ## Documentation The documentation can be found at: | language | documentation link | | :------: | ------------------------------------------: | | C | <https://iceoryx2.readthedocs.io> | | C++ | <https://iceoryx2.readthedocs.io> | | Rust | <https://docs.rs/iceoryx2/latest/iceoryx2/> | ## Performance ### Comparision Of Mechanisms  #### Benchmark-System * **CPU:** Intel i7 13700h * **OS:** Linux 6.10.10-arch1-1 #1 SMP PREEMPT_DYNAMIC * **Compiler:** * rustc 1.81.0 * gcc 14.2.1 20240910 ### Comparision Of Architectures  ## Getting Started ### Publish Subscribe This minimal example showcases a publisher sending the number 1234 every second, while a subscriber efficiently receives and prints the data. #### publisher.rs ```rust use core::time::Duration; use iceoryx2::prelude::*; const CYCLE_TIME: Duration = Duration::from_secs(1); fn main() -> Result<(), Box<dyn std::error::Error>> { let node = NodeBuilder::new().create::<ipc::Service>()?; let service = node.service_builder(&"My/Funk/ServiceName".try_into()?) .publish_subscribe::<usize>() .open_or_create()?; let publisher = service.publisher_builder().create()?; while node.wait(CYCLE_TIME).is_ok() { let sample = publisher.loan_uninit()?; let sample = sample.write_payload(1234); sample.send()?; } Ok(()) } ``` #### subscriber.rs ```rust use core::time::Duration; use iceoryx2::prelude::*; const CYCLE_TIME: Duration = Duration::from_secs(1); fn main() -> Result<(), Box<dyn std::error::Error>> { let node = NodeBuilder::new().create::<ipc::Service>()?; let service = node.service_builder(&"My/Funk/ServiceName".try_into()?) .publish_subscribe::<usize>() .open_or_create()?; let subscriber = service.subscriber_builder().create()?; while node.wait(CYCLE_TIME).is_ok() { while let Some(sample) = subscriber.receive()? { println!("received: {:?}", *sample); } } Ok(()) } ``` This example is a simplified version of the [publish-subscribe example](examples/rust/publish_subscribe/). You can execute it by opening two terminals and calling: **Terminal 1:** ```sh cargo run --example publish_subscribe_publisher ``` **Terminal 2:** ```sh cargo run --example publish_subscribe_subscriber ``` ### Events This minimal example showcases how push-notifications can be realized by using services with event messaging pattern between two processes. The `listener.rs` hereby waits for a notification from the `notifier.rs`. #### notifier.rs ```rust use core::time::Duration; use iceoryx2::prelude::*; const CYCLE_TIME: Duration = Duration::from_secs(1); fn main() -> Result<(), Box<dyn std::error::Error>> { let node = NodeBuilder::new().create::<ipc::Service>()?; let event = node.service_builder(&"MyEventName".try_into()?) .event() .open_or_create()?; let notifier = event.notifier_builder().create()?; let id = EventId::new(12); while node.wait(CYCLE_TIME).is_ok() { notifier.notify_with_custom_event_id(id)?; println!("Trigger event with id {:?} ...", id); } Ok(()) } ``` #### listener.rs ```rust use core::time::Duration; use iceoryx2::prelude::*; const CYCLE_TIME: Duration = Duration::from_secs(1); fn main() -> Result<(), Box<dyn std::error::Error>> { let node = NodeBuilder::new().create::<ipc::Service>()?; let event = node.service_builder(&"MyEventName".try_into()?) .event() .open_or_create()?; let listener = event.listener_builder().create()?; while node.wait(Duration::ZERO).is_ok() { if let Ok(Some(event_id)) = listener.timed_wait_one(CYCLE_TIME) { println!("event was triggered with id: {:?}", event_id); } } Ok(()) } ``` #### listener.rs (grabbing all events at once) ```rust use core::time::Duration; use iceoryx2::prelude::*; const CYCLE_TIME: Duration = Duration::from_secs(1); fn main() -> Result<(), Box<dyn std::error::Error>> { let node = NodeBuilder::new().create::<ipc::Service>()?; let event = node.service_builder(&"MyEventName".try_into()?) .event() .open_or_create()?; let listener = event.listener_builder().create()?; while node.wait(Duration::ZERO).is_ok() { listener.timed_wait_all( |event_id| { println!("event was triggered with id: {:?}", event_id); }, CYCLE_TIME, )?; } Ok(()) } ``` This example is a simplified version of the [event example](examples/rust/event/). You can execute it by opening two terminals and calling: **Terminal 1:** ```sh cargo run --example event_notifier ``` **Terminal 2:** ```sh cargo run --example event_listener ``` ### Custom Configuration It is possible to configure default quality of service settings, paths and file suffixes in a custom configuration file. For more details visit the [configuration directory](config/). ## Supported Platforms The support levels can be adjusted when required. | Operating System | State | Current Support Level | Target Support Level | | ---------------- | :------ | :-------------------: | -------------------: | | Android | planned | - | tier 1 | | FreeBSD | done | tier 2 | tier 1 | | FreeRTOS | planned | - | tier 2 | | iOS | planned | - | tier 2 | | Linux (x86_64) | done | tier 2 | tier 1 | | Linux (aarch64) | done | tier 2 | tier 1 | | Linux (32-bit) | done | tier 2 | tier 1 | | Mac OS | done | tier 2 | tier 2 | | QNX | planned | - | tier 1 | | VxWorks | planned | - | tier 1 | | WatchOS | planned | - | tier 2 | | Windows | done | tier 2 | tier 2 | * **tier 1** - All safety and security features are working. * **tier 2** - Works with a restricted security and safety feature set. * **tier 3** - Work in progress. Might compile and run or not. ## Language Bindings | Language | State | | -------- | ------: | | C / C++ | beta | | C# | planned | | Go | planned | | Java | planned | | Kotlin | planned | | Lua | planned | | Python | planned | | Swift | planned | | Zig | planned | ## Commercial Support <!-- prettier-ignore-start --> <!-- markdownlint-disable --> <table width="100%"> <tbody> <tr> <td align="center" valign="top" width="33%"> <a href="https://ekxide.io"> <img src="https://github.com/eclipse-iceoryx/iceoryx2/assets/56729169/c3ce8370-6cef-4c31-8259-93ddaa61c43e" alt="ekxide IO GmbH"/><br /> </a> <a href="mailto:[email protected]">[email protected]</a> </td> <td> <ul> <li>commercial extensions and tooling</li> <li>custom feature development</li> <li>training and consulting</li> <li>integration support</li> <li>engineering services around the iceoryx ecosystem</li> </ul> </td> </tr> </tbody> </table> <!-- markdownlint-restore --> <!-- prettier-ignore-end --> ## Thanks To All Contributors <!-- prettier-ignore-start --> <!-- markdownlint-disable --> <table> <tbody> <tr> <td align="center" valign="top" width="14.28%"> <a href="https://github.com/elfenpiff"> <img src="https://avatars.githubusercontent.com/u/56729169" width="120px;" alt="Christian »elfenpiff« Eltzschig"/><br /> _{<b>Christian »elfenpiff« Eltzschig</b>}</a></td> <td align="center" valign="top" width="14.28%"> <a href="https://github.com/elboberido"> <img src="https://avatars.githubusercontent.com/u/56729607" width="120px;" alt="Mathias »elBoberido« Kraus"/><br /> _{<b>Mathias »elBoberido« Kraus</b>}</a></td> <td align="center" valign="top" width="14.28%"> <a href="https://github.com/orecham"> <img src="https://avatars.githubusercontent.com/u/8487595" width="120px;" alt="»orecham«"/><br /> _{<b>»orecham«</b>}</a></td> <td align="center" valign="top" width="14.28%"> <a href="https://github.com/xieyuschen"> <img src="https://avatars.githubusercontent.com/u/52945328" width="120px;" alt="xieyuschen"/><br /> _{<b>»xieyuschen«</b>}</a></td> </tr> </tbody> </table> <!-- markdownlint-restore --> <!-- prettier-ignore-end --> ", Assign "at most 3 tags" to the expected json: {"id":"6037","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"