添加注释

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)));
    }
}