类之间解耦

consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySink.java

@@ -11,6 +11,6 @@ import org.springframework.messaging.SubscribableChannel;
 public interface MySink {
     String INPUT = "input";
 
-    @Input(Sink.INPUT)
+    @Input(MySink.INPUT)
     SubscribableChannel input();
 }

consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySource.java

@@ -10,6 +10,6 @@ import org.springframework.messaging.MessageChannel;
 public interface MySource {
     String OUTPUT = "output";
 
-    @Output("output")
+    @Output(MySource.OUTPUT)
     MessageChannel output();
 }

consumer/consumer-server/src/main/java/top/fjy8018/consumer/Consumer.java

@@ -13,6 +13,6 @@ import top.fjy8018.consumer.common.MySink;
 public class Consumer {
     @StreamListener(MySink.INPUT)
     public void receive(Message<String> message) {
-        System.out.println("接收到MQ消息:" + message);
+        System.out.println("接收到MQ消息:" + message.getPayload());
     }
 }

consumer/consumer-server/src/main/resources/application.yml

@@ -1,6 +1,6 @@
 spring:
   rabbitmq:
-    host: docker-1.fjy8018.cn
+    host: 192.168.163.128
     username: cms
     password: cms-mq-admin
   cloud:

producer/producer-server/src/main/java/top/fjy8018/producer/Producer.java

@@ -20,12 +20,11 @@ import java.util.Date;
 public class Producer {
 
     @Autowired
-    @Output(MySource.OUTPUT)
-    private MessageChannel channel;
+    private MySource channel;
 
     @RequestMapping("/send")
     public String send() {
-        channel.send(MessageBuilder.withPayload(new Date()).build());
+        channel.output().send(MessageBuilder.withPayload(new Date()).build());
         return "success";
     }
 }

producer/producer-server/src/main/resources/application.yml

@@ -1,6 +1,6 @@
 spring:
   rabbitmq:
-    host: docker-1.fjy8018.cn
+    host: 192.168.163.128
     username: cms
     password: cms-mq-admin
   cloud: