infinispan编组错误

Question

在dockerize spring boot应用程序中，我遇到了嵌入式infinispan编组的问题。此方法：

public  void incrementSmsSend( String key){

        AdvancedCache<String, DailySms> advancedCache=cacheManager.<String, DailySms>getCache("statistics-cache").getAdvancedCache() ;
        try {
            advancedCache.computeIfAbsentAsync("totalSms_"+key,s -> new DailySms(0L,null));

            advancedCache.getAdvancedCache().merge("totalSms_"+key,new DailySms(1L,null),(dailySmsInit, dailySms) -> {
                if(dailySms.isExpired()){
                    logger.debug("init numberDailySms: {}",dailySmsInit.getTotal());
                    return dailySmsInit;
                }else{
                    dailySms.increment();
                }
                logger.debug("numberDailySms: {}",dailySms.getTotal());
                return dailySms;
            });
        }catch (Exception e){
            logger.error("Error:",e);
        }
    }

使用此配置：

 @Bean
    public InfinispanCacheConfigurer cacheConfigurer() {
        return manager -> {
            final org.infinispan.configuration.cache.Configuration ispnConfig = new ConfigurationBuilder()
                    .clustering()
                    .cacheMode(CacheMode.REPL_SYNC).remoteTimeout(1,TimeUnit.SECONDS)
                    .statistics().enable()
                    .build();
            final org.infinispan.configuration.cache.Configuration ispnStatistics = new ConfigurationBuilder()
                    .clustering()
                    .cacheMode(CacheMode.REPL_SYNC).remoteTimeout(1,TimeUnit.SECONDS)
                    .statistics().enable()//.transaction().transactionMode(TransactionMode.TRANSACTIONAL)
                    .build();
            manager.defineConfiguration("vdc-cache", ispnConfig);
            manager.defineConfiguration("statistics-cache", ispnStatistics);

        };
    }

    @Bean
    public InfinispanGlobalConfigurationCustomizer globalCustomizer() {
        return builder -> builder.clusteredDefault().transport().clusterName("vdc-cache-cluster")
                .serialization().addContextInitializers(new Bucket4jProtobufContextInitializer(),new ManualSerializationContextInitializer())
                .whiteList().addClasses(Tps.class)
        ;
    }

生成此异常：

2020-07-30 09:19:09.981 - [vdc-ratelimiter-service] - [async-thread--p2-t5] - WARN  [o.i.PERSISTENCE] [] ISPN000559: Cannot marshall 'class org.infinispan.marshall.protostream.impl.MarshallableUserObject'
java.io.NotSerializableException: com.ericsson.vdc.ratelimiter.service.service.StatisticsService
    at java.base/java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1193)
    at java.base/java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:353)
    at org.infinispan.commons.marshall.JavaSerializationMarshaller.objectToBuffer(JavaSerializationMarshaller.java:44)
    at org.infinispan.commons.marshall.AbstractMarshaller.objectToByteBuffer(AbstractMarshaller.java:70)
...

我使用infinispan spring-boot-starter-embedded版本2.3.1。spring和infinispan10.1.8版本

Answer 1

我发现了问题。在Spring bean的StatisticsService方法中，incrementSmsSend使用了lambda表达式，所以infinispan会尝试序列化所有的bean。我创建了一个BiFunction并以这种方式更改了方法：

advancedCache.getAdvancedCache().computeIfPresentAsync("totalSms_"+key,new VdcSerializableFunction())

VdcSerializableFunction包括：

public class VdcSerializableFunction implements Serializable, BiFunction<String,DailySms,DailySms> {


@Override
public DailySms apply(String s, DailySms dailySms) {
    if(dailySms.isExpired()){
        return new DailySms(1L,null);
    }else{
        dailySms.increment();
    }
    return dailySms;
}

}

谢谢