Infinispan data load into Remote Cache multiple node concurrently

[abhishekdg1983]

I am trying to load data into Infinispan Multiple data node concurrently using RemoteCache. How can I achieve this into code?

I am doing like this:

final String host = "127.0.0.1";

      final int hotrodPort = 11222;

      final String cacheName = "";  // The name of the address book  cache, as defined in your server config.

      ConfigurationBuilder builder = new ConfigurationBuilder();

     /* builder.addServer()

            .host(host)

            .port(hotrodPort)

            .marshaller(new ProtoStreamMarshaller());*/  // The Protobuf based marshaller is required for query capabilities

      builder.addServer().host("127.0.0.1").port(11222).socketTimeout(1200000).security().authentication().enable().serverName("myhotrodserver").

      saslMechanism("DIGEST-MD5").callbackHandler(new MyCallBackHandler("myuser", "ApplicationRealm", "qwer1234!".toCharArray())).marshaller(new ProtoStreamMarshaller());

      cacheManager = new RemoteCacheManager(builder.build());

      addressbookCache = cacheManager.getCache(cacheName);

      if (addressbookCache == null) {

         throw new RuntimeException("Cache '" + cacheName + "' not found. Please make sure the server is properly configured");

      }

      registerSchemasAndMarshallers();

[rvansa]

Just spawn a couple of threads (or use a threadpool) and write the data to the cache. Both RemoteCacheManager and RemoteCache are safe for concurrent access.

[abhishekdg1983]

How can we connect to multiple port in Hotrod? And is there any example of

thread pool available for multiple port?

[rvansa]

The server handles connections from different destinations to single port. Just invoke RemoteCache.put() from different threads, the calls will proceed concurrently.

[abhishekdg1983]

Cannot we add programmatically different port in this code from the client:

builder.addServer().host("127.0.0.1").port(11222).socketTimeout(1200000).security().authentication().enable().serverName("myhotrodserver").

      saslMechanism("DIGEST-MD5").callbackHandler(new

MyCallBackHandler("myuser", "ApplicationRealm",

"qwer1234!".toCharArray())).marshaller(new ProtoStreamMarshaller());

      cacheManager = new RemoteCacheManager(builder.build());

      addressbookCache = cacheManager.getCache(cacheName);

      if (addressbookCache == null) {

         throw new RuntimeException("Cache '" + cacheName + "' not found.

Please make sure the server is properly configured");

      }

[rvansa]

Ah, do I understand correctly that you want to store the same data in several *not clustered* servers? There's no support for that; the expected use case is that you have several servers clustered together, and you store the data into such cluster transparently. All the client needs is address of one of those servers, it can figure out other servers and decide on which node should be the data stored automatically.