{"id":44936,"date":"2015-09-29T19:00:51","date_gmt":"2015-09-29T16:00:51","guid":{"rendered":"http:\/\/www.javacodegeeks.com\/?p=44936"},"modified":"2015-09-29T08:09:08","modified_gmt":"2015-09-29T05:09:08","slug":"spring-cloud-sidecar-initialization-of-nodes","status":"publish","type":"post","link":"https:\/\/www.javacodegeeks.com\/2015\/09\/spring-cloud-sidecar-initialization-of-nodes.html","title":{"rendered":"Spring Cloud Sidecar – Initialization of Nodes"},"content":{"rendered":"

In the last blog post<\/a> I had described how the Sidecar application can be used for registering the Cassandra nodes with Eureka and more generally can be used for registering any non-JVM application with Eureka.<\/p>\n

In this post I will cover how an application can go about querying the Sidecar registered nodes.<\/p>\n

Discovering Registered Nodes – Post Initialization<\/h2>\n

If the registered nodes are not required during the bean initialization phase then discovering the nodes is fairly straightforward along these lines:<\/p>\n

@Component\r\npublic class SampleCommandLineRunner implements CommandLineRunner {\r\n\r\n    @Autowired\r\n    private DiscoveryClient discoveryClient;\r\n\r\n    @PostConstruct\r\n    public void postConstruct() {\r\n\/\/        System.out.println(\"Printing from postConstruct\");\r\n\/\/        printDiscoveredNodes();\r\n    }\r\n\r\n    @Override\r\n    public void run(String... strings) throws Exception {\r\n        System.out.println(\"Printing from run method\");\r\n        printDiscoveredNodes();\r\n    }\r\n\r\n    public void printDiscoveredNodes() {\r\n        System.out.println(\" Printing Discovered Nodes \");\r\n\r\n        for (ServiceInstance instance: discoveryClient.getInstances(\"samplecassandra.vip\")) {\r\n            System.out.println(\"Host: Port = \" + instance.getHost() + \":\" + instance.getPort());\r\n        }\r\n    }\r\n}<\/pre>\n
These would print the nodes registered with a name of “samplecasssandra.vip” VIP.<\/p>\n
Note that the nodes are being printed from the run method which gets called past the initialization of Spring container. If however the nodes were attempted to be listed from one of the lifecycle stages say the postConstruct method then very likely an exception will be thrown (this behavior is seen with “Angel.SR3” release of Spring Cloud, but appears to work cleanly with “Brixton.*” versions)
 
<\/div> <\/div><\/p>\n
Discovering Registered Nodes – During Initialization<\/h2>\n
Now if an application needs to discover the nodes during initialization the flow is a little more complicated, for a potential issue look at this ticket<\/a>.<\/p>\n
The DiscoveryClient is initialized very late in the Spring Lifecycle and if DiscoveryClient is used in any post-processing activity of a bean it is likely to give an exception.<\/p>\n
As an example, say the Cassandra nodes registered using Sidecar is now used by an application to initialize Cassandra connectivity, a way to do it would be to create a wrapper around Cassandra connectivity this way:<\/p>\n
import org.springframework.data.cassandra.core.CassandraTemplate;\r\n\r\n\r\npublic class CassandraTemplateWrapper extends CassandraTemplate {\r\n\r\n    @Override\r\n    public void afterPropertiesSet() {\r\n        \r\n    }\r\n}<\/pre>\n
Here CassandraTemplate is being overridden to prevent the check in afterPropertiesSet method that a Cassandra session exists, as a session will be established much later in the start-up cycle.<\/p>\n
A Cassandra session can be injected into this custom CassandraTemplate lazily in a bean that implements SmartLifecyle<\/a> along these lines:<\/p>\n
package mvctest.cassandra;\r\n\r\nimport com.datastax.driver.core.Cluster;\r\nimport com.datastax.driver.core.Session;\r\nimport org.slf4j.Logger;\r\nimport org.slf4j.LoggerFactory;\r\nimport org.springframework.beans.factory.FactoryBean;\r\nimport org.springframework.beans.factory.annotation.Autowired;\r\nimport org.springframework.context.SmartLifecycle;\r\nimport org.springframework.core.Ordered;\r\nimport org.springframework.data.cassandra.core.CassandraTemplate;\r\nimport org.springframework.stereotype.Component;\r\n\r\n@Component(\"cassandraTemplate\")\r\npublic class EurekaCassandraTemplateFactoryBean implements SmartLifecycle, FactoryBean<CassandraTemplate>, Ordered {\r\n\r\n    ....\r\n\r\n\r\n    @Override\r\n    public boolean isAutoStartup() {\r\n        return true;\r\n    }\r\n\r\n    @Override\r\n    public void start() {\r\n        LOGGER.info(\"About to start Discovery client lookup of Cassandra Cluster!!!\");\r\n        final Cluster cluster = this.eurekaClusterBuilder.build();\r\n        Session session = cluster.connect(this.cassandraProperties.getKeyspace());\r\n        this.cassandraTemplateWrapper.setSession(session);\r\n        LOGGER.info(\"Completed Discovery client lookup of Cassandra Cluster!!!\");\r\n        running = true;\r\n    }\r\n\r\n    @Override\r\n    public boolean isRunning() {\r\n        return this.running;\r\n    }\r\n\r\n    @Override\r\n    public int getPhase() {\r\n        return Integer.MAX_VALUE;\r\n    }\r\n\r\n    @Override\r\n    public int getOrder() {\r\n        return 1;\r\n    }\r\n}<\/pre>\n
This way the Cassandra session can be created very late in the cycle. Somewhat rough, but the approach works.<\/p>\n