| <!-- |
| ▄▄▄ ██▓███ ▄▄▄ ▄████▄ ██░ ██ ▓█████ ██▓ ▄████ ███▄ █ ██▓▄▄▄█████▓▓█████ |
| ▒████▄ ▓██░ ██▒▒████▄ ▒██▀ ▀█ ▓██░ ██▒▓█ ▀ ▓██▒ ██▒ ▀█▒ ██ ▀█ █ ▓██▒▓ ██▒ ▓▒▓█ ▀ |
| ▒██ ▀█▄ ▓██░ ██▓▒▒██ ▀█▄ ▒▓█ ▄ ▒██▀▀██░▒███ ▒██▒▒██░▄▄▄░▓██ ▀█ ██▒▒██▒▒ ▓██░ ▒░▒███ |
| ░██▄▄▄▄██ ▒██▄█▓▒ ▒░██▄▄▄▄██ ▒▓▓▄ ▄██▒░▓█ ░██ ▒▓█ ▄ ░██░░▓█ ██▓▓██▒ ▐▌██▒░██░░ ▓██▓ ░ ▒▓█ ▄ |
| ▓█ ▓██▒▒██▒ ░ ░ ▓█ ▓██▒▒ ▓███▀ ░░▓█▒░██▓░▒████▒ ░██░░▒▓███▀▒▒██░ ▓██░░██░ ▒██▒ ░ ░▒████▒ |
| ▒▒ ▓▒█░▒▓▒░ ░ ░ ▒▒ ▓▒█░░ ░▒ ▒ ░ ▒ ░░▒░▒░░ ▒░ ░ ░▓ ░▒ ▒ ░ ▒░ ▒ ▒ ░▓ ▒ ░░ ░░ ▒░ ░ |
| ▒ ▒▒ ░░▒ ░ ▒ ▒▒ ░ ░ ▒ ▒ ░▒░ ░ ░ ░ ░ ▒ ░ ░ ░ ░ ░░ ░ ▒░ ▒ ░ ░ ░ ░ ░ |
| ░ ▒ ░░ ░ ▒ ░ ░ ░░ ░ ░ ▒ ░░ ░ ░ ░ ░ ░ ▒ ░ ░ ░ |
| ░ ░ ░ ░░ ░ ░ ░ ░ ░ ░ ░ ░ ░ ░ ░ ░ |
| --> |
| |
| <!-- |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you under the Apache License, Version 2.0 (the |
| "License"); you may not use this file except in compliance |
| with the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, |
| software distributed under the License is distributed on an |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| KIND, either express or implied. See the License for the |
| specific language governing permissions and limitations |
| under the License. |
| --> |
| |
| <!DOCTYPE html> |
| <html lang="en"> |
| <head> |
| <link rel="canonical" href="https://ignite.apache.org/features/messaging.html" /> |
| <meta charset="utf-8"> |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> |
| <meta http-equiv="Cache-Control" content="no-cache, no-store, must-revalidate" /> |
| <meta http-equiv="Pragma" content="no-cache" /> |
| <meta http-equiv="Expires" content="0" /> |
| <title>Distributed Messaging & Events - Apache Ignite</title> |
| <!--#include virtual="/includes/styles.html" --> |
| |
| |
| </head> |
| <body> |
| <!--#include virtual="/includes/header.html" --> |
| <article> |
| <header> |
| <div class="container"> |
| <h1>Distributed <strong>Messaging and Events</strong></h1> |
| </div> |
| </header> |
| <div class="container"> |
| |
| <p> |
| Apache Ignite® provides <b>high-performance cluster-wide messaging</b> functionality to exchange data via publish-subscribe and direct point-to-point communication models. Messages can be exchanged in an ordered or unordered fashion. Ordered messages are slightly slower, but when used, Ignite guarantees that messages will be received in the same order they were sent. |
| </p> |
| |
| <p> Ignite <b>distributed events</b> functionality allows applications to receive notifications when a variety of events occur in the distributed grid environment. You can automatically get notified for task executions, |
| read, write or query operations occurring on local or remote nodes within the cluster. |
| Event notifications can also be grouped together and sent in batches or timely intervals. |
| </p> |
| |
| <h2>Code Examples:</h2> |
| <!-- Nav tabs --> |
| <ul id="messaging-examples" class="nav nav-tabs"> |
| <li><a class="active" href="#messaging-example-ordered" aria-controls="home" data-toggle="tab">Ordered Messaging</a></li> |
| <li><a href="#messaging-example-unordered" aria-controls="profile" data-toggle="tab">Unordered Messaging</a></li> |
| <li><a href="#events-example-local" aria-controls="profile" data-toggle="tab">Local Events</a></li> |
| <li><a href="#events-example-remote" aria-controls="profile" data-toggle="tab">Remote Events</a></li> |
| </ul> |
| |
| <!-- Tab panes --> |
| <div class="tab-content"> |
| <div class="tab-pane active" id="messaging-example-ordered"> |
| <pre class="line-numbers"><code class="language-java"> |
| Ignite ignite = Ignition.ignite(); |
| |
| IgniteMessaging rmtMsg = ignite.message(ignite.cluster().forRemotes()); |
| |
| // Add listener for ordered messages on all remote nodes. |
| rmtMsg.remoteListen("MyOrderedTopic", (nodeId, msg) -> { |
| System.out.println("Received ordered message [msg=" + msg + ", from=" + nodeId + ']'); |
| |
| return true; // Return true to continue listening. |
| }); |
| |
| // Send ordered messages to remote nodes. |
| for (int i = 0; i < 10; i++) |
| rmtMsg.sendOrdered("MyOrderedTopic", Integer.toString(i), 0); |
| </code></pre> |
| </div> |
| <div class="tab-pane" id="messaging-example-unordered"> |
| <pre class="line-numbers"><code class="language-java"> |
| Ignite ignite = Ignition.ignite(); |
| |
| IgniteMessaging rmtMsg = ignite.message(ignite.cluster().forRemotes()); |
| |
| // Add listener for unordered messages on all remote nodes. |
| rmtMsg.remoteListen("MyUnOrderedTopic", (nodeId, msg) -> { |
| System.out.println("Received unordered message [msg=" + msg + ", from=" + nodeId + ']'); |
| |
| return true; // Return true to continue listening. |
| }); |
| |
| // Send unordered messages to remote nodes. |
| for (int i = 0; i < 10; i++) |
| rmtMsg.send("MyUnOrderedTopic", Integer.toString(i)); |
| </code></pre> |
| </div> |
| <div class="tab-pane" id="events-example-local"> |
| <pre class="line-numbers"><code class="language-java"> |
| Ignite ignite = Ignition.ignite(); |
| |
| // Local listener that listenes to local events. |
| IgnitePredicate<CacheEvent> locLsnr = evt -> { |
| System.out.println("Received local event [evt=" + evt.name() + "]"); |
| |
| return true; // Continue listening. |
| }; |
| |
| // Subscribe to specified cache events occuring on local node. |
| ignite.events().localListen(locLsnr, |
| EventType.EVT_CACHE_OBJECT_PUT, |
| EventType.EVT_CACHE_OBJECT_REMOVED); |
| |
| // Get an instance of named cache. |
| final IgniteCache<Integer, String> cache = ignite.cache("cacheName"); |
| |
| // Generate cache events. |
| for (int i = 0; i < 20; i++) |
| cache.put(i, Integer.toString(i)); |
| </code></pre> |
| </div> |
| <div class="tab-pane" id="events-example-remote"> |
| <pre class="line-numbers"><code class="language-java"> |
| Ignite ignite = Ignition.ignite(); |
| |
| // Get an instance of named cache. |
| final IgniteCache<Integer, String> cache = ignite.jcache("cacheName"); |
| |
| // Sample remote filter which only accepts events for keys |
| // that are greater than or equal to 10. |
| IgnitePredicate<CacheEvent> rmtLsnr = evt -> { |
| System.out.println("Received remote event [evt=" + evt.<Integer>key() >= 10 + "]"); |
| |
| return true; // Continue listening. |
| }; |
| |
| // Subscribe to specified cache events on all nodes that have cache running. |
| ignite.events(ignite.cluster().forCacheNodes("cacheName")).remoteListen(null, rmtLsnr, |
| EventType.EVT_CACHE_OBJECT_PUT, |
| EventType.EVT_CACHE_OBJECT_REMOVED); |
| |
| // Generate cache events. |
| for (int i = 0; i < 20; i++) |
| cache.put(i, Integer.toString(i)); |
| </code></pre> |
| </div> |
| </div> |
| |
| |
| <h2>GitHub Examples:</h2> |
| <p> |
| Also see <a href="https://github.com/apache/ignite/tree/master/examples/src/main/java/org/apache/ignite/examples/messaging" target="github">messaging examples</a>available on GitHub. |
| </p> |
| |
| |
| <h2>Messaging & Events Features</h2> |
| <table class="table table-bordered table-striped" name="Messaging Features"> |
| <thead> |
| <tr> |
| <th width="35%" class="left">Feature</th> |
| <th>Description</th> |
| </tr> |
| </thead> |
| <tbody> |
| <tr> |
| <td class="left">Topic Based Messaging</td> |
| <td> |
| <p> |
| Ignite distributed messaging allows for topic based cluster-wide communication between all nodes. |
| </p> |
| <div class="page-links"> |
| <a href="https://apacheignite.readme.io/docs/messaging" target="docs">Docs for this feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| <tr> |
| <td class="left">Point-to-Point Messaging</td> |
| <td> |
| <p> |
| Ignite messages can be sent to either a group of nodes or to an individual node. |
| </p> |
| <div class="page-links"> |
| <a href="http://apacheignite.readme.io/docs/messaging" target="docs">Docs for this Feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| <tr> |
| <td class="left">Ordered vs. Unordered</td> |
| <td> |
| <p> |
| Ignite supports ordered and unordered messages. Ordered messages are slightly slower, |
| but when used, Ignite guarantees that messages will be received in the same order they |
| were sent. |
| </p> |
| <div class="page-links"> |
| <a href="http://apacheignite.readme.io/docs/messaging" target="docs">Docs for this Feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| <tr> |
| <td class="left">Event Notifications</td> |
| <td> |
| <p> |
| Ignite distributed events functionality allows applications to receive notifications when a variety of events occur within the cluster. |
| </p> |
| <div class="page-links"> |
| <a href="https://apacheignite.readme.io/docs/events" target="docs">Docs for this feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| <tr> |
| <td class="left">Local vs. Remote Events</td> |
| <td> |
| <p> |
| Applications can get notified for task executions, read, write or query operations occurring on local or remote nodes within the cluster. |
| </p> |
| <div class="page-links"> |
| <a href="https://apacheignite.readme.io/docs/events" target="docs">Docs for this feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| <tr> |
| <td class="left">Automatic Batching</td> |
| <td> |
| <p> |
| Event notifications can be grouped together and sent in batches or timely intervals. |
| </p> |
| <div class="page-links"> |
| <a href="https://apacheignite.readme.io/docs/automatic-batching" target="docs">Docs for this feature <i class="fa fa-angle-double-right"></i></a> |
| </div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| </article> |
| |
| <!--#include virtual="/includes/footer.html" --> |
| |
| <!--#include virtual="/includes/scripts.html" --> |
| </body> |
| </html> |
