如何从C＃控制台应用程序使用RabbitMQ API创建RabbitMQ用户

如何解决如何从C＃控制台应用程序使用RabbitMQ API创建RabbitMQ用户

我正在使用C＃编写的Hashicorp Vault管理.net-core 3.1.3控制台应用程序。我的任务是使用RabbitMQ Restful API从控制台应用程序在MQ服务器上创建RabbitMQ用户。我对该API零经验。我一直在阅读文档，但仍然不知道如何开始。 一般而言，我对API的经验有限，并且从未尝试通过控制台应用程序执行类似的操作。 任何指导或示例代码将不胜感激。 干杯。 马特

解决方法

您将需要RabbitMQ Management HTTP API，其文档为here。具体来说，您需要在PUT端点上/api/users/name个用户。

有许多方法可以用c＃发出HTTP请求，最简单的方法可能是here中所述的WebRequest类。您需要set the method to PUT，write your json payload to the request和set your rabbitmq credentials for the request。

,

感谢线索蝙蝠侠亚当。这是我结束的地方，并且运行良好。

try
{
    // Set MQ server credentials
    NetworkCredential networkCredential = new NetworkCredential("mqUserName","mqPassword");

    // Instantiate HttpClientHandler,passing in the NetworkCredential
    HttpClientHandler httpClientHandler = new HttpClientHandler { Credentials = networkCredential };

    // Instantiate HttpClient passing in the HttpClientHandler
    using HttpClient httpClient = new HttpClient(httpClientHandler);

    // Get the response from the API endpoint.
    HttpResponseMessage httpResponseMessage = await httpClient.GetAsync("http://YourServer:AndPort/api/users/");

    // Get the response content.
    HttpContent httpContent = httpResponseMessage.Content;

    // Get the stream of the content.
    using StreamReader streamReader = new StreamReader(await httpContent.ReadAsStreamAsync());

    // Get the output string.
    string returnedJsonString = await streamReader.ReadToEndAsync();

    // Instantiate a list to loop through.
    List<string> mqAccountNames = new List<string>();

    if (returnedJsonString != "")
    {
        // Deserialize into object
        dynamic dynamicJson = JsonConvert.DeserializeObject(returnedJsonString);
        if (dynamicJson != null)
        {
            foreach (dynamic item in dynamicJson)
            {
                mqAccountNames.Add(item.name.ToString());
            }
        }
    }

    bool accountExists = false;

    foreach (string mqAccountName in mqAccountNames)
    {
        if (mqAccountName == userName)
        {
            accountExists = true;
        }
    }

    switch (accountExists)
    {
        case true:
            Console.WriteLine("This user already exists on the MQ server.");
            break;
        case false:
            // Create the new user on the MQ Server
            Console.WriteLine("This user will be created on the MQ server.");
                        
            string uri = $"http://YourServer:AndPort/api/users/{userName}";

            MqUser mqUser = new MqUser
            {
                password = password,tags = "administrator"
            };

            string info = JsonConvert.SerializeObject(mqUser);
            StringContent content = new StringContent(info,Encoding.UTF8,"application/json");

            httpResponseMessage = await httpClient.PutAsync(uri,content);
            if (!httpResponseMessage.IsSuccessStatusCode)
            {
                Console.WriteLine("There was an error creating the MQ user account.");
                Thread.Sleep(2500);
                return false;
            }

            uri = $"http://YourServer:AndPort/api/permissions/%2F/{userName}";

            MqPermissions mqPermissions = new MqPermissions
            {
                configure = ".*",write = ".*",read = ".*"
            };

            info = JsonConvert.SerializeObject(mqPermissions);
            content = new StringContent(info,content);

            if (!httpResponseMessage.IsSuccessStatusCode)
            {
                Console.WriteLine("There was an error creating the permissions on the MQ user account.");
                Thread.Sleep(2500);
                return false;
            }

            break;
    }
}
catch (Exception e)
{
    Console.WriteLine(e);
    throw;
}

我创建了简单的MqUser和MqPermissions类，因此可以通过JsonConvert.SerializeObject传递信息。 另一个奇怪的事情是我的公司选择将MQ虚拟主机命名为“ /”。 到目前为止，这还不是问题，因为我们之前从未尝试过使用API​​。 由于/字符在uri中是预期的，因此这是一个挂断，但是我尝试将其编码为％2F，并且效果很好。