powered by simpleCommunicator - 2.0.51     © 2025 Programmizd 02
Форумы / IBM DB2, WebSphere, IMS, U2 [игнор отключен] [закрыт для гостей] / MQSeries смщенное OnLine чтение при асинхронной загрузке
7 сообщений из 7, страница 1 из 1
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405070
TAir
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Гость
Насколько тривиальна задача организации чтения очереди сообшений в MQSeries, со строго установленной задержкой относительно объективного времени(времени события отраженного в сообшении, а не времени постановки сообщения в очередь).
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405187
Фотография NewYear
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
по рускки скажи, что ли...

PutDate, PutTime в MQMD не являются селекторами. любое MOM это асинхронная система, а не синхронная. ни о какой строго установленной задержке речи не идет.

В поля MsgId и CorrelId можно записать что угодно. хоть дату и время.
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405204
Фотография NewYear
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
в общем, фигня твоя задача...
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405431
TAir
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Гость
По русски: идут себе сообщения с информацией о событии внутри этих сообщений есть время события(200401012117), сообщения о событиях с таким временем могут быти поставлены в очередь в 21:18 или в 21:52 или 22:13, в общемм с какой попало задержкой (в разумных пределах - до одного часа)
но все сообшения с временем события 200401012117 нужно вытащить в 2004/01/01 22:17, события со временем 200401012118 в 2004/01/01 22:18 и т.д.
Нужна вся эта бодяга чтобы иметь объективную (на 99%) модель с задержкой в 1час от реального времени но каждую минуту.
к информации в среднем в секунду регистрируется 4-10 событий (345600-864000 в сутки), следовательно времени для проволочек нет.
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405537
Фотография NewYear
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
так бы сразу и сказал.

кода делаешь MQPUT или MQPUT1, запиши в CorrelId дату и время, когда ты хочешь обработать сообщение.

а на обратном конце в MQGET в CorrelId задай текушее время.
т.е

в 200401012117 нужно вытащить в 2004/01/01 22:17 ты ждешь сообщение
с CorrelId '2004010121172004/01/01 22:17' это так, примерно.


чтоб не ломать уже готовые приложения, напиши пару брокеров -- на входе и на выходе.

на входе -- идут себе сообшения, попадают в очередь. попало соощение в очередь, стартует брокер по триггеру. он смотрит сообщение, проставляет CorrelId и перекладывает его в другую очередю.

на входе -- лежат себе сообщения а очереди. очередь слушает брокер.

в '200401012117 2004/01/01 22:17' он читает сообщение c CorrelId '200401012117 2004/01/01 22:17'

в '200401012117 2004/01/01 22:18' он читает сообщение c CorrelId '200401012117 2004/01/01 22:18'


когда брокер прочитал сообщение, он перекладывает его в другую очередь. после этого по триггеру стартует приложение, которому педназначалось сообщение

10 сообщение в секунду -- это ерунда.
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405575
Фотография NewYear
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
правда, когда 36000 соощений в очереди, выборка по CorrelId выполняется долго. но можно увеличить кол-во очередей, чтоб где-то по 10000 сообщений.
...
Рейтинг: 0 / 0
MQSeries смщенное OnLine чтение при асинхронной загрузке
    #32405631
TAir
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Гость
Т.Е. задача в полне тривиальная!!!

Большое спасибо!!!
Будем пробовать...
...
Рейтинг: 0 / 0
7 сообщений из 7, страница 1 из 1
Форумы / IBM DB2, WebSphere, IMS, U2 [игнор отключен] [закрыт для гостей] / MQSeries смщенное OnLine чтение при асинхронной загрузке
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Найденые пользователи ...
Разблокировать пользователей ...
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]