P83-P94：完成消息驱动Stream、请求链路追踪Sleuth

.gitignore

@@ -129,4 +129,7 @@ cloud-gateway-gateway9527/target/
 cloud-gateway-gateway9527/src/test/
 cloud-config-center-3344/target/
 cloud-config-client-3355/target/
-cloud-config-client-3356/target/
\ No newline at end of file
+cloud-config-client-3356/target/
+cloud-stream-provider-rabbitmq8801/target/
+cloud-stream-consumer-rabbitmq8802/target/
+cloud-stream-consumer-rabbitmq8803/target/
\ No newline at end of file

README.md

@@ -14,26 +14,29 @@ Maven：3.5及以上
 MySQL：5.7及以上
 
 #### 项目结构
-| 项目名                               | 用途                                            | 所用技术                                         |
-| ------------------------------------ | :---------------------------------------------- | ------------------------------------------------ |
-| cloud-api-commons                    | 公共代码部分（返回结果集、实体等）              | \                                                |
-| cloud-consumer-consul-order80        | 消费方通过Consul调用服务方                      | 注册中心（Consul）、远程调用（RestTemplate）     |
-| cloud-consumer-feign-order80         | 消费方通过feign远程调用服务方                   | 服务调用（Openfeign）、注册中心（EurekaClient）  |
-| cloud-consumer-order80               | 消费方通过Eureka调用服务方等示例                | 注册中心（Eureka）、远程调用（RestTemplate）     |
-| cloud-consumer-zk-order80            | 消费方通过Zk调用服务方                          | 注册中心（Zk）、远程调用（RestTemplate）         |
-| cloud-eureka-server7001              | Eureka服务端1                                   | 注册中心（EurekaServer）                         |
-| cloud-eureka-server7002              | Eureka服务端2                                   | 注册中心（EurekaServer）                         |
-| cloud-provider-consul-payment8006    | 服务方通过Consul注册服务                        | 注册中心（Consul）                               |
-| cloud-provider-payment8001           | 服务方通过Eureka注册服务                        | 注册中心（Euraka）                               |
-| cloud-provider-payment8002           | 服务方通过Eureka注册服务                        | 注册中心（Euraka）                               |
-| cloud-provider-zk-payment8004        | 服务方通过Zk注册服务                            | 注册中心（Zk）                                   |
-| cloud-provider-hystrix-payment8001   | 服务方通过Hystrix服务降级和熔断                 | 服务降级和熔断（Hystrix）、服务监控（Actuator）  |
-| cloud-consumer-feign-hystrix-order80 | 消费方消费方通过feign远程调用服务方带降级和服务 | 服务降级和熔断（Hystrix）、服务调用（Openfeign） |
-| cloud-consumer-hystrix-dashboard9001 | Hystrix监控仪表盘                               | 服务监控（Hystrix）                              |
-| cloud-gateway-gateway9527            | 网关服务GateWay                                 | 网关（GateWay）                                  |
-| cloud-config-center-3344             | 配置中心服务端                                  | 配置中心（Config-Server）、服务总线（BUS）       |
-| cloud-config-client-3355             | 配置中心客户端1                                 | 配置中心（Config）、服务总线（BUS）              |
-| cloud-config-client-3356             | 配置中心客户端1                                 | 配置中心（Config）、服务总线（BUS）              |
+| 项目名                               | 用途                                            | 所用技术                                                     |
+| ------------------------------------ | :---------------------------------------------- | ------------------------------------------------------------ |
+| cloud-api-commons                    | 公共代码部分（返回结果集、实体等）              | \                                                            |
+| cloud-consumer-consul-order80        | 消费方通过Consul调用服务方                      | 注册中心（Consul）、远程调用（RestTemplate）                 |
+| cloud-consumer-feign-order80         | 消费方通过feign远程调用服务方                   | 服务调用（Openfeign）、注册中心（EurekaClient）              |
+| cloud-consumer-order80               | 消费方通过Eureka调用服务方等示例                | 注册中心（Eureka）、远程调用（RestTemplate）、链路追踪（Sleuth） |
+| cloud-consumer-zk-order80            | 消费方通过Zk调用服务方                          | 注册中心（Zk）、远程调用（RestTemplate）                     |
+| cloud-eureka-server7001              | Eureka服务端1                                   | 注册中心（EurekaServer）                                     |
+| cloud-eureka-server7002              | Eureka服务端2                                   | 注册中心（EurekaServer）                                     |
+| cloud-provider-consul-payment8006    | 服务方通过Consul注册服务                        | 注册中心（Consul）                                           |
+| cloud-provider-payment8001           | 服务方通过Eureka注册服务                        | 注册中心（Euraka）、链路追踪（Sleuth）                       |
+| cloud-provider-payment8002           | 服务方通过Eureka注册服务                        | 注册中心（Euraka）                                           |
+| cloud-provider-zk-payment8004        | 服务方通过Zk注册服务                            | 注册中心（Zk）                                               |
+| cloud-provider-hystrix-payment8001   | 服务方通过Hystrix服务降级和熔断                 | 服务降级和熔断（Hystrix）、服务监控（Actuator）              |
+| cloud-consumer-feign-hystrix-order80 | 消费方消费方通过feign远程调用服务方带降级和服务 | 服务降级和熔断（Hystrix）、服务调用（Openfeign）             |
+| cloud-consumer-hystrix-dashboard9001 | Hystrix监控仪表盘                               | 服务监控（Hystrix）                                          |
+| cloud-gateway-gateway9527            | 网关服务GateWay                                 | 网关（GateWay）                                              |
+| cloud-config-center-3344             | 配置中心服务端                                  | 配置中心（Config-Server）、服务总线（BUS）                   |
+| cloud-config-client-3355             | 配置中心客户端1                                 | 配置中心（Config）、服务总线（BUS）                          |
+| cloud-config-client-3356             | 配置中心客户端1                                 | 配置中心（Config）、服务总线（BUS）                          |
+| cloud-stream-provider-rabbitmq8801   | 消息驱动发送方                                  | 消息驱动（Stream）                                           |
+| cloud-stream-provider-rabbitmq8802   | 消息驱动接受方1                                 | 消息驱动（Stream）                                           |
+| cloud-stream-consumer-rabbitmq8803   | 消息驱动接受方2                                 | 消息驱动（Stream）                                           |
 
 
 

