Cluster Counter
In Infinispan 9.1 we introduce the clustered counters. It is a counter distributed and shared among all nodes in the cluster and today we are going to know more about it.
Installation
To use a counter in your Infinispan cluster, first you have to add the maven dependency to your project. As you can see, it is simple as doing:
After adding the module, you can retrieve the CounterManager and start creating and using counters.
CounterManager
Each CounterManager is associated to a CacheManager. But, before showing how to use it, first we have some configuration to be done.
There are two attributes that you can configure: The num-owner - that represents the number of copies of the counter’s value in a cluster; and the reliability - that represents the behavior of the counters in case of partitions.
Below, is the configuration example with their default values. XML:
Programmatically:
Then, you can retrieve the CounterManager from the CacheManager, as shown below, and start using the counters!
Counter
A counter is identified by its name. Also, it is initialized with an initial value (by default 0) and it can be persisted, if the value needs to survive a cluster restart.
There are 2 types of counters: strong and weak counters.
Strong Counters
The strong counter provides higher consistency. Its value is known during the update and its updates are applied atomically. This allows to set boundaries and provides conditional operation (as compare-and-set).
Configuration
A strong counter can be configured in the configuration file or programmatically. They can be also created dynamically at runtime. Below shows us how it can be done:
XML:
Programmatically:
Runtime:
Use Case
The strong counter fits the following uses cases:
-
Global Id Generator
Due to its strong consistency, it can be used as a global identifier generator, as in the example below:
-
Rate Limiter
If bounded, it can be used as a simple rate limiter. Just don’t forget to invoke reset()…
-
Simply count "stuff"
Well, it is a counter after all…
Weak Counters
The weak counter provides eventual consistency and its value is not known during updates. It provides faster writes when comparing with the strong counter.
Configuration
As in strong counter, the weak counter can be configure its name and its initial value. In addition, a concurrency-level can be configure to set the number of concurrent updates that can be handled in parallel. Below shows us how to configure it:
XML:
Programatically:
Runtime:
Use Case
The main use case for the weak counter includes all scenarios where its value isn’t needed while updating the counter. For example, it can be used to count the number of visits to some resource:
For more information, take a look at the documentation. If you have any feedback, or would like to request some new features, or found some issue, let us know via the forum, issue tracker or the #infinispan channel on Freenode.
Get it, Use it, Ask us!
We’re hard at work on new features, improvements and fixes, so watch this space for more announcements!Please, download and test the latest release.
The source code is hosted on GitHub. If you need to report a bug or request a new feature, look for a similar one on our GitHub issues tracker. If you don’t find any, create a new issue.
If you have questions, are experiencing a bug or want advice on using Infinispan, you can use GitHub discussions. We will do our best to answer you as soon as we can.
The Infinispan community uses Zulip for real-time communications. Join us using either a web-browser or a dedicated application on the Infinispan chat.
