broker

1热度

1回答

我想在两个节点中集成WSO2 Message Broker 3.1.0。我通过改变存储库/ conf目录/ Axis2的/ axis2.xml文件中配置这两个节点： <parameter name="localMemberHost">10.0.0.43</parameter> <parameter name="membershipScheme">wka</parameter> <clust

1热度

1回答

如何在两个桥接MQTT代理之间有条件地转发消息？

我有一个位于A站点的MQTT Broker（mosquitto），另一位经纪人（mosquitto或RabbitMQ）位于云端。为了将数据转发到云端，我计划将数据桥接起来，并进行TLS编辑以确保数据安全。在A站点，软件通过MQTT进行内部通信，我不希望将敏感数据发送到云端。（例如：带有“用户/密码”的主题）将诸如“用户/年龄”，“用户/性别”等非敏感信息发送到云进行统计分析。如何在站点A配

1热度

1回答

闪烁在arduino中使用MQTT引导

我必须实现一个原型场景，使用MQTT协议在arduino中闪烁LED。我已经尝试了几个MQTT库，但其中没有一个完美无缺。与MQTT代理的连接工作成功，但是当我发布带有在arduino中设置的主题的消息时，不会使LED闪烁。 Arduno要发布的消息，当它连接成功，但这种公布部分还没有工作这是我的代码 #include <SPI.h> #include <Ethernet.h> #inclu

-1热度

2回答

是INR到USD的换算，转换或翻译？在Websphere消息代理中？

目前我正在使用IBM Integration Bus v9.0，我有疑问。是INR到USD的换算，转换或翻译？请给我答案。在此先感谢。

1热度

1回答

在kafka中处理代理

我在异步模式下使用kafka生产者，但是当所有代理都关闭时，它的行为就像同步一样，并等待metadata.fetch.timeout.ms过期，这对我的情况来说是60秒。我的第一个问题，这是一个正常的行为，或者我做错了什么？由于我的逻辑中的事务应该在最大100毫秒内完成，所以这个超时值对我来说是一个非常大的延迟。也许设置metadata.fetch.timeout.ms到10毫秒可能会解决我的问

0热度

1回答

踢或Mosquitto MQTT

我有一个配置Mosquitto MQTT经纪人潘基用户或客户端... 我想踢或禁令的时间量的用户？我如何从另一个订阅的客户端做到这一点？我应该从经纪人那里做这件事吗？怎么样？

0热度

1回答

实时网站的架构.... PHP5 Angularjs和安卓MQTT

我想用android客户端做一个实时网站。如何将蚊子连接到PHP5，angularjs前端和android应用程序？是否必须使用nodeJs与socket.io为angularjs前端，然后NodeJs服务器为所有Android MQTT消息？这一切都很令人困惑。我尝试了一段时间与兔子，但卡住了:(

0热度

2回答

创建Apache Apollo经纪人时出错

我下载并解压Apache Apollo经销人为described in their site。 ~/Developer/Web/MQTT/apache-apollo-1.7.1/bin/apollo create mybroker 我在终端下面输出了。 Creating apollo instance at: mybroker ERROR: mybroker/etc/log4j.propert

0热度

1回答

MQTT客户端服务器通信

我想使用MQTT协议将消息从iOS应用程序发送到我的PC。我在我的fedora上安装了一个HiveMQ代理，我可以启动它。使用我的PC的IP地址可以发送消息吗？如何在PC上访问收到的消息？我是否需要另一个程序将收到的消息写入文本文件？

0热度

1回答

我怎样才能让一个新创建的主题在所有的代理上均匀分布？

我使用5个代理设置了一个Kafka（0.8.1.1）集群。然后我在Kafka集群上创建了一个包含16个分区2个复制因子的主题。我发现16 * 2分区只分布在3个经纪人（11个经纪人1,10个经纪人2和10个经纪人3）上。我怎么能让他们分布在5个经纪人而不是3个？