servicebus Balíček

Automatické prodlužování zámků pro zprávy a relace pomocí fondu vláken na pozadí

Automatické prodlužování zámků pro zprávy a relace pomocí fondu vláken na pozadí Doporučuje se nastavit max_worker na velký počet nebo předání ThreadPoolExecutoru velkého max_workers čísla, když autoLockRenewer má pracovat s více zprávami nebo relacemi současně.

Třída ServiceBusClient definuje rozhraní vysoké úrovně pro získání ServiceBusSender a ServiceBusReceiver.

Vlastnosti připojovacího řetězce

Zpráva služby Service Bus.

Dávka zpráv.

Odesílání zpráv v dávce je výkonnější než odesílání jednotlivých zpráv. ServiceBusMessageBatch pomáhá vytvořit maximální povolenou velikost dávky zprávy , aby se zlepšil výkon odesílání.

Pomocí metody add přidejte zprávy, dokud nebude dosaženo maximálního limitu velikosti dávky v bajtech – v tomto okamžiku bude vyvolána chyba MessageSizeExceededError .

Použijte metodu create_message_batch ServiceBusSender k vytvoření objektu ServiceBusMessageBatch místo přímé instance objektu ServiceBusMessageBatch.

Zpráva služby Service Bus přijatá ze strany služby

ServiceBusReceiver Třída definuje rozhraní vysoké úrovně pro příjem zpráv z odběru Azure Service Bus fronty nebo tématu.

Dva primární kanály pro příjem zpráv jsou receive() pro vytvoření jediného požadavku na zprávy a pro zprávy v příjemci: nepřetržitě přijímat příchozí zprávy průběžným způsobem.

K vytvoření instance ServiceBusReceiver použijte get_<queue/subscription>_receiver metodu ~azure.servicebus.ServiceBusClient.

ServiceBusSender Třída definuje rozhraní vysoké úrovně pro odesílání zpráv do Azure Service Bus fronty nebo tématu.

K vytvoření instance ServiceBusSender použijte get_<queue/topic>_sender metodu ~azure.servicebus.ServiceBusClient.

ServiceBusSession slouží ke správě stavů relací a prodlužování uzamčení.

Pomocí vlastnosti session ServiceBusReceiver získejte odpovídající objekt ServiceBusSession propojený s příjemcem místo přímé instance objektu ServiceBusSession.

Typ přenosu Základní typ přenosového protokolu:

Amqp: AMQP přes výchozí přenosový protokol TCP, používá port 5671. AmqpOverWebsocket: Amqp přes přenosový protokol webových soketů používá port 443.