node-service-discovery

    1.0.2 • Public • Published

    Build Status

    Service Discovery module for nodejs built on Zookeeper

    This is an extension to the nicely built Zoologist module. This also enables dynamic service registration and de-registration with ZK. It has support for watchers and periodic polling on Zookeeper to get the latest node data. Has support for healthchecks so you can safely take the nodes Out of Rotation(OOR) and bring Back In Rotation(BIR) and it will be removed from clients list.

    Getting started

    1. Start the client. Client emits 'connected' event. You can listen to this if required
    2. Create a serviceInstance which will be your current node. Add healthChecks to it to enable OOR, BIR support
    3. Create a serviceDiscovery instance and register your serviceInstance on ZK. Also define the refresh interval for polling dependent services from ZK.
    4. Create instance providers to get the dependent services from ZK. It will automatically add watcher to it.
    5. Get instance using instance providers.

    Note:

    1. Don't save a node. The getInstance query is extremely fast and in-memory. It doesn't make any remote calls

    Data Model

    Following data is stored on ZK path (/basePath/serviceName/HOST:PORT)

    {
        "host": "localhost",
        "port": 31299,
        "nodeData": {
            "environment": "stage"
        },
        "healthcheckStatus": "healthy",
        "lastUpdatedTimeStamp": 1478246554601
    }

    Health Check (Optional)

    Define a healthCheck. It should contain isHealthy() method. You can add an array of healthChecks if required

    var healthCheck = function () {
                    return {
                        isHealthy: function () {
                            return true; //add logic here for returning healthy/unhealthy status
                        }
                    }};

    Installation

    npm install node-service-discovery --save
    

    Examples

    Service Discovery

    'use strict';
     
    var Ranger                  = require('node-service-discovery').Ranger;
    var ServiceInstanceBuilder  = require("node-service-discovery").ServiceInstanceBuilder;
    var ServiceDiscoveryBuilder = require('node-service-discovery').ServiceDiscoveryBuilder;
     
    //Create a Ranger Client
    var rangerClient = Ranger.newClient(process.env.ZK_CONNECTION_STRING || '127.0.0.1:2181');
     
    /** start emits 'connected' event. You can initialize following things after the event
     *  Eg: rangerClient.once('connected') { //initialize following code }
     */
    rangerClient.start();
     
     
    /**
     * Create the Service Discovery Instance
     *
     * refreshInterval is the interval to check for the updation of nodes in ZK.
     */
    var serviceDiscovery = ServiceDiscoveryBuilder
            .builder()
            .client(rangerClient)
            .serviceInstance(serviceInstance)
            .basePath('services')
            .refreshInterval(5000)
            .build();
     
    // Create the instance provider (selectionStrategy: 'RoundRobin' or 'Random')
    var instanceProvider = serviceDiscovery
            .instanceProviderBuilder()
            .serviceName('dependent-service')
            .selectionStrategy('RoundRobin')
            .build()
     
    //init the provider, it adds watcher, adds periodic polling and gets instance data for first time
    instanceProvider.init(function(error) {
        //check for error here
    });
     
    // Get an instance. The returned value will have 'data' model specified above
    instanceProvider.getInstance();

    Service Registration

     
    'use strict';
     
    var Ranger                  = require('node-service-discovery').Ranger;
    var ServiceInstanceBuilder  = require("node-service-discovery").ServiceInstanceBuilder;
    var ServiceDiscoveryBuilder = require('node-service-discovery').ServiceDiscoveryBuilder;
     
    //Create a Ranger Client
    var rangerClient = Ranger.newClient(process.env.ZK_CONNECTION_STRING || '127.0.0.1:2181');
     
    /** start emits 'connected' event. You can initialize following things after the event
     *  Eg: rangerClient.once('connected') { //initialize following code }
     */
    rangerClient.start();
     
    /**
     * Register a Service
     *
     * process.env.environment is whatever is the environment you are using
     * Additionally, you can also bind the health-checks with the service instance (healthcheck is optional)
     */
    var serviceInstance = ServiceInstanceBuilder
            .builder()
            .host("localhost")
            .port(8080) //integer
            .environment(process.env.environment || 'development')
            .healthChecks([healthCheck])
            .name('my-service')
            .build();
     
    serviceDiscovery.registerService(function(error) {
        //check for error
    });

    Health Check change propagation

     
    'use strict';
     
    /* Register service using above example */
     
    /** Emit following event on serviceDiscovery instance when health of you app changes on OOR/BIR
     * This will update the correct status for serviceInstance in Zookeeper
     * isHealthy() method mentioned above should return corresponding value after health status change
     */
     
    serviceDiscovery.emit('healthCheckChange');
     
     

    Install

    npm i node-service-discovery

    DownloadsWeekly Downloads

    2

    Version

    1.0.2

    License

    BSD-3-Clause

    Last publish

    Collaborators

    • umangkedia