Я пытаюсь реализовать ограничитель скорости с помощью Bucket4j и Infinispan. Ниже приведен код, который я использую для хранения объектов LockFreeBucket в кеше Infinispan:
public boolean isRateLimited(String key) {
Bucket bucket = cacheManager.getCache("rate-limiter").get(key,
Bucket.class);
if (bucket == null) {
bucket = bucketSupplier.get();
Cache cache = cacheManager.getCache("rate-limiter");
cache.put(key, bucket);
}
return !bucket.tryConsume(1);
}
Когда он пытается поместить ключ, т.е. кэш.пут(ключ, ведро), я получаю исключение как org.infinispan.client.hotrod.Exceptions.HotRodClientException:: Невозможно маршалировать объект типа [io.github.bucket4j.local.LockFreeBucket]] с основной причиной
java.io.NotSerializableException: io.github.bucket4j.local.LockFreeBucket
И ниже моя конфигурация RemoteCacheManager
@Bean
public RemoteCacheManager getRemoteCacheManager() {
ConfigurationBuilder configurationBuilder = new ConfigurationBuilder();
configurationBuilder
.addServer()
.host("somehost")
.port(11222)
.marshaller(new JavaSerializationMarshaller())
.addJavaSerialWhiteList("io.github.bucket4j.*")
.security()
.ssl()
.sniHostName("infinispan")
.trustStoreFileName("./cacerts 2")
.trustStorePassword("changeit".toCharArray())
.authentication()
.username("some")
.password("somepassword")
.addContextInitializer(new CreateProtoImpl())
.clientIntelligence(ClientIntelligence.BASIC);
return new RemoteCacheManager(configurationBuilder.build());
}
Подробнее здесь: https://stackoverflow.com/questions/785 ... n-bucket4j
