Shiro Session Clustering с Hazelcast, а не в Интернете

Question

Я написал службу REST на основе Netty, которая развернута напрямую (т. Е. Без сервера Web/Application). Для authn, authz и управления сессиями я использую Apache Shiro. Теперь я хочу иметь возможность балансировать эту услугу без использования липких сеансов на нашем балансировщике нагрузки; и я пытаюсь установить это, используя in-process экземпляры Hazelcast.

До сих пор мне удалось запустить два экземпляра моего сервиса на двух разных машинах, создав кластер Hazelcast с двумя членами; но даже в этом случае, если я аутентифицирую на одной машине, другой все еще не распознает сеанс. Поэтому я думаю, что я, вероятно, допустил ошибку в моих файлах shiro.ini и/или моем файле конфигурации hazelcast.xml.

Я в основном использую класс HazelCastCacheManager здесь https://github.com/stormpath/shiro-hazelcast-web-sample/blob/master/src/main/java/com/stormpath/samples/shiro/hazelcast/cache/HazelcastCacheManager.java

Вот мой hazelcast.xml (наша установка не позволяет многоадресной рассылки, я должен указать IP-адрес машины непосредственно):

<hazelcast> 
    <properties> 
    <property name="hazelcast.logging.type">slf4j</property> 
    </properties> 

    <map name="shiro-activeSessionsCache"> 
    <async-backup-count>1</async-backup-count> 
    <time-to-live-seconds>600</time-to-live-seconds> 
    </map> 

    <network> 
    <join> 
     <multicast enabled="false"></multicast> 
     <tcp-ip enabled="true"> 
     <member>x.x.x.x:8050</member> <!-- server A --> 
     <member>x.x.x.x:8050</member> <!-- server B --> 
     </tcp-ip> 
    </join> 
    <interfaces enabled="true"> 
     <interface>x.x.x.*</interface> 
    </interfaces> 
    <port port-count="20" auto-increment="false">8050</port>  
    </network> 

</hazelcast> 

И часть моего shiro.ini

sessionDAO = org.apache.shiro.session.mgt.eis.EnterpriseCacheSessionDAO 
sessionManager = org.apache.shiro.session.mgt.DefaultSessionManager 

sessionDAO.activeSessionsCacheName = shiro-activeSessionsCache 
securityManager.sessionManager.sessionDAO = $sessionDAO 

cacheManager = HazelcastCacheManager 

securityManager.cacheManager = $cacheManager 

sessionManager.globalSessionTimeout = 600000 
sessionValidationScheduler = org.apache.shiro.session.mgt.ExecutorServiceSessionValidationScheduler 
sessionValidationScheduler.interval = 600000 
sessionManager.sessionValidationScheduler = $sessionValidationScheduler 

securityManager.sessionManager=$sessionManager 

Что мне не хватает? Как я могу дать указание Сиро поделиться сеансом среди всех экземпляров Hazelcast? Или моя ошибка в классе HazelcastCacheManager?

Вот журнал Hazelcast производит, когда я начинаю мои две услуги:

Это первый сервис, начиная от:

log4j:WARN No appenders could be found for logger (org.apache.commons.beanutils.converters.BooleanConverter). 
log4j:WARN Please initialize the log4j system properly. 
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 
Nov 24, 2015 9:03:42 AM com.hazelcast.config.XmlConfigLocator 
INFO: Loading 'hazelcast.xml' from working directory. 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Interfaces is enabled, trying to pick one address matching to one of: [x.x.x.*] 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Prefer IPv4 stack is true. 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Picked Address[x.x.x.x]:8050, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=8050], bind any local is true 
[main] INFO com.hazelcast.spi.OperationService - [x.x.x.x]:8050 [dev] [3.5.3] Backpressure is disabled 
[main] INFO com.hazelcast.spi.impl.operationexecutor.classic.ClassicOperationExecutor - [x.x.x.x]:8050 [dev] [3.5.3] Starting with 16 generic operation threads and 32 partition operation threads. 
[main] INFO com.hazelcast.system - [x.x.x.x]:8050 [dev] [3.5.3] Hazelcast 3.5.3 (20151011 - 64c663a) starting at Address[x.x.x.x]:8050 
[main] INFO com.hazelcast.system - [x.x.x.x]:8050 [dev] [3.5.3] Copyright (c) 2008-2015, Hazelcast, Inc. All Rights Reserved. 
[main] INFO com.hazelcast.instance.Node - [x.x.x.x]:8050 [dev] [3.5.3] Creating TcpIpJoiner 
[main] INFO com.hazelcast.core.LifecycleService - [x.x.x.x]:8050 [dev] [3.5.3] Address[x.x.x.x]:8050 is STARTING 
[cached1] INFO com.hazelcast.nio.tcp.SocketConnector - [x.x.x.x]:8050 [dev] [3.5.3] Connecting to /x.x.x.x:8050, timeout: 0, bind-any: true 
[cached1] INFO com.hazelcast.nio.tcp.SocketConnector - [x.x.x.x]:8050 [dev] [3.5.3] Could not connect to: /x.x.x.x:8050. Reason: SocketException[Connection refused to address /x.x.x.x:8050] 
[cached1] INFO com.hazelcast.cluster.impl.TcpIpJoiner - [x.x.x.x]:8050 [dev] [3.5.3] Address[x.x.x.x]:8050 is added to the blacklist. 
[main] INFO com.hazelcast.cluster.impl.TcpIpJoiner - [x.x.x.x]:8050 [dev] [3.5.3] 

