Azure Service Bus Java: AMQP caur WebSockets ar starpniekserveri

Mūsdienu Azure Service Bus Java ziņojumapmaiņas klients izmanto AMQP. Tā veidotājs pieprasa AMQP_WEB_SOCKETS, kad ir konfigurēts starpniekserveris.

Ar azure-messaging-servicebus 7.18.0 sūtītāju veidojiet šādi:

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

Konta mainīgie autentificējas pie starpniekservera, kas pieņem Basic. Savienojuma virkne un rindas nosaukums joprojām identificē Service Bus resursu. Saglabājiet izveidoto sūtītāju visā paredzētajā tā darbības laikā un aizveriet to, kad lietojumprogramma ir pabeigusi darbu ar to.

Šeit izmantojiet com.azure.core.amqp.ProxyOptions. Azure HTTP stekā ir cita līdzīgi nosaukta starpniekservera opciju klase; tā nav tipa, ko pieņem šis veidotājs.

Tas konfigurē ziņojumapmaiņas savienojumu. Lietojumprogrammai, kas izmanto patstāvīgi izveidotus identitātes akreditācijas datus, var būt jākonfigurē arī to pilnvaras HTTP pārsūtīšana.

Vecie Azure SDK 0.9 piemēri attiecas uz citu klienta paaudzi. Nepieņemiet, ka tā konfigurācijas konstantes vai vispārīgās HTTP īpašības raksturo mūsdienu AMQP veidotāju.