Как реализовать очередь HTTP-запросов в Java

Простым способом было бы иметь таблицу в вашей БД с запросами Http и программу, выполняющую запросы, когда находит результат, делает запрос, если не спать.

пока (правда) {

//query the DB
if (have_results){
         //http request
         // remove request from the DB

 }else{
     // sleep 1s

}

}

это не код, но это должно быть легко.

Спасибо

Вы можете использовать Active-MQ для организации очереди. Active MQ, Hello World

Если вы используете сервисный брокер MSSQL , он уже предоставляет очереди сообщений. вам просто нужно выяснить, как правильно использовать его в вашем случае.

Это ссылка на мост между Service Broker и JMS.

• Вам не нужно вызывать какое-либо приложение через базу данных.
• Программа C обрабатывает каждый HttpRequest по 20 минут.

Используйте следующие шаги:

Часть 1:

• p1.1 — Настройка очереди с помощью сервисного брокера MSSQL .
• p1.2 - Каждый раз при изменении базы данных отправлять сообщение в очередь.

• p2.1 - Иметь программу Java, которая опрашивает очередь и проверяет, есть ли какие-либо сообщения.
• п2.2 - Если сообщений нет, то некоторое время спит.
• p2.3 - Если есть новые сообщения, он просто принимает одно.
• p2.4 - Сообщение передается программе C программой Java (см. Конструктор процессов ).
• p2.5 - Дождитесь завершения процесса.
• p2.6 - Когда процесс завершится (через 20 минут), перейдите к p2.1.

Эта ссылка может помочь вам косвенно.

Поскольку Azure не поддерживает Service Broker, должен быть другой способ реализации части 1.

Часть 1 (выполните следующие шаги, насколько это возможно):

• Шаг 1. Генерируйте данные запроса (не сообщение, а просто данные) при изменении базы данных.

  I want to send modified or new data with request from DB to Java Application

  • I need to know how/where data is generated/gathered when database changes. Only this much in this step. Once this is clear, then we will forward. Please take one step at a time. -

• Шаг 2. Создайте сообщения из сгенерированных данных.

• Шаг 3. Прочитайте сообщения и отправьте их в очередь.

  send messages including data to Queue

  Структуры сообщений:

  Следующее сообщение указывает на Application1.

   App1?data="1,2,3,4,5,6,7,8,9,10..."
  

  Следующее сообщение указывает на Application2.

   App2?data="1,2,3,4,5,6,7,8,9,10..."
  

  If it allow to mention our own custom message,then I will create one more table in DB.This table have 2 columns.1 row points to ApplicationName and 2 row points to message Name.It is useful while forwarding time.

Часть 2 (на данный момент остается прежней):

• p2.1 - Иметь программу Java, которая опрашивает очередь и проверяет, есть ли какие-либо сообщения.
• п2.2 - Если сообщений нет, то некоторое время спит.
• p2.3 - Если есть новые сообщения, он просто принимает одно.
• p2.4 - Java-приложение импортирует файл XML и на основе контекста сообщения отправляет http-запрос в соответствующее приложение, включая данные
• p2.5 - Сообщение передается программе C программой Java (см. Конструктор процессов ).
• p2.6 - Дождитесь завершения процесса.
• p2.7 - Когда процесс завершится (через 20 минут), перейдите к p2.1.

Структура Xml выглядит следующим образом.

   <Message>
     <Message-Body>
       <Message-Context>App1</Message-Context>
       <URL>`http://localhost:8080/App1`</URL>
     </Message-Body>
     <Message-Body>
        <Message-Context>App2</Message-Context>
        <URL>`http://localhost:8080/App2`</URL>
     </Message-Body>
   </Message>