.net core实现从service bus读取消息，并且记录到Azure sql中简单例子

以下是一个简单的示例，展示如何使用Azure Service Bus和Azure SQL Server记录消息：

创建一个ASP.NET Core Web应用程序。
添加以下NuGet包：

Microsoft.Azure.ServiceBus
Microsoft.EntityFrameworkCore.SqlServer
Microsoft.EntityFrameworkCore.Tools

创建一个名为“Message”的模型类，用于表示要存储在Azure SQL Server中的消息。

public class Message
{
    public int Id { get; set; }
    public string Body { get; set; }
    public DateTime Timestamp { get; set; }
}

创建一个名为“MessageContext”的DbContext类，用于将消息保存到Azure SQL Server中。

public class MessageContext : DbContext
{
    public MessageContext(DbContextOptions<MessageContext> options) : base(options)
    {
    }

    public DbSet<Message> Messages { get; set; }
}

配置Azure SQL Server连接字符串，将其添加到appsettings.json文件中。

{
  "ConnectionStrings": {
    "MessageContext": "Server=<server>;Database=<database>;User Id=<user>;Password=<password>;"
  }
}

在Startup.cs文件中，将MessageContext添加到服务集合中。

services.AddDbContext<MessageContext>(options =>
    options.UseSqlServer(Configuration.GetConnectionString("MessageContext")));

创建一个名为“MessageReceiver”的类，用于从Azure Service Bus接收消息并将其保存到Azure SQL Server中。

public class MessageReceiver : IHostedService, IDisposable
{
    private const string ServiceBusConnectionString = "<service-bus-connection-string>";
    private const string QueueName = "<queue-name>";
    private readonly IQueueClient _queueClient;
    private readonly MessageContext _messageContext;

    public MessageReceiver(MessageContext messageContext)
    {
        _messageContext = messageContext;
        _queueClient = new QueueClient(ServiceBusConnectionString, QueueName);
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        var messageHandlerOptions = new MessageHandlerOptions(ExceptionReceivedHandler)
        {
            MaxConcurrentCalls = 1,
            AutoComplete = false
        };

        _queueClient.RegisterMessageHandler(ProcessMessageAsync, messageHandlerOptions);

        return Task.CompletedTask;
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        return _queueClient.CloseAsync();
    }

    public void Dispose()
    {
        _queueClient.Dispose();
    }

    private async Task ProcessMessageAsync(Message message, CancellationToken cancellationToken)
    {
        var body = Encoding.UTF8.GetString(message.Body);
        var messageToSave = new Message
        {
            Body = body,
            Timestamp = DateTime.UtcNow
        };

        _messageContext.Messages.Add(messageToSave);
        await _messageContext.SaveChangesAsync();

        await _queueClient.CompleteAsync(message.SystemProperties.LockToken);
    }

    private 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;
    }
}

在Startup.cs文件中，将MessageReceiver添加到服务集合中。

services.AddHostedService<MessageReceiver>();

这样，您就可以从Azure Service Bus接收消息并将其保存到Azure SQL Server中。

.net core实现从service bus读取消息，并且记录到Azure sql中简单例子