使用 .NET 6.0 从 Azure Service Bus 读取数据并写入数据库

要从 Azure Service Bus 读取数据并将其写入数据库，您需要使用 Service Bus SDK 和数据库驱动程序。

以下是一个示例代码，它使用 Azure Service Bus SDK 和 SQL Server 数据库驱动程序来读取队列中的消息并将其插入到数据库中：

using Azure.Messaging.ServiceBus;
using System.Data.SqlClient;

string connectionString = 'Data Source=myserver;Initial Catalog=mydatabase;Integrated Security=True';

// Create a Service Bus client
ServiceBusClient client = new ServiceBusClient('<connection-string>');

// Create a Service Bus processor
ServiceBusProcessor processor = client.CreateProcessor('<queue-name>', new ServiceBusProcessorOptions());

// Add message handler to the processor
processor.ProcessMessageAsync += async args =>
{
    // Get message body
    string messageBody = args.Message.Body.ToString();

    // Insert message into database
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();
        SqlCommand command = new SqlCommand('INSERT INTO MyTable (Message) VALUES (@Message)', connection);
        command.Parameters.AddWithValue('@Message', messageBody);
        await command.ExecuteNonQueryAsync();
    }

    // Complete the message
    await args.CompleteMessageAsync(args.Message);
};

// Start the processor
await processor.StartProcessingAsync();

// Wait for user input to stop the processor
Console.WriteLine('Press any key to stop processing...');
Console.ReadKey();

// Stop the processor
await processor.StopProcessingAsync();

在上面的代码中，我们创建了一个 Service Bus 客户端和处理器，并添加了一个消息处理程序。该处理程序将读取消息的主体并将其插入到 SQL Server 数据库中。最后，我们启动处理器并等待用户输入来停止处理器。

请注意，您需要将上面的代码中的 <connection-string> 和 <queue-name> 替换为您自己的值。另外，您还需要安装 Azure.Messaging.ServiceBus 和 System.Data.SqlClient NuGet 软件包。