Я использую Jedis для подключения к Redis и загрузки данных в список. Я использую rpush для данных JSON.
Вот шаги, которые я делаю:
- Выборка данных из Rabbitmq
- Сбор информации из данных JSON и подготовка ключа, пары значений
- Вставьте данные в redis, используя клавишу и значение.
Я не вижу, чтобы мой код масштабировал более 3000 запросов в секунду.
Примечание:
Я не использую конвейер, каждое сообщение приведет к получению ресурса jedis, добавлению его в redis и закрытию ресурса.