Non blocking TCP connect in Spring Integration -


i attempting use spring integration connect large number of devices (500-1000) on volatile network , i'm having issues default pool of 10 task schedulers blocking trying connect devices not available.

my implementation based on dynamic ftp example, new child application context created each of remote devices client tcp connection factory , tcp inbound adapter messages routed flow of root context.

the problem having is important these devices connected quickly, large number of them may offline @ time.

all connections seem sent out single 10 member task scheduler pool , end blocking on connect call, causing large delays connecting devices online further down list.

so question is, there way implement non blocking connect call using spring integration?

non-blocking connect won't because connections established on demand , sending thread needs block until connection enabled, if it's request/reply scenario. if using channel adapters one-way or arbitrary two-way communication (not using outbound gateway). can put requests in queue channel.

the poller resources limited , it's best not run long-running tasks on pollers directly, hand off task-executor instead.

you have several options:

  1. use task-executor don't hold poller thread.
  2. increase scheduler pool size - either define own taskscheduler bean, or add properties file classpath /meta-inf/spring.integration.properties containing spring.integraton.taskscheduler.poolsize=50 (or whatever).
  3. reduce connect timeout default on os.

the last bit more involved , depends on whether using nio or not. if not, provide custom tcpsocketfactorysupport returns factory createsocket(host, port) createsocket() , connect(socketadddress, timeout). if you're using nio, messages should buffered , not block until buffer full.

edit: see using inbound adapters; assumed outbound. presume have client-mode set. there no task executor option there; option configure custom task scheduler inbound adapter don't use main pool.


-

Comments

Post a Comment

Popular posts from this blog

OpenCV OpenCL: Convert Mat to Bitmap in JNI Layer for Android -

there several posts converting mat bitmap using utils.mattobitmap() function. i'm assuming function can called in java layer after importing utils class. i want transfer data memory address pointed uint32_t* bmpcontent; in code below. jniexport void jnicall java_com_nod_nodcv_nodcvactivity_runfilter( jnienv *env, jclass clazz, jobject outbmp, jbytearray indata, jint width, jint height, jint choice, jint filter) { int outsz = width*height; int insz = outsz + outsz/2; androidbitmapinfo bmpinfo; if (androidbitmap_getinfo(env, outbmp, &bmpinfo) < 0) { throwjavaexception(env,"gaussianblur","error retrieving bitmap meta data"); return; } if (bmpinfo.format != android_bitmap_format_rgba_8888) { throwjavaexception(env,"gaussianblur","expecting rgba_8888 format"); return; } uint32_t* bmpcontent; if (androidbitmap_lockpixels(env, outbmp,(void**)&bmpcontent)...
Read more

android - org.xmlpull.v1.XmlPullParserException: expected: START_TAG {http://schemas.xmlsoap.org/soap/envelope/}Envelope -

i trying hit soap api in application login purpose , getting above mentioned error , can 1 tell me going wrong , first time soap apis. here code hit soap :- vector<object> args = new vector<object>(); hashtable<string, object> hashtable = new hashtable<string, object>(); hashtable.put("email", "mss.siddhart28@gmail.com"); hashtable.put("password", "siddharth"); args.add(hashtable); soapserializationenvelope envelope = new soapserializationenvelope( soapenvelope.ver11); envelope.dotnet = true; envelope.xsd = soapserializationenvelope.xsd; envelope.enc = soapserializationenvelope.enc; (new marshalhashtable()).register(envelope); httptransportse androidhttptransport = new httptransportse( "http://tempuri.org/", 15000); androidhttptransport.debug = true; string result = ""; try { soapobject request = new soapobject("http:...
Read more

python - How to remove the Xframe Options header in django? -

i have made page has iframe . inside iframe want show multiple different links article facebook, or news, or youtube video or other possible url. but, due xframe header, unable so. referred following link: https://docs.djangoproject.com/en/1.8/ref/clickjacking/ , django xframeoptionsmiddleware (x-frame-options) - allow iframe client ip but didn't help. my settings.py file's middleware_classes is: middleware_classes = ( 'django.contrib.sessions.middleware.sessionmiddleware', 'django.middleware.common.commonmiddleware', 'django.middleware.csrf.csrfviewmiddleware', 'django.contrib.auth.middleware.authenticationmiddleware', 'django.contrib.auth.middleware.sessionauthenticationmiddleware', 'django.contrib.messages.middleware.messagemiddleware', 'django.middleware.clickjacking.xframeoptionsmiddleware', ) from http://django-secure.readthedocs.org/en/latest/middleware.html , found using ...
Read more