Azure Service Bus Explained | Why It Exists + Simple C# Demo скачать в хорошем качестве

Azure Service Bus Explained | Why It Exists + Simple C# Demo

In this video, we dive into Azure Service Bus — Microsoft’s enterprise-grade messaging service. 🔹 We’ll start by covering why Azure Service Bus exists and where it fits into modern cloud architecture. 🔹 Next, we’ll break down how it works, including queues, topics, and message handling. 🔹 Finally, we’ll build a simple C# application step by step to send and receive messages using Azure Service Bus. Whether you’re new to messaging systems or want a quick refresher with a practical example, this tutorial will give you a solid foundation to get started. 📌 What you’ll learn: 🔹Why Service Bus is used in distributed systems 🔹Core concepts (queues, topics, subscriptions) 🔹How to implement a simple sender and receiver in C# === Timestamps === 0:00 - Intro 0:41 - What does Azure Service Bus offer? 6:31 - Setting up an Azure Service Bus 13:41 - Building our C# App and testing the Queue ☕ SUPPORT THE CHANNEL If you’re enjoying these videos and want to help me make more, consider buying me a coffee: https://buymeacoffee.com/lukesaunders #azureservicebus #azuretutorials C# code: Receiver.cs using System; using System.Threading.Tasks; using Azure.Messaging.ServiceBus; class Receiver { private const string connectionString = "Connection string here"; private const string queueName = "queue name here"; static async Task Main(string[] args) { Console.WriteLine($"Listening to queue: {queueName}"); await using var client = new ServiceBusClient(connectionString); ServiceBusProcessor processor = client.CreateProcessor(queueName, new ServiceBusProcessorOptions { AutoCompleteMessages = true }); processor.ProcessMessageAsync += MessageHandler; processor.ProcessErrorAsync += ErrorHandler; await processor.StartProcessingAsync(); Console.WriteLine("Press [Enter] to exit..."); Console.ReadLine(); await processor.StopProcessingAsync(); } private static async Task MessageHandler(ProcessMessageEventArgs args) { string body = args.Message.Body.ToString(); string messageId = args.Message.MessageId; Console.WriteLine($"Received message:"); Console.WriteLine($" MessageId: {messageId}"); Console.WriteLine($" Body: {body}"); Console.WriteLine($" -------------------------------------------------------------"); } private static Task ErrorHandler(ProcessErrorEventArgs args) { Console.WriteLine($"Error: {args.Exception.Message}"); return Task.CompletedTask; } } --------------------------------------------------------------------------------------------------------------------- Sender.cs using System; using System.IO; using System.Threading.Tasks; using Azure.Messaging.ServiceBus; class Sender { // Azure Service Bus connection details private const string connectionString = "Connection string here"; private const string queueName = "queue name here"; static async Task Main(string[] args) { string directoryToWatch = @"C:\demos\servicebus\orderfiles"; // Change to your directory string archiveDir = Path.Combine(directoryToWatch, "archive"); if (!Directory.Exists(archiveDir)) { Directory.CreateDirectory(archiveDir); } Console.WriteLine($"Monitoring directory: {directoryToWatch}"); FileSystemWatcher watcher = new FileSystemWatcher(directoryToWatch, "*.xml"); watcher.Created += async (sender, e) ={angled bracket here} await OnNewFile(e.FullPath, archiveDir); watcher.EnableRaisingEvents = true; Console.WriteLine("Press [Enter] to exit..."); Console.ReadLine(); } private static async Task OnNewFile(string filePath, string archiveDir) { try { Console.WriteLine($"New file detected: {filePath}"); await Task.Delay(1000); string xmlContent = await File.ReadAllTextAsync(filePath); await SendMessageToQueue(xmlContent); string destFileName = Path.Combine(archiveDir, Path.GetFileName(filePath)); File.Move(filePath, destFileName, overwrite: true); Console.WriteLine($"File {Path.GetFileName(filePath)} sent and archived."); } catch (Exception ex) { Console.WriteLine($"Error processing file {filePath}: {ex.Message}"); } } private static async Task SendMessageToQueue(string messageBody) { await using var client = new ServiceBusClient(connectionString); ServiceBusSender sender = client.CreateSender(queueName); ServiceBusMessage message = new ServiceBusMessage(messageBody); await sender.SendMessageAsync(message); } }