vs2022 .net core 7.0 实现向service bus发送数据，再从service bus读取数据并写入Azure sql中

以下是实现向 Service Bus 发送数据，再从 Service Bus 读取数据并写入 Azure SQL 的步骤：

1. 创建一个 .NET Core 7.0 项目。

2. 安装以下 NuGet 包：

• Microsoft.Azure.ServiceBus

• Microsoft.Azure.Services.AppAuthentication

• Microsoft.Data.SqlClient

3. 创建一个 Service Bus，并获取连接字符串。

4. 创建一个 Azure SQL 数据库，并获取连接字符串。

5. 创建一个类，用于处理与 Service Bus 和 Azure SQL 的交互。以下是一个示例类：

using Microsoft.Azure.ServiceBus;
using Microsoft.Azure.Services.AppAuthentication;
using Microsoft.Data.SqlClient;
using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

public class ServiceBusToSqlHandler
{
    private readonly string _serviceBusConnectionString;
    private readonly string _serviceBusQueueName;
    private readonly string _sqlConnectionString;
    private readonly string _sqlTableName;

    public ServiceBusToSqlHandler(string serviceBusConnectionString, string serviceBusQueueName, string sqlConnectionString, string sqlTableName)
    {
        _serviceBusConnectionString = serviceBusConnectionString;
        _serviceBusQueueName = serviceBusQueueName;
        _sqlConnectionString = sqlConnectionString;
        _sqlTableName = sqlTableName;
    }

    public async Task SendMessageToServiceBusAsync(string messageBody)
    {
        var tokenProvider = new AzureServiceTokenProvider();
        var queueClient = new QueueClient(_serviceBusConnectionString, _serviceBusQueueName);
        var message = new Message(Encoding.UTF8.GetBytes(messageBody));
        await queueClient.SendAsync(message);
        await queueClient.CloseAsync();
    }

    public async Task ReadAndWriteToSqlAsync()
    {
        var tokenProvider = new AzureServiceTokenProvider();
        var queueClient = new QueueClient(_serviceBusConnectionString, _serviceBusQueueName);
        var sqlConnection = new SqlConnection(_sqlConnectionString);
        await sqlConnection.OpenAsync();

        var messageHandlerOptions = new MessageHandlerOptions(ExceptionReceivedHandler)
        {
            MaxConcurrentCalls = 1,
            AutoComplete = false
        };

        queueClient.RegisterMessageHandler(async (message, cancellationToken) =>
        {
            try
            {
                var messageBody = Encoding.UTF8.GetString(message.Body);

                // Write to Azure SQL
                var sqlCommand = new SqlCommand($"INSERT INTO {_sqlTableName} (Message) VALUES (@Message)", sqlConnection);
                sqlCommand.Parameters.AddWithValue("@Message", messageBody);
                await sqlCommand.ExecuteNonQueryAsync();

                // Complete the message
                await queueClient.CompleteAsync(message.SystemProperties.LockToken);
            }
            catch (Exception ex)
            {
                // Abandon the message
                await queueClient.AbandonAsync(message.SystemProperties.LockToken);

                // Log the exception
                Console.WriteLine($"Message processing failed: {ex.Message}");
            }
        }, messageHandlerOptions);

        while (true)
        {
            Thread.Sleep(1000);
        }
    }

    Task ExceptionReceivedHandler(ExceptionReceivedEventArgs exceptionReceivedEventArgs)
    {
        Console.WriteLine($"Message handler encountered an exception {exceptionReceivedEventArgs.Exception}.");
        var context = exceptionReceivedEventArgs.ExceptionReceivedContext;
        Console.WriteLine("Exception context for troubleshooting:");
        Console.WriteLine($"- Endpoint: {context.Endpoint}");
        Console.WriteLine($"- Entity Path: {context.EntityPath}");
        Console.WriteLine($"- Executing Action: {context.Action}");
        return Task.CompletedTask;
    }
}

6. 在 Main 方法中调用上面的类的方法。以下是一个示例 Main 方法：

static async Task Main(string[] args)
{
    var serviceBusConnectionString = "your_service_bus_connection_string";
    var serviceBusQueueName = "your_service_bus_queue_name";
    var sqlConnectionString = "your_azure_sql_connection_string";
    var sqlTableName = "your_azure_sql_table_name";

    var handler = new ServiceBusToSqlHandler(serviceBusConnectionString, serviceBusQueueName, sqlConnectionString, sqlTableName);

    // Send a message to Service Bus
    await handler.SendMessageToServiceBusAsync("Hello, Service Bus!");

    // Read from Service Bus and write to Azure SQL
    await handler.ReadAndWriteToSqlAsync();
}

7. 运行项目，确保程序正常运行并可以从 Service Bus 读取消息并将其写入 Azure SQL。

注意：此示例仅仅是示范，实际上应该处理更多的错误和异常情况，并针对性能进行优化。