Azure Service Bus Java: AMQP WebSocketsin yli välityspalvelimen kanssa

Azure Service Busin nykyaikainen Java-viestintäasiakas käyttää AMQP:tä. Sen rakentaja vaatii AMQP_WEB_SOCKETS-arvon, kun välityspalvelin on määritetty.

Kun käytössä on azure-messaging-servicebus 7.18.0, rakenna lähettäjä näin:

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();

Tilin muuttujat todentuvat välityspalvelimelle, joka hyväksyy Basicin. Yhteysmerkkijono ja jonon nimi tunnistavat edelleen Service Bus -resurssin. Pidä lähettäjä sen aiottuun elinkaaren ajan ja sulje se, kun sovellus on lopettanut sen käytön.

Käytä tässä com.azure.core.amqp.ProxyOptions-luokkaa. Azure'n HTTP-pinossa on toinen samanniminen välityspalvelinasetusten luokka; se ei ole tyyppi, jonka tämä rakentaja hyväksyy.

Tämä määrittää viestintäyhteyden. Sovellus, joka käyttää erikseen luotuja identiteettitunnuksia, saattaa myös joutua määrittämään niiden tunnuksen HTTP-siirron.

Vanhat Azure SDK 0.9 -esimerkit viittaavat toiseen asiakaspolveen. Älä päättele, että sen määritysvakiot tai yleiset HTTP-ominaisuudet kuvaavat nykyaikaista AMQP-rakentajaa.