Cluster


Overview


AKA: Running Actionhero in a Cluster

Actionhero can be run either as a solitary server or as part of a cluster. You can add or remove nodes from the cluster without fear of data loss or task duplication.


Cache


Using a redis backend, Actionhero nodes share memory objects (using the cache) and have a common queue for tasks. This means that all peers will have access to all data stored in the cache. The task system also becomes a common queue which all peers will work on draining. There should be no changes required to deploy your application in a cluster.

Keep in mind that many clients/server can access a cached value simultaneously, so build your actions carefully not to have conflicting state. You can learn more about the cache methods here. You can also review recommendations about Production Redis configurations.


RPC


In version 9.0.0, Actionhero introduced Remote Procedure Calls, or RPC for short. You can call an RPC method to be executed on all nodes in your cluster or just a node which holds a specific connection. You can call RPC methods with the redis.doCluster method. If you provide the optional callback, you will get the first response back (or a timeout error). RPC calls are invoked with redis.doCluster(method, args, connectionId, waitForResponse).

For example, if you wanted all nodes to log a message, you would do: redis.doCluster('api.log', ["hello from " + api.id])

If you wanted the node which holds connection abc123 to change their authorized status (perhaps because your room authentication relies on this), you would do:

// This will ask all nodes connected to the cluster if they have connection #\`abc123\`
//   and if they do, run \`connection.set('auth', true)\` on it
await connections.apply("abc123", "set", ["auth", true]);

The RPC system is used heavily by Chat.

Two options have been added to the config/redis.ts config file to support this: config.general.channel ( Which channel to use on redis pub/sub for RPC communication ) and config.general.rpcTimeout ( How long to wait for an RPC call before considering it a failure )

WARNING

RPC calls are authenticated against config.general.serverToken and communication happens over redis pub/sub. BE CAREFUL, as you can call any method within the API namespace on an Actionhero server, including shutdown() and read any data on that node.


Connections


Some special RPC tools have been added so that you can interact with connections across multiple nodes. Specifically the chat sub-system needs to be able to boot and move connections into rooms, regardless of which node they are connected to.

Actionhero has exposed connections.apply which can be used to retrieve data about and modify a connection on any node.

connections.apply(connectionId, method, args)

  • Learn More
  • connectionId is required
  • Both method and args can be ignored if you just want to retrieve information about a connection, IE: const connectionDetails = await api.connections.apply(connectionId)

PubSub


import { redis } from "actionhero";

// To subscribe to messages, add a callback for your \`messageType\`, IE:
redis.subscriptionHandlers["myMessageType"] = function (message) {
  // do stuff
};

// send a message
const payload = {
  messageType: "myMessageType",
  serverId: api.id,
  serverToken: config.general.serverToken,
  message: "hello!",
};

await api.redis.publish(payload);

Actionhero also uses redis to allow for pub/sub communication between nodes.

You can broadcast and receive messages from other peers in the cluster:

redis.publish(payload)

  • Learn More
  • payload must contain:
    • messageType : the name of your payload type,
    • serverId : api.id,
    • serverToken : config.general.serverToken,

    Solutions

    Actionhero was built from the ground up to include all the features you expect from a modern API framework.

    Open Source


    The Actionhero server is open source, under the Apache-2 license


    Actionhero runs on Linux, OS X, and Windows


    You always have access to the Actionhero team via Slack and Github



    Premium Training & Review


    We provide support for corporate & nonprofit customers starting at a flat rate of $200/hr. Our services include:


    • Remote training for your team
    • Code Reviews
    • Best Practices Audits
    • Custom plugin & Feature Development

    We have packages appropriate for all company sizes. Contact us to learn more.


    Premium Training & Review


    We provide support for corporate & nonprofit customers starting at a flat rate of $200/hr. Our services include:


    • Remote training for your team
    • Code Reviews
    • Best Practices Workshops
    • Custom plugin & Feature Development

    We have packages appropriate for all company sizes. Contact us to learn more.


    Enterprise


    For larger customers in need of a support contract, we offer an enterprise plan including everything in the Premium plan plus:


    • 24/7 access to core members of the Actionhero Team
    • Emergency response packages
    • Deployment support
    • ...and custom development against Actionhero’s core as needed.