问题:

I have a Java worker that are polling a external queue system for jobs, through web service calls.

What is the most solid way to ensure that the worker is operating at any given time?

回答1:

JVM execution is not different from any other program. So what you want to do is to put together a shell script and place it in /etc/init.d and link it appropriatelly to to /etc/rc.d. On RedHat flavors it will ensure service startup with the system.

Wring the script may be tricky, but I would copy one of existing ones and change it to call java executable with right parameters. In this script you would have to capture java process id. You can use it then to monitor your process and restart as necessary.

回答2:

The java.util.concurrent package offers a simple, solid framework for this kind of work.

Here's a simple example of some code that would work:

import java.util.concurrent.*;

public static void main(String[] args)
{
    ScheduledExecutorService service = Executors.newScheduledThreadPool(1);

    // Here's an anonymous class, but your should probably create a class for this
    Runnable poll = new Runnable()
    {
        public void run()
        {
            // put your polling code here
        }
    };

    // Have your code called every 5 seconds like this:
    service.scheduleAtFixedRate(poll, 0, 5, TimeUnit.SECONDS);
}