servicebus - 如何使用 webjob sdk 的内置功能发送服务总线消息

Question

我想使用 azure web job sdk 提供的内置功能推送服务总线消息。https://github.com/Azure/azure-webjobs-sdk/wiki/Service-Bus 这个链接提到了怎么做但还不清楚

Answer 1

Service Bus提供了所有先决条件和代码片段，供您接收/创建 Service Bus 消息。

要编写一个创建新队列消息的函数，请使用ServiceBus属性并将队列名称传递给属性构造函数。

创建单个队列消息：

public static void CreateServiceBusQueueMessage(
    [ServiceBusTrigger("inputqueue")] string queueMessage,
    [ServiceBus("<your-queue-name>")] out string outputMessage)
{
    outputMessage = queueMessage;
}

创建单个队列消息的输出参数可以是以下任意一种：

• 细绳
• 字节[]
• 代理消息
• 您定义的可序列化 POCO 类型。自动序列化为 JSON。

创建服务总线主题消息：

public static void CreateServiceBusTopicMessage(
    [ServiceBusTrigger("inputqueue")] string queueMessage,
    [ServiceBus("<your-topic-name>")] out string outputMessage)
{
    outputMessage = queueMessage;
}

此外，您还可以使用TimerTrigger, FileTrigger, QueueTrigger, BlobTrigger,EventHubTrigger来触发函数的执行以创建服务总线队列/主题消息。您可以在此处了解详细信息和Microsoft Azure WebJobs SDK ServiceBus Sample。