问题标签 [broker]

我已经使用MQL4了几天了，但是最近我收到了错误消息：

执行订单时。

通过阅读不同的论坛，我了解到一个普遍的看法是我必须与我的经纪人交谈才能启用智能交易系统，但直到现在，交易对我来说都有效（开启和关闭）！

有没有其他人遇到过这个错误 - 与从服务器启用 EA 无关？

我已经创建了service broker，但是当我启用它时，我的 CPU 使用率即将接近100%，一旦我删除我的队列和服务并禁用我service broker的SQL serverCPU 使用率，它就会再次恢复正常，50%接近60%.

谁能解释导致此问题的原因？

我正在尝试连接两个 Mqtt Broker (Mosquitto)。我在云中的服务器上安装了一个，在本地 Raspberry Pi 上安装了另一个。Raspeberry Pi Mosquitto 应该建立与云实例的连接。这是我在 Raspberry 上的配置（/etc/mosquitto/conf.d/bridge.conf）：

我可以直接连接到代理并发送和接收消息。我还看到在日志文件中建立了连接，但在代理之间没有传递任何消息。

有任何想法吗？

另一个谜团是，只有在 Raspberry Pi 上关闭 mosquitto 进程后，我才能看到日志输出。

此外由 Mqtt Lens 创建的消息：

我正在尝试扩展 ZeroMQ Majordomo 模式以与在网状网络中互连的多个代理一起操作。它将与原始的 Majordomo 模式相同地运行，除了如果 B1 无法服务其客户的请求但 B2 可以，则代理 B1 会将客户请求转发给代理 B2。

关于这个模式的实现，我有两个设计问题。

1) 经纪人 B1 如何知道 B2 上提供哪些服务？ 一种可能的解决方案是创建一个“哈希节点”，连接并跟踪网格中每个代理可用的服务。当代理想要转发客户端请求时，它会咨询哈希节点。但是，这需要所有代理定期与哈希节点通信。这种沟通会阻碍性能或产生任何我没有提到的微妙问题吗？

2) 代理应该使用什么样的套接字在网状网络中进行通信？ 每个 broker 显然都需要一个 ROUTER 套接字来接收消息、连接请求等。但是每个 broker 应该使用什么类型的套接字来发送请求呢？DEALER 套接字是一个糟糕的选择，因为每个代理都需要为每个其他代理打开一个 DEALER 套接字。ROUTER 会很好，但需要“hacks”来实现。有没有其他方法可以有效地将经纪人联系在一起？

据我了解，如果您subscribed使用topic特定QoS的 ，订阅者将只能看到代理topic提供的消息，其级别等于或低于发布主题时指定的级别。MQTTQoSQoS

换句话说，例如，将订阅topic = newsand with的客户QoS = 1，那么他将能够看到withpublished下的任何消息topic = newsQoS = 1 OR 0

我subscribed到一个topic = newswith QoS = 0，这topic是用 发布的QoS = 2，当我连接到 时broker，我收到了 te 已发布的消息，但用它QoS = 0，第二次，我发布了相同的主题，但用QoS = 1，当我订阅它时QoS = 0，我收到了消息但与QoS = 0.

那么，无论QoS我收到的消息是什么级别，但是，它QoS“降级”了，那又是什么？风险是什么？谁能解释一下？！！

为了测试，我创建了一个客户端clean sessin = false并setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true);运行了该应用程序。后来，我设置setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false);当我运行该应用程序时，我会收到以前的LWT消息。如何停止接收它们？

在本教程的部分message options

默认情况下，新消息实例设置为“至少一次”，服务质量 (QoS) 为 1，这意味着发送方将至少发送一次消息，如果没有确认，它将继续发送它设置了一个重复的标志，直到出现确认，

这是否意味着在setCallback listener-> onMessageArrived()我必须检查是否有任何消息到达时我必须再次重新发送消息并设置重复标志？

Since specifying the clienID is only a feature in the class MqttAndroidClient, and can not be specified when using classes IMqttClient and IMqttAsynchClient.

what is the real purpose of connecting a client with a unique ID?

我已经在 Google Cloud 的 Ubuntu VM 实例中安装了 mosquitto 代理。我还可以看到代理在 VM 的 1883 端口上运行。VM 的外部 IP 是 130.211.173.165 。现在，当我尝试通过命令为该代理创建客户端时

我收到一条错误消息，指出连接被远程 IP 主动拒绝。

我还添加了一条网络防火墙规则，说明以下内容，但似乎没有任何效果。

有人可以帮忙吗？

我有一个 activemq 代理，我想将其配置拆分为多个文件。我想准备一个单独的配置文件，它会自动生成，并且只包含队列的定义。

文件 1：activemq.xml

文件 2：queues.xml

我尝试使用：

春季进口：

但得到了

错误：org.springframework.beans.factory.BeanCreationException：在类路径资源[queues.xml]中定义名称为“org.apache.activemq.xbean.XBeanBrokerService#1”的bean创建错误：调用init方法失败；嵌套异常是 javax.management.InstanceAlreadyExistsException: org.apache.activemq:type=Broker,brokerName=localhost org.springframework.beans.factory.BeanCreationException:创建名为 'org.apache.activemq.xbean.XBeanBrokerService#1' 的 bean 时出错在类路径资源 [queues.xml] 中定义：调用 init 方法失败；嵌套异常是 javax.management.InstanceAlreadyExistsException : org.apache.activemq:type=Broker,brokerName=localhost

X包括：

activemq.xml：

但得到了

错误：org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException：类路径资源 [activemq.xml] 中的 XML > 文档中的第 142 行无效；嵌套异常是 org.xml.sax.SAXParseException；行号：142；列号：45；cvc-complex-type.2.4.c：匹配通配符是严格的，但找不到元素“xi:include”的声明。 org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException：来自类路径资源 [activemq.xml] 的 XML 文档中的第 142 行无效；嵌套异常是 org.xml.sax.SAXParseException；行号：142；列号：45；cvc-complex-type.2.4.c：匹配通配符是严格的，但找不到元素“xi:include”的声明。

XML 实体 activemq.xml

但得到了

错误：org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException：来自类路径资源 [activemq.xml] 的 XML 文档中的第 28 行无效；嵌套异常是 org.xml.sax.SAXParseException；行号：28；列号：3；必须声明元素类型“bean”。 org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException：来自类路径资源 [activemq.xml] 的 XML 文档中的第 28 行无效；嵌套异常是 org.xml.sax.SAXParseException；行号：28；列号：3；必须声明元素类型“bean”。

有任何想法吗？提前致谢。