如何使用嵌入式tomcat会话群集设置Spring Boot应用程序？

我想设置一个带有嵌入式tomcat会话群集的Spring Boot应用程序.

由于嵌入式tomcat没有server.xml文件,因此我创建了一个tomcatEmbeddedServletContainerFactory并以编程方式设置集群配置.代码如下：

@Configuration
public class tomcatConfig
{
    @Bean
    public EmbeddedServletContainerFactory servletContainerFactory()
    {
        return new tomcatEmbeddedServletContainerFactory()
        {
            @Override
            protected tomcatEmbeddedServletContainer gettomcatEmbeddedServletContainer(
                tomcat tomcat)
            {
                configureCluster(tomcat);
                return super.gettomcatEmbeddedServletContainer(tomcat);
            }

            private void configureCluster(tomcat tomcat)
            {
                // static membership cluster 

                SimpleTcpCluster cluster = new SimpleTcpCluster();
                cluster.setChAnnelStartOptions(3);
                {
                    DeltaManager manager = new DeltaManager();
                    manager.setNotifyListenersOnReplication(true);
                    cluster.setManagerTemplate(manager);
                }
                {
                    GroupChAnnel chAnnel = new GroupChAnnel();
                    {
                        NioReceiver receiver = new NioReceiver();
                        receiver.setPort(localClusterMemberPort);
                        chAnnel.setChAnnelReceiver(receiver);
                    }
                    {
                        ReplicationTransmitter sender = new ReplicationTransmitter();
                        sender.setTransport(new PooledParallelSender());
                        chAnnel.setChAnnelSender(sender);
                    }
                    chAnnel.addInterceptor(new TcpPingInterceptor());
                    chAnnel.addInterceptor(new TcpFailureDetector());
                    chAnnel.addInterceptor(new messageDispatch15Interceptor());
                    {
                        StaticMembershipInterceptor membership =
                            new StaticMembershipInterceptor();
                        String[] memberSpecs = clusterMembers.split(",",-1);
                        for (String spec : memberSpecs)
                        {
                            ClusterMemberDesc memberDesc = new ClusterMemberDesc(spec);
                            StaticMember member = new StaticMember();
                            member.setHost(memberDesc.address);
                            member.setPort(memberDesc.port);
                            member.setDomain("MyWebAppDomain");
                            member.setUniquEID(memberDesc.uniquEID);
                            membership.addStaticMember(member);
                        }
                        chAnnel.addInterceptor(membership);
                    }
                    cluster.setChAnnel(chAnnel);
                }
                cluster.addValve(new ReplicationValve());
                cluster.addValve(new JvmRouteBinderValve());
                cluster.addClusterListener(new clustersessionListener());

                tomcat.getENGIne().setCluster(cluster);
            }
        };
    }

    private static class ClusterMemberDesc
    {
        public String address;
        public int port;
        public String uniquEID;

        public ClusterMemberDesc(String speC) throws IllegalArgumentexception
        {
            String[] values = spec.split(":",-1);
            if (values.length != 3)
                throw new IllegalArgumentexception("clusterMembers element " +
                    "format must be address:port:uniqueIndex");
            address = values[0];
            port = Integer.parseInt(values[1]);
            int index = Integer.parseInt(values[2]);
            if ((index < 0)="" ||="" (index="" >="" 255))="" throw="" new="" illegalargumentexception("invalid="" unique="" index:="" must="" be="" >="0" and="">< 256");="" uniqueid="{" ;="" for="" (int="" i="0;" i="">< 16;="" i++,index++)="" {="" if="" (i="" !="0)" uniqueid="" +=',' ;="" uniqueid="" +="index" %="" 256;="" }="" uniqueid="" +='}' ;="" }="" };="" this="" is="" for="" example.="" in="" fact="" these="" are="" read="" from="" application.properties="" private="" int="" localclustermemberport="9991;" private="" string="" clustermembers="111.222.333.444:9992:1" ;="" }="">

我用以下环境测试了代码：

>单台Windows PC
> 2具有不同localClusterMemberPort和clusterMembers的Spring启动应用程序实例

由于cookie不占用帐户中的端口,因此包含JSESSIONID的cookie在两个实例之间共享.

启动实例时,tomcat集群似乎可以工作,因为2个实例的请求的JSESSIONID值是相同的.但是当我使用第一个实例登录后向第二个实例发出请求时,第二个实例找不到httpSession.它记录了以下消息：

w.c.httpSessionSecurityContextRepository : No httpSession currently exists
w.c.httpSessionSecurityContextRepository : No SecurityContext was available from the httpSession: null. A new one will be created.

显然httpSession没有被共享.但是,当第二个实例创建新会话时,将清除第一个实例的登录信息并使登录失效.

这里发生了什么？会话是共享但httpSession不共享？

顺便说一句,我读过< distributed="">必须在web.xml上指定tag才能使应用程序使用tomcat会话群集.但我不知道如何使用Spring Boot的no-xml环境来指定它.这是问题的原因吗？然后如何指定？

我搜索过并发现了一些使用redis显示聚类的文档.但目前我不想在我的配置中添加另一个移动部件.在我的配置中,3~4个节点是最大的.