Использование Redis в Java WEB applcation

В жизни каждого достаточно большого web-проекта наступает момент, когда требования к производительности заставляют поставить между кодом и данными в базе что-то достаточно быстрое и нетребовательное... Например Memcached или Redis. Первый инструмент достаточно известен, и обладает серьёзным недостатком: всё что не в памяти - удаляется. Второй - практически полноценная noSQL БД. И благодаря этой своей природе может быть крайне полезна, в первую очередь как дополнение к традиционной SQL СУБД. Действительно, так ли редко мы складываем в таблицы что-то совсем не "табличное"? Например, недавно мы вынесли в базу хранилище сессий пользователей (очень удобно для горизонтального масштабирования web-фронтэндов). Возникли проблемы с нагрузкой, потребовалась "тонкая" настройка и т.п. А ведь всё дело в том, что хранение таких данных в реляционной базе вообще-то "притянуто за уши". Что мы пишем в сесию? Правильно, пары ключ-значение. При чём тут SQL?. Короче, Redis с этой задачей справился идеально, что позволило нашему SQL-серверу снова "расправить крылья".

Вспомню, как я с этим разбирался...
После недолгого изучения разных источников нашёл вот эту wiki. Это перевод официальной документации. Пользовался почти исключительно этим сайтом. Но прежде чем начать изучение, установим себе эту систему.
На официальном сайте скачиваем версию (на данный момент последняя стабильная - 2.0). Это архив с исходниками, собираем сами: после распаковки в каталоге делаем make. После сборки запускаем сервер с помощью:

$ ./redis-server

По умолчанию он поднимается на порту 6379 и дальше с ним можно взаимодействовать хотя бы даже и обычным telnet-ом. Но мы не будем так суровы :)
Для начала сделаем минимальные правки в конфиге: redis.conf в каталоге приложения - поставим daemonize yes, это позволит нам запускать сервер не отдавая ему консоль. Более тонкую настройку оставим на потом.
Запускать сервер теперь будем с явным указанием конфига:

$ ./redis-server redis.conf 

Для освоения минимального набора команд воспользуемся консольным клиентом, который есть в сборке:

$ ./redis-cli <команда> <параметры ...>

Например, чтобы сохранить пару ключ-значение в Redis:

$ ./redis-cli set mykey myval
$ OK

... а чтобы получить значение по ключу:

$ ./redis-cli get mykey

$ "myval"

Redis поддерживает несколько типов данных для значений, которые мы "вкладываем" в ключи. Это строки, списки, множества и хэши. Детальнее посмотрите в руководстве, на пока понадобятся лишь имена команд, для каждого типа данных "геттеры" и "сеттеры" свои. Например для хэшей это:
hget, hset, hmset, hgetall... пока достаточно... (установить значение поля хэша, получить его, установить все поля-значения и получить все). Детально разбираться не будем, всё равно работать нам не в консоли. Достаточно просто понимать, какие есть инструменты.

Теперь переходим к Java.
Для работы с Redis есть несколько библиотек. Самая "живая" из них - Jedis, поддерживает версию 2.0, что нам и требуется.
Скачиваем её отсюда. Подключаем jedis-1.5.2.jar к проекту. Пишем класс для взаимодействия с redis:

