ZeroMQ，我们可以使用 inproc:transport 和 pub/sub 消息传递模式吗
场景: 我们正在评估事件驱动机制的 ZeroMQ(特别是 jeroMq). 应用程序是分布式的，其中多个服务(发布者和订阅者都是服务)可以存在于同一个 jvm 中，也可以存在于不同的节点中，这取决于部署架构. 观察 为了玩耍，我使用 jero 创建了一个 pub/sub 模式，使用 inproc: 作为传输mq(版本:0.3.5) 线程发布是可以发布的(看起来要发布了
..
publish-subscribe相关内容
android发布/订阅模式
android 中有发布/订阅模式吗? 我想要实现的是我有这个类可以通知感兴趣的一方事件.然后感兴趣的一方可以为所欲为. 来自 .net microsoft 世界，这种东西是内置的. android 有没有类似的东西，或者我必须写一些类似观察者模式的东西? 解决方案 我认为您说的是在应用程序中的类之间传递事件/消息.所以这个问题可能归结为这种模式的 Java 实现.
..
如何在反应本机中使用服务器实现发布/订阅功能
我正在尝试使用 redis pub/sub 在 react native 中构建一个聊天应用程序.已搜索 javascript 的 redis 客户端，但我没有得到.谁能告诉我如何在 React Native 中使用 redis pub/sub. 解决方案 你必须在后端实现 redis，而不是在前端.正如他们在网站上所说，Redis 是一个数据库这里 Redis 是一个开源(BSD
..
如何重定向redis订阅的输出
我正在探索 redis 以进行发布/订阅.我想编写一个脚本，使用 redis-cli 订阅频道并将发布的任何内容转储到文件中.然而，我注意到的是 redis-cli 订阅频道 > 输出不太工作. 非常感谢您的帮助. 问候，卡夏普 解决方案 这是因为当 redis-cli 显示与订阅关联的消息时，没有自动刷新 stdout.所以停止redis-cli之前的最后一条消息不会出现在输
..
在 ROS 中使用来自多个主题的数据 - Python
我能够显示来自两个主题的数据，但我无法在 ROS(用 Python 代码编写)中实时使用和计算来自这两个主题的数据. 您是否有任何想法来存储这些数据并实时计算? 谢谢;) #!/usr/bin/env python进口玫瑰花导入字符串从 std_msgs.msg 导入字符串从 std_msgs.msg 导入 Float64MultiArray从 std_msgs.msg 导入 Flo
..
PHP 实时聊天 +Redis +Pub/Sub +WebSockets (+NodeJS)
我想开发与频道的实时聊天，这是我的需求: 用于管理站点的 PHP 后端 Redis 作为会话和数据的主存储 Pub/Sub 仅向频道感兴趣的用户发送消息 一个用于发送和接收消息的 WebSocket 连接. (可选)NodeJS 使用很棒的 npm 包，例如 timesync 或 socket.io 我看到了两种不同的架构来实现这一点: 使用 Socket.io 使
..
如何使用redis发布/订阅
目前我正在使用 node.js 和 redis 来构建一个应用程序，我使用 redis 的原因是因为发布/订阅功能.该应用程序只是在用户进入用户或离开房间时通知管理员. function publishMsg( channel , mssage){redisClient.publish(channel,JSON.stringify());}publishMsg('room/1/user/b',{
..
Redis/Node.js - 2 个客户端(1 个发布/订阅)导致写入问题
尝试创建两个客户端；一个是发布/订阅，另一个是标准连接.这不可能吗?必须有一种方法可以将其抽象为工作:) 基本上，如果我在运行 test.js 后执行 get key，我看到的只是“valueBefore".输出: node test.js回复:好的/Users/franklovecchio/Desktop/development/node/node_modules/redis/index.js
..
RSS:刷新率?
我正在编写一个小应用程序供我自己使用，它将使用公开发布的 RSS 提要. 据我所知，协议中没有订阅/发布机制；我需要让我的应用程序定期 HTTP-GET RSS 提要. 如果是这样的话，我想每十分钟左右来一次，但我担心被视为施虐者.如果我连续几周看到有人每隔十分钟戳我的服务器，我肯定会担心. 这是一个有效的问题吗?关于什么是“合理"的刷新率，是否有任何一般性建议?我的事实是否直截
..
为什么 Redis 具有 Pub/Sub 功能?
为什么数据存储区 Redis 有 Pub/Sub 功能?我的第一个想法是实现这样的事情是错误的层.但也许我需要跳出框框思考. 解决方案 Redis 被定义为数据结构服务器.Redis 提供了多种功能，如 memcache、队列、pubsub 等.这对于云应用/网络堆栈非常有用，其中 3 个组件 RabbitMQ(queuing) + XMPP(pubsub) + Memcache 当前可以
..
在 Tornado 中处理 Redis 连接的正确方法是什么?(异步 - 发布/订阅)
我将 Redis 和 Tornado 应用程序与 asyc 客户端 Brukva 一起使用，当我查看 Brukva 站点上的示例应用程序时，它们正在通过 websocket 中的“init"方法建立新连接 class MessagesCatcher(tornado.websocket.WebSocketHandler):def __init__(self, *args, **kwargs):su
..
Rails pub/sub 与 faye
在 Rails 应用中，我使用 Faye(机架适配器)来推送通知(用于聊天). 我想将 Faye 用于另一个用例(更多推送通知)，但我似乎无法弄清楚. 在我的应用中，可以从后台作业创建模型，因此我想在创建模型时刷新我的一个视图(比如索引操作). 像这样: app/models/post.rb class Post包括 Mongoid::Documentafter_crea
..
Faye 或 Redis 发布订阅
我以为我了解这项技术，但也许我不了解.两者有什么区别?为什么你会选择一个而不是另一个? 用例:~实时更新. 解决方案 我是 Faye 的作者.从概念上讲，Faye 和 Redis pub/sub 做的事情非常相似，确实 Faye 的最新版本可以使用 Redis 作为后端.正如 Tom 所说，Redis 适用于您的服务器集群内的进程间消息传递，因为 Redis 客户端将可以访问您的整个
..
ActionController::Live 是否可以检查连接是否仍然存在?
我正在尝试使用 Rails 4 的实时流来实现文本/事件流.它工作得很好，我遇到的唯一问题是我无法在不发送任何消息的情况下检查连接是否有效. 我想出的唯一解决方案是使用循环滴答生成器制作支持频道，以便某些后台任务会定期向那里发送消息.但它似乎是凌乱和不可靠的.有什么更好的解决方案吗? 这是我的控制器: 需要'persistency/sse'需要“持久性/跟踪"类 Persistenc
..
什么是 Redis pubsub 以及如何使用它?
有人问我什么是 PubSub 以及如何创建频道(来自 我的回答)，我向他指出了关于 redis.io => http://redis.io/topics/pubsub.我认为这很清楚，但我想知道是否有人有更好的解释.理想情况下，使用 redis-cli 清楚地描述它. 解决方案 发布/订阅是一个非常简单的范例.把它想象成你在广播电台播放脱口秀.那是发布.您希望至少有一个或多个人会选择您的频
..
如何为即时通讯系统设计redis pub/sub?
我是 redis pub/sub 的新手.我在系统中有一个类似于 IM 的聊天工具.所以我想使用redis pub/sub.正如我检查过的样本，其中大部分是基于聊天室设计的.在我的系统中，我将有多个用户之间的聊天室； A:BA:CD:CE:F 所以，上面的线条是房间.我已经使用 node.js 实现了服务器，如下所示； var store = redis.createClient();var
..
ServiceStack:手动调用服务时恢复管道?
作为这个问题的后续，我想了解如何改进手动调用服务.这比我想要的要长，但我觉得需要背景信息. 在进行发布/订阅(广播)时，没有使用 Messaging API 中的正常顺序和流程，而是在收到发布/订阅消息时收到回调，使用 IRedisClient、IRedisSubscription: _subscription.OnMessage = (channel, msg) =>{onMessage
..
Redis PubSub 订阅机制是如何工作的?
我想创建一个发布-订阅基础设施，让每个订阅者都可以收听多个(比如 10 万个)频道. 我认为为此目的使用 Redis PubSub，但我不确定订阅数千个频道是否是这里的最佳实践.为了回答这个问题，我想知道 Redis 中的订阅机制在后台是如何工作的. 另一种选择是为每个订阅者创建一个频道，并在两者之间放置一些组件，这将获取所有消息并将其发布到相关频道. 还有其他想法吗? 解
..
Php在post请求中读取xml
所以，我执行了两个步骤 a) 在其中一个 php 文件中创建一些随机的 xml 文件.b) 在第二个文件中解析相同的 xml 文件. 关键点是a) 中的 .php 文件将向 php 文件 b) 发出一个 post 请求，并且只有 xml 作为它的请求. 文件 b) 必须使用 SImpleXml 读取 xml 文件. 我正在尝试为此做点什么http://blog.superf
..
ZeroMQ:我希望发布-订阅删除旧消息以支持新消息
我使用 ZeroMQ 发布订阅套接字来连接两个进程.发布过程是一个传感器，刷新率比订阅过程快得多.我希望订阅过程只使用队列中的最新消息，而完全忽略旧消息. 我已尝试为订阅者设置高水位标记，但这似乎会丢弃较新的消息，而不是较旧的消息. 有没有人可以为此目的指导我使用发布-订阅模式? 解决方案 从 zeromq 文档(有点新)，我认为这正是您想要的. 来自文档: ZMQ
..