Kurz: Aktualizace zásob pomocí portálu Azure Portal a témat/odběrů

2025-06-23

V tomto kurzu se dozvíte, jak používat témata a předplatná služby Service Bus ve scénáři zásob maloobchodního prodeje. Zahrnuje kanály publikování a odběru pomocí webu Azure Portal a .NET. V tomto scénáři pracujeme s příkladem aktualizace sortimentu zásob pro několik prodejen. Každá prodejna nebo sada prodejen v našem příkladu přijímá zprávy s pokyny, jak konkrétně má aktualizovat sortiment.

Azure Service Bus je víceklientská cloudová zprávová služba, která odesílá informace mezi aplikacemi a službami. Asynchronní operace umožňují flexibilní zprostředkované zasílání zpráv a také strukturované zasílání zpráv typu FIFO (first-in-first-out) a funkce pro publikování a přihlášení k odběru. Přehled najdete v tématu Co je Service Bus?

Tento kurz vysvětluje, jak tento scénář využívající odběry a filtry implementujete. Nejprve vytvoříte téma se třemi odběry, přidáte některá pravidla a filtry a pak odešlete a přijmete zprávy z tématu a odběrů.

Diagram znázorňující odesílatele, téma se třemi předplatnými a třemi příjemci

V tomto kurzu se naučíte:

Vytvoření tématu služby Service Bus a tří odběrů pro toto téma pomocí webu Azure Portal
Přidání filtrů pro předplatná pomocí kódu .NET
Vytváření zpráv s jiným obsahem
Odesílání zpráv a ověření doručení do očekávaných odběrů
Přijímat zprávy z odběrů

Požadavky

Abyste mohli absolvovat tento kurz, ujistěte se, že máte následující:

Předplatné služby Azure. Pokud chcete používat služby Azure, včetně Služby Azure Service Bus, potřebujete předplatné. Než začnete, můžete si vytvořit bezplatný účet .
Visual Studio 2019 nebo novější

Témata a odběry služby Service Bus

Každý odběr tématu může přijímat kopie všech zpráv. Témata jsou co do protokolu a sémantiky plně kompatibilní s frontami služby Service Bus. Témata služby Service Bus podporují širokou škálu pravidel pro výběr s podmínkami filtrů, včetně volitelných akcí, kterými se nastavují nebo upravují vlastnosti zprávy. Při každé shodě s pravidlem se vytvoří zpráva. Další informace o pravidlech, filtrech a akcích najdete v tématu Filtry a akce v tématu.

Vytvoření oboru názvů na webu Azure Portal

Pokud chcete začít používat entity zasílání zpráv Service Bus v Azure, vytvořte obor názvů s názvem, který je jedinečný v rámci Azure. Obor názvů poskytuje kontejner oborů pro prostředky služby Service Bus, jako jsou fronty a témata, ve vaší aplikaci.

Vytvoření oboru názvů:

Přihlaste se k portálu Azure.
V levém horním rohu vyberte kontextovou nabídku a přejděte na stránku Všechny služby.
Na levém navigačním panelu vyberte Integrace.
Posuňte se dolů ke službám zasílání zpráv>Service Bus a vyberte Vytvořit.
Na kartě Základy na stránce Vytvořit obor názvů postupujte podle těchto kroků:
1. V části Předplatné zvolte předplatné Azure, ve kterém chcete vytvořit obor názvů.
2. Pro skupinu prostředků zvolte existující skupinu prostředků nebo vytvořte novou.
3. Zadejte název oboru názvů, který splňuje následující konvence pojmenování.
  - Název musí být jedinečný v rámci Azure. Systém okamžitě kontroluje, jestli je název dostupný.
  - Délka názvu je nejméně 6 a maximálně 50 znaků.
  - Název může obsahovat pouze písmena, číslice, pomlčky -.
  - Název musí začínat písmenem a končit písmenem nebo číslem.
  - Název nekončí -sb nebo -mgmt.
