调整示例rocketmq

matrix-sample-hbase/matrix-sample-hbase-springboot/pom.xml

@@ -13,7 +13,7 @@
  <dependencies>
      <dependency>
          <groupId>com.secoo.mall</groupId>
-         <artifactId>matrix-sample-hbase-starter</artifactId>
+         <artifactId>matrix-bigdata-hbase-starter</artifactId>
      </dependency>
  </dependencies>
 

matrix-sample-rocketmq/matrix-sample-rocketmq-biz/src/main/java/com/secoo/mall/rocketmq/bean/User.java → matrix-sample-rocketmq/matrix-sample-rocketmq-biz/src/main/java/com/secoo/rocketmq/bean/User.java

-package com.secoo.mall.rocketmq.bean;
+package com.secoo.rocketmq.bean;
 
 
 import lombok.Data;

matrix-sample-rocketmq/matrix-sample-rocketmq-biz/src/main/java/com/secoo/mall/rocketmq/service/UserService.java → matrix-sample-rocketmq/matrix-sample-rocketmq-biz/src/main/java/com/secoo/rocketmq/service/UserService.java

-package com.secoo.mall.rocketmq.service;
+package com.secoo.rocketmq.service;
 
-import com.secoo.mall.rocketmq.bean.User;
+import com.secoo.rocketmq.bean.User;
 import org.springframework.stereotype.Service;
 
 @Service
 public class UserService {
 
-    public User create(User user){
+    public User create(User user) {
         //实际业务操作
         return user;
     }

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/pom.xml

@@ -10,6 +10,8 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>matrix-sample-rocketmq-springboot</artifactId>
+    <version>1.0.1</version>
+
     <dependencies>
         <dependency>
             <groupId>com.secoo.mall</groupId>
@@ -19,6 +21,7 @@
             <groupId>com.secoo.mall</groupId>
             <artifactId>matrix-sample-rocketmq-biz</artifactId>
         </dependency>
+
     </dependencies>
 
 

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/src/main/java/com/secoo/rocketmq/RoketMqSampleApplication.java

 package com.secoo.rocketmq;
 
 import com.secoo.mall.common.util.json.FastJsonUtil;
-import com.secoo.mall.rocketmq.bean.User;
+import com.secoo.rocketmq.bean.User;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.messaging.support.MessageBuilder;
 
 import javax.annotation.Resource;
 
@@ -17,7 +18,7 @@ public class RoketMqSampleApplication implements ApplicationRunner {
 
     @Resource
     private RocketMQTemplate template;
-    @Resource
+
     private String topicName = "roketmq-simple-springboot";
 
     public static void main(String[] args) {
@@ -40,8 +41,8 @@ public class RoketMqSampleApplication implements ApplicationRunner {
         msg.setMsgId(user.getId().toString());
         msg.setBody(FastJsonUtil.toString(user).getBytes());
         //2.指定tag，并同步发送消息
-        //指定tag为create发送到topic
-        template.syncSend(topicName + createTagName, msg);
+        //指定tag为create发送到topic 
+        template.syncSend(  topicName + createTagName,  msg);
 
     }
 }
\ No newline at end of file

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/src/main/java/com/secoo/rocketmq/consumer/MassageConsumer.java

 package com.secoo.rocketmq.consumer;
 
-import com.secoo.mall.rocketmq.bean.User;
-import com.secoo.mall.rocketmq.service.UserService;
+import com.secoo.rocketmq.bean.User;
+import com.secoo.rocketmq.service.UserService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/src/main/java/com/secoo/rocketmq/consumer/MessageExtConsumer.java

@@ -8,6 +8,7 @@ import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.apache.rocketmq.spring.core.RocketMQPushConsumerLifecycleListener;
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/src/main/resources/application.yml

+
+rocketmq:
+  name-server: dev01-mq-mall1.secoolocal.com:9876;dev01-mq-mall2.secoolocal.com:9876
+  producer:
+    group: simple-group
+
+server:
+  port: 9090
\ No newline at end of file