Merge branch 'master' of http://10.1.235.20:3000/rest/code-example.git

Conflicts:
	ipu-db-example/pom.xml

ipu-db-example/pom.xml

@@ -3,7 +3,6 @@
         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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-db-example</artifactId>
    <version>1.0-SNAPSHOT</version>
@@ -38,12 +37,19 @@
            <version>${ipu}</version>
        </dependency>
        <!-- 数据库SQL管理引入依赖 -->
        <!-- ipu-sql-mgmt(内部依赖了ipu-database，所有上面的ipu-database依赖实际可去掉) -->
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-sql-mgmt</artifactId>
            <version>${ipu}</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>${junit}</version>
@@ -51,4 +57,4 @@
		</dependency>
    </dependencies>
</project>
</project>

ipu-db-example/src/main/java/com/ai/ipu/example/db/IpuDatabaseExample.java

@@ -0,0 +1,86 @@
package com.ai.ipu.example.db;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import com.ai.ipu.example.db.service.IpuDbDemoService;
import org.junit.Before;
import org.junit.Test;
import java.math.BigDecimal;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 16:05
 */
public class IpuDatabaseExample {
    private IpuDbDemoService service;
    @Before
    public void before() throws Exception {
        service = new IpuDbDemoService();
    }
    /**
     * 普通查询
     */
    @Test
    public void testSelect() throws Exception {
        System.out.println(service.select());
    }
    /**
     * 条件查询
     */
    @Test
    public void testSelectById() throws Exception {
        System.out.println(service.selectById(0));
    }
    /**
     * 新增
     */
    @Test
    public void testInsert() throws Exception {
        int pk = 999;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
        ipuDbDemoDto.setPk(pk);
        ipuDbDemoDto.setString_type("测试新增");
        ipuDbDemoDto.setInt_type(10);
        ipuDbDemoDto.setDecimal_type(new BigDecimal(10.10));
        ipuDbDemoDto.setDate_type(new Date());
        ipuDbDemoDto.setDatetime_type(new Date());
        ipuDbDemoDto.setNull_type("");
        System.out.println(service.insert(ipuDbDemoDto));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
    /**
     * 条件删除
     */
    @Test
    public void testDeleteById() throws Exception {
        int pk = 1;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        System.out.println(service.deleteById(pk));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
    /**
     * 条件更新
     */
    @Test
    public void testUpdateString_typeById() throws Exception {
        int pk = 1;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        System.out.println(service.updateString_typeById(pk, "测试修改"));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/dao/IpuDbDemoDao.java

@@ -0,0 +1,87 @@
package com.ai.ipu.example.db.dao;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.*;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 16:10
 * @desc dao层，根据sql调用ipu-database的execute方法连接数据库
 */
public class IpuDbDemoDao extends AbstractBizDao {
    public IpuDbDemoDao(String connName) throws IOException {
        super(connName);
    }
    public List<IpuDbDemoDto> select() throws Exception {
        String sql = "select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo";
        List<Map<String, Object>> result = dao.executeSelect(sql);
        List<IpuDbDemoDto> list = new ArrayList<IpuDbDemoDto>();
        for (Map<String, Object> obj : result) {
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setDecimal_type((BigDecimal) obj.get("decimal_type"));
            ipuDbDemoDto.setDate_type((Date) obj.get("date_type"));
            ipuDbDemoDto.setDatetime_type((Date) obj.get("datetime_type"));
            ipuDbDemoDto.setNull_type((String) obj.get("null_type"));
            list.add(ipuDbDemoDto);
        }
        return list;
    }
    public IpuDbDemoDto selectById(int id) throws Exception {
        String sql = "select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo where pk=#{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk" ,id);
        List<Map<String, Object>> result = dao.executeSelect(sql, param);
        if (result == null || result.size() != 1) {
            return null;
        } else {
            Map<String, Object> obj = result.get(0);
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setDecimal_type((BigDecimal) obj.get("decimal_type"));
            ipuDbDemoDto.setDate_type((Date) obj.get("date_type"));
            ipuDbDemoDto.setDatetime_type((Date) obj.get("datetime_type"));
            ipuDbDemoDto.setNull_type((String) obj.get("null_type"));
            return ipuDbDemoDto;
        }
    }
    public int insert(IpuDbDemoDto ipuDbDemoDto) throws Exception {
        String sql = "insert into ipu_db_demo(pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type) values (#{pk}, #{string_type}, #{int_type}, #{decimal_type}, #{date_type}, #{datetime_type}, #{null_type})";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", ipuDbDemoDto.getPk());
        param.put("string_type", ipuDbDemoDto.getPk());
        param.put("int_type", ipuDbDemoDto.getInt_type());
        param.put("decimal_type", ipuDbDemoDto.getDecimal_type());
        param.put("date_type", ipuDbDemoDto.getDate_type());
        param.put("datetime_type", ipuDbDemoDto.getDatetime_type());
        param.put("null_type", ipuDbDemoDto.getNull_type());
        return dao.executeInsert(sql, param);
    }
    public int deleteById(int id) throws Exception {
        String sql = "delete from ipu_db_demo where pk = #{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", id);
        return dao.executeDelete(sql, param);
    }
    public int updateString_typeById(int id, String value) throws Exception {
        String sql = "update ipu_db_demo set string_type = #{string_type} where pk = #{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", id);
        param.put("string_type", value);
        return dao.executeDelete(sql, param);
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/model/IpuDbDemoDto.java

@@ -0,0 +1,96 @@
package com.ai.ipu.example.db.model;
import java.math.BigDecimal;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/16 17:16
 * @desc ipu_db_demo表的dto
 */
public class IpuDbDemoDto {
    private int pk;
    private String string_type;
    private int int_type;
    private BigDecimal decimal_type;
    private Date date_type;
    private Date datetime_type;
    private String null_type;
    public void setPk(int pk) {
        this.pk = pk;
    }
    public void setString_type(String string_type) {
        this.string_type = string_type;
    }
    public void setInt_type(int int_type) {
        this.int_type = int_type;
    }
    public void setDecimal_type(BigDecimal decimal_type) {
        this.decimal_type = decimal_type;
    }
    public void setDate_type(Date date_type) {
        this.date_type = date_type;
    }
    public void setDatetime_type(Date datetime_type) {
        this.datetime_type = datetime_type;
    }
    public void setNull_type(String null_type) {
        this.null_type = null_type;
    }
    public int getPk() {
        return pk;
    }
    public String getString_type() {
        return string_type;
    }
    public int getInt_type() {
        return int_type;
    }
    public BigDecimal getDecimal_type() {
        return decimal_type;
    }
    public Date getDate_type() {
        return date_type;
    }
    public Date getDatetime_type() {
        return datetime_type;
    }
    public String getNull_type() {
        return null_type;
    }
    @Override
    public String toString() {
        StringBuilder stringBuilder = new StringBuilder("{")
                .append("pk").append(":").append(pk).append(",")
                .append("string_type").append(":").append(string_type).append(",")
                .append("int_type").append(":").append(int_type).append(",")
                .append("decimal_type").append(":").append(decimal_type).append(",")
                .append("date_type").append(":").append(date_type).append(",")
                .append("datetime_type").append(":").append(datetime_type).append(",")
                .append("null_type").append(":").append(null_type)
                .append("}");
        return stringBuilder.toString();
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/service/IpuDbDemoService.java

@@ -0,0 +1,44 @@
package com.ai.ipu.example.db.service;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.example.db.dao.IpuDbDemoDao;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import java.util.List;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 17:02
 * @desc service层，绑定dao
 */
public class IpuDbDemoService {
    private IpuDbDemoDao dao;
    /**
     * 获取test的dao
     */
    public IpuDbDemoService() throws Exception {
        dao = IpuDaoManager.takeDao(IpuDbDemoDao.class, "test");
    }
    public List<IpuDbDemoDto> select() throws Exception {
        return dao.select();
    }
    public IpuDbDemoDto selectById(int id) throws Exception {
        return dao.selectById(id);
    }
    public int insert(IpuDbDemoDto ipuDbDemoDto) throws Exception {
        return dao.insert(ipuDbDemoDto);
    }
    public int deleteById(int id) throws Exception {
        return dao.deleteById(id);
    }
    public int updateString_typeById(int id, String value) throws Exception {
        return dao.updateString_typeById(id, value);
    }
}

ipu-db-example/src/main/resources/ipu-mybatis-config.xml

@@ -0,0 +1,39 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor">
	        <!-- config params as the following -->
		</plugin>
	</plugins>
	<environments default="test">
        <environment id="test">
            <transactionManager type="JDBC" />
            <dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
                <property name="driverClass" value="com.mysql.jdbc.Driver" />
                <property name="url" value="jdbc:mysql://47.105.160.21:3307/test" />
                <property name="username" value="iputest" />
                <property name="password" value="iputest@321" />
				<!-- 连接池用完时,等待获取新连接的时间 (毫秒) -->
				<property name="maxWait" value="5000" />
				<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
				<!--<property name="acquireRetryAttempts" value="5" />-->
				<!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
				<!--<property name="acquireRetryDelay" value="1000" />-->
				<property name="initialSize" value="3" />
				<property name="minIdle" value="3" />
				<property name="maxActive" value="3" />
				<!--<property name="maxIdleTime" value="600" />-->
				<!--<property name="idleConnectionTestPeriod" value="60" />-->
				<property name="validationQuery" value="SELECT 1" />
            </dataSource>
        </environment>
	</environments>
</configuration>

ipu-kafka-example/pom.xml

@@ -15,6 +15,7 @@
    </properties>
    <dependencies>
        <!-- msgframe依赖jar -->
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-common</artifactId>

ipu-kafka-example/src/main/java/com/ai/ipu/example/kafka/KafkaProducerExample.java

@@ -44,6 +44,9 @@ public class KafkaProducerExample {
        return MESSAGE + "_" + new Date().getTime();
    }
    /**
     * 普通消息发送
     */
    private void sendMessage(String topic, String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -57,6 +60,9 @@ public class KafkaProducerExample {
        }
    }
    /**
     * 异步消息发送
     */
    private void sendAsyncMessage(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -77,6 +83,9 @@ public class KafkaProducerExample {
        }
    }
    /**
     * 顺序消息发送
     */
    private void sendOrderMessage(String topic, final String text, String orderId) {
        try {
            MfProducerClient client = new MfProducerClient();

ipu-rabbitmq-example/pom.xml

@@ -15,6 +15,7 @@
    </properties>
    <dependencies>
        <!-- msgframe依赖jar -->
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-common</artifactId>

ipu-rabbitmq-example/src/main/java/com/ai/ipu/example/rabbitmq/RabbitMQProducerExample.java

@@ -44,6 +44,9 @@ public class RabbitMQProducerExample {
        return MESSAGE + "_" + new Date().getTime();
    }
    /**
     * 普通消息发送
     */
    private void sendMessage(String topic, String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -57,6 +60,9 @@ public class RabbitMQProducerExample {
        }
    }
    /**
     * 异步消息发送
     */
    private void sendAsyncMessage(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -77,6 +83,9 @@ public class RabbitMQProducerExample {
        }
    }
    /**
     * 顺序消息发送
     */
    private void sendOrderMessage(String topic, final String text, String orderId) {
        try {
            MfProducerClient client = new MfProducerClient();

ipu-rocketmq-example/pom.xml

@@ -15,6 +15,7 @@
    </properties>
    <dependencies>
        <!-- msgframe依赖jar -->
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-common</artifactId>

ipu-rocketmq-example/src/main/java/com/ai/ipu/example/rocketmq/RocketMQProducerExample.java

@@ -49,6 +49,9 @@ public class RocketMQProducerExample {
        return MESSAGE + "_" + new Date().getTime();
    }
    /**
     * 普通消息发送
     */
    private void sendMessage(String topic, String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -63,6 +66,9 @@ public class RocketMQProducerExample {
        }
    }
    /**
     * 异步消息发送
     */
    private void sendAsyncMessage(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -84,6 +90,9 @@ public class RocketMQProducerExample {
        }
    }
    /**
     * 顺序消息发送
     */
    private void sendOrderMessage(String topic, final String text, String orderId) {
        try {
            MfProducerClient client = new MfProducerClient();
@@ -98,6 +107,9 @@ public class RocketMQProducerExample {
        }
    }
    /**
     * 单向消息发送
     */
    private void sendOneWay(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();

ipu-zk-example/ipu-zk-example.iml

@@ -11,44 +11,70 @@
    </content>
    <orderEntry type="inheritedJdk" />
    <orderEntry type="sourceFolder" forTests="false" />
    <orderEntry type="library" name="Maven: com.ai.ipu:ipu-zk:3.1-SNAPSHOT" level="project" />
    <orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.4.9" level="project" />
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.6.1" level="project" />
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-log4j12:1.6.1" level="project" />
    <orderEntry type="library" name="Maven: log4j:log4j:1.2.16" level="project" />
    <orderEntry type="library" name="Maven: jline:jline:0.9.94" level="project" />
    <orderEntry type="library" name="Maven: io.netty:netty:3.10.5.Final" level="project" />
    <orderEntry type="library" name="Maven: com.google.guava:guava:16.0.1" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.3.2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.3.1" level="project" />
    <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.1.3" level="project" />
    <orderEntry type="library" name="Maven: xerces:xercesImpl:2.6.2" level="project" />
    <orderEntry type="library" name="Maven: xalan:xalan:2.6.0" level="project" />
    <orderEntry type="library" name="Maven: org.jsoup:jsoup:1.7.2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.poi:poi:3.9" level="project" />
    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.5" level="project" />
    <orderEntry type="library" name="Maven: com.ai.ipu:ipu-zk:3.1-SNAPSHOT" level="project" />
    <orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.5.5" level="project" />
    <orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper-jute:3.5.5" level="project" />
    <orderEntry type="library" name="Maven: org.apache.yetus:audience-annotations:0.5.0" level="project" />
    <orderEntry type="library" name="Maven: io.netty:netty-all:4.1.29.Final" level="project" />
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.25" level="project" />
    <orderEntry type="library" name="Maven: org.slf4j:slf4j-log4j12:1.7.25" level="project" />
    <orderEntry type="library" name="Maven: log4j:log4j:1.2.17" level="project" />
    <orderEntry type="library" name="Maven: org.apache.curator:curator-framework:2.8.0" level="project" />
    <orderEntry type="library" name="Maven: org.apache.curator:curator-client:2.8.0" level="project" />
    <orderEntry type="library" name="Maven: org.apache.curator:curator-recipes:2.8.0" level="project" />
    <orderEntry type="library" name="Maven: com.101tec:zkclient:0.10" level="project" />
    <orderEntry type="library" name="Maven: com.google.guava:guava:16.0.1" level="project" />
    <orderEntry type="library" name="Maven: com.google.guava:guava:27.0-jre" level="project" />
    <orderEntry type="library" name="Maven: com.google.guava:failureaccess:1.0" level="project" />
    <orderEntry type="library" name="Maven: com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava" level="project" />
    <orderEntry type="library" name="Maven: com.google.code.findbugs:jsr305:3.0.2" level="project" />
    <orderEntry type="library" name="Maven: org.checkerframework:checker-qual:2.5.2" level="project" />
    <orderEntry type="library" name="Maven: com.google.errorprone:error_prone_annotations:2.2.0" level="project" />
    <orderEntry type="library" name="Maven: com.google.j2objc:j2objc-annotations:1.1" level="project" />
    <orderEntry type="library" name="Maven: org.codehaus.mojo:animal-sniffer-annotations:1.17" level="project" />
    <orderEntry type="library" name="Maven: com.ai.ipu:ipu-basic:3.1-SNAPSHOT" level="project" />
    <orderEntry type="library" name="Maven: com.ai.ipu:ipu-common:3.1-SNAPSHOT" level="project" />
    <orderEntry type="library" name="Maven: com.ai.wade:wade-data:1.0" level="project" />
    <orderEntry type="library" name="Maven: com.mashape.unirest:unirest-java:1.3.8" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.3.2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.3.1" level="project" />
    <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.1.3" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpasyncclient:4.0.1" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore-nio:4.3.2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpmime:4.3.2" level="project" />
    <orderEntry type="library" name="Maven: org.json:json:20131018" level="project" />
    <orderEntry type="library" name="Maven: dom4j:dom4j:1.6.1" level="project" />
    <orderEntry type="library" name="Maven: xml-apis:xml-apis:1.0.b2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.5.5" level="project" />
    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.9" level="project" />
    <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.2" level="project" />
    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.10" level="project" />
    <orderEntry type="library" name="Maven: dom4j:dom4j:1.6" level="project" />
    <orderEntry type="library" name="Maven: xml-apis:xml-apis:1.4.01" level="project" />
    <orderEntry type="library" name="Maven: jaxen:jaxen:1.1.1" level="project" />
    <orderEntry type="library" name="Maven: jdom:jdom:1.0" level="project" />
    <orderEntry type="library" name="Maven: xerces:xercesImpl:2.6.2" level="project" />
    <orderEntry type="library" name="Maven: xom:xom:1.0" level="project" />
    <orderEntry type="library" name="Maven: xerces:xmlParserAPIs:2.6.2" level="project" />
    <orderEntry type="library" name="Maven: xalan:xalan:2.6.0" level="project" />
    <orderEntry type="library" name="Maven: com.ibm.icu:icu4j:2.6.1" level="project" />
    <orderEntry type="library" name="Maven: org.jsoup:jsoup:1.7.2" level="project" />
    <orderEntry type="library" name="Maven: xalan:xalan:2.7.2" level="project" />
    <orderEntry type="library" name="Maven: xalan:serializer:2.7.2" level="project" />
    <orderEntry type="library" name="Maven: xerces:xercesImpl:2.12.0" level="project" />
    <orderEntry type="library" name="Maven: org.jsoup:jsoup:1.9.2" level="project" />
    <orderEntry type="library" name="Maven: org.apache.commons:commons-lang3:3.4" level="project" />
    <orderEntry type="library" name="Maven: org.apache.poi:poi:3.9" level="project" />
    <orderEntry type="library" name="Maven: commons-codec:commons-codec:1.5" level="project" />
    <orderEntry type="library" name="Maven: org.apache.poi:poi:4.1.0" level="project" />
    <orderEntry type="library" name="Maven: org.apache.commons:commons-collections4:4.3" level="project" />
    <orderEntry type="library" name="Maven: org.apache.commons:commons-math3:3.6.1" level="project" />
    <orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.38" level="project" />
    <orderEntry type="library" name="Maven: org.yaml:snakeyaml:1.23" level="project" />
    <orderEntry type="library" name="Maven: com.ai.wade:wade-data:1.0" level="project" />
    <orderEntry type="library" name="Maven: junit:junit:4.12" level="project" />
    <orderEntry type="library" name="Maven: org.hamcrest:hamcrest-core:1.3" level="project" />
  </component>

ipu-zk-example/src/main/java/com/ai/ipu/example/zookeeper/ZookeeperExample.java

@@ -35,23 +35,39 @@ public class ZookeeperExample {
        OperType.Define.setVersionCtrl(VERSIONCTL);
    }
    /**
     * 给根节点赋值
     * @throws Exception
     */
    @Test
    public void testSetValue() throws Exception{
    public void testSetValueToRoot() throws Exception{
        LOG.debug(Boolean.toString(client.setValue(OperType.Define, PATH, "myData1")));
    }
    /**
     * 给叶子节点赋值，会触发监听器
     * @throws Exception
     */
    @Test
    public void testSetValue2() throws Exception{
    public void testSetValueToLeaf() throws Exception{
        LOG.debug(Boolean.toString(client.setValue(OperType.Define, PATH2, "myData1")));
    }
    /**
     * 获取节点的值
     * @throws Exception
     */
    @Test
    public void testGetValue() throws Exception {
        LOG.debug(client.getValue(OperType.Define, PATH2));
    }
    /**
     * 删除节点
     * @throws Exception
     */
    @Test
    public void deleteNode() throws Exception {
    public void testDeleteNode() throws Exception {
        LOG.debug(Boolean.toString(client.delete(OperType.Define, PATH2)));
    }
}