移除无用配置

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

@@ -15,7 +15,12 @@ public class ConsumerApplication {
     }
 
     @Bean
-    public Consumer<Date> receive() {
+    public Consumer<Date> sink1() {
+        return System.out::println;
+    }
+
+    @Bean
+    public Consumer<String> sink2() {
         return System.out::println;
     }
 }

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

@@ -3,10 +3,20 @@ spring:
     host: 192.168.133.128
     username: dev-user
     password: devpassword
+
   cloud:
     stream:
       bindings:
-        input:
+        send1:
-          destination: my-test-channel
+          destination: test2
+        send2:
+          destination: test3
+      function:
+        # 定义别名
+        bindings:
+          sink1-in-0: send1
+          sink2-in-0: send2
+        definition: sink1;sink2
+
 server:
   port: 8081

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

@@ -4,8 +4,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.stream.function.StreamBridge;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
-import top.fjy8018.consumer.common.MySource;
 
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.Date;
 
 /**
@@ -18,10 +19,16 @@ public class Producer {
     @Autowired
     private StreamBridge streamBridge;
 
-    @RequestMapping("/send")
+    @RequestMapping("/send1")
-    public String send() {
+    public String send1() {
-        streamBridge.send(MySource.OUTPUT, new Date());
+        streamBridge.send("send1", new Date());
-        return "success";
+        return "success1";
+    }
+
+    @RequestMapping("/send2")
+    public String send2() {
+        streamBridge.send("send2", LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME));
+        return "success2";
     }
 
 }

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

@@ -3,10 +3,15 @@ spring:
     host: 192.168.133.128
     username: dev-user
     password: devpassword
+
   cloud:
     stream:
       bindings:
-        output:
+        send1:
-          destination: my-test-channel
+          destination: test2
+        send2:
+          destination: test3
+
+
 server:
-  port: 8082
+  port: 8083