Azure Service Bus Java: WebSockets üzerinden proxy ile AMQP kullanma

Azure Service Bus'ın modern Java mesajlaşma istemcisi AMQP kullanır. Yapıcısı, bir proxy yapılandırıldığında AMQP_WEB_SOCKETS gerektirir.

azure-messaging-servicebus 7.18.0 ile göndericiyi şöyle oluşturun:

var address = new java.net.Proxy(
    java.net.Proxy.Type.HTTP,
    new java.net.InetSocketAddress("proxy.example", 8080));

var proxy = new com.azure.core.amqp.ProxyOptions(
    com.azure.core.amqp.ProxyAuthenticationType.BASIC,
    address, proxyUser, proxyPassword);

var sender = new com.azure.messaging.servicebus.ServiceBusClientBuilder()
    .connectionString(serviceBusConnectionString)
    .transportType(com.azure.core.amqp.AmqpTransportType.AMQP_WEB_SOCKETS)
    .proxyOptions(proxy)
    .sender()
    .queueName(queueName)
    .buildClient();

Hesap değişkenleri Basic kabul eden bir proxy'de kimlik doğrular. Bağlantı dizesi ve kuyruk adı Service Bus kaynağını yine tanımlar. Oluşturulan göndericiyi amaçlanan ömrü boyunca tutun ve uygulama işini bitirdiğinde kapatın.

Burada com.azure.core.amqp.ProxyOptions kullanın. Azure'un HTTP yığınında benzer adlı başka bir proxy seçenekleri sınıfı vardır; bu yapıcının kabul ettiği tür o değildir.

Bu, mesajlaşma bağlantısını yapılandırır. Bağımsız olarak oluşturulmuş kimlik kimlik bilgilerini kullanan bir uygulama, bu kimlik bilgilerinin belirteç HTTP taşımasını da yapılandırmak zorunda kalabilir.

Eski Azure SDK 0.9 örnekleri başka bir istemci neslini anlatır. Yapılandırma sabitlerinin veya genel HTTP özelliklerinin modern AMQP yapıcısını tanımladığını varsaymayın.