从Microsoft.Azure.ServiceBus迁移到Azure.Messaging.ServiceBus

z2acfund 于 2023-05-23 发布在其他

关注(0)|答案(3)|浏览(237)

我正在尝试更新此函数以使用Azure.Messaging.ServiceBus并完全删除Microsoft.Azure.ServiceBus，但似乎找不到任何资源。有人知道如何使用这个包向主题发送消息吗？
旧的函数是：

public async Task SendMessageToServiceBusTopic<T>(T request, string topicSubName, string submissionNumber)
    {
        ServiceBusConnectionStringBuilder serviceBusConnectionStringBuilder =
            new ServiceBusConnectionStringBuilder(settings.ServiceBusConnectionString)
            {
                EntityPath = settings.ServiceBusTopic
            };
     
            TopicClient topicClient = new TopicClient(serviceBusConnectionStringBuilder);
            byte[] bytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(request));
            await topicClient.SendAsync(new Message(bytes)
            {
                CorrelationId = context.CorrelationId,
                Label=topicSubName,
                UserProperties = { new KeyValuePair<string, object>("TrackingId", submissionNumber) }
            });          
    }

到目前为止，我已经做到了：
我走的方向对吗？

public async Task SendMessageToServiceBusTopic<T>(T request, string topicSubName, string submissionNumber)
    {
        ServiceBusClient client = new ServiceBusClient(settings.ServiceBusConnectionString);
        ServiceBusSender s = client.CreateSender(settings.ServiceBusTopic);
            byte[] bytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(request));
            await s.SendMessageAsync(new ServiceBusMessage(bytes));
      }

Azure

来源：https://stackoverflow.com/questions/69980614/migration-from-microsoft-azure-servicebus-to-azure-messaging-servicebus

3条答案

按热度按时间

h6my8fg21#

虽然每次都可以构造服务总线客户机，但这并不理想。假设您使用的是最新的In-Proc SDK，您可以使用以下选项之一：

[FunctionName("PublishToTopic")]
public static async Task Run(
    [TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,
    [ServiceBus("<topic_name>", Connection = "<connection_name>")] IAsyncCollector<ServiceBusMessage> collector)
{
    await collector.AddAsync(new ServiceBusMessage(new BinaryData($"Message 1 added at: {DateTime.Now}")));
    await collector.AddAsync(new ServiceBusMessage(new BinaryData($"Message 2 added at: {DateTime.Now}")));
}

或者，

[FunctionName("PublishWithSender"]
public static async Task Run(
    [TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,
    [ServiceBus("<topic_name>", Connection = "<connection_name>")] ServiceBusSender sender)
{
    await sender.SendMessagesAsync(new[]
    {
        new ServiceBusMessage(new BinaryData($"Message 1 added at: {DateTime.Now}")),
        new ServiceBusMessage(new BinaryData($"Message 2 added at: {DateTime.Now}"))
    });
}

对于隔离工作者SDK，它有些不同。详情请参见this post。

展开查看全部

赞(0）回复(0）举报 2023-05-23

inn6fuwd2#

我和你的情况一样（试图迁移到Azure.Messaging.ServiceBus，这是微软现在推荐的NuGet）。
你可以从他们的Github上看一下迁移指南，了解如何使过渡更平滑：https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/servicebus/Azure.Messaging.ServiceBus/MigrationGuide.md
/！*IQueueClient和ITopicClient*（均来自Microsoft.Azure.ServiceBus）已合并为一个名为ServiceBusSender的对象。
为什么？让我们的生活更轻松！实际上，在幕后，ServiceBusSender现在负责发送消息的过程，特别是因为队列和主题不能具有相同的名称（如果我没有错的话）。
下面是我使用新库发送消息的示例代码：

/// <summary>
    /// Send a message by serializing as JSON the object in input. 
    /// </summary>
    /// <param name="queueOrTopicName">Name of the queue or topic where the message will be sent.</param>
    /// <param name="messageToSend">Any C# object</param>
    /// <returns></returns>
    public async Task SendMessage(string queueOrTopicName, object messageToSend)
    {
        //ServiceBusSender should not be disposed (according to the documentation, Github, etc.)
        await using ServiceBusClient client = new ServiceBusClient(connectionString: "Your-ServiceBus-ConnectionString");
        await using ServiceBusSender sender = client.CreateSender(_queueOrTopicName);
        // create a message that we can send. UTF-8 encoding is used when providing a string.
        ServiceBusMessage message = BuildServiceBusMessage(messageToSend);
        // Finally send the message
        await sender.SendMessageAsync(message);
    }
    private ServiceBusMessage BuildServiceBusMessage<T>(T entity)
    {
        string serializedMessage = JsonConvert.SerializeObject(entity); // Still using Newtonsoft.Json but I don't see any obstacles of using System.Text.Json.
        ServiceBusMessage message = new ServiceBusMessage(serializedMessage)
        {
            MessageId = Guid.NewGuid().ToString(),
            ContentType = "application/json; charset=utf-8",
        };
        return message;
    }