Introducing new features.zk

@@ -27,5 +27,10 @@
             <groupId>io.springfox</groupId>
             <groupId>io.springfox</groupId>
             <artifactId>springfox-swagger-ui</artifactId>
             <artifactId>springfox-swagger-ui</artifactId>
         </dependency>
         </dependency>
+
+        <dependency>
+            <groupId>com.github.sgroschupf</groupId>
+            <artifactId>zkclient</artifactId>
+        </dependency>
     </dependencies>
     </dependencies>
 </project>
 </project>

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>netty-action</artifactId>
+        <groupId>com.crossoverjie.netty</groupId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>netty-action-zk</artifactId>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>com.crossoverjie.netty</groupId>
+            <artifactId>netty-action-common</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>de.codecentric</groupId>
+            <artifactId>spring-boot-admin-starter-client</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+    </dependencies>
+
+
+    <build>
+        <plugins>
+            <!-- spring-boot-maven-plugin (提供了直接运行项目的插件：如果是通过parent方式继承spring-boot-starter-parent则不用此插件) -->
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

+package com.crossoverjie.netty.action.zk;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author crossoverJie
+ */
+@SpringBootApplication
+public class Application implements CommandLineRunner{
+
+	private final static Logger LOGGER = LoggerFactory.getLogger(Application.class);
+
+
+
+	public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+		LOGGER.info("启动应用成功");
+	}
+
+	@Override
+	public void run(String... args) throws Exception {
+	}
+}

+package com.crossoverjie.netty.action.zk.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+
+@Configuration
+@EnableSwagger2
+/** 是否打开swagger **/
+@ConditionalOnExpression("'${swagger.enable}' == 'true'")
+public class SwaggerConfig {
+	
+    
+	@Bean
+    public Docket createRestApi() {
+        return new Docket(DocumentationType.SWAGGER_2)
+                .apiInfo(apiInfo())
+                .select()
+                .apis(RequestHandlerSelectors.basePackage("com.crossoverjie.netty.action.zk.controller"))
+                .paths(PathSelectors.any())
+                .build();
+    }
+	
+    private ApiInfo apiInfo() {
+        return new ApiInfoBuilder()
+                .title("netty-action-zk api")
+                .description("netty-action-zk api")
+                .termsOfServiceUrl("https://crossoverJie.top")
+                .contact("crossoverJie")
+                .version("1.0.0")
+                .build();
+    }
+    
+}

+package com.crossoverjie.netty.action.zk.controller;
+
+import com.crossoverjie.netty.action.common.enums.StatusEnum;
+import com.crossoverjie.netty.action.common.res.BaseResponse;
+import com.crossoverjie.netty.action.common.res.NULLBody;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * Function:
+ *
+ * @author crossoverJie
+ *         Date: 22/05/2018 14:46
+ * @since JDK 1.8
+ */
+@Controller
+@RequestMapping("/")
+public class IndexController {
+
+
+    /**
+     * 获取所有路由节点
+     * @return
+     */
+    @ApiOperation("获取所有路由节点")
+    @RequestMapping(value = "getRoute",method = RequestMethod.POST)
+    @ResponseBody()
+    public BaseResponse<NULLBody> getRoute(){
+        BaseResponse<NULLBody> res = new BaseResponse();
+        res.setCode(StatusEnum.SUCCESS.getCode()) ;
+        res.setMessage("127.0.0.1:8080") ;
+        return res ;
+    }
+
+
+}

+spring.application.name=netty-action-zk
+
+# web port
+server.port=8083
+
+# 是否打开swagger
+swagger.enable = true
+
+logging.level.root=info

@@ -31,12 +31,20 @@
 		<module>netty-action-heartbeat-client</module>
 		<module>netty-action-heartbeat-client</module>
 		<module>netty-action-common</module>
 		<module>netty-action-common</module>
 		<module>springboot-admin</module>
 		<module>springboot-admin</module>
+		<module>netty-action-zk</module>
 	</modules>
 	</modules>
 
 
 
 
 	<dependencyManagement>
 	<dependencyManagement>
 		<dependencies>
 		<dependencies>
 
 
+
+			<dependency>
+				<groupId>com.github.sgroschupf</groupId>
+				<artifactId>zkclient</artifactId>
+				<version>0.1</version>
+			</dependency>
+
 			<dependency>
 			<dependency>
 				<groupId>com.crossoverjie.netty</groupId>
 				<groupId>com.crossoverjie.netty</groupId>
 				<artifactId>netty-action-common</artifactId>
 				<artifactId>netty-action-common</artifactId>