在从生产者发布消息时，是否每次都将架构Id作为记录的一部分发送，还是仅为新注册的架构发送？
在从生产者发布消息时，通常只需要将新注册的架构Id作为记录的一部分发送，而不是每次都发送架构Id。这是因为在消息发布过程中，架构Id主要用于确保消息的消费者能够正确解析和处理消息。一旦架构Id被注册并与特定的消息结构关联起来，后续的消息发布可以仅发送该架构Id，而不必每次都发送完整的架构信息。
通过将架构Id作为记录的一部分发送，消费者可以根据该Id来获取相应的架构信息，并使用该信息来解析和处理消息。这种方式可以减少消息的传输量，提高消息发布的效率。
对于这个问题，腾讯云提供了一种解决方案，即使用腾讯云的消息队列服务CMQ（Cloud Message Queue）。CMQ支持消息发布和订阅，可以通过注册架构Id来确保消息的正确解析和处理。您可以使用CMQ的API来发布消息，并在消息中包含架构Id作为记录的一部分。消费者可以通过订阅相应的主题来接收消息，并使用架构Id来获取相应的架构信息。
更多关于腾讯云消息队列服务CMQ的信息，请访问腾讯云官方网站：腾讯云消息队列服务CMQ
相关·内容
如果订阅的客户端和发布消息的服务器都保持连接，那么Redis是否保证即使在客户端和/或服务器压力很大的情况下，最终也会始终将发布的消息传递给订阅的客户端？或者我应该考虑到这样一种可能性，Redis可能会在事情变得“热门”时偶尔丢弃消息？
浏览 31提问于2014-05-15得票数 16
我正在尝试使用Azure Service Bus主题来允许服务使用MassTransit消费消息。一条消息被发布到一个主题，每个订阅了该主题的服务都会收到一份该消息的副本。每种消息类型都有一个主题。
问题是，一旦解决了异常的来源，如何处理错误。一旦消息出错并最终进入_error队列，我希望在消息和/或服务修复后将消息移回进行处理。我不能将消息从_error队列移动到主题，因为该主题上的每个服务都会再次收到该消息。
我尝试使用名为_errorecovery的ReceiveEndpoint方法创建第二个队列，但这样做会导致队列订阅该主题，这意味着_errorrecovery队列将获取发布到该主题的
浏览 2提问于2020-07-09得票数 0
我有两个服务，一个是生产者(服务A)，另一个是消费者(服务B)。因此，服务A将生成一条消息，该消息将发布到Amazon SQS服务，然后在服务B订阅队列时将其交付给服务B。因此，在我拥有服务B的单个实例之前，它工作得很好。
但是，当我启动服务B的另一个实例时，现在有两个服务B的实例，这两个实例都订阅到相同的队列，因为它是相同的服务，我观察到来自SQS的消息现在以循环方式传递。这样在给定时间，只有一个服务B的实例接收由服务A发布的消息。我希望在将消息发布到此队列时，服务B的所有实例都应该接收该消息。
我们该怎么做呢？我已经开发了这些服务作为Springboot应用程序，以及Spring云依赖项。
浏览 0提问于2021-07-13得票数 0
2回答
我正在学习如何在Azure云应用程序和客户端应用程序之间进行通信，并学习了教程。
我目前有一个.exe工作进程的实例，它通过服务总线发送消息。我还有一个客户端角色，我在本地机器上运行这个角色来读取消息。但是，当我运行多个客户端实例时，每个客户端都会接收到一些消息，但没有一个得到完整的读取结果。是否可以使用队列或服务总线，以便客户机的每个实例都可以看到由工作人员生成的消息的all？
例如，3台不同计算机上的3个人可能希望独立监视同一计算机任务的状态。
浏览 4提问于2013-01-04得票数 2
回答已采纳
9回答
我想知道JMS队列和JMS主题之间有什么区别。
说
主题
在JMS中，主题实现发布和订阅语义。当您发布一条消息时，它会传递给所有感兴趣的订阅者--因此，对于许多订阅者来说，零将收到该消息的副本。只有在代理接收消息时具有活动订阅的订阅服务器才能获得消息的副本。
排队
JMS队列实现负载均衡器语义。一个单一的消息将被一个消费者接收。如果在发送消息时没有可用的使用者，它将一直保存到可以处理消息的使用者可用为止。如果使用者在关闭前收到一条消息而不承认它，那么该消息将被重新传递给另一个使用者。一个队列可以使许多消费者的消息负载在所有可用的消费者之间保持平衡。
我想要“一些东西”，它将以与Acti
浏览 8提问于2011-04-07得票数 228
回答已采纳
我正在尝试谷歌物联网和谷歌PubSub。我正在将MQTT消息从设备发送到我所订阅的pubsub队列(我将其称为“服务器”)。在google云控制台中，我更新了设备设置，并在设备中获得了设置消息。
google tutorial中的一切都运行得很好，但我想知道是否有可能以另一种方式设置消息传递:即“服务器”发送消息到设备使用MQTT订阅的pubsub队列。
末尾的模式让我认为只有"config“mqtt队列(/devices/XXXX/config)可以这样使用。
我需要的是从“服务器”到“设备”的一对一通信，恐怕唯一的方法就是使用配置
浏览 2提问于2018-04-25得票数 2
3回答
在过去的9个月里，我一直在做一个CQRS项目(我的第一个项目)，这是一个沉重的学习曲线。我目前在我的写模型中使用JOliver的优秀的EventStore，在我的读模型中使用PostGresSql。
我的读数据库和写数据库都在同一台机器上，这意味着当对写数据库进行更改时，在同一同步调用中也会对读模型进行更改。
当我在学习CQRS时，我觉得这是最好的方式，因为我没有使用MassTransit、NServiceBus等消息队列/服务总线框架的经验。
我现在已经准备好了我的大部分架构，可以引入消息队列框架了。
今天，我遇到了Redis MQ，它是ServiceStack的一部分，因为我们已经将Ser
浏览 2提问于2012-12-10得票数 5
回答已采纳
3回答
我的团队正在讨论如何使用RabbitMQ来进行微服务通信(除其他外)。我们还支持SAP后端，该后端将以目前尚未确定的方法(可能通过Boomi或Idocs)将数据推送给我们。我们对RabbitMQ几乎一无所知，除了消息队列的一般概念，以及我们能够从高层查看它们的文档时能够确定的内容。一般模式似乎是用户订阅了一个或多个队列，而兔子基于高度可配置的规则推送到这些队列，但是单个队列上的消息在被删除之前只被完全读取一次(这是一个泛化，因为关于确认和内容有很多选项)。
这是一个非常简单的设置图像，每个消费者只关心他们的不同主题：
📷
然而，这是一个更复杂的问题，其中一个主题被分割成多个队列。然而，当我们配
浏览 0提问于2018-08-17得票数 8
1回答
在我们的云环境中，当部署新实例时，我们运行集成测试。然而，这变得很棘手，因为新代码在队列中为正在部署的服务注入消息，而现有实例(以前的版本)仍在运行。我们有一个蓝/绿部署。
对于RabbitMQ来说，有可能有许多监听器监听一个队列，但只监听一个特定的版本吗？
例如，所有正在运行的服务器都会读取2017.10.20版(以前的版本)或更早版本的消息，但不会读取较新版本的消息。
这样，我就可以部署一个新的服务，而其他read都不会读取它的测试消息。
正在部署的新服务具有与现有服务相同的功能。它生成和使用与当前运行的服务相同的消息类型。
浏览 27提问于2017-12-19得票数 1
回答已采纳
2回答
也许我问错了问题。
我要做的是:多个生产者将动态类别中的数据推入一个命名的exchange中。多个使用者需要从这些动态命名的队列中获取这些数据，并对它们进行操作。
问题是，我看到的所有消费示例都要求使用者/订阅者有一个特定的队列名，而我的消费者不知道队列的名称，他们也不需要知道这一点。
我为什么要这么做？原因有二：
I可以一次拥有N个动态类别。我希望排队的人能平等地为这些类别服务。目前，我们有一个队列(msmq)，它接受所有这些类别，并在FIFO中为它们提供服务(这意味着一些类别在一段时间内都处于饥饿状态)。能够平等地为所有类别服务，而不是fifo，这让我想出了一个有趣的QoS (默认情况下，
浏览 1提问于2011-12-02得票数 4
回答已采纳
3回答
微服务和RabbitMQ
、、、、
我是微服务的新手，对RabbitMQ / EasyNetQ有一个问题。我正在从一个微服务向另一个微服务发送消息。
每个微服务都是Web API，我使用的是CQRS，我的命令处理程序将使用队列中的消息并执行一些业务逻辑。为了调用处理程序，它需要向API方法发出请求。
我想知道这一点，而不必显式调用API端点来访问消费消息的代码。有没有一种无需调用API端点就能自动完成的方法？
建议可以创建一个单独的解决方案，这将是一个控制台应用程序，将执行RabbitMQ，以便开始侦听。创建一个while循环来读取消息，然后调用web api端点来处理每次向队列发送新消息时的业务逻辑。
我的目标是创建一个监听器
浏览 2提问于2016-12-22得票数 2
在查看Pub/Sub模式时，我看到了研究方案：
假设您有一个水平缩放的应用程序，它有X个实例。他们都订阅了一个主题，比如“将10美元从帐户A转到帐户B”。当某人向该主题发布消息时，所有订阅者都会收到该消息吗？
在上述情况下，显然，消息应该只由一个订阅者接收，并且只处理一次。
如何处理这种情况？你会放弃酒吧/潜艇开始合并吗？
浏览 9提问于2019-09-25得票数 0
1回答
我正在通过Google Cloud Messaging和Firefox推送通知系统实现浏览器推送通知的发送。为此，我们必须向GCM和FPNS发出HTTP Post请求。
要向GCM/FPNS发出HTTP请求，我们应该拥有用户注册ID。使用JavaScript，我们收集注册in并将其存储在Cassandra中。每条记录都包含用户注册信息(注册ID和浏览器类型)。
当我们向GCM/FPNS发出HTTP请求时，我们应该根据浏览器类型将注册ID与请求一起发送到GCM/FPNS (如果用户注册ID属于Chrome，我们将发出GCM请求，否则将发送FPNS请求)。例如，如果我们有10,000条记录，我们应
浏览 0提问于2016-05-20得票数 2
我有许多设备使用MQTT通过Solace向后端服务器发送数据。由于我需要处理大量传入消息，因此我正在考虑启动一些侦听器实例来处理传入消息。但是，它没有帮助，因为MQTT pub/sub实际上是一对多消息传递，即相同的消息将被传递给所有订阅侦听器。我知道Solace支持DTO，但它支持使用MQTT的DTO吗？如果是这样，我该怎么做呢？如果没有，有什么建议我如何启动多个侦听器来处理大量的传入消息？我现在考虑的是创建订阅这些主题的非独占交付队列。不确定是否有其他更好的方法。
谢谢。
浏览 2提问于2016-06-06得票数 1
我有严重的问题，使消息传递失败证明在一个聊天系统。
在通过websocket与客户端进行多次node.js和实时通信之后，我使用rabbit回调特定节点上的正确使用者。
我将我的队列声明为{durable: true, prefetch:1, expires: 2*3600*1000, autoDelete: true}
consumerOption为{noAck: false, exclusive: false}
收到来自服务器的消息后，我会回调服务器，获取消息并使用message.ack(false)
有时，在rabbit中出现带有悬而未决的ACK的消息，正如我所预期的那样，消费者不再被回
浏览 2提问于2019-04-10得票数 0
2回答
我正在构建一个简单的解决方案，其中生产者服务将事件推送到消息队列，然后让流服务通过gRPC流API使这些事件可用。
云Pub/Sub似乎很适合这项工作，但是，扩展流媒体服务意味着，该服务的每个副本都需要在缩小之前创建自己的订阅并删除它，这似乎是不必要的复杂，而不是平台的初衷。
另一方面，Kafka似乎可以很好地处理类似的事情，但我想避免不得不管理底层平台本身，而是利用云基础设施。
我还应该提到，创建流API的原因是允许流到前端(可能无法访问底层基础设施)。
是否有更好的方法在GCP平台上进行这样的操作，而不选择部署和管理自己的基础设施的路线呢？
浏览 3提问于2019-03-17得票数 1
回答已采纳
Microsoft Azure同时提供Azure SignalR服务和Azure队列服务。我找不到的是使用一种与另一种的优缺点是什么。
你能在这里提供这些不同之处，或者提供一个文档或网页的链接来比较它们吗?我在这里或使用谷歌都找不到任何东西。
我们有一个web应用程序和一个移动应用程序，这些应用程序都连接到Azure功能。
我们需要添加向连接到打印机的远程位置的Windows服务发送消息的功能。
最初，我认为Azure Service Bus具有订阅队列，这样这些远程系统就会订阅一个队列，寻找消息供它们使用过滤器进行处理。
现在有人提出使用Azure SignalR，所以我试图了解微软的两个产
浏览 0提问于2020-03-28得票数 1
在面向服务的分布式体系结构中，假设我有一个生产者使用RMQ向使用者发送消息。
然后，我们决定通过增加更多的消费者来水平地扩展我们体系结构的消费部分，并且我们面临着一些限制。
发布服务器在它发送的每条消息中都提供一个序列号。消费者根据其拥有的序列号处理消息是非常重要的。
每次处理给定的资源(比如A )时，发行者都会发送RMQ消息，上面写着“嘿让我们为A做序列1”，然后“让我们为A做序列2”等等。
例如，如果发行者为A提供了3条具有序列1、2和3的消息，并且这3条消息被分发到我们的使用者的3个不同实例中。序列2的消息被请求，直到序列1被很好地处理，序列3也是如此。
最后消息都被很好地处理了，但是经
浏览 0提问于2018-02-14得票数 5
回答已采纳
3回答
我有一个基于服务的应用程序，它使用具有多个队列和多个使用者的Amazon。我这样做是为了实现一个基于事件的体系结构，并将所有服务解耦，在这些服务中，不同的服务对其他系统状态的变化做出反应。例如：
注册服务：
在新用户注册时发出事件“注册-新”。
用户服务：
当用户被更新时，发出事件‘用户更新’。
搜索服务：
读取队列‘注册-新’和索引用户在搜索。
从队列“用户更新”读取，并在搜索中更新用户。
计量服务：
从“注册-新”队列中读取并发送到混合面板。
从队列“用户更新”读取并发送到混合面板。
浏览 0提问于2015-05-18得票数 59
回答已采纳
Azure服务总线及其前提版本Windows的服务总线是否为每个订阅者复制了一条消息？
例如，假设有一个有五个订阅者的主题，那么该消息是五次存储在服务总线的数据库中--每个订阅者只存储一次--还是只存储了一次带有业务逻辑的消息，以确定哪些订阅者已经读取了消息？
如果有官方网站和/或文件作为参考，那就太好了。
浏览 6提问于2016-03-06得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
