如何远程查看和编辑Infinispan缓存数据

Question

我在WildFly 8.2服务器中嵌入了一个Infinispan缓存。

我在<subsystem xmlns="urn:jboss:domain:infinispan:2.0">标签内的standalone.xml文件中添加了以下内容：

<cache-container name="mycache" default-cache="cachedb">
    <transport lock-timeout="600000" />
    <replicated-cache name="cachedb" batching="true" mode="SYNC" />
</cache-container>

...并像这样注入缓存容器：

@Singleton
@Startup
public class CacheManager {

    @Resource(lookup = "java:jboss/infinispan/container/mycache")
    private CacheContainer container;
    . . . . 

}

我可以在我的应用程序中使用缓存。

然而，要求使用任何缓存监视API远程查看、编辑和删除缓存数据。

通过jconsole，我可以查看缓存信息，但无法查看缓存数据。

如何远程访问缓存？

- Sujith PS

---

你考虑过使用Infinispan Server吗？ - Galder Zamarreño

不需要。要求是将Infinispan嵌入Wildfly服务器中。 - Sujith PS

抱歉，您所能做的就是这些了。只有使用Infinispan服务器才能远程访问Infinispan缓存。 - Galder Zamarreño

Answer 1

首先，对于选择不走寻常道路的人我表示哀悼。

可以远程访问嵌入式Infinispan缓存。您需要在服务器进程中设置一个org.infinispan.server.hotrod.HotRodServer，实际上是反向工程预打包的Infinispan服务器分发版。 此方法未经记录，所以请自行承担风险。

您需要这些依赖项：

<dependency>
    <groupId>org.infinispan</groupId>
    <artifactId>infinispan-server-hotrod</artifactId>
    <version>7.1.0.Final</version>
</dependency>
<dependency>
    <groupId>org.infinispan</groupId>
    <artifactId>infinispan-client-hotrod</artifactId>
    <version>7.1.0.Final</version>
</dependency>
<dependency>
    <groupId>org.infinispan</groupId>
    <artifactId>infinispan-remote-query-server</artifactId>
    <version>7.1.0.Final</version>
</dependency>

配置一个缓存示例（infinispan.xml）：

<infinispan>
    <cache-container default-cache="default">
        <local-cache name="dumpster">
            <compatibility />
        </local-cache>
    </cache-container>
</infinispan>

服务器进程：

// Start a cache manager as usual
EmbeddedCacheManager cacheManager;
try (InputStream in = ClassLoader.getSystemResourceAsStream("infinispan.xml")) {
    cacheManager = new DefaultCacheManager(in);
}

// Start a server to allow remote access to the cache manager
HotRodServerConfiguration serverConfig = new HotRodServerConfigurationBuilder()
        .host("127.0.0.1").port(9999).build();
HotRodServer server = new HotRodServer();
server.start(serverConfig, cacheManager);

// Start the example cache
Cache<String, String> cache = cacheManager.getCache("dumpster", true);
cache.put("K", "V");
System.out.println(cache.get("K")); // V

客户端进程:

Configuration config = new ConfigurationBuilder().addServer()
        .host("127.0.0.1").port(9999).build();
RemoteCacheManager cacheManager = new RemoteCacheManager(config);
RemoteCache<String, String> cache = cacheManager.getCache("dumpster");
System.out.println(cache.get("K")); // V

- approxiblue