cloud-consumer-order80/pom.xml

@@ -13,6 +13,12 @@
     <artifactId>cloud-consumer-order80</artifactId>
 
     <dependencies>
+        <!--链路监控包含了sleuth+zipkin-->
+        <!--服务端下载地址：https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-zipkin</artifactId>
+        </dependency>
         <!--引入eureka客户端eureka-client -->
         <dependency>
             <groupId>org.springframework.cloud</groupId>

cloud-consumer-order80/src/main/java/com/lcry/springcloud/config/ApplicationContextConfig.java

@@ -15,7 +15,7 @@ import org.springframework.web.client.RestTemplate;
 @Configuration
 public class ApplicationContextConfig {
     @Bean //相当于Spring中applicationContext.xml中<bean id="" class="">
-    //@LoadBalanced //使用此注解赋予RestTemplate负载均衡的能力，测试自定义算法注释掉
+    @LoadBalanced //使用此注解赋予RestTemplate负载均衡的能力，测试自定义算法注释掉
     public RestTemplate getRestTemplate() {
         return new RestTemplate();
     }

cloud-consumer-order80/src/main/java/com/lcry/springcloud/controller/OrderController.java

@@ -79,4 +79,11 @@ public class OrderController {
     }
 
 
+    //链路追踪sleuth+zipkin测试
+    @GetMapping("/consumer/payment/zipkin")
+    public String paymentZipkin() {
+        String result = restTemplate.getForObject(PAYMENT_URL + "/payment/zipkin", String.class);
+        return result;
+    }
+
 }

