[feature]添加 README

boyunkai · boyunkai · commit 75bca270875a · 2021-02-05T16:22:27.000+08:00
diff --git a/09mq/activemq-demo/README.md b/09mq/activemq-demo/README.md
@@ -0,0 +1,6 @@
+
+## Week13 周四作业：
+### 1. [（必做）搭建 ActiveMQ 服务，基于 JMS，写代码分别实现对于 queue 和 topic 的消息生产和消费，代码提交到 github。](src/main/java/io/byk/activemq)
+
+使用`JmsMessagingTemplate`模板类来实现
+
diff --git a/09mq/activemq-demo/src/main/java/io/byk/activemq/JmsActiveMqApplication.java b/09mq/activemq-demo/src/main/java/io/byk/activemq/JmsActiveMqApplication.java
@@ -4,8 +4,6 @@
 import static io.byk.activemq.config.ActiveMqConfig.ACTIVE_MQ_QUEUE;
 import static io.byk.activemq.config.ActiveMqConfig.ACTIVE_MQ_TOPIC;
 
-import java.util.Queue;
-
 import javax.annotation.Resource;
 
 import org.springframework.boot.ApplicationArguments;
@@ -18,6 +16,8 @@
 import lombok.extern.slf4j.Slf4j;
 
 /**
+ * 启动类
+ *
  * @author boyunkai <boyunkai@kuaishou.com>
  * Created on 2021-02-05
  */
@@ -35,11 +35,12 @@ public static void main(String[] args) {
 
     @Override
     public void run(ApplicationArguments args) throws Exception {
+        // 测试队列
         for (int i = 0; i < 10; i++) {
             String message = "队列消息" + i;
             queueProducer.sendMessage(ACTIVE_MQ_QUEUE, message);
         }
-
+        // 测试主题
         for (int i = 0; i < 10; i++) {
             String message = "主题消息" + i;
             topicPublisher.sendMessage(ACTIVE_MQ_TOPIC, message);
diff --git a/09mq/activemq-demo/src/main/java/io/byk/activemq/queue/QueueProducer.java b/09mq/activemq-demo/src/main/java/io/byk/activemq/queue/QueueProducer.java
@@ -12,6 +12,7 @@
 
 /**
  * 队列生产者
+ *
  * @author boyunkai <boyunkai@kuaishou.com>
  * Created on 2021-02-05
  */
diff --git a/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/JmsContainerConfig.java b/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/JmsContainerConfig.java
@@ -9,6 +9,8 @@
 import org.springframework.jms.config.SimpleJmsListenerContainerFactory;
 
 /**
+ * ContainerFactor 配置
+ *
  * @author boyunkai <boyunkai@kuaishou.com>
  * Created on 2021-02-05
  */
diff --git a/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/TopicPublisher.java b/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/TopicPublisher.java
@@ -3,22 +3,20 @@
 import javax.annotation.Resource;
 import javax.jms.Destination;
 
-import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTopic;
 import org.springframework.jms.core.JmsMessagingTemplate;
 import org.springframework.stereotype.Service;
 
-import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 
 /**
- * 队列生产者
+ * 主题生产者
+ *
  * @author boyunkai <boyunkai@kuaishou.com>
  * Created on 2021-02-05
  */
 @Service
 @Slf4j
-@Getter
 public class TopicPublisher {
     // JMS 模板
     @Resource
diff --git a/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/TopicSubscriber.java b/09mq/activemq-demo/src/main/java/io/byk/activemq/topic/TopicSubscriber.java
@@ -1,6 +1,5 @@
 package io.byk.activemq.topic;
 
-import static io.byk.activemq.config.ActiveMqConfig.ACTIVE_MQ_QUEUE;
 import static io.byk.activemq.config.ActiveMqConfig.ACTIVE_MQ_TOPIC;
 
 import org.springframework.jms.annotation.JmsListener;
@@ -9,15 +8,15 @@
 import lombok.extern.slf4j.Slf4j;
 
 /**
- * 队列消费者
+ * 主题消费者
  *
  * @author boyunkai <boyunkai@kuaishou.com>
  * Created on 2021-02-05
  */
 @Service
 @Slf4j
 public class TopicSubscriber {
-    @JmsListener(destination = ACTIVE_MQ_TOPIC,containerFactory = "myJmsContainerFactory")
+    @JmsListener(destination = ACTIVE_MQ_TOPIC, containerFactory = "myJmsContainerFactory")
     public void receiveMessage(String message) {
         log.info("<=========== 收到消息" + message);
     }
