spring-boot-starter-rocketmq demo

whatsmars-mq/pom.xml

@@ -37,10 +37,16 @@
             <version>${rocketmq.version}</version>
         </dependency>
         <!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client -->
-        <dependency>
+        <!--<dependency>
             <groupId>org.apache.rocketmq</groupId>
             <artifactId>rocketmq-client</artifactId>
             <version>${rocketmq.version}</version>
+        </dependency>-->
+        <!-- https://mvnrepository.com/artifact/org.apache.rocketmq/spring-boot-starter-rocketmq -->
+        <dependency>
+            <groupId>com.qianmi</groupId>
+            <artifactId>spring-boot-starter-rocketmq</artifactId>
+            <version>1.0.2-RELEASE</version>
         </dependency>
 
         <dependency>

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ConsumerApplication.java

+package com.whatsmars.mq.rocketmq.boot;
+
+import com.qianmi.ms.starter.rocketmq.annotation.RocketMQMessageListener;
+import com.qianmi.ms.starter.rocketmq.core.RocketMQListener;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.stereotype.Service;
+
+@SpringBootApplication
+public class ConsumerApplication{
+    
+    public static void main(String[] args){
+        SpringApplication.run(ConsumerApplication.class, args);
+    }
+    
+    @Service
+    @RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")
+    public class MyConsumer implements RocketMQListener<String> {
+        public void onMessage(String message) {
+            System.out.println("received message: " + message);
+        }
+    }
+    
+    @Service
+    @RocketMQMessageListener(topic = "test-topic-2", consumerGroup = "my-consumer_test-topic-2")
+    public class MyConsumer2 implements RocketMQListener<OrderPaidEvent>{
+        public void onMessage(OrderPaidEvent orderPaidEvent) {
+            System.out.println("received orderPaidEvent: " + orderPaidEvent);
+        }
+    }
+}
\ No newline at end of file

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java

+package com.whatsmars.mq.rocketmq.boot;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+public class OrderPaidEvent implements Serializable {
+        private String orderId;
+        
+        private BigDecimal paidMoney;
+
+        public OrderPaidEvent() {}
+
+        public OrderPaidEvent(String orderId, BigDecimal paidMoney) {
+            this.orderId = orderId;
+            this.paidMoney = paidMoney;
+        }
+
+        public String getOrderId() {
+            return orderId;
+        }
+
+        public void setOrderId(String orderId) {
+            this.orderId = orderId;
+        }
+
+        public BigDecimal getPaidMoney() {
+            return paidMoney;
+        }
+
+        public void setPaidMoney(BigDecimal paidMoney) {
+            this.paidMoney = paidMoney;
+        }
+    }
\ No newline at end of file

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ProducerApplication.java

+package com.whatsmars.mq.rocketmq.boot;
+
+import com.qianmi.ms.starter.rocketmq.core.RocketMQTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.messaging.support.MessageBuilder;
+
+import java.math.BigDecimal;
+
+@SpringBootApplication
+public class ProducerApplication implements CommandLineRunner {
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
+    
+    public static void main(String[] args){
+        SpringApplication.run(ProducerApplication.class, args);
+    }
+    
+    public void run(String... args) throws Exception {
+        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
+        rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! I'm from spring message").build());
+        rocketMQTemplate.convertAndSend("test-topic-2", new OrderPaidEvent("T_001", new BigDecimal("88.00")));
+        
+//        rocketMQTemplate.destroy(); // notes:  once rocketMQTemplate be destroyed, you can not send any message again with this rocketMQTemplate
+    }
+
+}
\ No newline at end of file

whatsmars-mq/src/main/resources/application.yml

+spring:
+  rocketmq:
+    name-server: 127.0.0.1:9876
+    producer:
+      group: boot_producer_group
\ No newline at end of file