一个应用程序中的多个发布/订阅订阅者
在一个应用程序中的多个发布/订阅订阅者是指应用程序中的多个组件或模块，它们可以同时订阅并接收来自发布者的消息或事件。这种模式被称为发布/订阅模式，也被称为观察者模式或消息队列模式。
发布/订阅模式的优势在于解耦和灵活性。发布者和订阅者之间没有直接的依赖关系，发布者只需要发布消息，而不需要关心具体的订阅者是谁。订阅者可以根据自己的需求选择订阅感兴趣的消息，而不需要关心消息是从哪个发布者发送的。这种解耦和灵活性使得应用程序的组件之间可以更加独立地进行开发和维护。
应用场景：
- 实时通信：多个用户可以订阅一个聊天室的消息，当有新消息发布时，所有订阅者都能够接收到。
- 日志记录和监控：多个日志记录器可以订阅应用程序中的日志事件，以便进行日志记录和监控。
- 消息队列：多个消费者可以订阅一个消息队列，以便处理队列中的消息。
- 事件驱动架构：多个组件可以订阅应用程序中的事件，以便根据事件触发相应的操作。
腾讯云相关产品推荐： 腾讯云提供了一系列的云计算产品，以下是一些与发布/订阅模式相关的产品：
- 腾讯云消息队列 CMQ：腾讯云消息队列 CMQ 是一种高可用、高可靠、高性能的分布式消息队列服务，可以实现消息的发布和订阅，支持多种消息协议和消息类型。详情请参考：腾讯云消息队列 CMQ
- 腾讯云云函数 SCF：腾讯云云函数 SCF 是一种事件驱动的无服务器计算服务，可以根据事件触发相应的函数执行，适用于发布/订阅模式的场景。详情请参考：腾讯云云函数 SCF
- 腾讯云物联网平台 IoT Hub：腾讯云物联网平台 IoT Hub 提供了设备管理、数据采集、消息通信等功能，可以支持发布/订阅模式的物联网应用。详情请参考：腾讯云物联网平台 IoT Hub
以上是腾讯云提供的一些与发布/订阅模式相关的产品，可以根据具体需求选择适合的产品进行开发和部署。
相关·内容
我正在开发分布式应用程序(4个实例正在运行并由负载平衡控制。每个实例都是相同的。一个实例将不依赖于另一个实例，每个实例将执行所有操作)。应用程序需要侦听一个名为“结果”的JMS主题。4个实例将使用相同的订阅id侦听相同的主题。我在用骆驼酒吧的潜艇。会发生什么，
所有实例都会得到相同的JMS消息吗？(重复的事务发生在应用程序中)
只有一个实例会得到消息，而其余的实例将不会得到消息吗？
如果问题2的答案是“是”。相同的实例会在所有时间得到消息吗？
如果问题3的答案是“是”，那么另一个实例是否会收到消息，因为该实例已关闭？
I希望在分布式应用程序中实现JMS子，而不需要重复消
浏览 2提问于2016-09-06得票数 3
我想创建一个向多个用户广播流的android应用程序。我正在为广播者和订阅者使用发布者令牌，因为我希望看到来自所有订阅了主流的订阅者的流。因为所有的订阅者都在发布流simultaneously.The错误，我遇到的错误是，当一个新订阅者加入会话时，新订阅者订阅另一个订阅者(用户)的steam，而不是我希望他们订阅的主流。你能告诉我，我如何确保会话中的每个人都订阅来自特定人的特定流？
浏览 13提问于2018-02-07得票数 0
我是新接触JMS.I的。我从hello world开始，我在主题上发布来自java应用程序的消息，并从客户端(node.js javascript).I通过收听它。现在，基于我以前的理论理解，我有了一些疑问，在上面的链接中有什么建议？
根据我的理解，点对点是队列实现，在队列中最多只能有一个消费者订阅，并且只能由该消费者消费。生产者和消费者都不知道每个other.Queue都是托管在消息代理上的，在我的例子中是Apache active MQ。队列可以在消息发布前由生产者创建(也可以通过控制台提前创建)。
在发布/订阅模型的情况下，除了我们使用主题而不是queue.In这个模型之外，它几乎与Po
浏览 5提问于2012-11-14得票数 19
回答已采纳
我正在寻找一种方法来管理来自多个出版商的信息流。
一个人为的例子是这样的。
我的每个发布者都在提交作业，这些作业可以分解为更小的组件，可以按任何顺序进行处理。每个组件都需要几秒钟的处理时间。
发布者A向包含1000个较小组件的队列提交作业。使用者X订阅队列，并开始处理队列消息并将结果发送到结果队列。
作业进行到一半时，发布者B提交了一个包含1000个组件的作业。
我希望Consumer X现在可以在来自Publisher A和Publisher B的消息之间交替，这样Publisher B就不需要在接收结果之前等待第一个作业完成，而Publisher A只是在Publisher B有了作业之后
浏览 16提问于2016-07-29得票数 0
2回答
我试图使用Nservice总线实现publisher订阅者模式，我要做的是：
我有网页应用，用户可以写新闻和添加文件到应用程序使用他的帐户。
我有一个运行在用户机器上的Windows窗体桌面应用程序，他们可以使用访问web应用程序所用的凭证登录这个桌面应用程序。
我需要做的是，当web应用程序上的用户添加新闻或文档时，安装的桌面应用程序应该收到通知，通知它添加的新闻……
我想象我的桌面应用程序将是订阅将从服务器发布的事件的订阅者，我需要知道的是
当多个用户(例如1000名用户)在不同的机器上安装这个桌面应用程序以开始使用它时，在这种情况下，Nservice总线会将他们视为多个订阅者，并将消息副
浏览 11提问于2016-04-05得票数 0
1回答
我需要在我的应用程序中建立与发布者和使用者的点对点通信。我所得到的只是一个话题。因此，我应该确保主题中的消息只使用一次，只有一个实例应该使用它。(使用者有多个实例。)
我理解消息队列是上述需求的解决方案。但我得用这个题目来代替。
我尝试了一个示例应用程序，我所有的使用者实例都使用了主题中的消息。我计划使用一个表来跟踪消息处理，但这似乎不是一个好的解决方案。我们在spring引导JMS中使用IBM。这是可行的吗？
浏览 4提问于2022-03-02得票数 1
回答已采纳
我们希望在spring boot集群环境中实现websocket。我们使用JWT进行身份验证。我知道我们可以使用ActiveMQ或RabbitMQ作为stomp代理。但是我们已经在使用redis了，我们能不能使用redis，因为我们不想增加维护另一个消息服务的额外开销？
浏览 3提问于2017-08-28得票数 3
1回答
我正在尝试学习GCP Pub/Sub，并且对于Pub/Sub中的消息的生命周期有一个问题。事实上，我使用作为我的参考。在这篇文章中，他们说：
一旦每个订阅的至少一个订阅者确认了该消息，Pub/Sub将从存储中删除该消息。
因此，我的Subscription第一个问题是:例如，我有一个订阅 A，它连接到订阅服务器X et 订阅服务器 Y。根据这些文档，当订阅者<code>E 214</code>X接收到消息并将ACK发送到A时，Pub/Sub将删除存储中的消息，而不考虑<code>E 117<//code>订阅者<code>E
浏览 7提问于2021-03-23得票数 0
回答已采纳
1回答
目前，我们正在寻找mqtt将我们的控件连接到互联网上。在我们的应用程序中，恒温器将是服务器/发送者，电话应用程序可以是客户端。
据我所见，该协议适合于向连接的客户端发送测量的温度。但我看不出有什么办法写回一个设定点。这可以通过第二个连接完成，就像手机应用程序的恒温器。能用另一种方式做吗？
浏览 1提问于2016-02-01得票数 1
回答已采纳
我正在尝试创建一个事件处理程序，它将遍历相同类型的委托列表，并在需要时调用它们。我最终想要的是一个“主”处理程序，它控制调用哪些子处理程序(这是用于实现默认事件处理的嵌套状态机，因此如果在嵌套级别中处理事件，则阻止它向上传播到更高级别)。 我最简单的解决方案是只订阅“最深”的事件处理程序。但这并不是我真正想要的行为，我希望该处理程序的主体表明它是否真的“处理”了事件，如果它没有“处理”事件，则调用下一个级别。 所以我的第二种方法是事件只有一个实际的订阅者。这会依次遍历委托列表，并使用修改后的方法签名调用它们，如果它处理了事件，该签名将返回一个布尔值。 我的.NET事件定义：
浏览 27提问于2019-04-06得票数 0
AWS的之一是通过设备网关提供双向通信.知道实现是私有的，有人能从概念上解释网关如何能够将消息推送到本地网络上的设备上吗？服务是否保持与设备的持久连接？
为了添加上下文，在我使用AWS IOT之前的经验中，如果我想与我的嵌入式应用程序(使用HTTP)通信，我需要设置端口转发，所以这对我来说是一个谜，为什么设备网关可以在没有这一步的情况下工作。
浏览 0提问于2018-02-22得票数 1
回答已采纳
1回答
我有一个web应用程序，它将消息发布到某个主题，然后是几个订阅这些主题的Windows服务，其中一些具有多个实例。如果消息发布时服务正在运行，那么所有消息都能正常工作，但如果它们不能正常运行，则消息将保留在订阅该主题的队列上，但在服务启动备份时不会读取。
想要的行为-
当消息发布到主题字符串MyTopic时，只从MyTopicQueue读取一次。我使用一些通配符主题，以便将每条消息发送到多个队列，但是服务的多个实例订阅相同的主题字符串，并且每条消息都应该仅由这些实例读取。
如果消息发布时MyTopic主题的订阅者不在网上，则消息将保留在MyTopicQueue.上。
当订阅特定主题的服务重新联
浏览 6提问于2022-03-03得票数 2
回答已采纳
1回答
来自
以更高的开销为代价，您可以使用Session.createDurableSubscriber方法创建持久订阅服务器。持久订阅一次只能有一个活动订阅服务器。
你能解释为什么如此选择设计吗？
从我的角度来看，话题是被入侵的，特别是在我们有很多订阅者的情况下。
浏览 2提问于2017-08-22得票数 0
我正在寻找一个可伸缩的pub子集群，如果有订阅者，发布者可以只向socketcluster发送给定主题的消息吗？ 原因是，我所有的发布者都在为许多主题处理数百万条消息，而这些主题在很长一段时间内都没有订阅者。因此，在计算和价格方面，将所有内容都发送到pub sub集群是一种巨大的浪费。
浏览 23提问于2020-07-14得票数 0
回答已采纳
我想知道，如果我们在JMS队列中有多个消费者，我们如何区分哪个消费者将从队列中获得消息？例如，如果我们有1个生产者和3个消费者(以及1个队列)，我如何知道哪个消费者将获得消息？
谢谢
浏览 1提问于2010-11-28得票数 0
回答已采纳
2回答
在JMS发布/订阅模式中，两个使用者订阅相同的主题。一个消费者正在运行，但是当生产者发出消息时，另一个消费者关闭了，它仍然为没有运行的消费者保存消息吗？
谢谢
浏览 2提问于2013-03-26得票数 1
1回答
观察者模式与事件总线消息方法
、、、、
我一直在仔细研究MVC实现和事件总线。
为什么不使用事件总线而不是观察者模式来实现MVC应用程序呢？
例如，假设我有两个类Model和View，在典型的观察者模式中是：
public class Model implements Subject { ... }
public class View implements Observer { ... }
相反，使用或任何其他事件总线的方法的好处/缺点是什么？
应该是这样的：
public class Model {
private int field = 0;
void someFunctionNowTriggerStateCh
浏览 0提问于2019-07-14得票数 4
我正在开发一个使用Google /Sub作为消息代理的分布式、高度可伸缩的应用程序。在阅读文章时，我喜欢订阅过滤器的pub/sub功能。
我想要有一个有多个订阅的单一主题。多个发布者将向同一主题发布离散消息。每个订阅都将使用属性筛选器来提取特定于其需求的消息。
有人知道使用pub/sub订阅过滤器的缺点吗？我应该继续使用这种单一主题的方法，还是为每种消息类型创建单独的主题？
浏览 4提问于2022-07-11得票数 3
回答已采纳
1回答
我正在为一个中型系统测试ZeroMQ作为发布-订阅(服务总线风格)基础架构。我们大约有50个节点，它们都应该是发布者和订阅者。网络是一种星型拓扑，但边缘相互“对话”。我们需要动态发现(不需要对参与者的网络地址进行硬编码)，但也不需要SPOF (单点故障)。
我读过，据我所知，建议的动态发现0MQ方法涉及一个代理节点(XPUB/XSUB)，它转发订阅和发布。我考虑过在我们的系统中使用这样的代理作为中心中介器，然而，我对这种体系结构有以下担忧：(A)代理节点是SPOF -当它发生故障时，整个系统不起作用(B)所有流量，包括数据，都通过代理节点，这意味着延迟和性能问题。
假设我正确理解了发布-订阅白
浏览 9提问于2013-08-20得票数 12
1回答
我试图从一个程序发送一个视频流到任意数量的客户端(比如0-10个客户端)。
我可以很容易地用一个发布者和一个订阅者来完成这个任务，但是如果我启动另一个客户端应用程序，在我关闭第一个应用程序之前，它不会接收到任何数据。
我的代码如下所示：
服务器
import zmq
import imageio
import simplejpeg
context = zmq.Context()
publisher = context.socket(zmq.PUB)
publisher.connect("ipc:///tmp/v4l")
gif = imageio.get_reader
浏览 9提问于2021-06-28得票数 0
回答已采纳
通过阅读wiki中的部分，您似乎可以使用单向模式在rebus中进行单向发布。但我认为单向模式只允许bus.send？
如果在一个场景中，有两个应用程序都可以发布SomethingHappened消息，但是只有一个应用程序应该处理来自ProcessManager的答复，例如DoSomethingElse，，我应该如何为这两个应用程序配置rebus？
问候
阴
浏览 4提问于2014-09-01得票数 1
回答已采纳
从kafka，rabbit，hornet mq，activemq等系统的消息传递角度来看……pub/sub和prod/con之间有区别吗?还是可以互换使用？
浏览 100提问于2017-02-27得票数 32
回答已采纳
虽然我看过了指南，但我找不到一种方法来做以下事情：
我们有n个出版商，
我们有百万订阅者。
每个订阅者订阅某种类型的消息(一个发布者可以发送一种以上的消息，多个pubs可以发出相同类型的消息)。
如何在0MQ中创建N到N(或N到1到N)模式？
浏览 2提问于2012-09-04得票数 8
当从私有存储库()推送/拉取任何映像时，docker存储库向端点提供通知。Google Cloud镜像存储库是否提供了类似的通知机制？这篇文档谈到了发布者应用程序，它将发布消息到pub-sub，但我不清楚-1) GCR是否会直接将消息发布到pub-sub 2)如果不是，如果我必须编写一个发布者应用程序，它如何知道我的存储库上的任何更改。我可能在这里遗漏了一些非常基本的东西，请帮助我理解流程。
浏览 1提问于2018-02-20得票数 0
2回答
我是JMS的新手，目前正在开发一个简单的聊天应用程序，在Oreilly的“Java消息服务”中解释道。我已经在ActiveMQ中配置了一个TopicConnectionFactory，它接收来自TopicPublishers的聊天消息并将其发送到TopicSubscribers。
我的问题是“为什么我们需要在任何JMS应用程序中创建多个TopicConnectionFactory”？既然Connectionfactory实例不与主题/队列捆绑在一起，为什么我们不能使用一个ConnectionFactory实例来创建到应用程序中配置的所有主题(或队列)的连接？
浏览 1提问于2014-03-18得票数 1
2回答
我在三个城市有相同的数据库，每个数据库有三个表：
1- tbl_worker
2-tbl_workshop
3-tbl_users
and cities are:city1,city2,city3
city2 and city3在它们的数据库中插入信息。
city1数据库应该从插入到city1 and city2数据库中的数据每1小时更新一次。
例如，插入到tbl_kargah中的city1 and city2数据库中的数据应该每1小时合并并插入到city1数据库的tbl_kargah中。
使用复制是否包括我的需求和哪个复制？
正如我在MSDN中所看到的那样，publisher在订阅服务器中分
浏览 0提问于2011-04-20得票数 4
1回答
是否有可能在webspehre mq队列上建立双向复制，以便像数据库集群一样工作，其中数据被复制到所有成员实例想象以下场景：
队列管理器
QM1
DESTINATION.QUEUE
RESPONSE.QUEUE
QM2
DESTINATION.QUEUE
RESPONSE.QUEUE
应用程序
application A issues **put** on DESTINATION.QUEUE@QM1
application B issues **get** on DESTINATION.QUEUE@QM2
application B sends response
浏览 1提问于2012-10-10得票数 1
回答已采纳
由于我每次都需要最新数据的应用程序不会发送更改通知，因此我需要每秒轮询一次才能获得更新。由于我每秒需要更新的项目有数千个，所以我想设计一个有数千个轮询器的应用程序，当然，我会欢迎您提出更好的解决方案的建议。
从了解到，每台服务器上的Java都可以支持很多线程。我只想提一下，我不受语言的约束。
现在，我正在试图弄清楚如何使其可伸缩，并使其在分布式环境中工作。
一种想法是创建一个主服务器，其中包含要轮询的数千个项目的列表。它将它们中的一小部分传递给从服务器进行轮询，同时从这些服务器获取心跳。另一个是关于服务器之间的对话，共享索引范围(可能是S3中的文件)，彼此了解谁在处理哪些项目。我甚至不确定他们
浏览 2提问于2017-09-16得票数 1
我目前正在尝试api管理器(1.6).Is，有一种方法可以将api的每个使用者限制到一个特定的限制(请求/秒)？
我看到了在发布服务器级别(作为发布服务器)和应用程序级别(在api存储中)节流的选项，但这与指定每个订阅服务器可以调用多少api并不相同。
另外，应用程序级节流在api存储中意味着什么？它是指定一个应用程序可以进行多少次总的api调用？
浏览 0提问于2014-06-27得票数 0
回答已采纳
我是Azure Service Bus的新手，我想知道是否可以多个订阅者订阅一个队列或主题？在rabbit中，我可以拥有一个发布者的多个订阅者。
我尝试做的是，我正在使用CQRS，当某些命令进入系统时，当事件被处理时，我希望将它们推入消息队列。
我希望2个订阅者能够从该队列中获得消息，一个供我在内部处理。另一个用于处理并向外部发送。
浏览 0提问于2017-08-25得票数 11
回答已采纳
嗨，我有元数据，HashMap对象，需要在我的Actor类中被访问，并且需要被查找。如果找到密钥，我应该在Actor业务逻辑中使用它。如果找不到，我需要创建一个键和值，并更新HashMap对象。
那么如何在演员系统中处理这个问题呢？如您所知，每个参与者实例将同时生成一个未找到的键，这将导致重复和不恒定。那么，处理这种情况的行业标准是什么呢？请提供您的意见，如何处理它。
浏览 0提问于2019-08-21得票数 0
回答已采纳
我想知道我是不是无意中使用了设计模式？请帮帮我。
我有一个应用程序，它将生成事件(event1，事件2，...事件n)。
我还有另一个库(Event Hanlder Library)，其中编写了事件处理方法。
我使用一个接口(通信器)，它的方法是由事件处理程序库实现的"GenerateEvent“。
最后，生成事件的主应用程序...使用反射来加载事件处理程序库，并在运行时根据event no，挂钩( event handler的)特定于事件的类。主应用程序使用接口方法GenerateEvent发送事件
这是一种设计模式，因为在两个程序集之间使用接口来共同工作吗？我可以在伪代码方面提供更
浏览 0提问于2012-08-01得票数 1
我在一个微服务架构中工作，并在k8s中部署它们。对于不同应用程序之间的通信，我们使用Azure eventhub来发布和订阅事件。我的问题是，如果一个应用程序的多个实例( POD )正在运行，那么subscribed事件回调将在单个POD中触发还是在每个POD中触发？ 是否需要将PODs划分到不同的消费群中？
浏览 17提问于2020-08-12得票数 0
Transaction包含一个或多个LineItem。一个LineItem与一个Item有关系。每个Item都有一个数字字段，表示库存中的数量。
使用这种方法，每个Transaction创建都需要减少Item中的数量。如果用户更新Transaction，则需要调整Item中的数量。如果用户删除Transaction，则需要增加Item中的数量。
在域模型层中实现此规则或行为的最佳方法是什么？Transaction操作(如创建、更新或删除)位于数据访问层。
浏览 0提问于2013-05-18得票数 0
回答已采纳
2回答
我偶然发现了webhook和发布者/订阅者的概念。在webhook中，当依赖的应用程序发生更新时，第三方应用程序发送信息，第三方将发送HTTP post请求到您的应用程序的上述URL，而在发布者和订阅者中，订阅者将注册主题并对该主题进行发布者写入，然后注册者(如第三方)将基于订阅的主题将信息发送给订阅者。
两者是相似的还是不同的？
我很困惑，有没有人能解决这个问题？
浏览 1提问于2017-07-22得票数 5
1回答
我正在尝试从mysql数据库中读取数据，它基本上是PIN码，并将其与附近位置进行比较。
我需要每隔2秒检查一次数据库中的新记录，而不需要刷新rails应用程序中的页面。有没有可能。
浏览 0提问于2018-02-16得票数 0
2回答
由于SQS对支持多个使用者并行处理消息有限制。即。进程1选择m1到m10，进程2选择m11到m20，等等。有重复。由于SQS不支持这一点，所以我考虑使用SNS + SQS (订阅的队列列表)，其中每个进程侦听其特定的队列和进程记录。
在SNS和SQS之间是否有像循环一样设置的选项，以便SNS以循环的方式将消息分发给SQS，从而使每个队列具有唯一的消息而不会跨队列重复？
提前感谢！
你好，库马尔
浏览 0提问于2018-03-28得票数 0
回答已采纳
1回答
在探索新API akka.actor.typed，中的分布式发布订阅时，我们看到分布式发布订阅是通过使用一个参与者akka.actor.typed.pubsub.Topic.表示每个发布子主题来实现的。为了模拟同样的情况，创建了一个本地akka集群，其中3个种子节点，其中一个充当发布者，另外两个是使用者。在使用时，我们看到两个订户都在接收相同的数据，即去重复不会发生。请查找发行者的示例代码：
object PubApp {
def pubsubImplementor() = {
val pubsubGurdian = Behaviors.setup[Unit] { (conte
浏览 9提问于2022-03-22得票数 1
最近我读了一篇物联网的文章，他说，通过协议，客户端可以通过一对多和多对一的方式进行通信。在mqtt规范本身中提到了一对多，但我在多对一中几乎没有混淆。我所理解的是，许多客户端在同一主题上发布，并且这些不同的publishers.Then只有一个订阅者，订阅者(用户)应该如何识别消息属于哪个发布者？另一个疑问是，如果两个发布者使用相同的主题发布他们的数据而不知道对方，因为每个客户端都连接到互联网，订阅者将获得这两个数据。但这并不是订阅者expected.He想要的仅来自一个发布者的数据。在mqtt通信中有没有可能发生同样的情况？
浏览 1提问于2015-09-12得票数 8
刚刚开始学习NServiceBus，并试图理解它的概念。当它谈到队列时，我们是在谈论发布者和订阅者上的MSMQ吗？因此，如果我有一个应用程序生成了某个东西的列表(比如动物的名字)，那么它会将该列表转储到publisher的队列中。发布者每分钟轮询队列一次，如果队列中有内容，它将发布到订阅者的队列中进行进一步处理。这有意义吗？
谢谢。
浏览 1提问于2011-03-02得票数 2
回答已采纳
现在我正在做一个项目，主要使用ActionScript 3.0在RTMP上移动视频流(服务器端使用了一点2.0 )，我们已经有了在客户端级对这些视频流的带宽使用进行节流的功能。然而，我们只能通过调用类Camera的setQuality()方法来实现这一点，它会影响该视频流的每个接收器。现在，虽然我们确实需要一种方法来有效地设置单个接收器的带宽使用，但显然VideoDisplay、NetStream和NetConnection都几乎没有这种功能。在AS3中没有什么好的方法可以做到这一点吗？如果有办法，怎么做？谢谢!
编辑:为了清楚起见，假设视频流的发送方将其摄像机对象的质量设置为使用1兆的带宽。
浏览 7提问于2012-09-28得票数 0
回答已采纳
嗨，我想知道是否有一个模式来对发布者-订阅者模式进行单元测试？
有什么例子或建议吗？
谢谢
浏览 3提问于2011-05-18得票数 2
回答已采纳
我正在寻找一种方法来实现这一点。
假设我有10个节点订阅到同一个队列。他们中的一个发布了这条消息。但我希望消息只传递到所有连接的节点中的一个节点。
此外，该节点将决定是否希望更多节点处理相同的内容，然后再次发布该内容并获得额外的帮助。
用ActiveMQ能做到吗？如果不是，还有什么适合这个要求？
谢谢
浏览 0提问于2013-01-17得票数 0
3回答
我希望定期从后端触发一个推送通知。做这件事的最好方法是什么？我想要有一个“cron”的表情，我会安排每一分钟。我正在做股票应用程序，我需要向用户发送一个关于股票涨跌的通知。我已经将前端和后端与客户端触发的通知集成在一起了。但是我需要从后端触发它，而客户端不需要每秒触发它，因为它会影响性能。
我的应用程序在react、node和AWS中。
浏览 4提问于2020-07-06得票数 1
回答已采纳
3回答
我正在尝试用ZeroMQ设置“倒置”的发布/订阅。
这意味着订阅(子)套接字属于多个长期存在的服务器，执行zmq_bind()；而发布(PUB)套接字是一个短暂的客户端，执行zmq_connect()。
我使用单个ipc://套接字。
我期望来自发布者的消息将到达每个订阅者。
问题是:只有一个订阅者进程会收到消息。如果这个过程结束了，publisher就会被zmq_term()卡住。
zmq是否支持这种操作模式？如果是，那么我做错了什么？如果没有，那么如何实现我需要的内容？
带有一些附加细节的最小示例(在Lua中，但这不重要)：
浏览 1提问于2011-04-23得票数 6
回答已采纳
我有多个需要通知某些事件的微服务。所有这些微服务都运行在Cloud Run上。鉴于Cloud Run可以缩减到0个实例，我假设推送模型更适合我们的情况。 问题出现在需要将通知发送到多个端点的情况下。例如，我们有一个OrderService、一个InventoryService和PaymentService。后两者都需要监听“OrderPlaced”事件。问题是，我们如何才能在不显式调用它(例如，使用任务队列)或在OrderService中创建依赖项的情况下，将此消息推送到这两个服务？有没有一个“Google Cloud”的方法来解决这个问题？ 我已经考虑过创建“拉”监听器，但问题是Cloud
浏览 38提问于2020-04-26得票数 0
回答已采纳
我正在尝试将PubNub iOS SDK集成到我的项目中。如何确认已发布的消息已送达？
浏览 13提问于2016-08-10得票数 0
回答已采纳
1回答
我已经开发了应用程序，我已经将它部署到了亚马逊的EC2映像中--这一切看起来都很棒。
但是，我需要在位于不同机器上的应用程序的多个实例(即不在同一个Tomcat容器中)之间自动缩放和共享用户请求。Amazon管理负载平衡，应用程序使用AMQ主题在每个实例之间传递关键应用程序级别的更改。
其中一个通知可能是属性。我有几个属性文件，我使用@Value注释注入了相关的Spring。这些属性文件驻留在属性文件夹中，类路径根(classpath: properties /)
在单个节点上操作时，当我更新一个属性时，我使用setter更新内存中的值，并使用FileInputStream和FileOutpu
浏览 4提问于2012-08-29得票数 1
回答已采纳
我正在构建一个win应用程序，该应用程序具有针对sql数据库的用户访问控制，所有数据也存储在此数据库中。这个项目将被安装在一个站点的30-40台机器上(我的意思是说，它不是web，它都在一个地方，最多称为intranet)。
我希望当程序登录时，登录的用户应该能够与其他登录的用户聊天。
在C#和VB中有什么推荐的方法吗？我将感谢任何想法，链接或提示。
请与我分享你的经验，谢谢！
注意:如果重要的话，这个程序是用Wpf编写的。
浏览 0提问于2009-07-22得票数 1
回答已采纳
1回答
我正在尝试使用pyzmq的内置日志处理程序为我的分布式应用程序实现一个集中式日志服务器(请参阅)。尽管从体系结构的角度来看，我可以理解PUB/SUB模式的使用，但我不能掌握这样一个系统的正确的技术实现。
根据我到目前为止所理解的情况，由于我将有N个单独的进程在N个单独的端口上发布，我确实需要N个单独的记录器来捕获所有的消息。
因此，这意味着我需要为系统上的每一个新出版商打开一个单独的“侦听器”进程？
编辑：来澄清这个问题:在pyzmq提供的工具的上下文中，如何实现集中式日志服务器？
浏览 5提问于2014-03-19得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