Members [1] { 
     Member [x.x.x.x]:8050 this 
} 

И это продолжение, когда начинается вторая служба:

[main] INFO com.hazelcast.core.LifecycleService - [x.x.x.x]:8050 [dev] [3.5.3] Address[x.x.x.x]:8050 is STARTED 
[main] INFO org.apache.shiro.config.IniSecurityManagerFactory - Realms have been explicitly set on the SecurityManager instance - auto-setting of realms will not occur. 
Open your web browser and navigate to https://127.0.0.1:8113/ 
[hz._hzInstance_1_dev.IO.thread-Acceptor] INFO com.hazelcast.nio.tcp.SocketAcceptor - [x.x.x.x]:8050 [dev] [3.5.3] Accepting socket connection from /x.x.x.x:35316 
[cached2] INFO com.hazelcast.nio.tcp.TcpIpConnectionManager - [x.x.x.x]:8050 [dev] [3.5.3] Established socket connection between /x.x.x.x:8050 
[hz._hzInstance_1_dev.generic-operation.thread-10] INFO com.hazelcast.cluster.ClusterService - [x.x.x.x]:8050 [dev] [3.5.3] 

Members [2] { 
     Member [x.x.x.x]:8050 this 
     Member [x.x.x.x]:8050 
} 

Это второй сервис запуска, с первым уже работает:

log4j:WARN No appenders could be found for logger (org.apache.commons.beanutils.converters.BooleanConverter). 
log4j:WARN Please initialize the log4j system properly. 
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 
Nov 24, 2015 9:04:16 AM com.hazelcast.config.XmlConfigLocator 
INFO: Loading 'hazelcast.xml' from working directory. 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Interfaces is enabled, trying to pick one address matching to one of: [x.x.x.*] 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Prefer IPv4 stack is true. 
[main] INFO com.hazelcast.instance.DefaultAddressPicker - [LOCAL] [dev] [3.5.3] Picked Address[x.x.x.x]:8050, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=8050], bind any local is true 
[main] INFO com.hazelcast.spi.OperationService - [x.x.x.x]:8050 [dev] [3.5.3] Backpressure is disabled 
[main] INFO com.hazelcast.spi.impl.operationexecutor.classic.ClassicOperationExecutor - [x.x.x.x]:8050 [dev] [3.5.3] Starting with 8 generic operation threads and 16 partition operation threads. 
[main] INFO com.hazelcast.system - [x.x.x.x]:8050 [dev] [3.5.3] Hazelcast 3.5.3 (20151011 - 64c663a) starting at Address[x.x.x.x]:8050 
[main] INFO com.hazelcast.system - [x.x.x.x]:8050 [dev] [3.5.3] Copyright (c) 2008-2015, Hazelcast, Inc. All Rights Reserved. 
[main] INFO com.hazelcast.instance.Node - [x.x.x.x]:8050 [dev] [3.5.3] Creating TcpIpJoiner 
[main] INFO com.hazelcast.core.LifecycleService - [x.x.x.x]:8050 [dev] [3.5.3] Address[x.x.x.x]:8050 is STARTING 
[cached1] INFO com.hazelcast.nio.tcp.SocketConnector - [x.x.x.x]:8050 [dev] [3.5.3] Connecting to /x.x.x.x:8050, timeout: 0, bind-any: true 
[cached1] INFO com.hazelcast.nio.tcp.TcpIpConnectionManager - [x.x.x.x]:8050 [dev] [3.5.3] Established socket connection between /x.x.x.x:35316 
[hz._hzInstance_1_dev.generic-operation.thread-3] INFO com.hazelcast.cluster.ClusterService - [x.x.x.x]:8050 [dev] [3.5.3] 

Members [2] { 
     Member [x.x.x.x]:8050 
     Member [x.x.x.x]:8050 this 
} 

[main] INFO com.hazelcast.core.LifecycleService - [x.x.x.x]:8050 [dev] [3.5.3] Address[x.x.x.x]:8050 is STARTED 
[main] INFO org.apache.shiro.config.IniSecurityManagerFactory - Realms have been explicitly set on the SecurityManager instance - auto-setting of realms will not occur. 
Open your web browser and navigate to https://127.0.0.1:8113/ 

Answer 1

Я думаю, что моя ошибка была в моем фактическом коде Java, а не в файлах конфигурация:

Во всех моих первоначальных тестах, запустив службу на одном сервере, я использовал это, чтобы получить текущий пользователь Shiro:

Subject currentUser = SecurityUtils.getSubject(); 

Однако ключ сеанса производства это то же самое для одного пользователя на одном сервере, но разные для одного пользователя на различных серверах; а ключ сеанса используется для идентификации сеанса в кеше. Первоначально я надеялся, что не смогу передать ключ сеанса вместе с вызовом REST. но если я явно передать ключ сеанса, а затем использовать это для получения текущего пользователя, то сеансы могут успешно быть признаны в различных серверах:

Subject currentUser = null; 
if (parameters.containsKey("session")) { 
    sId = parameters.get("session"); 
    currentUser = new Subject.Builder().sessionId(sId).buildSubject(); 
} else { 
    currentUser = SecurityUtils.getSubject(); 
} 

(я использую карту, чтобы сохранить все параметры URL до достижения этого кода snippet)

Последующий вопрос: можно ли делиться сеансами Shiro без куки или явно передавать ключ сеанса другими способами от клиента к серверу?