1. /*
2. * Redis get|set implementation
3. */
4.  
5. package net.multipi.connector.redis;
6.  
7. import java.io.IOException;
8. import java.util.Map;
9. import java.util.Set;
10. import redis.clients.jedis.Jedis;
11.  
12. public class RedisConnector {
13.     private Jedis cli;
14.     
15.     /**
16.      * constructor: connect to Redis server and authorization
17.      * @param host
18.      * @param port
19.      * @param password
20.      */
21.     public RedisConnector(String host, int port, String password) {
22.         cli = new Jedis(host, port, 5000);
23.         cli.auth(password);
24.         try {
25.             cli.connect();
26.         } catch (Exception ex) {
27.             ex.printStackTrace(System.err);
28.         }
29.     }
30.  
31.     /**
32.      * calculate keys count (eg count of active sessions)
33.      * @return
34.      */
35.     public long getKeysCount() {
36.         return cli.dbSize();
37.     }
38.  
39.     /**
40.      * get all keys that begin with "begin" string
41.      * @param begin
42.      * @return
43.      */
44.     public Set<String> getAllKeys(String begin) {
45.         return cli.keys(begin+"*");
46.     }
47.  
48.     /**
49.      * set session values as map
50.      * @param sess
51.      * @param m
52.      * @return
53.      */
54.     public boolean setAll(String sess, Map<String, String> m) {
55.         String r = cli.hmset(sess, m);
56.         return (r.equals("OK"));
57.     }
58.  
59.     /**
60.      * set session values as map and set expire the session
61.      * @param sess
62.      * @param m
63.      * @param expire
64.      * @return
65.      */
66.     public boolean setAll(String sess, Map<String, String> m, int expire) {
67.         boolean rez = false;
68.         String r = cli.hmset(sess, m);
69.         long er = cli.expire(sess, expire);
70.         rez = (r.equals("OK") && er>0);
71.         return rez;
72.     }
73.  
74.     /**
75.      * set one of session values
76.      * @param sess
77.      * @param key
78.      * @param value
79.      * @return
80.      */
81.     public boolean set(String sess, String key, String value) {
82.         boolean rez = false;
83.         Map m = getAll(sess);
84.         if (m!=null) {
85.             m.put(key, value);
86.             rez = setAll(sess, m);
87.         }
88.         return rez;
89.     }
90.     
91.     /**
92.      * set or update session values and set expire
93.      * @param sess
94.      * @param key
95.      * @param value
96.      * @param expire
97.      * @return
98.      */
99.     public boolean set(String sess, String key, String value, int expire) {
100.         boolean rez = false;
101.         Map m = getAll(sess);
102.         if (m!=null) {
103.             m.put(key, value==null ? "" : value);
104.             rez = setAll(sess, m, expire);
105.         }
106.         return rez;
107.     }
108.     /**
109.      * check if session exists
110.      * @param sess
111.      * @return
112.      */
113.     public boolean isExists(String sess) {
114.         return cli.exists(sess);
115.     }
116.     /**
117.      * get session values
118.      * @param sess
119.      * @return
120.      */
121.     public Map<String, String> getAll(String sess) {
122.         return cli.hgetAll(sess);
123.     }
124.  
125.     /**
126.      * det session values and prolongs session
127.      * @param sess
128.      * @param expire
129.      * @return
130.      */
131.     public Map<String, String> getAll(String sess, int expire) {
132.         Map m = cli.hgetAll(sess);
133.         cli.hmset(sess, m);
134.         cli.expire(sess, expire);
135.         return m;
136.     }
137.  
138.     /**
139.      * get one of session values
140.      * @param sess
141.      * @param key
142.      * @return
143.      */
144.     public String get(String sess, String key) {
145.         return cli.hget(sess, key);
146.     }
147.  
148.     /**
149.      * delete session with all session data
150.      * @param sess
151.      * @return
152.      */
153.     public boolean del(String sess) {
154.         Long del = cli.del(sess);
155.         return del>0;
156.     }
157.  
158.     /**
159.      * close connection
160.      */
161.     public void close() {
162.       if (cli.isConnected()) {
163.             try {
164.                 cli.disconnect();
165.             } catch (IOException ie) {}
166.         }
167.     }
168. }

Как видно из кода все методы библиотеки есть простые java-обёртки над командами Redis. А все наши методы - вызовы методов библиотеки. В конструктор нужно передать ip-адрес машины на которой запущен Redis-сервер, порт и пароль доступа к серверу. Третьим параметром передаём время ожидания ответа сервера в миллисекундах. Вообще, если есть такая возможность Redis лучше всего поднимать на той же машине, где работает наше приложение. Скорость обработки запросов у Redis на базе из миллиона записей составляет 1-2 миллисекунды. В сравнении с этим потери 20-50 ms на соединение (в лучшем случае) выглядят неприятно. Требования к памяти у Redis весьма скромные.
Использование Redis в качестве сессионного хранилища приятно ещё и тем, что в нём реализован механизм "устаревания" ключей. Достаточно установить срок жизни ключу и сервер сам "приберёт" его через указанное время. В текущей версии была неприятная особенность: после обновления значения ключ становился "вечным". Поэтому мы "напоминаем" ключам время жизни после апдейта, там где это нужно.
Ещё одна особенность едва не испортила впечатление от Jedis: при использовании внутреннего механизма пула соединений в этой библиотеке спустя 5-10 минут работы под нагрузкой система "засыпала", без видимой причины и без каких-либо ошибок прекращая реагировать на запросы. От пула пришлось отказаться, благо высокая скорость обработки запросов делала контроль за числом открытых коннектов задачей чисто "академической" важности.
В целом: инструмент весьма порадовал. После изнурительной борьбы за производительность запросов на "основной" БД скорость ответов от Redis создаёт прямо-таки фантастическое впечатление. А возможность работать с сервером "чем угодно", просто посылая команды на порт так и провоцирует написать свою реализацию клиента.