4. V části Umístění zvolte oblast pro hostování vašeho oboru názvů.
5. V části Cenová úroveň vyberte cenovou úroveň (Basic, Standard nebo Premium) pro obor názvů. Pro účely tohoto rychlého startu vyberte Standard.
  
  Pokud vyberete úroveň Premium , můžete pro obor názvů povolit geografickou replikaci . Funkce geografické replikace zajišťuje, aby se metadata a data oboru názvů průběžně replikovaly z primární oblasti do jedné nebo více sekundárních oblastí.
  
  Důležité
  
  Pokud chcete použít témata a předplatná, zvolte Standard nebo Premium. Témata a předplatná se nepodporují v cenové úrovni Basic.
  
  Pokud jste vybrali cenovou úroveň Premium , zadejte počet jednotek zasílání zpráv. Úroveň Premium poskytuje izolaci prostředků na úrovni procesoru a paměti, aby každá úloha běžela izolovaně. Kontejner prostředků se nazývá jednotka zasílání zpráv. Obor názvů premium má alespoň jednu jednotku zasílání zpráv. Pro každý obor názvů služby Service Bus Premium můžete vybrat 1, 2, 4, 8 nebo 16 jednotek zasílání zpráv. Další informace najdete v tématu Úroveň zasílání zpráv služby Service Bus úrovně Premium.
6. Vyberte Zkontrolovat a vytvořit v dolní části stránky.
7. Na stránce Zkontrolovat a vytvořit zkontrolujte nastavení a vyberte Vytvořit.
Po úspěšném nasazení prostředku vyberte na stránce nasazení Přejít k prostředku.
Zobrazí se domovská stránka vašeho oboru názvů služby Service Bus.

Získání připojovací řetězec k oboru názvů (Azure Portal)

Vytvoření nového oboru názvů automaticky vygeneruje počáteční zásadu sdíleného přístupového podpisu (SAS). Zásady zahrnují primární a sekundární klíče a primární a sekundární připojovací řetězce, z nichž každý uděluje úplnou kontrolu nad všemi aspekty oboru názvů. Další informace o vytváření pravidel s více omezenými právy pro běžné odesílatele a příjemce najdete v tématu Ověřování a autorizace služby Service Bus.

Klient se může pomocí připojovací řetězec připojit k oboru názvů služby Service Bus. Pokud chcete zkopírovat primární připojovací řetězec pro váš obor názvů, postupujte takto:

Na stránce Obor názvů služby Service Bus rozbalte Nastavení a pak vyberte Zásady sdíleného přístupu.
Na stránce Zásady sdíleného přístupu vyberte RootManageSharedAccessKey.
V okně Zásady SAS: RootManageSharedAccessKey vyberte tlačítko kopírování vedle primárního připojovacího řetězce. Tato akce zkopíruje připojovací řetězec do schránky pro pozdější použití. Vložte tuto hodnotu do Poznámkového bloku nebo jiného dočasného umístění.

Na této stránce můžete kopírovat primární klíč, sekundární klíč, primární připojovací řetězec a sekundární připojovací řetězec.

Vytvoření tématu pomocí webu Azure Portal

Na stránce Obor názvů služby Service Bus rozbalte Entity v navigační nabídce vlevo a vyberte Témata.
Vyberte + téma.
Zadejte název tématu. U ostatních možností ponechte jejich výchozí hodnoty.
Vyberte Vytvořit.

Vytvoření odběrů tématu

Vyberte téma, které jste vytvořili v předchozí části.
Na stránce Téma služby Service Bus vyberte + Předplatné.
Na stránce Vytvořit předplatné postupujte takto:
1. Jako název předplatného zadejte S1 .
2. Potom vyberte Vytvořit a vytvořte předplatné.
Opakováním předchozího kroku dvakrát vytvořte předplatná s názvem S2 a S3.

Vytvoření pravidel filtrů u odběrů

Jakmile zřídíte obor názvů, témata a odběry a získáte připojovací řetězec k oboru názvů, jste připraveni vytvořit pravidla filtrování pro předplatná. Potom můžete odesílat a přijímat zprávy. Kód můžete zkontrolovat v této složce s ukázkami na GitHubu.

Odesílání a příjem zpráv

Kód spustíte takto:

V okně příkazového řádku nebo na příkazovém řádku PowerShellu naklonujte úložiště GitHub služby Service Bus:
```
git clone https://github.com/Azure/azure-service-bus.git
```
Přejděte do složky s ukázkou azure-service-bus\samples\DotNet\Azure.Messaging.ServiceBus\BasicSendReceiveTutorialWithFilters.
Získejte připojovací řetězec, který jste dříve v tomto kurzu zkopírovali do Poznámkového bloku. Potřebujete také název tématu, které jste vytvořili.
Do příkazového řádku zadejte následující příkaz:
```
dotnet build
```
Přejděte do složky BasicSendReceiveTutorialWithFilters\bin\Debug\netcoreapp3.1.
Pokud chcete program spustit, zadejte následující příkaz. Nezapomeňte nahradit myConnectionString hodnotou a myTopicName názvem tématu, které jste vytvořili:
```
dotnet --roll-forward Major BasicSendReceiveTutorialWithFilters.dll -ConnectionString "myConnectionString" -TopicName "myTopicName"
```
Podle pokynů v konzole nejprve vyberte vytvoření filtru. Součástí vytváření filtrů je odebrání výchozích filtrů. Pokud používáte PowerShell nebo CLI, nemusíte výchozí filtr odstraňovat. Pokud k vytváření filtrů používáte kód, nejprve odeberte výchozí filtr. Příkazy konzoly 1 a 3 vám pomůžou se správou filtrů u odběrů, které jste už vytvořili:
- Příkaz 1 slouží k odebrání výchozích filtrů.
- Příkazem 2 můžete přidat vlastní filtry.
- Spusťte 3: Tento krok pro kurz přeskočte. Tato možnost volitelně odebere vlastní filtry. Nevytváří výchozí filtry.
Po vytvoření filtru můžete odesílat zprávy. Stiskněte klávesu 4 a sledujte, jak se do tématu odešle 10 zpráv:
Stiskněte klávesu 5 a sledujte příjem zprávy. Pokud jste zpátky nedostali 10 zpráv, stisknutím klávesy "m" zobrazte nabídku a pak znovu stiskněte 5.

Vyčištění prostředků

Pokud už prostředky nepotřebujete, vyčistěte prostředky podle těchto kroků.

Na webu Azure Portal přejděte do svého oboru názvů.
Na stránce Obor názvů služby Service Bus vyberte z panelu příkazů odstranit obor názvů a prostředky (fronty, témata a odběry).

Vysvětlení vzorového kódu

Tato část obsahuje další podrobnosti o chování ukázkového kódu.

Získání připojovacího řetězce a tématu

Nejprve kód deklaruje sadu proměnných, které řídí další provádění programu.

string ServiceBusConnectionString;
string TopicName;

static string[] Subscriptions = { "S1", "S2", "S3" };
static IDictionary<string, string[]> SubscriptionFilters = new Dictionary<string, string[]> {
    { "S1", new[] { "StoreId IN('Store1', 'Store2', 'Store3')", "StoreId = 'Store4'"} },
    { "S2", new[] { "sys.To IN ('Store5','Store6','Store7') OR StoreId = 'Store8'" } },
    { "S3", new[] { "sys.To NOT IN ('Store1','Store2','Store3','Store4','Store5','Store6','Store7','Store8') OR StoreId NOT IN ('Store1','Store2','Store3','Store4','Store5','Store6','Store7','Store8')" } }
};
// You can have only have one action per rule and this sample code supports only one action for the first filter, which is used to create the first rule. 
static IDictionary<string, string> SubscriptionAction = new Dictionary<string, string> {
    { "S1", "" },
    { "S2", "" },
    { "S3", "SET sys.Label = 'SalesEvent'"  }
};
static string[] Store = { "Store1", "Store2", "Store3", "Store4", "Store5", "Store6", "Store7", "Store8", "Store9", "Store10" };
static string SysField = "sys.To";
static string CustomField = "StoreId";
static int NrOfMessagesPerStore = 1; // Send at least 1.

Připojovací řetězec a název tématu se předávají pomocí parametrů příkazového řádku, jak je znázorněno. V metodě Main() se čtou.

static void Main(string[] args)
{
    string ServiceBusConnectionString = "";
    string TopicName = "";

    for (int i = 0; i < args.Length; i++)
    {
        if (args[i] == "-ConnectionString")
        {
            Console.WriteLine($"ConnectionString: {args[i + 1]}");
            ServiceBusConnectionString = args[i + 1]; // Alternatively enter your connection string here.
        }
        else if (args[i] == "-TopicName")
        {
            Console.WriteLine($"TopicName: {args[i + 1]}");
            TopicName = args[i + 1]; // Alternatively enter your queue name here.
        }
    }

    if (ServiceBusConnectionString != "" && TopicName != "")
    {
        Program P = StartProgram(ServiceBusConnectionString, TopicName);
        P.PresentMenu().GetAwaiter().GetResult();
    }
    else
    {
        Console.WriteLine("Specify -Connectionstring and -TopicName to execute the example.");
        Console.ReadKey();
    }
}

