Azure Service Bus Java: коришћење AMQP-а преко WebSockets-а уз прокси

Конфигуришите Java клијент за размену порука Azure Service Bus-а на AMQP преко WebSockets-а и поставке проксија из AMQP библиотеке.

Савремени Java клијент за размену порука Azure Service Bus-а користи AMQP. Његов градитељ захтева AMQP_WEB_SOCKETS када је конфигурисан прокси.

Уз azure-messaging-servicebus 7.18.0 пошиљаоца градите овако:

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

Променљиве налога проверавају се код проксија који прихвата Basic. Низ за повезивање и назив реда и даље идентификују Service Bus ресурс. Задржите добијеног пошиљаоца током предвиђеног животног века и затворите га када апликација заврши с њим.

Овде користите com.azure.core.amqp.ProxyOptions. HTTP стек Azure-а има другу класу сличног назива за прокси опције; то није тип који овај градитељ прихвата.

Ово конфигурише везу за размену порука. Апликација која користи самостално креиране акредитиве идентитета можда ће морати да конфигурише и HTTP пренос токена тих акредитива.

Стари примери за Azure SDK 0.9 односе се на другу генерацију клијента. Немојте закључивати да његове конфигурационе константе или општа HTTP својства описују савремени AMQP градитељ.

Повезани чланци