c# - 获取Azure Servicebus队列错误 "The argument namespaceConnectionString is null or white space.\r\nParameter name: namespaceConnectionString"

Question

我正面临这个问题。我已在 Azure 门户上创建了 ServiceBus 队列。我还编写了用于发送数据的.Net core 应用程序。当我从应用程序将数据发送到队列时，当 QueueClient 初始化时，我在连接字符串处收到以下错误消息:

“参数namespaceConnectionString为空或空格。\r\n参数名称:namespaceConnectionString”

我也有谷歌并尝试了所有选项，例如从连接字符串中删除EntityPath。还尝试了不同的目标框架版本(直到 3.1)以及当前使用的 .Net Core 2.2。

请帮助我。

using AzureTestProject.Interface;
using Microsoft.Azure.ServiceBus;
using Microsoft.Extensions.Configuration;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace AzureQueueService
{
    public class ServiceBusQueue  
    {
        private  QueueClient _queueClient;
        private readonly IConfiguration _configuration;
        private const string QUEUE_NAME = "devicetestqueue";
        private string _connectionString;

        // Payload =  {"Id":"1","Type":"Device1","SerialNumber":"10001"}
        public async Task SendMessage(object payload)
        {
            try
            {
                _queueClient = new QueueClient(
                _configuration.GetConnectionString("Endpoint=sb://Subscription.servicebus.windows.net/;SharedAccessKeyName=DeviceTestQueueListenAccessKey;SharedAccessKey=hjklgtfapinznyx2gSnPqngQgIa9p7AxeihLoBz8+Sc=;EntityPath=devicetestqueue"),
                QUEUE_NAME);

                string data = JsonConvert.SerializeObject(payload);
                Message message = new Message(Encoding.UTF8.GetBytes(data));

                await _queueClient.SendAsync(message);
            }
            catch (Exception ex)
            {
                throw;
            }            
        }
    }
}

Answer 1

我得到的解决方案如下:

 public async Task SendMessage(object payload)
        {
            try
            {                
                _queueClient = new QueueClient("Endpoint=sb://Subscription.servicebus.windows.net/;SharedAccessKeyName=DeviceTestQueueListenAccessKey;SharedAccessKey=hjklgtfapinznyx2gSnPqngQgIa9p7AxeihLoBz8+Sc=;EntityPath=devicetestqueue", QUEUE_NAME);
                string data = JsonConvert.SerializeObject(payload);
                Message message = new Message(Encoding.UTF8.GetBytes(data));

                await _queueClient.SendAsync(message);
            }
            catch (Exception ex)
            {
                throw;
            }

        }