Odebrání výchozích filtrů

Při vytváření odběru pro něj služba Service Bus vytvoří výchozí filtr. Ten umožňuje příjem všech zpráv odeslaných do tématu. Pokud chcete použít vlastní filtry, můžete výchozí filtr odebrat, jak je vidět v následujícím kódu:

private async Task RemoveDefaultFilters()
{
    Console.WriteLine($"Starting to remove default filters.");

    try
    {
        var client = new ServiceBusAdministrationClient(ServiceBusConnectionString);
        foreach (var subscription in Subscriptions)
        {
            await client.DeleteRuleAsync(TopicName, subscription, CreateRuleOptions.DefaultRuleName);
            Console.WriteLine($"Default filter for {subscription} has been removed.");
        }

        Console.WriteLine("All default Rules have been removed.\n");
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.ToString());
    }

    await PresentMenu();
}

Vytváření filtrů

Následujícím kódem přidáte vlastní filtry definované v tomto kurzu:

private async Task CreateCustomFilters()
{
    try
    {
        for (int i = 0; i < Subscriptions.Length; i++)
        {
            var client = new ServiceBusAdministrationClient(ServiceBusConnectionString);
            string[] filters = SubscriptionFilters[Subscriptions[i]];
            if (filters[0] != "")
            {
                int count = 0;
                foreach (var myFilter in filters)
                {
                    count++;

                    string action = SubscriptionAction[Subscriptions[i]];
                    if (action != "")
                    {
                        await client.CreateRuleAsync(TopicName, Subscriptions[i], new CreateRuleOptions
                        {
                            Filter = new SqlRuleFilter(myFilter),
                            Action = new SqlRuleAction(action),
                            Name = $"MyRule{count}"
                        });
                    }
                    else
                    {
                        await client.CreateRuleAsync(TopicName, Subscriptions[i], new CreateRuleOptions
                        {
                            Filter = new SqlRuleFilter(myFilter),
                            Name = $"MyRule{count}"
                        });
                    }
                }
            }

            Console.WriteLine($"Filters and actions for {Subscriptions[i]} have been created.");
        }

        Console.WriteLine("All filters and actions have been created.\n");
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.ToString());
    }

    await PresentMenu();
}

Odebrání vašich vlastních filtrů

Pokud u odběru chcete odebrat všechny filtry, použijte následující kód:

private async Task CleanUpCustomFilters()
{
    foreach (var subscription in Subscriptions)
    {
        try
        {
            var client = new ServiceBusAdministrationClient(ServiceBusConnectionString);
            IAsyncEnumerator<RuleProperties> rules = client.GetRulesAsync(TopicName, subscription).GetAsyncEnumerator();
            while (await rules.MoveNextAsync())
            {
                await client.DeleteRuleAsync(TopicName, subscription, rules.Current.Name);
                Console.WriteLine($"Rule {rules.Current.Name} has been removed.");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.ToString());
        }
    }
    Console.WriteLine("All default filters have been removed.\n");

    await PresentMenu();
}

Odesílání zpráv

Odeslání zprávy do tématu je podobné jako odesílání zpráv do fronty. Tento příklad ukazuje, jak odesílat zprávy pomocí seznamu úloh a asynchronního zpracování:

public async Task SendMessages()
{
    try
    {
        await using var client = new ServiceBusClient(ServiceBusConnectionString);
        var taskList = new List<Task>();
        for (int i = 0; i < Store.Length; i++)
        {
            taskList.Add(SendItems(client, Store[i]));
        }

        await Task.WhenAll(taskList);
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.ToString());
    }
    Console.WriteLine("\nAll messages sent.\n");
}

private async Task SendItems(ServiceBusClient client, string store)
{
    // create the sender
    ServiceBusSender tc = client.CreateSender(TopicName);

    for (int i = 0; i < NrOfMessagesPerStore; i++)
    {
        Random r = new Random();
        Item item = new Item(r.Next(5), r.Next(5), r.Next(5));

        // Note the extension class which is serializing an deserializing messages
        ServiceBusMessage message = item.AsMessage();
        message.To = store;
        message.ApplicationProperties.Add("StoreId", store);
        message.ApplicationProperties.Add("Price", item.GetPrice().ToString());
        message.ApplicationProperties.Add("Color", item.GetColor());
        message.ApplicationProperties.Add("Category", item.GetItemCategory());

        await tc.SendMessageAsync(message);
        Console.WriteLine($"Sent item to Store {store}. Price={item.GetPrice()}, Color={item.GetColor()}, Category={item.GetItemCategory()}"); ;
    }
}

