IllegalStateException for distributed system in Infinispan -


i have been trying implement distributed system store data in node command. idea use keyaffinityservice find key associated local node , each time before put command done, store key refer same local node , use grouping api use key store value in local node. code have following:

simplecache.java:

import java.util.*; import java.util.concurrent.*; import org.infinispan.cache; import org.infinispan.affinity.*; import org.infinispan.manager.*;  //used store key local node class locaddr{ static string nut; static string sim;}  public class simplecache { public void start() throws exception {     embeddedcachemanager manager = new defaultcachemanager("democluster.xml");      cache<string, string> cache = manager.getcache();     string command = "";     int ticketid = 1;      scanner scan = new scanner(system.in);     cache.start();     manager.start();      // create affinity service find key manager     keyaffinityservice keyaffinityservice = keyaffinityservicefactory.newlocalkeyaffinityservice(             cache,             (keygenerator)new rndkeygenerator(),             executors.newsinglethreadexecutor(),             100);       //find key associated local node     locaddr.nut = objects.tostring(keyaffinityservice.getkeyforaddress(manager.getaddress()));       log("start of program.....");     log("input 1 of following commands:");     log("book");     log("pay");     log("list");     log("locaddr");     log("quit");     while (true){         command = scan.nextline();         if (command.equals("book")) {             log("enter name ");              string name = scan.nextline();              locaddr.sim = objects.tostring(keyaffinityservice.getcollocatedkey(locaddr.nut));             cache.put(integer.tostring(ticketid)+manager.getaddress().tostring(),name);              log("booked ticket " + name);             ticketid++;         }         else if (command.equals("pay")) {              log("enter ticket number ");             string id = scan.nextline();              log("display ticket:"+cache.get(id));              string ticket = cache.remove(id);             log("checked out ticket " + ticket);         }         else if (command.equals("list")) {             set <string> set = cache.keyset();             (string ticket: set) {                 log(ticket + " " + cache.get(ticket));             }         }         else if (command.equals("quit")) {             cache.clear();             cache.stop();             manager.stop();             keyaffinityservice.stop();             log("bye");             break;         }         else if (command.equals("locaddr")) {             log("local key manager is: "+locaddr.nut);             log("manager address is: " + manager.getaddress());         }         else {             log("unknown command " + command);         }     } }  public static void main(string[] args) throws exception{     new simplecache().start(); } public static void log(string s){     system.out.println(s); } }

democluster.xml:

<infinispan xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"  xsi:schemalocation="urn:infinispan:config:6.0  http://www.infinispan.org/schemas/infinispan-config-6.0.xsd"         xmlns="urn:infinispan:config:6.0">  <global>         <transport>             <properties>                 <property name="configurationfile" value="jgroups-tcp.xml" />             </properties>         </transport> </global>  <default>     <clustering mode="distributed" >         <sync/>         <hash numowners="1" numsegments="100" capacityfactor="1">             <groups enabled="true">                 <grouper class="kxgrouper"/>             </groups>         </hash>     </clustering> </default> </infinispan>

kxgrouper.java:

import org.infinispan.distribution.group.grouper;  public class kxgrouper implements grouper<string> {  public string computegroup(string key, string group) {     string g = locaddr.sim;     return g; }  public class<string> getkeytype() {     return string.class; } }

my implementation based in simple cache implementation example of infinispan. having 2 main issues:

1. when run code in separate jvms, work when "book" command (which invokes collocated key command , cache put command), error says node no longer part of cluster. error looks this:

exception in thread "main" java.lang.illegalstateexception: address sri-pc-4630 no longer in cluster     @ org.infinispan.affinity.keyaffinityserviceimpl.getkeyforaddress(keyaffinityserviceimpl.java:107)     @ org.infinispan.affinity.keyaffinityserviceimpl.getcollocatedkey(keyaffinityserviceimpl.java:91)     @ simplecache.start(simplecache.java:77)     @ simplecache.main(simplecache.java:125)     @ sun.reflect.nativemethodaccessorimpl.invoke0(native method)     @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:57)     @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43)     @ java.lang.reflect.method.invoke(method.java:601)     @ com.intellij.rt.execution.application.appmain.main(appmain.java:120)

where "address sri-pc-4630" address of manager in jvm running. have been looking online solution issue no 1 seems have similar problem.

2. if running , "book" , have key/value stored in local node, cannot access other node.

i have been trying fix no avail , advice or recommendation appreciated.


Comments

Post a Comment

Popular posts from this blog

commonjs - How to write a typescript definition file for a node module that exports a function? -

consider, toml node module can use: // toml.d.ts declare module toml { export function parse(value:string):any; } declare module "toml" { export = toml; } then: /// <reference path="../../../../../defs/toml/toml.d.ts"/> import toml = require('toml'); toml.parse(...); however, node module export single function, such 'glob' ( https://github.com/isaacs/node-glob ). the node usage of module be: var glob = require("glob") glob("*.js", {}, callback(err, files) { ... }); you'd naively expect this: // glob.d.ts declare function globs(paths:string, options:any, callback:{(err:any, files:string[]):void; ...but because typescripts 'import' semantics bit strange, seems can use 'import .. = require()' statement alias modules . trying call: /// <reference path="../../../../../defs/glob/glob.d.ts"/> import blog = require('glob'); results in: error ts2072: mod...
Read more

openid - Okta: Failed to get authorization code through API call -

i'm integrating okta own idp server using okta's api. i'm implementing authorization code flow following steps below: in own server, use /api/v1/authn endpoint sessiontoken. use sessiontoken obtain authorization calling endpoint: /oauth2/v1/authorize?client_id=" + clientid + "&sessiontoken=" + sessiontoken + "&response_type=code&response_mode=query&scope=openid&redirect_uri=" + redirecturl + "&state=evanyang&nonce=" it's supposed return response status code 302 , location header containing redirect url code value. however, keep getting response status code 200 , without location header, html body saying "you using unsupported browser." , "javascript disabled on browser." according api documentation: http://developer.okta.com/docs/api/resources/oidc.html#authentication-request , sessiontoken parameter sufficient this: an okta one-time sessiontoken. allows api-based ...
Read more

ios - Change Storyboard View using Seague -

i have following code checks connection server, , depending on want change views if no connection found. nsstring *connect = [nsstring stringwithcontentsofurl:[nsurl urlwithstring:@"http://myserver.com"] encoding:nsutf8stringencoding error:nil]; if (connect == null) { [self performseguewithidentifier:@"network_failure" sender:self]; } else { // other code here } my problem not change views. have added storyboard segue between 2 views identifier of network_failure . not have navigation controller or that, problem? thanks help! no not problem. first of all, in objectivec exists nil object oriented null . must use that. so: if(connect == nil) or better: if(!connect) so due fact nil not same of null , probably code does't enter in if scope . you have been able discover breakpoint. anyway: be sure set trigger segue (line) 2 view controller , , name network_failure (that not best name. should instead view1toview2 ) as, m...
Read more