Azure Service Bus Topic And Subscription (Pub-Sub)

Azure Service Bus - Topic

This articles explains about Azure Service Bus Topic and Subscription which is commonly known as pub-sub with a real world scenario.

Business Requirement

The business requirement is in my previous article,

So far we have seen about mobile recharge where we have used queuing mechanism. Now a company wants to provide some offers on regular recharge. But how will registered users come to know about these offers?

So again the company has started looking for some solution and finally it has come up with the solution of Azure Service Bus - Topic. Topic works like pub-sub model where one is the publisher and there can be many subscribers for the same publisher. In our scenario the publisher will publish offers and subscribed users will get the offers immediately.

Now let's see the step by step implementation of the below to design a solution:

• Log in to the Azure portal via portal.azure.com
• Explore previously created Service Namespace; i.e. Mobile Recharge
• Click on '+Topic' under Topics to create a new topic
  
  
  

• Give appropriate name for Topic
• Keep the rest of the input values as is and click on 'Create' button
  
  
  

We can see that Topic is created in it is shown under topics list.

• Click on previously created topic; i.e. 'Offers', which will show the list of subscriptions. As of now it shows empty
• Click on '+Subscription' under subscriptions to create subscription
  
  
  

• Give proper name of subscription
• Change Lock duration to 5 minutes and click on 'Create' button, which will create subscription for topic
  
  
  

• Follow the preceding steps and create one more subscription
  
  
  

We can see both the subscriptions in the list.

Credentials

Click on 'Shared access policies' from the left panel, click on 'RootManageSharedAccessKey' to explore keys and connection strings which will be used further to connect.

Publish Message

• Create a console application in Visual Studio
• Set variables, one for connection string which you can copy from Shared access policies section and another is topic name; i.e. offers
• In order to publish the offers, we need an offer from user
• Add Microsoft.Azure.ServiceBus from a NuGet package manager
• Create topic client using connection string and queue name
• Convert string message to Azure Service Bus message
• Using topic client, call SendAsync method to publish the message.
• Call CloseAsync to close opened connection in finally block.
  
  1. class Program
  2. {
  3. static ITopicClient topicClient;
  4. static void Main(string[] args)
  5. {
  6. string sbConnectionString = "Endpoint=sb://mobilerecharge.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=KVb9ubc9XaV0dT/1dMjW9CzPWvA/JGvVvUZ64U21IBI=";
  7. string sbTopic = "offers";
  9. string messageBody=string.Empty;
  10. try
  11. {
  12. Console.WriteLine("-------------------------------------------------------");
  13. Console.WriteLine("Publish Offer");
  14. Console.WriteLine("-------------------------------------------------------");
  15. Console.WriteLine("Offers");
  16. Console.WriteLine("1. Recharge with 100 and get talk time of 110");
  17. Console.WriteLine("2. Get 5 GB data on recharge of 300. Validity 28 days");
  18. Console.WriteLine("3. 1000 SMS in recharge of 100");
  19. Console.WriteLine("-------------------------------------------------------");
  21. Console.WriteLine("Offer:");
  22. string offer = Console.ReadLine();
  24. Console.WriteLine("-------------------------------------------------------");
  26. switch (offer)
  27. {
  28. case "1":
  29. offer = "Recharge with 100 and get talk time of 110";
  30. break;
  31. case "2":
  32. offer = "Get 5 GB data on recharge of 300. Validity 28 days";
  33. break;
  34. case "3":
  35. offer = "1000 SMS in recharge of 100";
  36. break;
  37. default:
  38. break;
  39. }
  41. messageBody = offer;
  42. topicClient = new TopicClient(sbConnectionString, sbTopic);
  44. var message = new Message(Encoding.UTF8.GetBytes(messageBody));
  45. Console.WriteLine($"Message Published: {messageBody}");
  47. topicClient.SendAsync(message);
  49. }
  50. catch (Exception ex)
  51. {
  52. Console.WriteLine(ex.Message);
  53. }
  54. finally
  55. {
  56. Console.ReadKey();
  57. topicClient.CloseAsync();
  58. }
  59. }
  60. }