hugheba-graaljs-ignite v1.0.0-RC9

hugheba-graaljs-ignite

Apache Ignite integration into Node.js running under GraalVM.

This module allows you to use an Apache Ignite in-memory cluster for caching, distributed messaging, grid computing and machine learning.

Quickstart

Install the Node.js module

$> npm install hugheba-graaljs-ignite

Run your Node.js application under GraalVM.

$> node \
      --jvm \
      --jvm.cp='./node_modules/hugheba-graaljs-ignite/lib/hugheba-graaljs-ignite-all.jar" \ 
      index.js
      

Apache Ignite

Apache Ignite is a memory-centric distributed database, caching, and processing platform for transactional, analytical, and streaming workloads delivering in-memory speeds at petabyte scale

For more info, see: https://ignite.apache.org

GraalVM

GraalVM is a universal virtual machine for running applications written in JavaScript, Python 3, Ruby, R, JVM-based languages like Java, Scala, Kotlin, and LLVM-based languages such as C and C++.

GraalVM removes the isolation between programming languages and enables interoperability in a shared runtime. It can run either standalone or in the context of OpenJDK, Node.js, Oracle Database, or MySQL.

For more info, see: https://www.graalvm.org/docs/

Version Dependencies

The IgniteBridge requires several Java dependencies.

This bundle provides two options for adding dependencies through the node --jvm.cp argument.

• hugheba-graaljs-ignite-all.jar : An all-in-one jar with with the dependencies below included.
• hugheba-graaljs-ignite.jar : A jar containing only module functionality and no dependences.

Manual Dependency Management

To use this plugin and supply your own dependencies, download the required jars and add them to a folder named lib the root of your project.

Modify the run command above to look like this:

$> node \
      --jvm \
      --jvm.cp="lib/*:./node_modules/hugheba-graaljs-ignite/lib/hugheba-graaljs-ignite.jar" \
      index.js

Usage

This module provides functionality to cluster multiple instances of a Node.Js application running under a GraalVM.

The IgniteBridge is the module's main class which provides simplified access to Ignite features detailed below.

Although the IgniteBridge covers most of Ignite's higher level functionality, direct access to the Ignite instance is still available.

Configuration

See test/resources/igniteConfig.js for more configuration examples.

var IgniteBridge = require('hugheba-graaljs-ignite');

var config = {
        connection: {
            ipFinder: 'TcpDiscoveryMulticastIpFinder', 
            addresses: ['127.0.0.1:47500..47509'],
            multicastGroup: '228.10.10.157', 
        },
        caches: {
            'default' : {
                cacheMode: 'PARTITIONED' 
            },
        },
};

var ib = new IgniteBridge(config);

Ignite Direct Access

The underlying Ignite instance can be accessed for more advanced configuration and functionality.

var ignite = ib.getIgnite();

Caches

Cluster wide shared caches.

var defaultCache = ib.getCache(config.caches[0].name),
cacheKey = 'cache_key_1';

// Cache Example
defaultCache.put(cacheKey, 'My Cache Data');
console.log('Cache returned ' + defaultCache.get(cacheKey));

Records

Records are similar to caches but are wired up to allow for listening to property changes.

This functionality can be extended to notify client UI's of state changes over WebSockets.

var bobRecord = ib.getRecord("users/bob");
bobRecord.subscribe('firstname', function(newVal) {
    console.log("users/bob firstname changed to " + newVal);
});
bobRecord.put('firstname', 'Bob');
bobRecord.put('firstname', 'Robert');
bobRecord.put('firstname', 'Bobby');

Counters

Counters allow for atomic increment/decrement operations across the cluster.

var counter = ib.getCounter('mycounter');
console.log("The current counter value is " + counter.incrementAndGet());

Pub/Sub

Cluster wide pub/sub functionality.

var eventBus = ib.getEventBus();
var topic = 'my_cluster_topic';

eventBus.subscribe(topic, function(message) {
    console.log('Topic ' + topic + ' received message: ' + message);
    console.log('Topic ' + topic + '.message: ' + JSON.parse(message).message);
});
eventBus.broadcast(topic, {
    status: true,
    code: 200,
    message: 'This object will be JSON serialized over the wire, and sent to every subscriber in the cluster.',
});

More examples

See module-node/test/test.js for more examples.