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

@@ -83,6 +83,7 @@ public class KafkaProducerExample {
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.sendOrderMsg(topic, message, orderId);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            throw new RuntimeException(e);

ipu-rabbitmq-example/pom.xml

@@ -0,0 +1,86 @@
<?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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-rabbitmq-example</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <ipu>3.1-SNAPSHOT</ipu>
        <jdk>1.8</jdk>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-common</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-client</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-server</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>xmlmsgframe</artifactId>
            <version>2.6.4</version>
        </dependency>
        <dependency>
            <groupId>org.apache.xmlbeans</groupId>
            <artifactId>xmlbeans</artifactId>
            <version>2.6.0</version>
        </dependency>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>3.6.5</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.1.46</version>
        </dependency>
        <dependency>
            <groupId>org.hamcrest</groupId>
            <artifactId>hamcrest-core</artifactId>
            <version>1.3</version>
        </dependency>
        <dependency>
            <groupId>javax.jms</groupId>
            <artifactId>jms</artifactId>
            <version>1.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>0.10.2.0</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.12</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>3.5.9</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>
</project>

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

@@ -0,0 +1,15 @@
package com.ai.ipu.example.rabbitmq;
import com.ai.aif.msgframe.consumer.MfServiceStartup;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/10 17:09
 * @desc rabbitmq消费者启动器
 */
public class RabbitMQCustomer {
    public static void main(String[] args){
        MfServiceStartup.main();
    }
}

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

@@ -0,0 +1,22 @@
package com.ai.ipu.example.rabbitmq;
import com.ai.aif.msgframe.common.IConsumerProcessor;
import com.ai.aif.msgframe.common.exception.ConsumerException;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/10 16:20
 * @desc rabbitmq消费者
 */
public class RabbitMQCustomerExample implements IConsumerProcessor {
    @SuppressWarnings("rawtypes")
    public Object process(MsgFMessage message) throws ConsumerException {
        if (message instanceof MsgFTextMessage) {
            System.out.println("{topic:" + message.getTopic() + ",value:" + ((MsgFTextMessage) message).getText() + "}");
        }
        return true;
    }
}

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

@@ -0,0 +1,92 @@
package com.ai.ipu.example.rabbitmq;
import com.ai.aif.msgframe.MfProducerClient;
import com.ai.aif.msgframe.common.CompletionListener;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
import org.apache.log4j.Logger;
import org.junit.Test;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/6 16:07
 * @desc rabbitmq生产者
 */
public class RabbitMQProducerExample {
    private static final Logger LOG = Logger.getLogger(RabbitMQProducerExample.class);
    private final String TOPIC = "test";
    private final String MESSAGE = "test";
    private final String ORDERID = "1000";
    @Test
    public void testSendMessage() {
        String message = getMessage();
        sendMessage(TOPIC, message);
    }
    @Test
    public void testSendAsyncMessage() {
        String message = getMessage();
        sendAsyncMessage(TOPIC, message);
    }
    @Test
    public void testSendOrderMessage() {
        String message = getMessage();
        sendOrderMessage(TOPIC, message, ORDERID);
    }
    private String getMessage() {
        return MESSAGE + "_" + new Date().getTime();
    }
    private void sendMessage(String topic, String text) {
        try {
            MfProducerClient client = new MfProducerClient();
            MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.send(topic, message);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    private void sendAsyncMessage(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.asyncSend(topic, message, new CompletionListener() {
                public void onCompletion(MsgFMessage msgFMessage) {
                    LOG.debug("Sent Success:" + msgFMessage.getMsgId() + "-" + text);
                }
                public void onException(MsgFMessage msgFMessage, Exception e) {
                    LOG.debug("Sent Error:" + msgFMessage.getMsgId() + "-" + text);
                }
            });
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    private void sendOrderMessage(String topic, final String text, String orderId) {
        try {
            MfProducerClient client = new MfProducerClient();
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.sendOrderMsg(topic, message, orderId);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

ipu-rabbitmq-example/src/main/resources/log4j.properties

@@ -0,0 +1,8 @@
log4j.rootLogger=error, console
log4j.logger.org.apache.zookeeper=error
log4j.logger.com.ai.ipu.example=debug
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.target=System.out
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %5p [%t] (%F:%L) - %m%n

ipu-rabbitmq-example/src/main/resources/msgframe-config.xml

@@ -0,0 +1,22 @@
<?xml version="1.0" encoding="UTF-8"?>
<msgframeCfg xmlns="http://www.asiainfo.com/msgframe">
    <centerCfg>
        <name>ipu-rabbitmq-example</name>
        <destinations>
            <queue name="test" belong="myCenter"/>
        </destinations>
        <subscribes>
            <subscribe subDestination="test">
                <implclass>com.ai.ipu.example.rabbitmq.RabbitMQCustomerExample</implclass>
            </subscribe>
        </subscribes>
        <centers>
            <center name="myCenter" containClusters="rabbitmq-cluster"/>
        </centers>
        <clusters>
            <cluster name="rabbitmq-cluster" type="RabbitMQ">
                <url user="admin" password="admin">47.105.160.21</url>
            </cluster>
        </clusters>
    </centerCfg>
</msgframeCfg>

ipu-rocketmq-example/pom.xml

@@ -0,0 +1,86 @@
<?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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-rocketmq-example</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <ipu>3.1-SNAPSHOT</ipu>
        <jdk>1.8</jdk>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-common</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-client</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>msgframe-server</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>com.ai.aif.msgframe</groupId>
            <artifactId>xmlmsgframe</artifactId>
            <version>2.6.4</version>
        </dependency>
        <dependency>
            <groupId>org.apache.xmlbeans</groupId>
            <artifactId>xmlbeans</artifactId>
            <version>2.6.0</version>
        </dependency>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>3.6.5</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.1.46</version>
        </dependency>
        <dependency>
            <groupId>org.hamcrest</groupId>
            <artifactId>hamcrest-core</artifactId>
            <version>1.3</version>
        </dependency>
        <dependency>
            <groupId>javax.jms</groupId>
            <artifactId>jms</artifactId>
            <version>1.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>0.10.2.0</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.12</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>3.5.9</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>
</project>

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

@@ -0,0 +1,15 @@
package com.ai.ipu.example.rocketmq;
import com.ai.aif.msgframe.consumer.MfServiceStartup;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/10 14:13
 * @desc 启动RocketMQ消费者
 */
public class RocketMQCustomer {
    public static void main(String[] args){
        MfServiceStartup.main();
    }
}

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

@@ -0,0 +1,23 @@
package com.ai.ipu.example.rocketmq;
import com.ai.aif.msgframe.common.IConsumerProcessor;
import com.ai.aif.msgframe.common.exception.ConsumerException;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/10 14:15
 * @desc RocketMQ消费者
 */
public class RocketMQCustomerExample implements IConsumerProcessor {
    @SuppressWarnings("rawtypes")
    public Object process(MsgFMessage message) throws ConsumerException {
        if (message instanceof MsgFTextMessage) {
            System.out.println("{topic:" + message.getTopic() + ",value:" + ((MsgFTextMessage) message).getText() + "}");
        }
        return true;
    }
}

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

@@ -0,0 +1,114 @@
package com.ai.ipu.example.rocketmq;
import com.ai.aif.msgframe.MfProducerClient;
import com.ai.aif.msgframe.common.CompletionListener;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
import org.apache.log4j.Logger;
import org.junit.Test;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/6/10 14:16
 * @desc RocketMQ生产者
 */
public class RocketMQProducerExample {
    private static final Logger LOG = Logger.getLogger(RocketMQProducerExample.class);
    private final String TOPIC = "test";
    private final String MESSAGE = "test";
    private final String ORDERID = "1000";
    @Test
    public void testSendMessage() {
        String message = getMessage();
        sendMessage(TOPIC, message);
    }
    @Test
    public void testSendAsyncMessage() {
        String message = getMessage();
        sendAsyncMessage(TOPIC, message);
    }
    @Test
    public void testSendOrderMessage() {
        String message = getMessage();
        sendOrderMessage(TOPIC, message, ORDERID);
    }
    @Test
    public void testSendOneWay() {
        String message = getMessage();
        sendOneWay(TOPIC, message);
    }
    private String getMessage() {
        return MESSAGE + "_" + new Date().getTime();
    }
    private void sendMessage(String topic, String text) {
        try {
            MfProducerClient client = new MfProducerClient();
            MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.send(topic, message);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            LOG.debug(e);
            throw new RuntimeException(e);
        }
    }
    private void sendAsyncMessage(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.asyncSend(topic, message, new CompletionListener() {
                public void onCompletion(MsgFMessage msgFMessage) {
                    LOG.debug("Sent Success:" + msgFMessage.getMsgId() + "-" + text);
                }
                public void onException(MsgFMessage msgFMessage, Exception e) {
                    LOG.debug("Sent Error:" + msgFMessage.getMsgId() + "-" + text);
                }
            });
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            LOG.debug(e);
            throw new RuntimeException(e);
        }
    }
    private void sendOrderMessage(String topic, final String text, String orderId) {
        try {
            MfProducerClient client = new MfProducerClient();
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.sendOrderMsg(topic, message, orderId);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            LOG.debug(e);
            throw new RuntimeException(e);
        }
    }
    private void sendOneWay(String topic, final String text) {
        try {
            MfProducerClient client = new MfProducerClient();
            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.sendOneway(topic, message);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            LOG.debug(e);
            throw new RuntimeException(e);
        }
    }
}

ipu-rocketmq-example/src/main/resources/log4j.properties

@@ -0,0 +1,8 @@
log4j.rootLogger=error, console
log4j.logger.org.apache.zookeeper=error
log4j.logger.com.ai.ipu.example=debug
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.target=System.out
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %5p [%t] (%F:%L) - %m%n

ipu-rocketmq-example/src/main/resources/msgframe-config.xml

@@ -0,0 +1,22 @@
<?xml version="1.0" encoding="UTF-8"?>
<msgframeCfg xmlns="http://www.asiainfo.com/msgframe">
    <centerCfg>
        <name>ipu-rocketmq-example</name>
        <destinations>
            <queue name="test" belong="myCenter"/>
        </destinations>
        <subscribes>
            <subscribe subDestination="test">
                <implclass>com.ai.ipu.example.rocketmq.RocketMQCustomerExample</implclass>
            </subscribe>
        </subscribes>
        <centers>
            <center name="myCenter" containClusters="rocketmq-cluster"/>
        </centers>
        <clusters>
            <cluster name="rocketmq-cluster" type="RocketMQ">
                <url>47.105.160.21:9876</url>
            </cluster>
        </clusters>
    </centerCfg>
</msgframeCfg>