当前位置: 首页 > 知识库问答 >
问题:

连接到分布式代理的Eclipse paho

苗森
2023-03-14
MqttClient cl = new MqttClient("LIST OF IPs", "Publisher", new    
MemoryPersistence());
MqttClient cl = new MqttClient("tcp://localhost:1883", "Publisher", new 
MemoryPersistence());

以便当到第一个地址的连接失败时,尝试到下一个地址的连接。

谁能在这里指点一下吗?非常感谢。

共有1个答案

颜楚青
2023-03-14

许多语言的客户端库都有此选项。可以在这里查看列表:https://www.eclipse.org/paho/downloads.php

对于那些标记为“高可用性”的客户端,支持使用“MQTTConnections”指定的URL列表。

示例:

        String[] URIs = {"address1","address2"};
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setServerURIs(URIs);
 类似资料:
  • 我们已经成功地使用了MySQL - 使用jdbc独立连接器的kafka数据摄取,但现在在分布式模式下使用相同的连接器(作为kafka connect服务)时面临问题。 用于独立连接器的命令,工作正常 - 现在,我们已经停止了这一项,并以分布式模式启动了kafka connect服务,如下所示 2 个节点当前正在运行具有相同连接服务。 连接服务已启动并正在运行,但它不会加载 下定义的连接器。 应该对

  • 我是AnyLogic的新手,我正在尝试创建一个自定义网络...但我无法成功完成此任务:( 然后我有一个变量“network”,它包含年龄类之间链接的平均数。 我想要的是每个代理根据矩阵创建与其他代理的链接。 我不知道如何对一个座席说“连接到另一个具有AgeClass=3的座席” 谢谢大家的支持!!!

  • OpenStack使用RabbitMQ作为消息传递系统。为此,有几个交换机和队列。我发现名为“nova”的“topic”类型的交换用于消息传输。Exchange使用路由密钥将消息路由到队列(http://www.rabbitmq.com/tutorials/amqp-concepts.html). (有用图像位于http://www.rabbitmq.com/img/tutorials/intro

  • 我正在开发debezium mongodb源连接器。我可以通过提供kafka引导服务器地址作为远程机器(部署在Kubernetes中)和远程MongoDB URL在分布式模式下在本地机器中运行连接器吗? 我尝试了这一点,我看到连接器成功启动,没有错误,只有几个警告,但没有数据从MongoDB流动。 使用以下命令运行连接器 遵循以下教程:https://medium.com/tech-that-wo

  • 我正在寻找将Python连接到交互式代理应用编程接口。谷歌搜索显示了ibPy的可用性(见https://pypi.python.org/pypi/ib),但是这个库似乎没有得到维护,也不支持Python 3。我还发现https://github.com/colin1alexander/IbPython3但是这个项目已经被取消了。 我知道Quantopian使用交互式代理作为其执行代理,但有一个用于