Описание тега publish-subscribe

Публикация / подписка - это шаблон обмена сообщениями, при котором отправители (издатели) сообщений не программируют сообщения для отправки напрямую определенным получателям (подписчикам). Скорее, опубликованные сообщения классифицируются по каналам, без информации о том, какие подписчики там могут быть.
2 ответа

ejabberd pubsub отписаться вопрос

У меня возникают проблемы при попытке отписаться от узла pubsub. Я пишу BOSH-клиент в JS. Вот как я подписываюсь (с полным JID): <body rid='1023502710' xmlns='http://jabber.org/protocol/httpbind' sid='2ded0255fc6e8bf912a2871d415173faadecfea6'>…
14 сен '12 в 13:15
1 ответ

Показать в реальном времени положение конкретного устройства

Я хотел бы создать приложение (на Android сейчас и впоследствии на IOS), которое могло бы отслеживать положение определенного устройства в режиме реального времени. что-то вроде: user1 получить список ближайших пользователей user1 "попросить" user2,…
31 май '14 в 15:33
2 ответа

Meteor/Mongodb - массивы, поддокументы и перекрывающиеся подписки

Я делаю игру; игроки формируют лиги и делают конкурирующие прогнозы. Лига выглядит так: { leagueName: "Premier League", players:[ {name: "Goodie", secretPrediction: "abc"}, {name: "Baddie", secretPrediction: "def"} ] } Для каждого игрока мне нужно о…
0 ответов

Laravel - это Artisan:call() синхронно?

Я следил за документацией redis pub/sub, предоставленной laravel, и создал команду для подписки. Тем не менее, когда я пишу логику подписки в моем контроллере (это длительная команда), используя Aritsan::call()код не выполняется дальше, так как кома…
15 авг '16 в 16:24
1 ответ

Как масштабировать издателя NServiceBus

Я знаю, что не должно быть нескольких издателей, публикующих одно и то же событие. Но как мне масштабировать подписчика, который публикует событие после обработки события, на которое он подписан? Масштабирование приведет к тому, что несколько издате…
02 май '12 в 10:16
5 ответов

Какую технологию следует использовать для реализации надежного абонента, доступного из.NET?

Предполагая, что проект "зеленого поля", какой выбор технологий, библиотек, промежуточного программного обеспечения и т. Д. Облегчит реализацию обмена сообщениями "публикация-подписка" с надежными подписками в Windows и.NET? Я нашел WCF Peer Channel…
06 апр '09 в 15:23
2 ответа

Ошибка создания экземпляра EventBus в Java

Я пытаюсь использовать EventBus из библиотек Google Guava. Из документации Guava должно быть легко создать экземпляр объекта EventBus. Мой код: package test; import com.google.common.eventbus.EventBus; public class Test { public static void main(Str…
09 июл '12 в 16:31
1 ответ

ActiveMQ, тема не отказов сообщения

Imho, следующий код должен создать новое сообщение, которое снова извлекается. Но выход равен нулю. Зачем? public static void main(String[] args) throws JMSException, NamingException { Properties props = new Properties(); props.setProperty(Context.I…
03 янв '14 в 11:04
2 ответа

Backbone pubsub - глобальное событие, не запускаемое внутри маршрута по умолчанию при загрузке страницы

Я создал объект pubSub с Backbone следующим образом: App.Vent = _.extend({}, Backbone.Events); Я также создал маршрутизатор, который запускает глобальное событие по умолчанию URI: http://localhost/ App.Router = Backbone.Router.extend({ routes: { '':…
1 ответ

Отслеживание сообщений в общественном транспорте

Я использую masstransit в качестве сервисной шины и использую шаблон pub/sub для своего приложения. Я хотел бы выяснить, могу ли я отследить сообщение, которое приходит от автобуса подписчикам. Я использую json сериализатор. Есть ли у МТ некоторая "…
14 июл '12 в 03:43
2 ответа

Связанные предметы в Метеор

У меня есть группы и предметы, и предметы относятся к конкретным группам. На "странице подробностей" группы я хочу видеть все элементы, принадлежащие определенной группе. Я пробовал это Router.route('/group/:_id', { name: 'group', template: 'group',…
1 ответ

Не удается подписаться на канал после успешной выдачи

Вот что я делаю в PHP: $pubnub = new Pubnub(array( 'subscribe_key' => '<SUBSCRIBE_KEY>', 'publish_key' => '<PUBLISH_KEY>', 'secret_key' => '<SECRET_KEY>', 'uuid' => $uuid, )); $grants = $pubnub->grant(true, true, $ch…
25 ноя '15 в 15:44
2 ответа

Как я могу ограничить общее количество одновременных подключений подписчиков к конечной точке издателя ZeroMQ?

При создании службы pub-sub с использованием ZeroMQ в системе Linux, существует ли какой-либо способ принудительного ограничения одновременных абонентов? Например, я мог бы захотеть создать службу издателя ZeroMQ в системе с ограниченными ресурсами …
14 авг '14 в 02:16
1 ответ

Redis Pub/ Sub Design проблема

У меня есть клиент Redis, вот так: var redis = require("redis"); var client = redis.createClient(); client.config("SET","notify-keyspace-events", "KEA"); с 3-й строкой кода, теперь он настроен на прослушивание наборов и удалений ключей Redis. Таким …
23 апр '15 в 19:22
2 ответа

Как показать общее количество элементов и лимитный список элементов в одном шаблоне

У меня есть два раздела на моей странице. Первый раздел имеет ограниченный список предметов. Второй раздел имеет общее количество элементов (recordsCount). Когда сервер добавляет новый элемент, я вижу, что список элементов обновляется, но общее коли…
3 ответа

Ruby и Redis: установите тайм-аут для подписок

Я хотел бы подождать сообщения в канале Redis не более 2 секунд, затем я хочу, чтобы срок действия подписки истек / истекло, и я прекратил блокировать мой код. redis = Redis.new redis.subscribe(channel) do |on| on.message do |channel, message| # ...…
29 окт '14 в 06:56
4 ответа

Железный роутер meteorjs waitOn и использование в качестве данных о рендеринге

Я пытаюсь получить возвращенные данные в моем Template.rendered функция. Текущий код: this.route('editCat', { layoutTemplate : 'layoutCol2Left', template : 'modCategoriesEdit', path : '/mod/categories/edit/:_id', yieldTemplates : _.extend(defaultYie…
10 май '14 в 00:14
1 ответ

Не получать обновления по модели. socket.io с sails.js

У меня есть приложение паруса, созданное с использованием параметров --no-linker --no-front end, Внешний интерфейс приложения написан на angular2, Делая запрос получить и опубликовать, кажется, работает нормально. Когда я отправляю запрос на получен…
3 ответа

Какие методы доступны в Unix для Pub Sub IPC?

Существуют различные варианты IPC. По сети: для клиента-сервера, можно использовать TCP для sub sub можно использовать многоадресную рассылку UDP Локально: для клиент-сервера можно использовать доменные сокеты unix для паба саб, можете использовать?…
14 сен '14 в 00:23
2 ответа

Службы Windows, обменивающиеся данными через MSMQ. Нужна ли служебная шина?

У меня есть эта проблема, когда система содержит узлы (службы Windows), которые отправляют сообщения для обработки и другие, которые извлекают сообщения и обрабатывают их. Это было разработано таким образом, что push-узлы балансируют нагрузку между …
08 окт '11 в 11:24