Вопросы по теме 'publish-subscribe'
Ошибка создания экземпляра EventBus в Guava Java
Я пытаюсь использовать EventBus библиотек Google Guava.
Из документации Guava должно быть легко для создания экземпляра объекта EventBus.
Мой код:
package test;
import com.google.common.eventbus.EventBus;
public class Test {
public...
6232 просмотров
schedule
27.02.2024
Использование очереди rabbitmq и вставка сообщений в Mysql в облаке?
Я разработал приложение для Android, в котором оно подписывается на очередь, а также публикуется в других очередях. Одновременно он публикует одно и то же сообщение в двух разных очередях, одна из них представляет собой очередь с именем «Очередь», и...
1463 просмотров
schedule
23.10.2022
Индивидуальные очереди подписчиков ZeroMQ
У меня есть вопрос о ZeroMQ PUB/SUB . Создает ли издатель отдельную очередь для каждого отдельного подписчика или есть одна очередь для всех подписчиков (и, следовательно, ограниченная самым медленным подписчиком)?
156 просмотров
schedule
04.05.2024
Проблема клиента Jabber с аутентификацией С#
Ниже приведен пример консольного приложения, использующего клиент jabber-net для отправки тестового сообщения после аутентификации соединения. Я получаю сообщение об ошибке при аутентификации запроса на вход. Ошибка приведена ниже.
"Невозможно...
2110 просмотров
schedule
30.04.2024
Как запустить поток с функцией другого соглашения о вызовах
Ссылаясь на эту публикацию , я есть чистый виртуальный класс:
#define CALL __stdcall
class IIEvent
{
virtual ~IIEvent() {}
virtual void CALL ev1(int) = 0;
virtual void CALL ev2(int) = 0;
};
Этот интерфейс используется для...
141 просмотров
schedule
11.01.2024
Метеор, отношения «один ко многим» и добавить поле только в коллекцию на стороне клиента в публикации?
Может ли кто-нибудь увидеть, что может быть не так в этом коде, в основном я хочу проверить, было ли опубликовано сообщение текущим вошедшим в систему пользователем, И добавить временное поле в коллекцию на стороне клиента: isCurrentUserShared.
Это...
2757 просмотров
schedule
10.11.2022
Разрешить серверу Node.js WAMP.IO подписаться на публикацию клиентов с целью измерения задержки.
Я знаю, что предполагаемый вариант использования шаблона Pub/Sub состоит в том, чтобы позволить клиентам «многоадресно передавать» друг другу напрямую, а серверы работать прозрачно. Но было несколько случаев, когда я хотел бы, чтобы мой сервер...
543 просмотров
schedule
20.04.2024
Какие методы доступны в Unix для pub sub IPC?
Существуют различные варианты IPC.
По сети:
для клиент-сервера можно использовать TCP
для pub sub можно использовать многоадресную рассылку UDP
Локально:
для клиент-сервера можно использовать доменные сокеты unix
для паба можно...
2677 просмотров
schedule
06.03.2024
Python переключился с Threading на Multiprocessing, теперь публикация/подписка (Луи) не работает
Сегодня я переключил большинство своих реализаций потоков на многопроцессорность, и все прошло отлично, за исключением сообщений диспетчера louie. Конечно, это, вероятно, не последний модуль публикации/подписки, но я использую его, потому что мне уже...
467 просмотров
schedule
21.10.2022
Как установить издателя на узле PubSub с помощью Smack?
Я разрабатываю чат с библиотеками Smack и сервером Openfire. Я хотел бы сделать пользователя издателем на моем узле pubsub. Я искал в Интернете, но я ничего не могу найти.
Я установил pubsub с этой конфигурацией:...
604 просмотров
schedule
08.04.2024
Многократное хранилище данных с использованием pubnub?
Я разработал приложение для общения в чате для Android, в котором пользователи могут общаться только с командой обслуживания клиентов, подписаться на пять конкретных каналов, т. е. прачечная, еда, домашние услуги и т. д. Я использую PubNub, чтобы...
57 просмотров
schedule
26.10.2022
Java API клиента CometD Как это сделать?
Для моего проекта я должен использовать подписчика pubsub и cometD . Я использую сервер приложений Oracle Weblogic для двух приложений. Один из них публикует некоторые сообщения на каналах pubsubs, а другой подписывается на каналы для...
314 просмотров
schedule
19.12.2023
Динамически назначать публикации/подписки различных типов событий нескольким агрегаторам
У меня есть различные модули, которые могут отправлять и получать разные Event<T> . Например
class A : ISub<Event<Picture>>
class B : ISub<Event<SomeObject>>
class C : IPub<Event<Picture>>
...
и т....
48 просмотров
schedule
09.04.2024
Публикация / подписка для надежного обмена сообщениями: Redis VS RabbitMQ
Фон
Я делаю типичное приложение публикации / подписки, в котором издатель отправляет сообщения потребителю.
Издатель и потребитель находятся на разных машинах, и связь между ними может иногда прерываться.
Задача
Здесь цель состоит в том,...
13383 просмотров
schedule
07.06.2024
Как вызвать событие Pubsub.js в шутливом тесте для react.js
Я реализую интернационализацию в реагирующем приложении с библиотекой react-intl . Язык может запускаться в разных компонентах, поэтому я использовал библиотеку pubsub-js для публикации события каждый раз. когда язык меняется, и подпишитесь на...
1952 просмотров
schedule
14.09.2022
Не удается получить сообщения от сервера Vert.x MQTT
Я пытаюсь заставить некоторых клиентов на основе Paho работать с сервером Vert.x MQTT. Я пытаюсь опубликовать в тестовой теме, на которую подписан мой принимающий клиент. Мне трудно получить сообщение от моего клиентского издателя моему клиентскому...
612 просмотров
schedule
20.01.2024
Akka Distributed Pub/Sub противодавление
Я использую Akka Distributed Pub/Sub и имею одного издателя и подписчика. Мой издатель намного быстрее, чем подписчик. Есть ли способ замедлить работу издателя после определенного момента?
Код издателя:
public class Publisher extends...
771 просмотров
schedule
06.12.2022
Является ли шаблон Observer и pub-sub одинаковыми, когда в реализации используется база данных?
Я пытаюсь понять шаблон наблюдателя и застрял в одной конкретной точке. Насколько я понимаю, как только наблюдатель подписывается на уведомление о любом изменении события, подписка где-то сохраняется, а затем, когда событие изменяется, подписчик...
795 просмотров
schedule
31.05.2024
Google IOT - устройство подписывается на что-то еще, кроме / devices / XXXX / config
Я пробую Google IOT и Google PubSub. Я отправляю сообщения MQTT с устройства в очередь pubsub, на которую я подписался (что-то, что я назову «сервером»). В облачной консоли Google я обновляю настройки устройства и получаю сообщение о настройках на...
880 просмотров
schedule
08.01.2024
Создание службы Pub / Sub БЕЗ сторонних инструментов
Я хотел бы найти решение для создания среды pub / sub для двух микросервисов, чтобы они могли общаться друг с другом, я знаю, что могу использовать некоторые третьи стороны, например Redis, RabbitMQ Реализация связи между микросервисами на основе...
1203 просмотров
schedule
21.04.2024
