Очередь в исходящем потоке

События отправляются по правилу: первый вошёл - первый вышел.

Очередь в исходящем потоке - это разница между номером последнего события в RITM.LINK и номером последнего отправленного события в данном исходящем потоке.

Иногда образуются очереди в исходящем потоке. Причины могут быть различны, одна из причин - в RITM.LINK есть события, но в данный исходящий поток их не нужно отправлять.

Пример для трансляции в исходящий поток в RITM.LINK. Допустим существует исходящий поток в протоколе GEORITM, и создана трансляция из входящего потока в исходящий поток GEORITM. В RITM.LINK поступило 11 событий от 6 разных приборов. Прибора с IMEI = 860665052198940 нет в GEO.RITM, но от него есть события в RITM.LINK и они самые последние. Тогда все события от других приборов (1-7) будут отправлены в GEO.RITM, но четыре последних события от объекта 860665052198940 не будут отправлены в GEO.RITM, т.к. по данному объекту не будут приняты события.

№ записи в БД RITM.LINK	Событие	IMEI	Событие отправлено в исходящий поток?
1	005018138101002F	864120055143946	✅
2	2060181147000316	864120054632774	✅
3	2060181147000334	864120054632774	✅
4	206018160200000E	864120054632774	✅
5	3629181602000007	864120053246980	✅
6	1111181602000008	860665052146642	✅
7	071018160200000E	863591029978594	✅
8	094018140201001E	860665052198940	❌
9	094018140202001D	860665052198940	❌
10	094018111002004E	860665052198940	❌
11	0940183406020017	860665052198940	❌

При этом в исходящем потоке появится очередь на отправку в 4 события.

Протокол	Очередь на отправку	Входящий трафик	Исходящий трафик
GeoRitm	4	18 kbit/s	0.008 kbit/s

Это не отправленные события по объекту, которого нет в GEO.RITM. Их не нужно отправлять в GEO.RITM, т.к. объекта с IMEI = 860665052198940 в GEO.RITM нет.

После этого в RITM.LINK поступило ещё одно событие от объекта, который добавлен в GEO.RITM.

№ записи в БД RITM.LINK	Событие	IMEI	Событие отправлено в исходящий поток?
1	005018138101002F	864120055143946	✅
2	2060181147000316	864120054632774	✅
3	2060181147000334	864120054632774	✅
4	206018160200000E	864120054632774	✅
5	3629181602000007	864120053246980	✅
6	1111181602000008	860665052146642	✅
7	071018160200000E	863591029978594	✅
8	094018140201001E	860665052198940	❌
9	094018140202001D	860665052198940	❌
10	094018111002004E	860665052198940	❌
11	0940183406020017	860665052198940	❌
12	206018160200000E	864120054632774	✅

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

Протокол	Очередь на отправку	Входящий трафик	Исходящий трафик
GeoRitm	Нет	0.11 kbit/s	25 kbit/s

Дерево страниц

Очередь в исходящем потоке