messagebroker 相关问题

Message Broker是一种模式,旨在消费来自应用程序的消息并执行转换等操作,提供消息路由机制的点对点和发布 - 订阅模式。它调解应用程序之间的通信,最大限度地减少应用程序之间应该具有的相互意识,以便能够交换消息,有效地实现解耦。

收件箱模式和发件箱模式

我没有看到收件箱模式和发件箱模式之间的区别。 收件箱模式将消息保存在数据库中。发件箱模式也是如此,那么有什么区别呢?

回答 1 投票 0

SQL 队列不启动激活过程 SQL Server

SQL Server 2019 我正在尝试从触发器启动存储过程(以便触发器保持精简)来处理某些生产设施中的数据。使用队列/消息等对我来说是新的 我已经

回答 1 投票 0

Kafka是消息队列还是消息代理?

在阅读了几篇解释消息队列和消息代理之间区别的文章后,我对 Kafka 是消息队列还是消息代理感到非常困惑。 主要

回答 1 投票 0

ESQL:从重复的 XML 段中提取唯一元素

我面临着 ESQL 代码的挑战。我有一条包含重复段的 XML 消息,我需要从该段内的特定元素中提取唯一值。以下是...

回答 2 投票 0

ESQL 用于将字符串拆分为多个值

以下输入 xml 字段需要按 6 个字符进行子串化,并且每 6 个字符应拆分并保存在输出的选项字段中。 输入: 124414500045563879 以下输入 xml 字段需要按 6 个字符进行子字符串化,并且每 6 个字符应拆分并保存在输出的选项字段中。 Input: <feature>124414500045563879</feature> output: <option>124414</option> <option>500045</option> <option>563879</option> IIB ESQL 中是否有可用的 tokenizer 函数来实现上述结果。 据我所知,ESQL 中没有 String Tokenizer 函数。 但是您可以使用以下过程作为基础来实现您的目标。该方法将 Delim 上的 S 拆分为 Env 中的数组(Environment.Split.Array[]) 并在重新填充之前删除Environment.Split。 在您的情况下,您不需要 Delim,您应该在子字符串部分使用固定长度。 CREATE PROCEDURE Split (IN S CHARACTER, IN Env REFERENCE, IN Delim CHARACTER) BEGIN DECLARE P INTEGER; DECLARE Idx INTEGER 1; SET Env.Split = NULL; REPEAT SET P = POSITION(Delim IN S); IF P = 0 THEN SET Env.Split.Array[Idx] = S; ELSE SET Env.Split.Array[Idx] = LEFT(S, P - 1); SET S = SUBSTRING(S FROM P + LENGTH(Delim)); SET Idx = Idx + 1; END IF; UNTIL P = 0 END REPEAT; END; 来源:http://www.mqseries.net/phpBB2/viewtopic.php?p=97845& 另一种解决方案可能是将特征值作为比特流,从中构建新的 BLOB 消息,并使用描述该值中令牌的消息定义重新解析它。重新解析后,就可以进一步处理新的逻辑消息了。 ESQL 中没有内置的 split 函数。然而,人们可以在 ESQL 中创建自己的 split 函数。您可以使用以下过程根据 delemeter 拆分字符串并将其存储在数组中。 CREATE FUNCTION split(string CHARACTER, delimiter CHARACTER, IN result REFERENCE) BEGIN DECLARE index INTEGER 1; WHILE SUBSTRING(string BEFORE delimiter) <> '' DO EVAL('SET result.index[' || CAST(index AS CHARACTER) || ']=''' || SUBSTRING(string BEFORE delimiter) || ''''); SET index = index + 1; SET string = SUBSTRING(string AFTER delimiter); END WHILE; EVAL('SET result.index[' || CAST(index AS CHARACTER) || ']=''' || string || ''''); END;

回答 3 投票 0

消息代理与 Java 阻塞队列与休息

我必须创建两个服务,让我们调用服务A和服务B。A需要向B发送消息并且不期望得到响应。考虑到消息数量并不大,假设每秒 5 条......

回答 1 投票 0

.NET - 使用消息代理测试系统

我有一个关于测试我的应用程序的问题,我在其中使用消息代理(公共交通库、Azure 服务总线实现)在服务之间进行通信。假设我有 ServiceA 和

回答 1 投票 0

尽管订阅但未调用 MQTT handleMessage 函数

我正在开发一个 Go 应用程序,该应用程序订阅 MQTT 主题并使用 handleMessage 函数处理传入消息。但是,我遇到了一个问题,handleMessage 函数......

回答 1 投票 0

是CCSID 1208支持的字符§吗

我需要知道CCSID 1208是否支持字符§。一般来说,我们如何找到特定CCSID支持的字符列表。 谢谢

回答 2 投票 0

Paho MQTT cleanSession 设置为 false 但未接收消息

我正在为一个项目测试 MQTT。当客户端连接时,我还能够接收有关我的客户端订阅的主题的消息。我已将 QoS 设置为 1,并将 cleanSession 设置为 false....

回答 3 投票 0

将清除会话标志设置为 FALSE 时,我丢失了已发布的值

是否有人有一个合乎逻辑的解释,为什么尽管我有明确的会话标志= false,但我在未连接到代理时却没有收到我订阅的更新的已发布消息? 机智...

回答 3 投票 0

什么时候在消息代理中创建队列?

什么时候习惯在消息代理中创建队列?例如,我的应用程序中有一个 RabbitMQ,因此我需要在启动它之前创建队列。 我还在想...

回答 1 投票 0

x时间后消费服务总线消息

我正在做一个项目来研究更多的经纪人,我正在使用.NET 6.0和服务总线来做到这一点。 我的问题是:我需要发布一条消息并仅在一段时间后使用同一条消息(我放...

回答 1 投票 0

错误:空响应。没有订阅者正在收听该消息(“x”)

我正在尝试通过 Nestjs 和 Nats 创建微服务,但收到错误错误:空响应。没有订阅者正在收听该消息(“checkUserExists”) 现在我...

回答 1 投票 0

与消息代理的粘性会话

我正在开发一个项目,我们正在尝试利用消息代理,在类型消息开始发送给给定的消费者之后,它会继续发送给该消费者。这本质上是...

回答 1 投票 0

使用 NTLM 进行 RabbitMQ 身份验证(无密码)

我已经配置了 RabbitMQ,但目前它使用简单的用户名/密码连接到队列。这并不理想,因为我必须将密码存储在应用程序配置中。 理想情况下,我

回答 1 投票 0

RabbitMQ 本地主机管理无法启动,日志文件中出现端口 5672 错误

我已经在Windows 10机器上安装了RabbitMQ 3.11.2和Erlang版本25.1.1。 我对 RabbitMQ 非常陌生,无法启动 RabbitMQ 管理门户。我启用了 RabbitMQ 管理...

回答 2 投票 0

RabbitMQ 自动删除超时队列

我有一个k8s服务,使用rabbitMQ作为消息代理。 如果可能有多个 Pod 的服务部署停止,我希望能够删除特定队列。 阅读 Rab 文档...

回答 1 投票 0

MassTransit 状态机等待所有消息

我正在尝试使用公共交通创建一个状态机,在其中等待 3 个状态更改为“已完成”。然后当我确定所有 3 个都已完成时,我想调用一些最终代码或其他东西......

回答 1 投票 0

用于自定义消息传递协议的消息代理?

是否有任何框架或平台能够以可靠、灵活且可扩展的方式提供消息交换?我有以下场景: 我有外部设备与...

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.