cloud-consumer-order80/src/main/resources/application.yml

@@ -4,6 +4,12 @@ server:
 spring:
   application:
     name: cloud-order-service
+  #链路监控配置，配置链路监控服务端地址
+  zipkin:
+    base-url: http://localhost:9411
+  sleuth:
+    sampler:
+      probability: 1 #采样率，0~1之间，1表示全部采集
 
 eureka:
   client:

cloud-provider-payment8001/pom.xml

@@ -13,6 +13,12 @@
     <artifactId>cloud-provider-payment8001</artifactId>
 
     <dependencies>
+        <!--链路监控包含了sleuth+zipkin-->
+        <!--服务端下载地址：https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-zipkin</artifactId>
+        </dependency>
         <!--引入eureka客户端eureka-client -->
         <dependency>
             <groupId>org.springframework.cloud</groupId>

cloud-provider-payment8001/src/main/java/com/lcry/springcloud/controller/PaymentController.java

@@ -98,4 +98,11 @@ public class PaymentController {
         }
         return serverPort;
     }
+
+
+    //链路追踪sleuth+zipkin测试
+    @GetMapping("/payment/zipkin")
+    public String paymentZipkin() {
+        return "paymentzipkin调用成功~ ，O(∩_∩)O哈哈~";
+    }
 }

cloud-provider-payment8001/src/main/resources/application.yml

@@ -4,6 +4,15 @@ server:
 spring:
   application:
     name: cloud-payment-service
+  #链路监控配置，配置链路监控服务端地址
+  zipkin:
+    base-url: http://localhost:9411
+  sleuth:
+    sampler:
+    #采样率值介于 0 到 1 之间，1 则表示全部采集
+    probability: 1
+
+  #数据源配置
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
     driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包

cloud-stream-consumer-rabbitmq8802/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>2020SpringCloud</artifactId>
+        <groupId>com.lcry</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <!--    cloud-stream 接受消息服务8802-->
+    <artifactId>cloud-stream-consumer-rabbitmq8802</artifactId>
+    <dependencies>
+        <!--      stream-rabbit  -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <!--基础配置-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/StreamMQMain8802.java

+package com.lcry.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+/**
+ * 消息接受方
+ */
+@SpringBootApplication
+@EnableEurekaClient
+public class StreamMQMain8802 {
+    public static void main(String[] args) {
+        SpringApplication.run(StreamMQMain8802.class, args);
+    }
+}

cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java

+package com.lcry.springcloud.controller;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.StreamListener;
+import org.springframework.cloud.stream.messaging.Sink;
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+
+
+@Component
+@EnableBinding(Sink.class)
+public class ReceiveMessageListenerController {
+    @Value("${server.port}")
+    private String serverPort;
+
+
+    @StreamListener(Sink.INPUT)  //固定的写法，对应yml配置的通道名称
+    public void input(Message<String> message) {
+        System.out.println("消费者1号,----->接受到的消息: " + message.getPayload() + "\t  port: " + serverPort);
+    }
+}

cloud-stream-consumer-rabbitmq8802/src/main/resources/application.yml

