Untitled

import java.util.SortedMap;
import java.util.TreeMap;
import java.io.*;
import java.util.*; 

public class ConsistentHashing {
    private final SortedMap<Integer, String> ring = new TreeMap<>();
    private final int numberOfReplicas;

    public ConsistentHashing(int numberOfReplicas) {
        this.numberOfReplicas = numberOfReplicas;
    }

    public void addServer(String serverName) {
        for (int i = 0; i < numberOfReplicas; i++) {
            int hash = (serverName + i).hashCode();
            ring.put(hash, serverName);
        }
    }

    public void removeServer(String serverName) {
        for (int i = 0; i < numberOfReplicas; i++) {
            int hash = (serverName + i).hashCode();
            ring.remove(hash);
        }
    }

    public String getServer(String key) {
        if (ring.isEmpty()) {
        	System.out.println("There is no available servers currently.");
            return null;
        }
        int hash = key.hashCode();
        System.out.println("Key: " + key + " Hash: " + String.valueOf(hash));
        SortedMap<Integer, String> tailMap = ring.tailMap(hash);
        if (tailMap.isEmpty()) {
            return ring.get(ring.firstKey());
        }

        return tailMap.get(tailMap.firstKey());
    }

    public static void main(String[] args) {
        ConsistentHashing consistentHashing = new ConsistentHashing(2);

        // Add worker servers
        consistentHashing.addServer("112.55.66.68");
        consistentHashing.addServer("166.22.23.36");

        // Simulate distributing traffic
        String[] keys = {"Key1", "Key2", "SomethingDifferent", "AnotherTesting", "RandomTesting"};

        for (String key : keys) {
            String server = consistentHashing.getServer(key);
            System.out.println("Key: " + key + " -> Server: " + server);

            // then we can send the work to the selected server
        }
    }
}