SpringNamespaceWikiTest.java 文件源码

@Test
public void testCluster() throws Exception {
    ClusterRunner clusterRunner = new ClusterRunner()
            .addNode(new RedisRunner()
                    .requirepass("do_not_use_if_it_is_not_set")
                    .port(6379)
                    .randomDir()
                    .nosave())
            .addNode(new RedisRunner()
                    .requirepass("do_not_use_if_it_is_not_set")
                    .port(6380)
                    .randomDir()
                    .nosave())
            .addNode(new RedisRunner()
                    .requirepass("do_not_use_if_it_is_not_set")
                    .port(6381)
                    .randomDir()
                    .nosave());
    ClusterRunner.ClusterProcesses cluster = clusterRunner.run();

    try {
        ((ConfigurableApplicationContext)
                new ClassPathXmlApplicationContext("classpath:org/redisson/spring/support/namespace_wiki_cluster.xml"))
                .close();
    } finally {
        cluster.shutdown();
    }
}