Contexto
Eu tenho um cluster com alguns nós do JBoss EAP 6.4. Aplicações em nós desse cluster compartilham um cache do Infinispan em modo embarcado com distribuição síncrona via UDP (JGroups):
<cache-container name="meu-container"
default-cache="meu-cache"
jndi-name="java:jboss/infinispan/cache/meu-container">
<transport stack="udp"/>
<distributed-cache name="meu-cache"
owners="2"
mode="SYNC" />
<!-- Outros caches -->
</cache-container>
Esse cache usa uma String
como chave e um POJO como valor:
@Resource(lookup="java:jboss/infinispan/cache/meu-container/meu-cache")
private Cache<String, MeuPojo> meuCache;
MeuPojo
é um objeto simples Serializable
:
public class MeuPojo implements java.io.Serializable {
private static final long serialVersionUID = 4L;
private String campoUm;
private Integer campoDois;
// Outros campos, getters, setters, etc
}
O cache distribuído funciona perfeitamente e todas as instâncias de meuCache
"enxergam" todas as entradas. Alterações em qualquer instância de MeuPojo
são vistas em todos nós, novas entradas ou exclusões de entradas em qualquer nó são "refletidas" nos demais nós.
Durante um upgrade da aplicação sem atualizações em MeuPojo
os nós do cluster sobem e descem um a um sem prejuízo para o cache. Assim que um nó sobe ele ganha acesso à cópia dele das entradas do cache.
O problema
O problema acontece quando modifico MeuPojo
. Nesse caso o Infinispan não se comporta muito bem devido a diferenças na serialização. Se eu adicionar um novo campo (e.g., private String campoTres;
) os nós atualizados não conseguem enxergar as entradas com versões não atualizadas do MeuPojo
no meuCache
e vice-versa (nós não atualizados não enxergam versões do MeuPojo
atualizados).
Nada de significativo acontece nos logs independente do valor de serialVersionUID
. O que me leva a crer que o Infinispan está engolindo exceções como InvalidClassException
.
Atualmente toda vez que queremos adicionar um novo campo em MeuPojo
é uma luta. O workaround é usar dois caches (meu-cache
e meu-cache-v2
) e duas classes diferentes MeuPojo
e MeuPojoV2
. Copiamos as entradas manualmente na aplicação e trocamos qual cache está "valendo" para as aplicações em cada upgrade.
Penso que deve existir uma maneira menos "burra" de evoluir MeuPojo
sem perder as entradas no cache, porém não consegui encontrar uma solução. O ideal seria que nós atualizados enxergassem entradas em versões não atualizadas de MeuPojo
(como se eles tivessem campo3 = null
) e vice-versa.
Alguém já passou por isso e conhece uma solução ou ao menos um work-around menos trabalhoso?