java - multicast receive wrong message -



java - multicast receive wrong message -

i'm working on multicastsocket. testing websphere 8.0.0.5 on aix 7. problem getting wrong message sender. testing scenario is: 1. run sendmulticast (new thread) 2. run receivemulticast (new thread) 3. run receivemulticast (new thread)

the first receiver thread receives right message. secondary receiver thread receives wrong message.

but interesting thing tried on same machine (aix 7) java 6 console application , every thing ok.

here code:

static final int port = 9999; static final string multicastaddress = "224.2.2.3"; public static void sendmulticast() { multicastsocket socket = null; datagrampacket outpacket = null; byte[] outbuf; long t= system.currenttimemillis(); //run 60 seconds long end = t+60000; seek { socket = new multicastsocket(); string msg; while(system.currenttimemillis() < end) { msg = "//172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data"; outbuf = msg.getbytes(); inetaddress address = inetaddress.getbyname(multicastaddress); outpacket = new datagrampacket(outbuf, outbuf.length, address, port); socket.settimetolive(32); socket.send(outpacket); system.out.println("server sends : " + msg); seek { thread.sleep(500); } grab (interruptedexception ie) { } } } grab (ioexception ioe) { ioe.printstacktrace(); } socket.close(); } public static void receivemulticast() { multicastsocket socket = null; datagrampacket packet = null; byte[] inbuf = new byte[1500]; long t= system.currenttimemillis(); //run 60 seconds long end = t+60000; seek { // prepare bring together multicast grouping socket = new multicastsocket(port); inetaddress address = inetaddress.getbyname(multicastaddress); socket.joingroup(address); while(system.currenttimemillis() < end) { packet = new datagrampacket(inbuf, inbuf.length); socket.receive(packet); byte[] payload = packet.getdata(); string msg = new string(payload); system.out.println("from " + packet.getaddress() + " msg : " + msg); } } grab (ioexception ioe) { ioe.printstacktrace(); } socket.close(); }

and here log: can see @ 10:39:47:675 , 10:39:48:177 missing string coming receiver.

what problem?

[2/20/13 10:39:45:162 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:45:163 eet] 0000003b systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:45:665 eet] 0000003b systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:45:665 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:46:167 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:46:168 eet] 0000003b systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:46:672 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:46:673 eet] 0000003b systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:47:173 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:47:174 eet] 0000003b systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:47:674 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:47:675 eet] 0000003b systemout o /46.50.52.50 msg : ce_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data131.242:51860/reference_data [2/20/13 10:39:47:676 eet] 0000003c systemout o /172.21.131.242 msg : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:48:176 eet] 0000003a systemout o server sends : //172.21.131.242:51860/service_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data [2/20/13 10:39:48:177 eet] 0000003b systemout o /46.50.52.50 msg : ce_execution_cache|//172.21.131.242:51860/error_codes_cache|//172.21.131.242:51860/accounting_cache|//172.21.131.242:51860/configuration_items_cache|//172.21.131.242:51860/reference_data131.242:51860/reference_data

java multicast

Comments

Post a Comment

Popular posts from this blog

web services - java.lang.NoClassDefFoundError: Could not initialize class net.sf.cglib.proxy.Enhancer -

web services - java.lang.NoClassDefFoundError: Could not initialize class net.sf.cglib.proxy.Enhancer - when trying request rest service @ time of response getting exception.. feb 21, 2013 2:34:49 pm com.sun.jersey.spi.container.containerresponse mapmappablecontainerexception severe: exception contained within mappablecontainerexception not mapped response, re-throwing http container java.lang.noclassdeffounderror: not initialize class net.sf.cglib.proxy.enhancer @ org.hibernate.proxy.pojo.cglib.cgliblazyinitializer.getproxyfactory(cgliblazyinitializer.java:117) @ org.hibernate.proxy.pojo.cglib.cglibproxyfactory.postinstantiate(cglibproxyfactory.java:43) @ org.hibernate.tuple.entity.pojoentitytuplizer.buildproxyfactory(pojoentitytuplizer.java:162) @ org.hibernate.tuple.entity.abstractentitytuplizer.<init>(abstractentitytuplizer.java:135) @ org.hibernate.tuple.entity.pojoentitytuplizer.<init>(pojoentitytuplizer.java:55) @ org.hibernate.tuple.e...
Read more

Accessing MATLAB's unicode strings from C -

Accessing MATLAB's unicode strings from C - how can access underlying unicode info of matlab strings through matlab engine or mex c interfaces? here's example. let's set unicode characters in utf-8 encoded file test.txt, read as fid=fopen('test.txt','r','l','utf-8'); s=fscanf(fid, '%s') in matlab. now if first feature('defaultcharacterset', 'utf-8') , c engevalstring(ep, "s") , output text file utf-8. proves matlab stores unicode internally. if mxarraytostring(enggetvariable(ep, "s")) , unicode2native(s, 'latin-1') give me in matlab: non-latin-1 characters replaced character code 26. need getting access underlying unicode info c string in unicode format (utf-8, utf-16, etc.), , preserving non-latin-1 characters. is possible? my platform os x, matlab r2012b. addendum: documentation explicitly states "[mxarraytostring()] supports multibyte encoded characters...
Read more

javascript - mongodb won't find my schema method in nested container -

javascript - mongodb won't find my schema method in nested container - i trying access method of schema stored within mixed container. here situation : have cases model can many different things, have schema each of these things stored in "casecontent" mixed property. var caseschema = mongoose.schema({ casecontent : {}, object : {type:string, default : "null"}, collision : {type : boolean, default : false} }); the casecontent property filled model of 1 of schemas, 1 exemple : var treeschema = new mongoose.schema({ applecount : {type : number, default : 3} }); treeschema.methods.dostuff = function (data) { console.log('hey, listen'); homecoming true; }; then, want utilize method of schema original container : caseschema.methods.dostuff = function (data) { if (this.casecontent.dostuff !== undefined) { this.casecontent.dostuff(); console.log('it worked'); } else { ...
Read more