AWS AMQP＆＃x2B; SSL与VERTX连接

Question

我正在尝试将服务与我本地的ActiveMQ连接，我正在尝试使用此连接：

fun start(vertx: Vertx, address: String): Single<MQServerConnection> {
    val options: AmqpClientOptions = AmqpClientOptions()
        .setHost("localhost")
        .setPort(5672)
    logger.info("ACTIVE_MQ_PROVIDER_STARTING_IN_THREAD_[" + Thread.currentThread().name + "]")

    return AmqpClient.create(vertx, options).rxConnect().flatMap { amqpConnection ->
        amqpConnection.rxCreateAnonymousSender().flatMap { responseSender ->
            amqpConnection.rxCreateReceiver(address).map { receiver ->
                MQServerConnection(amqpConnection, responseSender, receiver)
            }
        }
    }
}

在哪里

data class MQServerConnection(
    val amqpConnection: AmqpConnection,
    val amqpSender: AmqpSender,
    val amqpReceiver: AmqpReceiver
)

工作正常。

现在，我正在尝试使用AWS服务，但是它返回我：

failover:(amqp+ssl://b-4eb4c78c-048b-436c-941e-31250830323e-1.mq.us-east-1.amazonaws.com:5671,amqp+ssl://b-4eb4c78c-048b-436c-941e-31250830323e-2.mq.us-east-1.amazonaws.com:5671)

我不知道如何发送主机而不是Localhost

并登上端口。

问候

Answer 1

AmqpClientOptions 的 ssl 属性对于 AMQPS 必须为 true，即

val options: AmqpClientOptions = AmqpClientOptions()
    .setHost("b-4eb4c78c-048b-436c-941e-31250830323e-1.mq.us-east-1.amazonaws.com")
    .setPort(5671)
    .setSsl(true)
    .setUsername("admin")
    .setPassword("admin")
    //This is required only if the AWS service uses a self-signed certificate
    .setTrustAll(true)
    //This is required only if the AWS service uses a certificate with a CN that doesn't match the hostname
    .setHostnameVerificationAlgorithm("")