提交全局搜索引擎工程，采用Apache Lucene搭建

src/pom.xml

@@ -40,6 +40,7 @@
     <module>project-sso</module>
     <module>project-quartz</module>
     <module>taoshop-common</module>
+    <module>project-search</module>
   </modules>
 
   <build>

src/taoshop-common/pom.xml

@@ -13,4 +13,18 @@
 
     <packaging>jar</packaging>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.alibaba.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>3.0.10</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba.rocketmq</groupId>
+            <artifactId>rocketmq-all</artifactId>
+            <version>3.0.10</version>
+            <type>pom</type>
+        </dependency>
+    </dependencies>
+
 </project>
\ No newline at end of file

src/taoshop-common/src/test/java/com/mq/test/Consumer.java

+package com.mq.test;
+
+import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
+import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
+import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
+import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
+import com.alibaba.rocketmq.client.exception.MQClientException;
+import com.alibaba.rocketmq.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+    public static void main(String[] args) throws MQClientException {
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(
+                "rmq-group");
+
+        consumer.setNamesrvAddr("123.207.63.192:9876");
+        consumer.setInstanceName("consumer");
+        consumer.subscribe("TopicA-test", "TagA");
+
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(
+                    List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println(new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        consumer.start();
+        System.out.println("Consumer Started.");
+    }
+}
\ No newline at end of file