订阅主题未赋值
是指在使用消息队列服务时，订阅者未正确设置订阅主题。订阅主题是消息队列中的一个重要概念，它用于标识消息的分类或者主题。订阅者可以根据自己的需求选择订阅感兴趣的主题，以接收相关的消息。
分类： 订阅主题可以根据业务需求进行分类，例如按照产品类型、地理位置、事件类型等进行分类。
优势：
- 灵活性：订阅主题可以根据业务需求进行自定义，灵活适应不同的场景。
- 解耦性：通过订阅主题，消息的发送者和接收者之间实现了解耦，发送者只需要将消息发送到对应的主题，而不需要关心具体的接收者。
- 扩展性：可以根据业务需求动态增加或删除订阅者，实现系统的扩展性。
应用场景：
- 实时数据处理：订阅主题可以用于实时数据处理场景，例如实时日志分析、实时监控等。
- 事件驱动架构：订阅主题可以用于构建事件驱动架构，实现系统之间的解耦和异步通信。
- 消息通知：订阅主题可以用于消息通知场景，例如用户注册成功后发送邮件通知、订单状态变更后发送短信通知等。
腾讯云相关产品： 腾讯云提供了消息队列服务 CMQ（Cloud Message Queue），可以满足订阅主题的需求。CMQ 提供了高可靠、高可用的消息队列服务，支持消息的发布和订阅，以及消息的持久化存储和重复消费等功能。
产品介绍链接地址： 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
相关·内容
我创建了一个订阅一个主题的参与者来获取消息。这是唯一订阅此主题的行为者。
我想知道，如果由于某种原因，参与者将取消订阅，然后再次订阅同一主题(例如，如果参与者重新启动)，将会发生什么情况。
来自Akka文档()：
当主题参与者没有订阅某个主题的订阅者时，它会将自己从接待员中取消注册，这意味着发布的主题消息不会发送给它。
这意味着什么？这是否意味着在重启之后-没有人可以通过这个主题向这个参与者发送消息？
浏览 0提问于2022-07-26得票数 1
我开发了一个带有嵌入式activeMQ消息服务器的Java应用程序(在GlassFish上)。我可以向我的消息驱动Bean发送消息。现在，我想通过我的activeMQ代理将消息发送回另一个主题。
不会将任何消息传递到主题“答案”。我在activeMQ-web-前端看到了它，没有抛出异常。
我看不出有什么问题。有没有人能给我一个可以搜索的提示？
下面是我的类：
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destination", propert
浏览 1提问于2014-08-22得票数 3
1回答
查看问题的前2条答案(见本文)就会发现，对于导航-属性集合(即entity1.Entity2Collection.Attach(entity2))，存在一个附加方法。问题是，我有VS 2015 / EF 6.1.3 (VB和DBContext)，而且该方法似乎不存在于导航-属性集合(或者至少Intellisense没有显示它)。我做错了什么吗？
浏览 0提问于2017-01-09得票数 0
谁能清楚地解释一下JMS话题中什么是持久的，什么是非持久的？
到目前为止，我有服务器和客户端模型，服务器向客户端发送请求，完成服务器发送的请求，客户端接受请求，并将响应返回给服务器。
我有一个场景，而不是服务器发起的请求发送给我的客户端，我的客户端必须在服务器中查找特定的请求，并将响应发送回服务器。
我可以应用JMS主题来解决这个问题吗？如果任何人清楚地解释，将不胜感激。提前谢谢。
浏览 1提问于2016-03-01得票数 2
1回答
场景:向主题"X“发送通知，过期时间为4周。
在下列情况下会发生什么：
主题不存在，没有人订阅它。一个小时后，有人订阅了它。这个设备会收到这个通知吗？
主题存在或存在(有一个订阅者，但他取消了)，现在他在发送一个小时后再次订阅。它会得到它吗？
一个或多个设备都订阅了主题X。一个新的设备现在订阅它，之后，一如既往，一个小时后发送。它会得到它吗？
有东西告诉我对所有这些答案都是“不”，但是在fcm文档中找到这个答案有问题。
如果我猜对了，得到以前的通知的解决方案是什么？比方说，对于业务来说，这是很重要的，而且通知只存在一个小时，但在这段时间内，他可以更改订阅，在返回之后
浏览 1提问于2018-04-11得票数 0
回答已采纳
我有一个发布者正在发布关于主题的消息，我有2个订阅者S1 & S2正在接收这些消息。当我的发布者发送一条消息，并且两个订阅者都在运行时，他们都会收到该消息。但是，当我的订阅服务器没有启动，而我的发布者发送消息时，当订阅服务器出现时，它们就不会收到消息。我的订阅服务器如何接收未运行的消息？
注意:我正在使用Spring。
MessageProducer.java
@RestController
@RequestMapping("/rest/produce")
public class MessageProducer {
private static final L
浏览 0提问于2019-01-20得票数 0
回答已采纳
1回答
最近我调查了推送服务。
FCM文档指出，对iOS & Android消息的支持订阅数量没有限制。
而且订阅的频率受到项目的限制，因此如果您在短时间内发送大量订阅请求，FCM服务器将返回一个429响应代码。
问题是
FCM发送特定主题的订阅请求。在此之后，如果在短时间内发送大量订阅请求，它将返回一个429响应代码。因此，如果是的话，应用服务器必须处理，在执行指数退避方法时，
FCM是否知道未订阅订阅的数量(=失败的设备)？
当FCM再次发出请求时，它是否只为未订阅的订阅数量(=失败的设备)发送消息？
我想知道。
谢谢。
浏览 1提问于2019-07-09得票数 1
回答已采纳
操作系统:Mac达尔文内核15.6.0版
卡夫卡版本:0.11.0.0
使用python创建一个使用者，group_id = 'my_ group '，使用group方法订阅一个特定的主题= ' assign _ topic '，分区= 0,1,2,3,4，创建五个使用者来消费消息，consumer.assign()不使用使用者的组管理功能。
现在我创建一个新的使用者，使用consumer.subscribe()方法订阅新主题=‘consumer.subscribe’，分区可以动态平衡，分区= 0,1,2,3,4，group_id = 'my_g
浏览 3提问于2017-08-24得票数 1
我在我们的java应用程序中使用logback来记录日志。每当我在日志中遇到错误时，我都希望通过AWS SNS发送电子邮件。我怎样才能在SNS上做到这一点呢？我必须为它编写一个自定义的附加器吗？
浏览 0提问于2017-09-14得票数 0
1回答
我想通过批处理文件自动安装我的MQTT代理，但是批处理文件中的这段代码什么也不做。 用于publishing#的###code @ECHO OFF
cd "C:\program files\mosquitto"
mosquitto_pub -t 'test/topic' -m 'helloWorld'
PAUSE 用于subscribing#的####code @ECHO OFF
cd "C:\program files\mosquitto"
mosquitto_sub -t topic/test
PAUSE 注意:如果我在cm
浏览 29提问于2021-08-08得票数 0
2回答
我正在尝试从主题中取消订阅持久订阅者。
我的应用是一种社交网络:每个用户都是其他用户的话题。因此，每次用户在做某件事时，都会通知他的朋友。当然，订阅者可能取消订阅某个主题，希望不再接收有关用户的通知。
每次我试图从主题中取消订阅用户时，我都会遇到一个错误，告诉我："javax.jms.JMSException:持久性消费者在使用“
这是我的两个类，发送者和接收者。有人能告诉我我做错了什么吗？
发件人班：
package com.citizenweb.classes;
import java.util.Date;
import javax.jms.Connection;
import
浏览 9提问于2016-09-16得票数 0
我正在尝试测试订阅到事件网格的函数。
我发现了以下创建自定义事件的代码：
string topicEndpoint = "https://<topic-name>.<region>-1.eventgrid.azure.net/api/events";
string topicKey = "<topic-key>";
string topicHostname = new Uri(topicEndpoint).Host;
TopicCredentials topicCredentials = new TopicCredentia
浏览 0提问于2018-10-15得票数 0
2回答
可能是GCM的新手问题...
我或多或少了解如何订阅主题以及如何向主题发送消息。但我想知道:主题是如何创建的？
从我读过的文档中，我猜当至少有一个应用程序订阅了一个主题时，它就存在了，对吗？(据我所知，没有专门的api来“创建”一个主题)。
我还注意到，应该可以将应用程序注册到主题，而不是从应用程序本身，而是从应用程序服务器(通过向特定的URL发送HTTP POST消息)。这是同样的工作方式吗？
例如，如果订阅时主题不存在，它将被“创建”？
浏览 0提问于2016-02-05得票数 0
1回答
我想将MQTT消息记录到持久存储中，并记录它们的控制数据包类型，例如CONNECT, CONNACK, PUBLISH, SUBSCRIBE等。具体地说，我想使用SQL来仅应用控制数据包类型为特定类型的规则，例如PUBLISH。这是可能的吗，我没有看到在docs中检索此信息的相关函数。例如SELECT *, [control packet type] as method FROM '#' WHERE method = 'PUBLISH'，其中的括号将替换为我要查找的值。
浏览 20提问于2019-02-01得票数 0
回答已采纳
我目前正在使用stomp客户端库编写两个脚本来订阅消息服务器，write.py用于编写数据，read.py用于获取数据。
如果我先启动read.py，然后运行write.py，write.py将正确地接收消息。
但是，如果我先运行write.py，然后运行read.py，则read.py不会检索以前发送给服务器的任何消息。
下面是脚本的相关部分。
在write.py订阅和检索消息之前，如何实现将read.py放入队列中的消息保留下来？
write.py
def writeMQ(msg):
queue = '/topic/test'
conn = stomp.Co
浏览 1提问于2016-08-25得票数 0
回答已采纳
如果我们必须同时使用沃森IoT平台提供的auth令牌在设备上发布事件到云并订阅MQTT消息，那么将遵循什么方法(在设备上)。当我们尝试发布到某个主题时，当设备已经订阅了某些主题时，连接就会丢失。为了同时发布和订阅，应该遵循什么正确的方法？MQTT连接的详细信息如下，
Client id- <d:orgId:deviceType:deviceId>
Username - use-token-auth
Password - <platform-generated-token>
浏览 3提问于2016-08-30得票数 2
我有一个Android应用程序，我通过firebase向它发送推送通知。现在我正在制作一个Django应用程序，它将在我的服务器上运行。我想使用django应用程序将通知发送到我的应用程序。我开始测试python的firebase管理SDK。我在向学习。我实现了文档中给出的示例代码，你可以看到，它可以在测试的安卓应用程序上工作。问题是我需要设备的注册令牌来发送我没有收集到的通知。或者，我可以向某个主题发送通知，但问题是应用程序用户尚未订阅主题。我之前使用firebase控制台发送通知。我在发送通知时使用了此选项：
使用此选项，我将通知发送给我的应用程序的所有用户。如何使用admin sdk完
浏览 1提问于2019-08-05得票数 0
1回答
我有一个web应用程序，它将消息发布到某个主题，然后是几个订阅这些主题的Windows服务，其中一些具有多个实例。如果消息发布时服务正在运行，那么所有消息都能正常工作，但如果它们不能正常运行，则消息将保留在订阅该主题的队列上，但在服务启动备份时不会读取。
想要的行为-
当消息发布到主题字符串MyTopic时，只从MyTopicQueue读取一次。我使用一些通配符主题，以便将每条消息发送到多个队列，但是服务的多个实例订阅相同的主题字符串，并且每条消息都应该仅由这些实例读取。
如果消息发布时MyTopic主题的订阅者不在网上，则消息将保留在MyTopicQueue.上。
当订阅特定主题的服务重新联
浏览 6提问于2022-03-03得票数 2
回答已采纳
1回答
我试图使用Azure对模式进行编码。基本思想是，我有许多客户端维护与中央服务器的TCP连接。
我想要做的是在服务总线主题上发布消息，然后由这个中央服务器使用这些消息，然后发送给相应的客户机。我认为解决这个问题的正确方法是每个客户端拥有一个队列的语义等价，这将是非常有用的，因为客户端可以随意断开连接，并且消息应该保存在队列上，直到它们重新连接。我希望有强有力的信息传递保证，所以我认为Peek-Lock在这里最好(而不是接收和删除)。
我可以想出几种方法来做到这一点：
维护每个客户端的单独队列。我认为这是太重量级和天真的解决方案。
在中央服务器上启动n个订阅(其中n是客户机的数目)，当新消
浏览 0提问于2014-02-04得票数 0
1回答
我目前正在运行一组拓扑，我希望在运行时更改拓扑属性，如
更改线程计数将源主题添加到现有主题列表添加接收器
是否可以在不停止kafka流的情况下在运行时更改属性。我的一个想法是停止卡夫卡流，然后加载这些配置，然后重新启动。但似乎不是解决这个问题的理想方法。有人能提出更好的方法吗？
浏览 3提问于2020-03-31得票数 0
我有两个云函数，当用户使用我的前端web应用程序进行身份验证时，它会在user对象上设置一个标志，这会触发第一个云函数执行：
exports.observeUserUpdate = functions.firestore
.document("/data/{uid}")
.onUpdate(async (snapshot) => {
const user = snapshot.after.data() as User;
if (user.scanRepositories) {
await pubSubClient
浏览 0提问于2021-10-27得票数 1
1回答
考虑到标准的OnPrem/Cloud混合场景，我们有多个OnPrem客户端连接到云中的一个服务，那么我们如何从一个扩展的服务(即多个为多个客户端服务的侦听器)中为它们提供服务？
假设我们有一个实现混合中继侦听器的云服务，为了服务我们的所有客户端，我们将它扩展到N个实例(最多25个)。客户端通过记录的负载平衡特性分配给每个实例，以便每个侦听器为客户端的一部分提供服务。如果我们需要向所有客户端广播消息(比如聊天应用程序)，怎么办？据我所知，任何一个侦听器都无法访问所有客户端连接。我是不是遗漏了什么？
我以为例，通过站起多台服务器(侦听器)和多个客户端(连接)连接到每个服务器来处理这个场景，但似乎没
浏览 3提问于2017-08-04得票数 0
回答已采纳
我已经在Azure中创建了一个服务总线、主题和对该主题的订阅。我有一个逻辑应用程序，它在消息到达时触发，但我需要应用过滤器(或规则？)在逻辑应用程序处理消息之前，它在消息头中查找特定值。我在逻辑应用或Azure门户中看不到为订阅创建筛选器的任何地方。有什么机制可以为订阅创建筛选器？
浏览 13提问于2018-07-25得票数 0
回答已采纳
我是Azure服务总线的新手，我创建了成功的pocs来创建一个主题和一个单独的订阅者应用程序来接收它的消息。
基于本文，我引用如下：“一个主题可以有多达2,000个与其相关联的订阅，每个订阅可以获得发送给主题的所有消息的独立副本。一个或多个订阅者可以独立订阅订阅，而则与竞争来自订阅的消息。”
我感兴趣的是将其扩展到多个应用程序，以便独立订阅相同的主题，但没有为它们与竞争。
我当前的poc有一个发件人和两个单独的应用程序订阅相同的主题和订阅。我所看到的行为是，如果我从发送方发送一条消息，两个正在运行的订阅应用程序中的任何一个都会收到它，而不是另一个。
我的问题是，多个独立的应用程序是否能够接收
浏览 0提问于2014-01-18得票数 13
我在premise Windows Service Bus 1.0上运行，我得到了异常MessaingEntityNotFoundException 40400: Endpoint not found。
这是因为队列没有被创建吗？我在服务器上看不到可以创建队列的任何地方(我使用的是2K8R2)，当我运行Service Bus配置工具时，它只询问我是否要从场中删除。
我需要添加一个队列吗?如果是的话，是否有一个gui或powershell脚本，或者我做错了什么？
app.config中的连接字符串
<appSettings>
<!-- Service Bus speci
浏览 2提问于2013-03-17得票数 9
回答已采纳
我已经阅读了所有内容:aws文档、IoT文档、控制台文档。
真的没有什么可补充的了：
是否有方法检查AWS IoT主题的订阅者是否和/或有多少？无趣的方式？
问一些模棱两可的问题，但不一样&它没有答案。
浏览 2提问于2017-08-23得票数 1
回答已采纳
我有一个粒子模拟程序，想把它分割到局域网中的多台机器上。每个服务器节点计算多个粒子的位置，并需要将更新的位置(即相同的数据)发送到所有其他服务器节点。因此，每个服务器节点都需要连接到所有其他服务器节点。
这种可靠的全方位通信应该在没有中央服务器/消息代理的情况下工作，并且应该没有延迟。如果可能的话，也应该避免通过网络多次发送相同的数据(就像多播一样)。
我环顾四周， (支持总线、Pub/Sub和PGM)以及 (支持总线和Pub/Sub，但没有PGM)看起来像适合这个问题的伟大库。
在这种情况下，哪种网络技术最适合，消息总线、发布/订阅或多播/PGM？
浏览 1提问于2014-03-29得票数 2
回答已采纳
我有一个订阅主题的队列。我的MQTT客户端将消息发布到该主题。我的Java程序使用JCSMP API使用队列中的消息。但是，我注意到Java程序从队列接收的消息的传递模式是直接的，有时是非持久的。那么，这是否意味着我的消息不会假脱机到SAN？是否可以为我的队列设置主题订阅，以使从该主题接收并存储在该队列中的所有消息都是持久的？
谢谢。
浏览 2提问于2016-03-24得票数 1
让我说我确实有一个主题A和多个关于这个话题的科学研究。是否有任何代用的到期日，或者只要该主题存在，它们是否存在？
重要的是要知道，因为如果我们有一个长期没有使用的订阅，它是否在某个时间点被清理？
浏览 1提问于2018-02-08得票数 3
回答已采纳
3回答
考虑到实体：Topics和Subscriptions具有多到多的关系和相应的表：Topics、Subscriptions、TopicsSubscriptions，我只想使用EF从TopicsSubscriptions中删除一行，但不加载任何额外的数据(除了可能只有一个主题和一个订阅)。
最后，我希望EF生成类似于以下内容的SQL：
exec sp_executesql N'delete [dbo].[TopicSubscriptions]
where (([TopicId] = @0) and ([SubscriptionId] = @1))',N'@0 int,@1
浏览 1提问于2014-02-20得票数 1
回答已采纳
我有一个应用程序，它可以接收不同的通知类型(例如News和Podcast)。目前，它有两个简单的开关，用户可以在其中启用和禁用这些不同的通知类型。它的工作方式只是订阅和取消订阅从相应的Firebase主题类型。明显的优点是设备只接收用户想要的通知，而不必在本地过滤=>电池和数据效率。
问题是，我想把它和新的android通知通道结合起来。我认为唯一的方法是只订阅Firebase中的所有主题，并让用户手动禁用android设置中不需要的主题，这是正确的吗？
有没有更好的方法来节省更多的电池寿命(通过没有收到所有通知)？
浏览 6提问于2017-07-31得票数 6
回答已采纳
我使用的是Active MQ和99%的非持久性主题。对于仅使用非持久消息的一些测试，我尝试了强制代理使用memoryPersistenceAdapter是否会有所不同。我将配置更改为：
<beans>
...
<broker ... persistent="false"*>
...
</beans>
这真的很重要！吞吐量提高约20%。
从理论上讲，因为没有什么是必须坚持的，所以应该没有任何区别。这里发生什么事情？
浏览 4提问于2016-04-08得票数 4
我正在创建用于检查死消息队列的警报系统，在这个中，我看到了两个度量标准:订阅/num_un呈消息和订阅/ in __ message _count。我发现很难理解其中的区别，因为我假设未传递的消息被发布到死消息队列中。如果是这样的话，这些指标报告的不是相同的数字吗？
浏览 2提问于2022-07-14得票数 0
回答已采纳
2回答
我无法理解这个API的设计！
在下面的代码中，我们订阅了一个具有动态分配分区的主题列表。这完全没问题。
KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(properties);
consumer.subscribe(Arrays.asList("some-topic"));
while(true){
ConsumerRecords<String, String> records = consumer
浏览 0提问于2019-07-27得票数 2
1回答
我正在尝试创建一个“警报”应用程序，它必须处理来自多个kafka主题的信息。有数千个主题，但实际上，根据警报配置，在任何给定的时间只需要处理几百个主题。如果我不断地用“订阅”更新我的主题列表，那么再平衡的延迟可能会延迟我的警报。
如何有效地实现订阅一组不断变化的主题的使用者组？
浏览 1提问于2017-09-15得票数 2
1回答
我已经在c中创建了kafka consumer，并创建了一个具有10个分区的主题，当我尝试使用consumer读取数据时，它只从2个分区读取，然后显示没有更多的消息。我尝试使用这两种方法，即订阅和分配，但它们都不起作用。我应该如何将所有10个分区分配给一个消费者，这是将分区分配给消费者的正确方式吗？我已经使用这个存储库和修改了上面存储库的第173和180行号和下面的行构建了自定义消费者，这样我就可以从所有分区消费。但它仍然不起作用。
for(int partition_number = 0 ; partition_number < 10 ; partition_number) {
浏览 59提问于2021-07-16得票数 0
我想要创建一个高可用性集群。但是我找不到任何步骤从IBM文档中创建一个步骤。
我按照指南创建了集群。
这两种QM都部署在坞-组合中：
version: '3.7'
services:
london:
build:
context: ./config/london
environment:
LICENSE: "accept"
MQ_QMGR_NAME: "QM1"
MQ_ENABLE_METRICS: "true"
ports:
- 9443:9
浏览 2提问于2020-05-25得票数 0
回答已采纳
1回答
如果我有如下测试：
it('should return some observable', async(() => {
mockBackend.connections.subscribe((mockConnection: MockConnection) => {
const responseOptions = new ResponseOptions({
body: JSON.stringify(/* some response */)
});
mockConnection.mockRespond(new Response(r
浏览 1提问于2017-04-09得票数 21
回答已采纳
我有一个连接到ActiveMQ服务器的队列生产者(NON_PERSISTENT)和一个队列消费者。如果生产者向队列发送消息，而消费者没有连接到ActiveMQ，那么当消费者启动并连接到ActiveMQ时，消息就会被存储和传递。
如果消费者在传递时没有连接，我希望ActiveMQ忽略该消息。我如何才能做到这一点？
提前谢谢。
浏览 3提问于2018-05-23得票数 0
我希望在确认来自pubsub主题的所有消息后执行操作。我尝试使用Stackdriver监控API来衡量“被云区域分解的未确认消息的数量”，但不理解区域的过滤器以及为什么需要它。在哪里可以看到我的主题所使用的区域？由于一些未知的原因，对于某些主题，API调用完全没有原因地失败。了解是否已确认所有消息的最佳方法是什么？
浏览 0提问于2018-12-01得票数 1
2回答
我见过这个问题的零碎部分，但没有什么能直接回答这个问题。
以下是假设的环境：
20台以Java为中心的服务器(即Tomcat / Glassfish / Jboss /任何东西)通过HTTP与客户端进行通信
服务器前面的HTTP负载均衡器不能保证将您带回到每个客户端连接的同一服务器。
其他任何东西都是可用的，技术上是明智的。(JMS / Camel / Memcached / Hazelcast /任何其他)
我们希望Joe和他的浏览器(可能使用Flash或HTML5或任何客户端技术)接收所有发布到所有20个服务器都可用的JMS主题的消息。
以下是一个例子：
Joe的第
浏览 0提问于2013-01-08得票数 2
回答已采纳
当最后一个主题观察者从主题中取消订阅时，AsyncSubject变得可观察。这是
当它完成了，它就完成了。主题在未订阅、完成或错误后不能重用。
下面是演示：
const ofObservable = Rx.Observable.of(1, 2, 3);
const subject = new Rx.AsyncSubject();
ofObservable.subscribe(subject);
subject.subscribe((v) => {
console.log(v);
});
subject.unsubscribe((v) => {
cons
浏览 2提问于2017-07-14得票数 4
回答已采纳
1回答
主题是否可能有一个订阅者来订阅由多个订阅者自己生成的死信？
例如，一个主题的两个订阅者，分a和子b，如果他们中的任何一个生成一封死信，订阅者“亚死信”就应该把它捡起来。这个是可能的吗？
所有这些的上下文都是一个C#蔚蓝函数。
浏览 0提问于2018-10-10得票数 0
回答已采纳
2回答
我是新使用Firebase消息的。我构建了一个IOS应用程序来接收推送通知。这个应用程序运行良好。我从Firebase控制台发送消息并正确显示。
现在，我正在尝试构建一个web，以允许我的客户发送推送消息(而不访问firebase控制台)。研究文档时，我意识到我总是有一个" to "，意思是一个组、主题或设备id。
我的问题是:我是否可以向所有设备发送消息(就像在控制台中那样)？是的，怎么回事？
提前感谢！
浏览 3提问于2016-09-29得票数 5
回答已采纳
我正在考虑一种可以拥有大量订阅者的单一主题的架构。就像数以万计的个人订户。每个过滤器都有一个SQL过滤器，如下所示：
User = 'SomeUserIdentifier'
只是想知道我是否会在某一主题上遇到最大数量的订阅。
浏览 0提问于2014-01-05得票数 11
回答已采纳
2回答
我刚接触到Azure服务总线，我正在研究它是否可以取代我们的RabbitMQ基础设施。
总之，我想知道使用队列是否有意义？如果主题和订阅提供相同的功能，+为独立于多个来源的用户提供灵活性。
例如，如果我现在只有一个使用者组(可能是多个使用者，但所有共享相同的消息队列)的设置，我可以处理一个只有一个订阅的主题。
排队有什么意义？它是否提供了对主题和订阅的某种优化？
浏览 0提问于2019-02-10得票数 2
回答已采纳
我有一个ActiveMQ Artemis队列使用者，客户机id被设置为主机名。这是在库伯奈特的复制品上运行的。现在的问题是，每当一个吊舱崩溃时，它就被分配了新的主机名，而使用者就失去了它在代理上的状态。有没有办法在整个吊舱生命周期内保持一个一致的客户身份？是否有一种方法可以从代理中分配所有的客户id，以便从一个id池中分配已知的id？
浏览 0提问于2020-08-05得票数 1
回答已采纳
我在这里对如何正确使用ActiveMQ感到有点困惑。
我想做什么，
我有一个系统A，它生成一个虚拟主题的消息。然后是system和C，它们都使用来自同一个虚拟主题的消息。系统B或C有可能脱机。所以当他们回到网上时，我需要他们接收在离线期间产生的所有消息。
到目前为止我尝试过的
我读过关于持久订阅者(和)的文章。这似乎符合我的问题描述，在做了一些实现之后，一切似乎都像我最初想要的那样正常工作。
什么会造成混乱
然后我读到了有关订阅恢复策略()的文章。这是我应该配置的东西，还是我完全误解了什么？例如，如果我想存储指定数量的消息，我是应该配置FixedCountSubscriptionRecover
浏览 10提问于2015-09-05得票数 1
回答已采纳
我有一个MQTT客户端，它订阅多个主题。我设置了clean session、false和QoS 1，以便当我脱机时，消息将被排队。
但是每次我上网的时候，我都会订阅同样的主题，并在init功能上使用相同的标志。会引起什么问题吗？
浏览 0提问于2021-07-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
