我正在尝试使用 C# azure 函数从队列中读取消息(通知而不是轮询)。
我目前正在使用控制台应用程序将消息推送到队列中,见下文。
似乎有两种不同的产品,Azure 服务总线和存储帐户中的队列。下面的代码用的是后面的,不知道怎么读取队列的消息?
非常感谢,
代码示例
StorageCredentials creds = new StorageCredentials(accountname, accountkey);
CloudStorageAccount account = new CloudStorageAccount(creds, useHttps: true);
CloudQueueClient queueClient = account.CreateCloudQueueClient();
CloudQueue queue = queueClient.GetQueueReference("test-queue");
queue.CreateIfNotExists();
while (true)
{
CloudQueueMessage message = new CloudQueueMessage(JsonConvert.SerializeObject("my message"));
queue.AddMessage(message);
}
更新
在专家建议的评论和以下链接试图帮助之后,我尝试了以下代码示例将消息推送到 Azure 服务总线(即不是存储帐户中的队列)
namespace ConsoleApp1
{
using System;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.ServiceBus;
class Program
{
const string ServiceBusConnectionString = "Endpoint=sb://xxx.servicebus.windows.net/;SharedAccessKeyName=xxx;SharedAccessKey=xxx";
const string QueueName = "name_of_queue";
static IQueueClient queueClient;
public static async Task Main(string[] args)
{
const int numberOfMessages = 10;
queueClient = new QueueClient(ServiceBusConnectionString, QueueName);
await SendMessagesAsync(numberOfMessages);
await queueClient.CloseAsync();
}
static async Task SendMessagesAsync(int numberOfMessagesToSend)
{
for (var i = 0; i < numberOfMessagesToSend; i++)
{
string messageBody = $"Message {i}";
var message = new Message(Encoding.UTF8.GetBytes(messageBody));
Console.WriteLine($"Sending message: {messageBody}");
// Send the message to the queue
try
{
await queueClient.SendAsync(message); // this line
}
catch (Exception ex)
{
throw ex;
}
}
}
}
}
当我在控制台窗口上方运行代码时,什么都不做,没有错误消息,什么都没有..!奇怪..查看天蓝色服务总线概述它的活动消息计数为零。
我正在使用这个示例项目,但 queueClient.SendAsync 永远不会返回。我是否需要在天蓝色的权限中设置一些东西?
https://github.com/Azure/azure-service-bus
最终收到错误
连接尝试失败,因为连接的一方在一段时间后没有正确响应,或者连接失败,因为连接的主机没有响应
我可以在门户服务总线屏幕中看到请求