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

Qpid JMS中具有SSL/TLS的故障切换连接URL

田易安
2023-03-14

我尝试使用故障切换URI连接到Qpid JMS 0.48.0客户端和启用SSL的RabbitMQ集群(启用了AMQP 1.0插件)。

这不起作用:

failover:(amqps://host1:5671?transport.verifyHost=false,amqps://host2:5671?transport.verifyHost=false,amqps://host3:5671?transport.verifyHost=false)

但这是有效的(没有SSL):

failover:(amqp://host1:5672,amqp://host2:5672,amqp://host3:5672)

SSL配置良好,如下所示:

amqps://host1:5671?transport.verifyHost=false

标准输出上没有错误消息,没有日志。

当连接到Artemis集群时,我得到了完全相同的行为。

此外,我可以在Python中使用Qpid Proton客户端的多个URI和SSL:

server_addr = ['amqps://host1:5671', 'amqps://host2:5671', 'amqps://host3:5671']

你能告诉我发生了什么事吗?

共有2个答案

柴赞
2023-03-14

您可以这样连接:

failover:amqps://host1:5671,amqps://host2:5671?transport.verifyHost=false
曹振
2023-03-14

使用不同的AMQP服务器实现对客户端进行测试,结果表明,客户端在组合中启用或禁用“验证主机”选项(无论是否有故障切换)都没有问题。您应该在路径上使用类似于log4j的东西来启用客户端日志记录,并在连接-断开连接周期内收集数据,并确定为什么使用RabbitMQ失败。

 类似资料:
  • 我想知道是否可以在Kafka制作程序中配置2个不同的Kafka集群。 目前我正试图让我的制片人 我正在使用Apache Kafka 2.8和Python 3.7的confluent_kafka==1.8.2包。 生产商代码下方: 当我杀死clusterB时,我得到了以下错误消息。

  • 我正在研究MQTT协议。我配置了它的服务器,并使用端口1883上的Mosquito库用java进行了通信。现在,我想让这种通信更加安全。据我所知,8883端口是为其基于tls的安全通信保留的。它需要X.509证书。为此,我找到了以下教程。 http://www.embedded101.com/Blogs/PaoloPatierno/entryid/366/mqtt-over-ssl-tls-wit

  • 如果应用程序存在连接问题,AWS建议增加KCL(kinesis)的故障切换时间。https://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html 但我找不到如何更改故障切换时间。 我正在寻找(一个或全部): > node.jskcl包的设置 地形设置

  • 我正在尝试将OSS Ehcache与兵马俑集群一起使用,但未能从ehcache客户端实现故障转移。 我在这里的文档中找到了这种配置 但是这个连接只接受一个URL。如果集群中有两台terracotta服务器,我希望HA具有故障转移功能。类似ActiveMQ故障转移url: 我的问题是:这在开源ehcache中是可能的,还是我需要有企业版本,如果可能的话,如何配置它。 更新 我试过<代码> 如果我尝试

  • 我在使用合流Kafka连接图像中的AWS MSK TLSendpoint时遇到了麻烦,因为它超时了创建/阅读主题。当我传递明文endpoint时,工作完全正常。 INFO org.apache.kafka.clients.admin.AdminClientConfig-AdminClientConfig值: