add rocketmq demo

Author: kimmking

09mq/rabbit/src/main/java/io/kimmking/mq/camel/README.md

@@ -0,0 +1 @@
+使用代码方式，实现camel的操作。

09mq/rocket/pom.xml

@@ -19,10 +19,10 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-web</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-web</artifactId>-->
+<!--        </dependency>-->
 
         <dependency>
             <groupId>org.apache.rocketmq</groupId>

09mq/rocket/src/main/java/io/kimmking/mq/rocket/DemoController.java

@@ -0,0 +1,16 @@
+package io.kimmking.mq.rocket;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Order {
+
+    private long id;
+    private String symbol;
+    private double price;
+
+}

09mq/rocket/src/main/java/io/kimmking/mq/rocket/Order.java

@@ -0,0 +1,16 @@
+package io.kimmking.mq.rocket;
+
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQReplyListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RocketMQMessageListener(consumerGroup = "test2", topic = "test-k2")
+public class OrderConsumerDemo implements RocketMQReplyListener<Order,String> {
+
+    @Override
+    public String onMessage(Order order) {
+        System.out.println(this.getClass().getName() + " -> " + order);
+        return "Process&Return [" + order + "].";
+    }
+}

09mq/rocket/src/main/java/io/kimmking/mq/rocket/OrderConsumerDemo.java

@@ -1,13 +1,56 @@
 package io.kimmking.mq.rocket;
 
+import org.apache.rocketmq.client.producer.SendCallback;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.messaging.MessageHeaders;
+import org.springframework.messaging.support.MessageBuilder;
+import org.springframework.util.MimeTypeUtils;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.List;
 
 @SpringBootApplication
-public class RocketApplication {
+public class RocketApplication implements CommandLineRunner {
 
     public static void main(String[] args) {
         SpringApplication.run(RocketApplication.class, args);
     }
 
+    @Resource
+    private RocketMQTemplate rocketMQTemplate;
+
+    @Override
+    public void run(String... args) throws Exception {
+
+        String topic = "test-k1";
+        SendResult sendResult = rocketMQTemplate.syncSend(topic, "Hello, World!" + System.currentTimeMillis());
+        System.out.printf("syncSend1 to topic %s sendResult=%s %n", topic, sendResult);
+
+        sendResult = rocketMQTemplate.syncSend(topic, MessageBuilder.withPayload(
+                new Order(System.currentTimeMillis(),"CNY2USD", 0.1501d))
+                .setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON_VALUE).build());
+        System.out.printf("syncSend1 to topic %s sendResult=%s %n", topic, sendResult);
+
+        String topic1 = "test-k2";
+        rocketMQTemplate.asyncSend(topic1, new Order(System.currentTimeMillis(),"CNY2USD", 0.1502d), new SendCallback() {
+            @Override
+            public void onSuccess(SendResult result) {
+                System.out.printf("async onSucess SendResult=%s %n", result);
+            }
+
+            @Override
+            public void onException(Throwable throwable) {
+                System.out.printf("async onException Throwable=%s %n", throwable);
+            }
+
+        });
+
+
+    }
+
 }

09mq/rocket/src/main/java/io/kimmking/mq/rocket/RocketApplication.java

@@ -0,0 +1,15 @@
+package io.kimmking.mq.rocket;
+
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RocketMQMessageListener(consumerGroup = "test1", topic = "test-k1")
+public class StringConsumerDemo implements RocketMQListener<String> {
+
+    @Override
+    public void onMessage(String message) {
+        System.out.println(this.getClass().getName() + " -> " + message);
+    }
+}

09mq/rocket/src/main/java/io/kimmking/mq/rocket/StringConsumerDemo.java

@@ -0,0 +1,5 @@
+
+rocketmq.name-server=localhost:9876
+rocketmq.producer.group=my-group1
+rocketmq.producer.sendMessageTimeout=300000
+