Доверенные
FlexyPool отслеживает использование пула соединений, поэтому ему необходимо перехватить вызов метода закрытия соединения.
Для простоты в первой версии для этой цели использовались динамические прокси:
|
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
private static class ConnectionInvocationHandler implements InvocationHandler { public static final String CLOSE_METHOD_NAME = "close"; private final Connection target; private final ConnectionCallback callback; public ConnectionInvocationHandler( Connection target, ConnectionCallback callback) { this.target = target; this.callback = callback; } @Override public Object invoke( Object proxy, Method method, Object[] args) throws Throwable { if (CLOSE_METHOD_NAME.equals(method.getName())) { callback.close(); } return method.invoke(target, args); }} |
Как бы просто это ни было, вызов прокси медленнее, чем декоратор, который вызывает целевой метод с использованием прямого вызова.
Так как все пулы соединений в любом случае используют прокси, добавление другого уровня прокси только увеличивает накладные расходы во время вызова, и теперь FlexyPool также поддерживает декораторы соединений.
Декораторы
ConnectionDecorator оборачивает базовое соединение с базой данных, делегируя все вызовы фактическому экземпляру объекта. Как и его прокси-аналог, только метод close выполняет любую дополнительную логику:
|
001
002
003
004
005
006
007
008
009
010
011
012
013
014
015
016
017
018
019
020
021
022
023
024
025
026
027
028
029
030
031
032
033
034
035
036
037
038
039
040
041
042
043
044
045
046
047
048
049
050
051
052
053
054
055
056
057
058
059
060
061
062
063
064
065
066
067
068
069
070
071
072
073
074
075
076
077
078
079
080
081
082
083
084
085
086
087
088
089
090
091
092
093
094
095
096
097
098
099
100
101
102
103
104
105
|
public class ConnectionDecorator implements Connection { private final Connection target; private final ConnectionCallback callback; public ConnectionDecorator( Connection target, ConnectionCallback callback) { this.target = target; this.callback = callback; } public Connection getTarget() { return target; } public ConnectionCallback getCallback() { return callback; } @Override public Statement createStatement() throws SQLException { return target.createStatement(); } @Override public void close() throws SQLException { callback.close(); target.close(); } /** * More methods omitted for brevity sake */ public void setSchema(String schema) throws SQLException { ReflectionUtils.invoke( target, ReflectionUtils.getMethod( target, "setSchema", String.class ), schema ); } public String getSchema() throws SQLException { return ReflectionUtils.invoke( target, ReflectionUtils.getMethod( target, "getSchema" ) ); } public void abort(Executor executor) throws SQLException { ReflectionUtils.invoke( target, ReflectionUtils.getMethod( target, "abort", Executor.class ), executor ); } public void setNetworkTimeout( Executor executor, int milliseconds) throws SQLException { ReflectionUtils.invoke( target, ReflectionUtils.getMethod( target, "setNetworkTimeout", Executor.class, int.class ), executor, milliseconds ); } public int getNetworkTimeout() throws SQLException { return (Integer) ReflectionUtils.invoke( target, ReflectionUtils.getMethod( target, "getNetworkTimeout" ) ); }} |
Как вы уже могли заметить, некоторые методы используют Java Reflection вместо прямого вызова метода:
Эти методы были добавлены в Java 1.7, и при компиляции проекта с Java 1.6 произойдет сбой прямого вызова. Поскольку Java 1.6 является минимальным требованием для большинства модулей FlexyPool, эти методы перенаправляют входящий вызов метода через вызов отражения Java. Пропуск этих методов также не является обязательным, потому что на 1.7 JVM у декоратора Соединения не будет этих методов, и будет сгенерирована ошибка загрузки класса.
В проектах, использующих как минимум Java 1.7, FlexyPool также предлагает Java7ConnectionDecorator :
|
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
public class Java7ConnectionDecorator extends ConnectionDecorator { public Java7ConnectionDecorator( Connection target, ConnectionCallback callback) { super(target, callback); } @Override public void setSchema(String schema) throws SQLException { getTarget().setSchema(schema); } @Override public String getSchema() throws SQLException { return getTarget().getSchema(); } @Override public void abort(Executor executor) throws SQLException { getTarget().abort(executor); } @Override public void setNetworkTimeout( Executor executor, int milliseconds) throws SQLException { getTarget().setNetworkTimeout(executor, milliseconds); } @Override public int getNetworkTimeout() throws SQLException { return getTarget().getNetworkTimeout(); }} |
Этот класс не является частью базовой библиотеки и включен в отдельный совместимый с Java 1.7 модуль. Чтобы использовать его, вам нужно добавить следующую зависимость Maven:
|
1
2
3
4
5
|
<dependency> <groupId>com.vladmihalcea.flexy-pool</groupId> <artifactId>flexy-pool-core-java7</artifactId> <version>${flexy-pool.version}</version></dependency> |
Механизм обнаружения услуг
С самого начала FlexyPool предложил поддержку для настройки экземпляра ConnectionProxyFactory , поэтому переключение на декораторы не требовало интенсивного рефакторинга кода.
До выпуска 1.2.4 поставщиком соединений по умолчанию был JdkConnectionProxyFactory , который использует динамические прокси.
Начиная с версии 1.2.4 FlexyPool использует декораторы соединений в качестве механизма перехвата соединений по умолчанию.
Фактическая версия декоратора определяется во время выполнения, а механизм загрузки состоит из следующих компонентов:
Фактическая фабрика декораторов соединений определяется следующим методом:
|
01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
public ConnectionDecoratorFactory resolve() { int loadingIndex = Integer.MIN_VALUE; ConnectionDecoratorFactory connectionDecoratorFactory = null; Iterator<ConnectionDecoratorFactoryService> connectionDecoratorFactoryServiceIterator = serviceLoader.iterator(); while (connectionDecoratorFactoryServiceIterator.hasNext()) { try { ConnectionDecoratorFactoryService connectionDecoratorFactoryService = connectionDecoratorFactoryServiceIterator.next(); int currentLoadingIndex = connectionDecoratorFactoryService.loadingIndex(); if (currentLoadingIndex > loadingIndex) { ConnectionDecoratorFactory currentConnectionDecoratorFactory = connectionDecoratorFactoryService.load(); if (currentConnectionDecoratorFactory != null) { connectionDecoratorFactory = currentConnectionDecoratorFactory; loadingIndex = currentLoadingIndex; } } } catch (LinkageError e) { LOGGER.info("Couldn't load ConnectionDecoratorFactoryService on the current JVM", e); } } if (connectionDecoratorFactory != null) { return connectionDecoratorFactory; } throw new IllegalStateException("No ConnectionDecoratorFactory could be loaded!");} |
Как и у MetricsFactory , у каждой фабрики декораторов соединений есть связанный поставщик услуг . Несколько таких сервис-провайдеров могут быть загружены во время выполнения (сервис декоратора соединений Java 1.6 по умолчанию или сервис Java 1.7). Выбор выполняется на основе индекса (последняя версия Java имеет приоритет) и текущей поддержки JVM версии JVM (декоратор соединений Java 1.7 не будет разрешен в среде выполнения Java 1.6).
Вывод
Декораторы несут больше затрат на конфигурирование, чем прокси, но если вы хотите выжать последнее падение производительности, стоит рассмотреть преимущество прямого вызова метода.
| Ссылка: | Как FlexyPool поддерживает прокси-серверы Connection и декораторы от нашего партнера по JCG Влада Михалча в блоге Влада Михалча . |