我已经做了3个客户端连接到一个订阅，和一个发行商。在图像2中，订阅在终端上，一个订阅不被看作是托管在DigitalOcean液滴上的订阅。似乎每5条消息，它切换的订阅者实际上收到的消息，这是不应该发生的。我也改变了速度，它总是大约5条信息。以下是用于订阅的所有客户端的代码： console.log(`Message:1 ${msg.data.toString(&qu
浏览 2提问于2019-11-06得票数 2
回答已采纳
2回答
当消息到达时，对主题的订阅是否需要一直处于活动状态？当消息到达主题时，如果订阅服务器没有活动，那么稍后启动订阅服务时我会收到消息吗？
浏览 6提问于2022-08-07得票数 0
回答已采纳
我正在寻找一个可伸缩的pub子集群，如果有订阅者，发布者可以只向socketcluster发送给定主题的消息吗？原因是，我所有的发布者都在为许多主题处理数百万条消息，而这些主题在很长一段时间内都没有订阅者。因此，在计算和价格方面，将所有内容都发送到pub sub集群是一种巨大的浪费。
浏览 23提问于2020-07-14得票数 0
回答已采纳
2回答
我正在从事一个Nodejs项目，该项目发布和订阅Google平台PubSub的数据。目前，我通过提供订阅名称来订阅Google平台PubSub。但是为了提高性能，我建议找出一种方法，我们可以使用PubSub主题名而不是订阅名来订阅主题。我们有办法做到吗？
浏览 5提问于2020-09-04得票数 2
回答已采纳
希望建立一个aws SNS主题-我打算向第三方订阅这个主题，我希望我可以使用它的消息过滤来确保所述第三方只获得他们需要的消息。
这有可能吗？
浏览 2提问于2019-02-27得票数 0
2回答
在JMS发布/订阅模式中，两个使用者订阅相同的主题。一个消费者正在运行，但是当生产者发出消息时，另一个消费者关闭了，它仍然为没有运行的消费者保存消息吗？
谢谢
浏览 2提问于2013-03-26得票数 1
1回答
Azure服务总线主题，订阅丢失
、、、、
我有自动创建订阅使用从持续数周开始(当我们获得流量增量时)，有时我们的订阅客户端停止接收消息await OnMessageReceived(message, $"{_subscriptionClient.SubscriptionName}", token), messageOptions);
订阅客户端是否有可能断开连接而不再连接我有4-5个客户端进程连接到这个主题，每个客户端都有自己
浏览 1提问于2018-08-03得票数 0
一个是通知程序进程( notifier )，它运行在媒体服务器上，并在修改文件时使用NServiceBus发布消息。另一个是MVC web应用程序(PhotoWeb)，它订阅这些消息以执行缓存失效等。UnicastBusConfig>--我误解了队列实际上是什么--而PhotoWebInputQueue实际上是一个共享的网络资源，而不是特定服务器的本地队列--以前的部署导致NServiceBus订阅了暂存web服务器上的活动webmedia队列，并且这种订阅在重新启动期间
浏览 6提问于2011-12-02得票数 0
回答已采纳
2回答
我正在努力理解持久订阅。我知道当监听器将自己注册为一个主题的持久订阅者时，它会告诉JMS -“嘿，我是一个持久订阅者，从现在开始，如果我不在，你需要将所有消息存储在主题中，并在我回来时将这些消息传递给我。”现在，如果是这样的话，为什么两个订阅者不能请求这个持久订阅呢？
我是不是遗漏了什么？
浏览 1提问于2012-11-08得票数 0
回答已采纳
我有一个主题有一个订阅的公共服务。nodejs服务器的每个实例都侦听订阅。每当有消息时，如果它被传递到任何一个服务器实例，其他实例就不会接收它。是否有办法让每个实例接收消息？还是必须为每个实例创建单独的订阅？
浏览 0提问于2019-03-27得票数 0
回答已采纳
2回答
我曾问过是否会在某个主题中保留一条消息，我从那里得到了大部分答案。
但是这种情况如何?假设代理已经重新启动，并且一些发布者已经开始向某个主题发送消息，现在一些持久订阅者将与此主题连接，但目前还没有持久订阅者，因此如果代理重新启动，发布者发送到该主题的所有消息到现在都会丢失？而且，我尝试过这种情况--我有一个活跃的持久订阅者，它能够将消息推送到主题上，然后它被关闭，同时更多的消息被推送到主题上，然后代理重新启动，最后所有的增量消息都丢失
浏览 1提问于2017-04-18得票数 0
回答已采纳
当您想要在Google /Sub之上实现生产者/消费者模式时，您会期望每条消息只能由一个使用者处理。但是Google /Sub会将每条消息发送给所有订阅者。但是AWS/SQS具有以下特性以方便地保证这一点：
当接收到一条消息时，它在被处理时变成“锁定”。这使其他计算机无法同时处理消息。如果消息处理失败，锁将过期，消息将再次可用。
浏览 2提问于2017-02-27得票数 2
回答已采纳
当我希望向特定用户发送消息时，我使用映射来确定要在哪个主题上发布它。这就引出了我的问题--我如何用PubSub实现这一点？
目前我使用的是请求订阅，是否需要使用推送订阅？In传递拉模式，如果
浏览 1提问于2021-06-20得票数 1
回答已采纳
1回答
我有一个有多个订阅的主题。当其中一个订阅失败时，消息将被移动到DLQ。有没有办法找出哪个订阅失败了？如果再次处理相同的消息，那么如何确保已经处理该消息的订阅不再处理它？
浏览 6提问于2022-10-17得票数 0
1回答
我正在使用activeMQ进行消息传递。当发送方和接收方都可用时，我成功地接收到了消息。但是当我放下接收器并重新启动时，排队的消息就不会再被接收到接收方了。我需要做什么配置吗？
浏览 3提问于2019-11-28得票数 0
回答已采纳
在最新的更新中，Pub/Sub添加了对以前处理过的消息的支持，这是一个值得欢迎的变化。我在他们的文档中找不到的一个特点是，我们是否可以有类似于Kafka的消费者组，即有一组订阅者，每个用户处理来自同一主题的数据，并且能够从一开始就为一些订阅者(消费者组)重新处理数据，而其他人则不受其影响例：你有两个消费群体CG2:和另外两个消费者
在Kafka中，我可以在这些组之间独立地阅读消息，但是我可以用Pub/Sub做同样的事情。卡夫卡允许你从一开
浏览 0提问于2019-11-14得票数 1
回答已采纳
我正在使用回调函数向google发送消息，该函数读取来自未来的消息id。我正在成功地接收消息id，但现在出现了错误/异常，但是我发现有些消息没有被读入pubsub (当从GCP控制台查看消息时)。如果是这样的话，“丢弃”消息的原因是什么？
浏览 4提问于2019-09-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
