Мобильная версияПакетная обработка неопределенного размера [закрыто] ⇐ JAVA
-
Гость
Пакетная обработка неопределенного размера [закрыто]
Я новичок в разработке Java. Пожалуйста, дайте мне знать, если сообщение непонятно.
Мой сценарий состоит в том, чтобы получать сообщения из pubsub и группировать его, скажем, по 10 сообщений. Следующий шаг — отправить эти пакеты в службу.
Все идет нормально, если количество сообщений кратно 10. Я пытаюсь понять, как обрабатывать сообщения, содержащие менее 10 сообщений. Например, в моей текущей реализации, если я получу 27 сообщений в pubsub, мой текущий процессор создаст 2 пакета, но для третьего (короткого пакета) мне придется подождать, пока в теме не будет добавлено еще 3 сообщения. Не существует точного способа узнать, когда придут 3 сообщения. Я думаю, смогу ли я поставить таймер, который будет запускать обработку «короткой партии», но понятия не имею, как этого добиться.
Я пытался использовать переменную уровня класса для регистрации момента отправки последнего сообщения, но не знаю, как ее использовать в потоке демона.
Я новичок в разработке Java. Пожалуйста, дайте мне знать, если сообщение непонятно.
Мой сценарий состоит в том, чтобы получать сообщения из pubsub и группировать его, скажем, по 10 сообщений. Следующий шаг — отправить эти пакеты в службу.
Все идет нормально, если количество сообщений кратно 10. Я пытаюсь понять, как обрабатывать сообщения, содержащие менее 10 сообщений. Например, в моей текущей реализации, если я получу 27 сообщений в pubsub, мой текущий процессор создаст 2 пакета, но для третьего (короткого пакета) мне придется подождать, пока в теме не будет добавлено еще 3 сообщения. Не существует точного способа узнать, когда придут 3 сообщения. Я думаю, смогу ли я поставить таймер, который будет запускать обработку «короткой партии», но понятия не имею, как этого добиться.
Я пытался использовать переменную уровня класса для регистрации момента отправки последнего сообщения, но не знаю, как ее использовать в потоке демона.
