¶ Описание
VK Cloud Solutions Queues - это высокоскоростной облачный сервис обмена сообщениями между приложениями с высоким уровнем надежности и гибкими возможностями по масштабированию. Его API совместим с AWS SQS и для подключения вы можете использовать Amazon SDK.
¶ Главные достоинства этого решения:
- высокий уровень безопасности
- надежность
- доступность
- масштабируемость
- возможность гибкой настройки
¶ VK Cloud Solutions Queues предоставляет два типа очередей:
- Стандартная (порядок сообщений не гарантируется)
- FIFO (порядок отправки и получения сообщений сохраняется)
¶ Создание и настройка
Для создания очереди необходимо перейти на портал VK Cloud Solutions и выбрать пункт меню 'Очереди сообщений->Список очередей'.
После нажатия кнопки "Создать очередь" появится окно конфигурирования параметров нового ресурса.
Далее для подключения к сервису необходимо создать ключ доступа, для этого необходимо выбрать пункт меню 'Очереди сообщений->Ключи доступа' и нажать кнопку 'Добавить ключ доступа'.
Вы можете добавить сообщение в очередь из личного кабинета, для этого необходимо нажать кнопку 'Добавить сообщение'
и добавить текст.
Список сообщений можно увидеть на вкладке 'Сообщения в очереди'.
¶ Подключение, отправка и получение сообщения
- В IDE создайте новое решение (в качестве примера будет использоваться JB Rider) с двумя проектами QueueSender и QueueReceiver.
- После создания необходимо открыть NuGet менеджер и добавить к проектам библиотеку ' AWSSDK.SQS', или просто воспользоваться командой
Install-Package AWSSDK.SQS - В проект 'Sender' добавьте следующий код:
using Common;
const string QUEUE_NAME = "user-order";
var appConfig = GetAppConfig();
using var sqsClient = AmazonSqsClientFactory.CreateClient(appConfig);
await sqsClient.PostMessageAsync(QUEUE_NAME, $"Hello! It is my message! [{DateTime.Now}]");
Console.WriteLine("Message sent");
Console.WriteLine("Press any key to end the application");
Console.ReadKey();
static AppConfig GetAppConfig()
=> new AppConfig()
{
AwsAccessKey = "{AccessKey}",
AwsSecretKey = "{AccessSecret}",
AwsQueueName = "user-order",
};
- В проект 'Receive' добавьте следующий код:
using Common;
const string QUEUE_NAME = "user-order";
var appConfig = GetAppConfig();
using var sqsClient = AmazonSqsClientFactory.CreateClient(appConfig);
var messages = await sqsClient.GetMessagesAsync(QUEUE_NAME);
foreach (var message in messages)
{
Console.WriteLine(message.Body);
}
Console.WriteLine("All messages handled!");
Console.WriteLine("Press any key to end the application");
Console.ReadKey();
static AppConfig GetAppConfig()
=> new AppConfig()
{
AwsAccessKey = "{AccessKey}",
AwsSecretKey = "{AccessSecret}",
AwsQueueName = "user-order",
};
- Адрес сервиса: https://sqs.mcs.mail.ru
- Запустите Sender и Receiver. Если ошибок нет, то вы должны получить отправленное сообщение.