+server:
+  port: 8802
+
+spring:
+  application:
+    name: cloud-stream-consumer
+  cloud:
+      stream:
+        binders: # 在此处配置要绑定的rabbitmq的服务信息；
+          defaultRabbit: # 表示定义的名称，用于于binding整合
+            type: rabbit # 消息组件类型
+            environment: # 设置rabbitmq的相关的环境配置
+              spring:
+                rabbitmq:
+                  host: 192.168.179.150
+                  port: 5672
+                  username: admin
+                  password: admin
+        bindings: # 服务的整合处理
+          input: # 这个名字是一个通道的名称
+            destination: studyExchange # 表示要使用的Exchange名称定义
+            content-type: application/json # 设置消息类型，本次为对象json，如果是文本则设置“text/plain”
+            binder: defaultRabbit # 设置要绑定的消息服务的具体设置
+            group: receiveclientA  #分组避免重复消费和持久化问题
+
+eureka:
+  client: # 客户端进行Eureka注册的配置
+    service-url:
+      defaultZone: http://localhost:7001/eureka
+  instance:
+    lease-renewal-interval-in-seconds: 2 # 设置心跳的时间间隔（默认是30秒）
+    lease-expiration-duration-in-seconds: 5 # 如果现在超过了5秒的间隔（默认是90秒）
+    instance-id: cloud-stream-consumer8802  # 在信息列表时显示主机名称
+    prefer-ip-address: true     # 访问的路径变为IP地址
\ No newline at end of file

cloud-stream-consumer-rabbitmq8803/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>2020SpringCloud</artifactId>
+        <groupId>com.lcry</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <!--    cloud-stream 接受消息服务8803-->
+    <artifactId>cloud-stream-consumer-rabbitmq8803</artifactId>
+
+    <dependencies>
+        <!--      stream-rabbit  -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <!--基础配置-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/StreamMQMain8803.java

+package com.lcry.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+/**
+ * 消息接受方
+ */
+@SpringBootApplication
+@EnableEurekaClient
+public class StreamMQMain8803 {
+    public static void main(String[] args) {
+        SpringApplication.run(StreamMQMain8803.class, args);
+    }
+}

cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java

+package com.lcry.springcloud.controller;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.StreamListener;
+import org.springframework.cloud.stream.messaging.Sink;
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * @author lcry
+ */
+@Component
+@EnableBinding(Sink.class)
+public class ReceiveMessageListenerController {
+    @Value("${server.port}")
+    private String serverPort;
+
+
+    @StreamListener(Sink.INPUT)  //固定的写法，对应yml配置的通道名称
+    public void input(Message<String> message) {
+        System.out.println("消费者2号,----->接受到的消息: " + message.getPayload() + "\t  port: " + serverPort);
+    }
+}

cloud-stream-consumer-rabbitmq8803/src/main/resources/application.yml

+server:
+  port: 8803
+
+spring:
+  application:
+    name: cloud-stream-consumer
+  cloud:
+      stream:
+        binders: # 在此处配置要绑定的rabbitmq的服务信息；
+          defaultRabbit: # 表示定义的名称，用于于binding整合
+            type: rabbit # 消息组件类型
+            environment: # 设置rabbitmq的相关的环境配置
+              spring:
+                rabbitmq:
+                  host: 192.168.179.150
+                  port: 5672
+                  username: admin
+                  password: admin
+        bindings: # 服务的整合处理
+          input: # 这个名字是一个通道的名称
+            destination: studyExchange # 表示要使用的Exchange名称定义
+            content-type: application/json # 设置消息类型，本次为对象json，如果是文本则设置“text/plain”
+            binder: defaultRabbit # 设置要绑定的消息服务的具体设置
+            group: receiveclientA  #分组避免重复消费和持久化问题
+
+eureka:
+  client: # 客户端进行Eureka注册的配置
+    service-url:
+      defaultZone: http://localhost:7001/eureka
+  instance:
+    lease-renewal-interval-in-seconds: 2 # 设置心跳的时间间隔（默认是30秒）
+    lease-expiration-duration-in-seconds: 5 # 如果现在超过了5秒的间隔（默认是90秒）
+    instance-id: cloud-stream-consumer8803  # 在信息列表时显示主机名称
+    prefer-ip-address: true     # 访问的路径变为IP地址
\ No newline at end of file

cloud-stream-provider-rabbitmq8801/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>2020SpringCloud</artifactId>
+        <groupId>com.lcry</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <!--    cloud stream 生产者rabbitmq实现-->
+    <artifactId>cloud-stream-provider-rabbitmq8801</artifactId>
+    <dependencies>
+        <!--        引入stream-rabbit-->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <!--基础配置-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>
+

cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/StreamMQMain8801.java

+package com.lcry.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+
+@SpringBootApplication
+@EnableEurekaClient
+public class StreamMQMain8801 {
+    public static void main(String[] args) {
+        SpringApplication.run(StreamMQMain8801.class, args);
+    }
+}

cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/controller/SendMessageController.java

+package com.lcry.springcloud.controller;
+
+import com.lcry.springcloud.service.IMessageProvider;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+
+/**
+ * 消息发送者
+ */
+@RestController
+public class SendMessageController {
+    @Resource
+    private IMessageProvider messageProvider;
+
+    @GetMapping(value = "/sendMessage")
+    public String sendMessage() {
+        return messageProvider.send();
+    }
+
+}

cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/IMessageProvider.java

+package com.lcry.springcloud.service;
+
+/**
+ * @auther zzyy
+ * @create 2020-02-22 10:55
+ */
+public interface IMessageProvider
+{
+    public String send();
+}

cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/impl/MessageProviderImpl.java

+package com.lcry.springcloud.service.impl;
+
+import com.lcry.springcloud.service.IMessageProvider;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.messaging.Source;
+import org.springframework.integration.support.MessageBuilder;
+import org.springframework.messaging.MessageChannel;
+
+import javax.annotation.Resource;
+import java.util.UUID;
+
+/**
+ * //定义消息的推送管道
+ */
+@EnableBinding(Source.class) //定义消息的推送管道，生产者固定写法
+@Slf4j
+public class MessageProviderImpl implements IMessageProvider {
+    @Resource
+    private MessageChannel output; // 消息发送管道
+
+    @Override
+    public String send() {
+        String serial = UUID.randomUUID().toString();
+        output.send(MessageBuilder.withPayload(serial).build());
+        log.info(String.format("生成的流水号:{%s}", serial));
+        return serial;
+    }
+}

cloud-stream-provider-rabbitmq8801/src/main/resources/application.yml

+server:
+  port: 8801
+
+spring:
+  application:
+    name: cloud-stream-provider
+  cloud:
+      stream:
+        binders: # 在此处配置要绑定的rabbitmq的服务信息；
+          defaultRabbit: # 表示定义的名称，用于于binding整合
+            type: rabbit # 消息组件类型
+            environment: # 设置rabbitmq的相关的环境配置
+              spring:
+                rabbitmq:
+                  host: 192.168.179.150
+                  port: 5672
+                  username: admin
+                  password: admin
+        bindings: # 服务的整合处理
+          output: # 这个名字是一个通道的名称
+            destination: studyExchange # 表示要使用的Exchange名称定义
+            content-type: application/json # 设置消息类型，本次为json，文本则设置“text/plain”
+            binder: defaultRabbit # 设置要绑定的消息服务的具体设置
+
+eureka:
+  client: # 客户端进行Eureka注册的配置
+    service-url:
+      defaultZone: http://localhost:7001/eureka
+  instance:
+    lease-renewal-interval-in-seconds: 2 # 设置心跳的时间间隔（默认是30秒）
+    lease-expiration-duration-in-seconds: 5 # 如果现在超过了5秒的间隔（默认是90秒）
+    instance-id: cloud-stream-provider8801  # 在信息列表时显示主机名称
+    prefer-ip-address: true     # 访问的路径变为IP地址
+
+
+
+
+
+

pom.xml

@@ -26,6 +26,9 @@
         <module>cloud-config-center-3344</module>
         <module>cloud-config-client-3355</module>
         <module>cloud-config-client-3356</module>
+        <module>cloud-stream-provider-rabbitmq8801</module>
+        <module>cloud-stream-consumer-rabbitmq8802</module>
+        <module>cloud-stream-consumer-rabbitmq8803</module>
     </modules>
     <packaging>pom</packaging>