java - How to implement this Queue in a Jboss cluster? -

-

My application works as an intermediate object, receiving requests from customers, then changing it into some arguments and the other Send a Changed Request to General HTTP Request or Webservice Soap Request as Service Provider

We say that my application is A, Service Provider is s.

Now I have been informed that there will be several (3-5) times every year under two zebus servers (in the cluster) behind a balance, each time the run time will last for about 4 hours. I can get a program about the time below.

During the downtime, changing A and requesting S.'s request should not be sent anymore, but get requests in the queue. After returning S, the queued requests should be processed.

Note:

  1. Received requests should be processed in exactly the same order as they did. One-by-one process to process a request means sending a sent request to S., and receiving the success or error of the response. Usually it will not take much time.

  2. Based on 1, when A is working on queued requests, new incoming requests should be encrypted, though S is already available. Unless the queue is vacant, it may continue to send AS to S.

  3. In each minute, 2-3 requests are received.

Since we have two labels, I was planning to maintain this line in the database, manage queue threads and downtime status. However, synchronization between two jabos always makes me a headache.

Soon, the problems I had met:

  • To set the flag of the time below, so that requests request instead of sending two papers . (I thought the solution, before processing each request, was set by the query database. Flags thread for this flag, this could be a poor solution.)

  • < P> After returning to s, how to design the dequeue operation of two jboss (it seems that, at the same time always a weasel is useless ...)

  • How to notify two pockets, "Now the queue is empty, do not do any now."

Logic little Til. I hope I explained my problem clearly ...

Do you have any thoughts on that?

There is more details about FIFA if there is no downtime, then one can process those requests in parallel with different customers. Since this 'transaction choice' order has been ensured by the customers, for example. 

  Client X: -Send http: // \ / createUser ... -exassed http: //../... Success was obtained from updateUser ...- if the API ( ) If unsuccessful, the update user is not the sender.  
  Client y: -Service http: // CreateCompany ...  
 
 Given that another client (y) remained to make the request With the Thakampani X, x.create user can process these two requests simultaneously by A in parallel. 
 
 While thinking about downtime and queue: 
 
  - http: // // send the cooker user .. (downtime) - Received 'enque' (s) Is back) - Send http: //../ updateUser ...  
 
 Now the order "Create-> Update" is required 
 
 
 Kent

Itemprop = "text">

Have you got any approval from S Has any specific request received properly? (If not, you should consider applying it to reduce your chances of making your app even more robust and losing requests due to network problems, server crashes, etc.)

This type of acceptance system can be extended with an algorithm, after using a deadline to send an application to an ACK on time. To wit. If the ACK is not received within a configured timeout interval, then the request has been declined again. Next time a big time ends, eg. 2 * t, then 4 * t etc. As long as the original request is not accepted, the incoming new requests are queued. After the actual request is successfully sent, the queued requests are processed in the FIFO command. If the queue is empty, normal processing will resume.

This algorithm will automatically process s shed downtime as well as some other network failures, and will be at the expense of some more resources and network traffic. But with 2-3 requests per minute, it should not be a concern (unless the individual request is huge, not at all).

Of course, it can also be improved from time to time to configuring the default timeout. To wit. For the duration of scheduled downtime of 4 hours, the default timeout can be set up to 4 hours. After the downtime is over, timeout is reset to the default value.


Comments

Post a Comment

Popular posts from this blog

c# - sqlDecimal to decimal clr stored procedure Unable to cast object of type 'System.Data.SqlTypes.SqlDecimal' to type 'System.IConvertible' -

-
I'm new to this I'm writing a clr. stored procedure that can be used to get values ​​used in a calculation Call for another stored procedure for Gives an archived methodology int (I think SqlInt32? Value of the table's value is int) which is then necessary to convert to decimal. Here I have the code: Public static integral mood (SQL MDMMYLUE, escalistering AMY type, out of SQLDCM Result) {aResult = 0; Try {SqlConnection conn = New SqlConnection ("Reference Connection = True"); SqlCommand cmd = New SqlCommand ("sp_GetType", conn); Cmd.Parameters.AddWithValue ("@ myValueType", aMyValueType); Cmd.CommandType = CommandType.StoredProcedure; Conn.Open (); Object type = CMD. Exclamation Asser (); Conn.Close (); Decimal type FORCalculation = Convert. ToDecimal (type); Decimal value = convert toDecimal (aMyValue); // ** calculation calc = new calculation (); Decimal result = calorie.docalulation (typefarculation, value); I get an exception...
Read more

Calling GetGUIThreadInfo from Outlook VBA -

-
I need to find the active window'm writing a VBA macro in MS Outlook, which is a specific process. The goal of this is to get the active window / document name even if its original application has more than one document interface. User processor with GetCurrentThreadId is active, I am using GetGUIThreadInfo to get .dll. Here is the correct code: private type RECT as as Left LongPtr top LongPtr right LongPtr down LongPtr termination of private type GUITHREADINFO cbSize as LongPtr flags LongPtr hwndActive LongPtr hwndFocus LongPtr hwndCapture LongPtr as as as as as reset as LongPtr rcCaret as LongPtr hwndCreate as LongPtr hwndMoveSize as HwndMenuOwner end of Private Equity PtrSafe function GetWindowThreadProcessId Lib "user32" (_BVV hnw LongPtr as LongPtr Nig Mr. announced as PtrSafe function GetGUIThreadInfo Lib "user32" _ (ByVal dwthreadid as LongPtr, _ lpguithreadinfo as GUITHREADINFO) LongPtr Sub MyFunction () as dim strWindowTitle string = space as s...
Read more

Obfuscating Python code? -

-
I'm looking for a way to hide my Python source code. print "Hello World!" How can I encode this example so that it is not human-readable? I have been asked to use Base 64 but I'm not sure how. itemprop = "text"> It is limited only, first level ambiguous resolution, but has built-in: byte-code in Python Is a compiler for: dragon-o-m py_compile & lt; Your program.py & gt; creates a .pyo file with a byte-code, and where the docstrings are removed, etc. You can rename .pyo with the .py extension, and python & lt; Your program.py & gt; runs as your program, but it does not have your source code. PS : If your program blur modules like this, you need to rename them with the .pyc suffix (I Not sure it will not break a day), or you can work with .pyo and run them with python -o ... .pyo ( Import should work). This will allow dragon to search your modules (otherwise, Python looks for the .py module).
Read more