VS2022 .NET Core 7.0 实现 Service Bus 数据发送和 Azure SQL 数据写入

使用 .NET Core 7.0 和 VS2022 实现 Service Bus 数据发送和 Azure SQL 数据写入

本指南将详细介绍如何使用 .NET Core 7.0 和 VS2022 在 Azure Service Bus 中发送和接收数据，并将其写入 Azure SQL 数据库。

1. 创建 .NET Core 7.0 项目

首先，我们需要创建一个 .NET Core 7.0 项目。可以使用 Visual Studio 2022 或者 .NET Core CLI 创建。

2. 安装 Microsoft.Azure.ServiceBus NuGet 包

打开 NuGet 包管理器，搜索 Microsoft.Azure.ServiceBus，并安装。

3. 创建 Service Bus 的连接字符串

在 Azure 门户中创建一个 Service Bus 命名空间，然后创建一个队列或主题。在'共享访问策略'选项卡中创建一个新的策略，并复制连接字符串。

4. 发送消息到 Service Bus

使用以下代码向 Service Bus 发送数据：

using Microsoft.Azure.ServiceBus;
using System;
using System.Text;
using System.Threading.Tasks;

public class ServiceBusProducer
{
    const string ServiceBusConnectionString = '<your_connection_string>';
    const string QueueName = '<your_queue_name>';
    static IQueueClient queueClient;

    public async Task SendMessagesAsync()
    {
        queueClient = new QueueClient(ServiceBusConnectionString, QueueName);

        // Send messages.
        await SendMessagesAsync();

        await queueClient.CloseAsync();
    }

    static async Task SendMessagesAsync()
    {
        try
        {
            // Create a new message to send to the queue.
            string messageBody = 'Hello, World!';
            var message = new Message(Encoding.UTF8.GetBytes(messageBody));

            // Send the message to the queue.
            await queueClient.SendAsync(message);
        }
        catch (Exception exception)
        {
            Console.WriteLine($'{DateTime.Now} :: Exception: {exception.Message}');
        }
    }
}

5. 从 Service Bus 读取消息并写入 Azure SQL

使用以下代码从 Service Bus 读取数据并将其写入 Azure SQL：

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

public class ServiceBusConsumer
{
    const string ServiceBusConnectionString = '<your_connection_string>';
    const string QueueName = '<your_queue_name>';
    static IQueueClient queueClient;

    const string SqlConnectionString = '<your_sql_connection_string>';

    public async Task ReceiveMessagesAsync(CancellationToken cancellationToken)
    {
        queueClient = new QueueClient(ServiceBusConnectionString, QueueName);

        // Register the function that processes messages.
        queueClient.RegisterMessageHandler(ProcessMessagesAsync, new MessageHandlerOptions(ExceptionReceivedHandler));

        await Task.Delay(Timeout.Infinite, cancellationToken);

        await queueClient.CloseAsync();
    }

    static async Task ProcessMessagesAsync(Message message, CancellationToken token)
    {
        // Deserialize the message body.
        var messageBody = Encoding.UTF8.GetString(message.Body);

        // Write the message to Azure SQL.
        using (var connection = new SqlConnection(SqlConnectionString))
        {
            await connection.OpenAsync();

            var command = new SqlCommand($'INSERT INTO MyTable (Message) VALUES ('{messageBody}')', connection);
            await command.ExecuteNonQueryAsync();
        }

        // Complete the message.
        await queueClient.CompleteAsync(message.SystemProperties.LockToken);
    }

    static Task ExceptionReceivedHandler(ExceptionReceivedEventArgs exceptionReceivedEventArgs)
    {
        Console.WriteLine($'Message handler encountered an exception {exceptionReceivedEventArgs.Exception}.');
        return Task.CompletedTask;
    }
}

总结

以上就是实现向 Service Bus 发送数据，再从 Service Bus 读取数据并写入 Azure SQL 的步骤了。当然，这只是一个简单的示例，实际应用中还需要考虑更多的情况，如异常处理、并发控制等。