Affinity Dispatcher is a high-performance, low-latency message routing framework in Java. It routes messages to workers based on key affinity and supports multiple key types.

• Overview
• Key Components

The dispatcher uses a multiply-high scaling algorithm to map hash codes to routing nodes efficiently.

✨ Features:

• Lock-free internal channels (SPSC / MPSC)
• Configurable worker count & routing nodes
• Branchless and consistent key routing
• Low-latency message handling
• Atomic state management (started, non-started, terminated)

Main dispatcher for routing messages to workers.

Supports: int, long, String, byte[] keys

Important Methods:

• dispatch(String key, T value)
• dispatch(int key, T value)
• dispatch(long key, T value)
• dispatch(byte[] key, T value)
• start() ✅
• shutdown() 🛑

Worker thread consuming messages from its channel.

Routing table node holding a reference to a worker and publishing messages.

Internal message queue:

• SPSC – Single-producer, single-consumer
• MPSC – Multi-producer, single-consumer

Handler<Object> handler = (workerName, value) -> {
    System.out.println("Handled by " + workerName + ": " + value);
};
AffinityDispatcher<Object> dispatcher = new AffinityDispatcher<>("test", handler, DefaultHashCodeProvider.INSTANCE, Config.builder().build());
dispatcher.start();

for (int i = 0; i < 10_000_000; i++) {
    dispatcher.dispatch(UUID.randomUUID().toString(), i);
}