Příjem zpráv

Zprávy se znovu přijímají pomocí seznamu úkolů a kód používá dávkování. Pomocí dávkování můžete zprávy odesílat i přijímat, tento příklad ale ukazuje jenom postup při dávkovém příjmu. Ve skutečnosti byste smyčku neprolomili, ale zachovali smyčku a nastavili vyšší časový rozsah, například jednu minutu. Příjem volání do zprostředkovatele je po tuto dobu otevřené. Pokud zprávy dorazí, jsou vráceny okamžitě. Je vydáno nové přijímací volání.

Tato technika se označuje jako dlouhé intervaly dotazování. Použití přijímacího čerpadla, které můžete vidět v několika příkladech v úložišti, je obvyklejší možnost. Další informace najdete v odkazu Použití portálu Azure k vytvoření oboru názvů služby Service Bus a fronty.

public async Task Receive()
{
    var taskList = new List<Task>();
    for (var i = 0; i < Subscriptions.Length; i++)
    {
        taskList.Add(this.ReceiveMessages(Subscriptions[i]));
    }

    await Task.WhenAll(taskList);
}

private async Task ReceiveMessages(string subscription)
{
    await using var client = new ServiceBusClient(ServiceBusConnectionString);
    ServiceBusReceiver receiver = client.CreateReceiver(TopicName, subscription);

    // In reality you would not break out of the loop like in this example but would keep looping. The receiver keeps the connection open
    // to the broker for the specified amount of seconds and the broker returns messages as soon as they arrive. The client then initiates
    // a new connection. So in reality you would not want to break out of the loop. 
    // Also note that the code shows how to batch receive, which you would do for performance reasons. For convenience you can also always
    // use the regular receive pump which we show in our Quick Start and in other GitHub samples.
    while (true)
    {
        try
        {
            //IList<Message> messages = await receiver.ReceiveAsync(10, TimeSpan.FromSeconds(2));
            // Note the extension class which is serializing an deserializing messages and testing messages is null or 0.
            // If you think you did not receive all messages, just press M and receive again via the menu.
            IReadOnlyList<ServiceBusReceivedMessage> messages = await receiver.ReceiveMessagesAsync(maxMessages: 100);

            if (messages.Any())
            {
                foreach (ServiceBusReceivedMessage message in messages)
                {
                    lock (Console.Out)
                    {
                        Item item = message.As<Item>();
                        IReadOnlyDictionary<string, object> myApplicationProperties = message.ApplicationProperties;
                        Console.WriteLine($"StoreId={myApplicationProperties["StoreId"]}");
                        if (message.Subject != null)
                        {
                            Console.WriteLine($"Subject={message.Subject}");
                        }
                        Console.WriteLine(
                            $"Item data: Price={item.GetPrice()}, Color={item.GetColor()}, Category={item.GetItemCategory()}");
                    }

                    await receiver.CompleteMessageAsync(message);
                }
            }
            else
            {
                break;
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.ToString());
        }
    }
}

Poznámka:

Prostředky služby Service Bus můžete spravovat pomocí Service Bus Exploreru. Service Bus Explorer umožňuje uživatelům připojit se k oboru názvů služby Service Bus a snadno spravovat entity zasílání zpráv. Nástroj poskytuje pokročilé funkce, jako jsou funkce importu a exportu nebo možnost testovat téma, fronty, odběry, předávací služby, centra oznámení a centra událostí.

V tomto kurzu jste zřídili prostředky na portálu Azure Portal a poté odesílali a přijímali zprávy z tématu služby Service Bus a jeho odběrů. Naučili jste se:

Pomocí portálu Azure Portal vytvořit téma služby Service Bus a k němu jeden nebo více odběrů
Přidávat filtry témat pomocí kódu .NET
Vytvořit dvě zprávy s různým obsahem
Odeslat zprávy a ověřit, že dorazily do očekávaných odběrů
Přijímat zprávy z odběrů

Další příklady odesílání a přijímání zpráv najdete v ukázkách služby Service Bus na GitHubu.

Přejděte k dalšímu kurzu, kde se dozvíte více o možnostech publikování a přihlášení k odběru ve službě Service Bus.

Reakce na události přes Event Grid

Sdílet prostřednictvím