Я разрабатываю систему с использованием кометы, где есть общий канал, по которому публикуются данные. Мне нужно отфильтровать данные, используя некоторые условия на основе сведений о клиентской подписке. Может ли кто-нибудь сказать, как я могу это сделать? Я думал, что могу сделать это с помощью DataFilter.
Channel.addDataFilter(DataFilter filter);
Это правильный путь? Если да, то какой-нибудь пример кода для этого, пожалуйста?
Метода Channel.addDataFilter(DataFilter) не существует, но вы можете добиться тех же результатов другим способом.
Во-первых, взгляните на доступные DataFilter реализации уже доступен.
Тогда достаточно добавить DataFilterMessageListener к каналу, по которому вы хотите отфильтровать данные, и указать один или несколько DataFilter к DataFilterMessageListener.
Вы можете найти пример этого в демонстрациях CometD, поставляемых с дистрибутивом CometD, например, здесь.
Правильный способ добавить DataFilterMessageListener — во время инициализации канала, как это делается в примере, указанном выше, с помощью аннотации @Configure или, что то же самое, с помощью ServerChannel.Initializer.
Наконец, посмотрите, как сообщения обрабатываются на сервере, из документации: http://docs.cometd.org/reference/#concepts_message_processing. Важно понимать, что изменения, сделанные DataFilter, видят все подписчики.
ServerChannel.publish(...), потому что они будут отправлять одно и то же сообщение всем подписчикам. Вместо этого вам нужно использовать ServerSession.deliver(...), взяв список ServerSession от подписчиков канала. Поскольку вы перебираете подписчиков, вы можете применять/изменять свои сообщения для каждого ServerSession, применяя DataFilter вручную. Наконец, если вы вернете false из MessageListener, обработка сообщения будет прервана.
- person sbordet; 02.04.2013
