diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 98fd4332df8c29f675d80062cc666ca461b7d3d9..78b4474483d4319ccd1e660d5291339040e942e9 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -25,6 +25,7 @@
+
diff --git a/.idea/encodings.xml b/.idea/encodings.xml
index b7856674a9f4fe7255ea8f167a7ac3335f9c3469..be0a86f952131ac33cc1f2da2d6f01458d8f7c2e 100644
--- a/.idea/encodings.xml
+++ b/.idea/encodings.xml
@@ -20,6 +20,7 @@
+
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index ee819d789fea16984cb2ca70e39e3fc2ffd1d00a..2f99f3304f85e5a7c7ee9e7135e7a49f9309bec6 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -26,6 +26,7 @@
+
@@ -52,7 +53,63 @@
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
@@ -134,7 +193,7 @@
-
-
+
+
@@ -166,9 +225,6 @@
-
-
-
@@ -176,10 +232,76 @@
+
@@ -430,12 +539,19 @@
-
+
+
+
+
+
+
+
+
-
+
@@ -450,7 +566,7 @@
-
+
@@ -461,17 +577,18 @@
+
-
+
-
+
-
+
-
-
+
+
@@ -479,11 +596,46 @@
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
@@ -497,344 +649,360 @@
-
+
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
+
+
+
-
+
-
-
+
+
-
+
-
+
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
+
+
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
-
-
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
-
+
-
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
+
+
+
+
+
+
+
-
+
-
+
-
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
-
+
-
-
-
-
-
-
+
+
-
+
-
-
+
+
-
+
-
-
+
+
+
+
+
+
+
-
+
-
-
+
+
-
+
-
-
+
+
+
+
+
+
+
diff --git a/cloud-config-center-3344/pom.xml b/cloud-config-center-3344/pom.xml
index a402bca098e3daeceafe07e9fb0c93188ec2f0b4..25ecaade2f92cfe33f13ebadc943dcc53c00ebb5 100644
--- a/cloud-config-center-3344/pom.xml
+++ b/cloud-config-center-3344/pom.xml
@@ -25,6 +25,7 @@
spring-cloud-starter-netflix-eureka-client
+
org.springframework.boot
spring-boot-starter-actuator
diff --git a/cloud-config-center-3344/src/main/java/com/aiguigu/springcloud/ConfigCenterMain3344.java b/cloud-config-center-3344/src/main/java/com/aiguigu/springcloud/ConfigCenterMain3344.java
index a721cc85c7cbc42ae069f8e51700aea3f10cfe0a..ea176a691ba6b8f3f313ba1121bba5b72c672925 100644
--- a/cloud-config-center-3344/src/main/java/com/aiguigu/springcloud/ConfigCenterMain3344.java
+++ b/cloud-config-center-3344/src/main/java/com/aiguigu/springcloud/ConfigCenterMain3344.java
@@ -13,5 +13,9 @@ public class ConfigCenterMain3344 {
//这里已经将windows的hosts配置了映射
//启动7001和3344，访问http://config-3344.com:3344/master/config-dev.yml
SpringApplication.run(ConfigCenterMain3344.class, args);
+
+ //通过访问curl -X POST "http://localhost:3344/actuator/bus-refresh"实现3344广播通知3355、3366
+ //bus-refresh为bootstrap.yml中配置的bus暴露点
+ //通过curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355实现定点通知3355
}
}
\ No newline at end of file
diff --git a/cloud-config-center-3344/src/main/resources/application.yml b/cloud-config-center-3344/src/main/resources/application.yml
index 7f6dd5f954b818de35121f31a0d5880a209acdf2..1749cba8ddb3a18391e3ea4889eedb288cec4816 100644
--- a/cloud-config-center-3344/src/main/resources/application.yml
+++ b/cloud-config-center-3344/src/main/resources/application.yml
@@ -28,4 +28,5 @@ management:
endpoints: #暴露bus刷新配置的端点
web:
exposure:
- include: "bus-refresh"
\ No newline at end of file
+ include: "bus-refresh"
+ #通过访问curl -X POST "http://localhost:3344/actuator/bus-refresh"实现3344广播通知3355、3366
\ No newline at end of file
diff --git a/cloud-config-center-3344/target/classes/application.yml b/cloud-config-center-3344/target/classes/application.yml
index 7f6dd5f954b818de35121f31a0d5880a209acdf2..1749cba8ddb3a18391e3ea4889eedb288cec4816 100644
--- a/cloud-config-center-3344/target/classes/application.yml
+++ b/cloud-config-center-3344/target/classes/application.yml
@@ -28,4 +28,5 @@ management:
endpoints: #暴露bus刷新配置的端点
web:
exposure:
- include: "bus-refresh"
\ No newline at end of file
+ include: "bus-refresh"
+ #通过访问curl -X POST "http://localhost:3344/actuator/bus-refresh"实现3344广播通知3355、3366
\ No newline at end of file
diff --git a/cloud-config-client-3366/src/main/java/com/atguigu/springcloud/ConfigClientMain3366.java b/cloud-config-client-3366/src/main/java/com/atguigu/springcloud/ConfigClientMain3366.java
index f3d66fb8b839cd0128ebe9371341553b75f090a0..2b0adae2b390508e263e851c9217a482310211f7 100644
--- a/cloud-config-client-3366/src/main/java/com/atguigu/springcloud/ConfigClientMain3366.java
+++ b/cloud-config-client-3366/src/main/java/com/atguigu/springcloud/ConfigClientMain3366.java
@@ -18,7 +18,7 @@ public class ConfigClientMain3366 {
*/
//利用消息总线，触发一个服务器端ConfigServer的bus/refresh端点，而刷新所有客户端的配置，总的来说就是：实现自动刷新配置功能
- //用3344通知3355、3366
+ //用3344作为Server,通知3355、3366两个Client
public static void main(String[] args) {
SpringApplication.run(ConfigClientMain3366.class, args);
}
diff --git a/cloud-config-client-3366/target/classes/bootstrap.yml b/cloud-config-client-3366/target/classes/bootstrap.yml
new file mode 100644
index 0000000000000000000000000000000000000000..5026c480d09501b0c393d901822f54d19db85e1c
--- /dev/null
+++ b/cloud-config-client-3366/target/classes/bootstrap.yml
@@ -0,0 +1,28 @@
+server:
+ port: 3366
+
+spring:
+ application:
+ name: config-client
+ cloud:
+ config:
+ label: master
+ name: config
+ profile: dev
+ uri: http://localhost:3344
+ #15672是管理界面端口，5672是MQ访问的端口
+ rabbitmq:
+ host: localhost
+ port: 5672
+ username: guest
+ password: guest
+eureka:
+ client:
+ service-url:
+ defaultZone: http://localhost:7001/eureka
+# 暴露监控端点
+management:
+ endpoints:
+ web:
+ exposure:
+ include: "*"
\ No newline at end of file
diff --git a/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/OrderFeignMain80.java b/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/OrderFeignMain80.java
index 9ef0629132c3d4dcbebf7e3c78599a60a0666111..d1e0aa06744a7f985d9e765f64b85a2b484a7fa9 100644
--- a/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/OrderFeignMain80.java
+++ b/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/OrderFeignMain80.java
@@ -8,6 +8,10 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
@EnableFeignClients
public class OrderFeignMain80 {
public static void main(String[] args) {
+ /*Feign是一个声明式WebService客户端，使用feign能让编写WebService客户端更加简单，
+ *使用方式-定义一个服务接口然后在上面添加注解
+ * Feign可以与Eureka和Ribbon结合使用以支持负载均衡
+ */
SpringApplication.run(OrderFeignMain80.class,args);
}
}
diff --git a/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/service/PaymentFeignService.java b/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/service/PaymentFeignService.java
index 84be372758342f7958f1337790cd5482ec24d869..f894eeea024ec6e6e723db575de335f2f67dea13 100644
--- a/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/service/PaymentFeignService.java
+++ b/cloud-consumer-feign-order80/src/main/java/com/atguigu/springcloud/service/PaymentFeignService.java
@@ -8,7 +8,8 @@ import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@Component
-@FeignClient(value = "CLOUD-PAYMENT-SERVICE")
+@FeignClient(value = "CLOUD-PAYMENT-SERVICE") //8001微服务名称
+//使用方式：微服务调用接口+注解 即->提供方8001微服务调用接口PaymentService+@FeignClient
public interface PaymentFeignService {
@GetMapping("/payment/get/{id}")
diff --git a/cloud-consumer-order80/src/test/java/TestEquals.java b/cloud-consumer-order80/src/test/java/TestEquals.java
new file mode 100644
index 0000000000000000000000000000000000000000..2a3888563d68702f5964a01e09ba3359b97a28c7
--- /dev/null
+++ b/cloud-consumer-order80/src/test/java/TestEquals.java
@@ -0,0 +1,9 @@
+public class TestEquals {
+ public static void main(String[] args) {
+ String s1 = new String("123");
+ String s2 = new String("123");
+ System.out.println(s1 == s2);
+ System.out.println(s1.equals(s2));
+
+ }
+}
diff --git a/cloud-gateway-gateway9527/src/test/java/Person.java b/cloud-gateway-gateway9527/src/test/java/Person.java
new file mode 100644
index 0000000000000000000000000000000000000000..9014906ed42abdbea54db0d4a75dd7d43fe9af8a
--- /dev/null
+++ b/cloud-gateway-gateway9527/src/test/java/Person.java
@@ -0,0 +1,29 @@
+public class Person {
+ Integer id;
+ String name;
+
+ public Person(String name) {
+ this.name = name;
+ }
+
+ public Integer getId() {
+ return id;
+ }
+
+ public void setId(Integer id) {
+ this.id = id;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public Person(Integer id, String name) {
+ this.id = id;
+ this.name = name;
+ }
+}
diff --git a/cloud-gateway-gateway9527/src/test/java/StringTest.java b/cloud-gateway-gateway9527/src/test/java/StringTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..57660fd5b3625dea692bbdfc6658129c797743c7
--- /dev/null
+++ b/cloud-gateway-gateway9527/src/test/java/StringTest.java
@@ -0,0 +1,19 @@
+public class StringTest {
+ public static void main(String[] args) {
+ String str1=new String("666");//执行完这行代码后，常量池中会有"java"和"虚拟机"，但是不会有"java虚拟机"。
+ String intern1 = str1.intern();
+ String poolsStr1 = "666";
+ System.out.println("str1堆上字符串 与 intern1的字符串："+str1 == intern1);
+ System.out.println("str1常量池字符串 与 intern1的字符串："+poolsStr1 == intern1);
+ System.out.println("str1常量池字符串 与 str1堆上字符串："+poolsStr1 == str1);
+
+ System.out.println("--------------------------------------------------------");
+
+ String str2=new String("zhangsan")+new String("feng");//执行完这行代码后，常量池中会有"java"和"虚拟机"，但是不会有"java虚拟机"。
+ String intern2 = str2.intern();
+ String poolsStr2 = "zhangsanfeng";
+ System.out.println("str2堆上字符串 与 intern2的字符串："+str2 == intern2);
+ System.out.println("str2常量池字符串 与 intern2的字符串："+poolsStr2 == intern2);
+ System.out.println("str2常量池字符串 与 str2堆上字符串："+poolsStr2 == str2);
+ }
+}
diff --git a/cloud-gateway-gateway9527/src/test/java/Test2.java b/cloud-gateway-gateway9527/src/test/java/Test2.java
new file mode 100644
index 0000000000000000000000000000000000000000..bb63ad66f3be22e871a5df8829697c2ba5ec036c
--- /dev/null
+++ b/cloud-gateway-gateway9527/src/test/java/Test2.java
@@ -0,0 +1,44 @@
+import java.util.HashSet;
+import java.util.Set;
+
+public class Test2 {
+ public void changeValue1(int age){
+ age = 30;
+ }
+ public void changeValue2(Person person){
+ person.setName("zhangsanfeng");
+ }
+ public void changeValue3(String str){
+ str = "zhangsanfeng";
+ }
+ public static void main(String[] args) {
+
+ String s1 = new String("123");
+ String s2 = new String("123");
+ System.out.println(s1 == s2);//false
+ System.out.println(s1.equals(s2));//true
+
+ Set set1 = new HashSet();
+ set1.add(s1);
+ set1.add(s2);
+ System.out.println(s1.hashCode()+"\t"+s2.hashCode());
+ System.out.println(set1.size());//1
+ System.out.println("**************************************************");
+ Person p1 = new Person("zhangsanfeng");
+ Person p2 = new Person("zhangsanfeng");
+ System.out.println(p1 == p2);//false
+ System.out.println(p1.equals(p2));//false
+ Set set2 = new HashSet();
+ set2.add(p1);
+ set2.add(p2);
+ System.out.println(p1.hashCode()+"\t"+p2.hashCode());
+ System.out.println(set2.size());//2
+
+ /*
+ Test2 test2 = new Test2();
+ int age = 10;
+ test2.changeValue1(age);
+ System.out.println("age ----->"+age);
+*/
+ }
+}
diff --git a/cloud-gateway-gateway9527/src/test/java/Test3.java b/cloud-gateway-gateway9527/src/test/java/Test3.java
new file mode 100644
index 0000000000000000000000000000000000000000..ba5703d29a3701af699692d2bf11089767ee3a3c
--- /dev/null
+++ b/cloud-gateway-gateway9527/src/test/java/Test3.java
@@ -0,0 +1,21 @@
+public class Test3 {
+ public void changeValue1(int age){
+ age = 30;
+ }
+ public void changeValue2(Person person){
+ person.setName("zhangsanfeng");
+ }
+ public void changeValue3(String str){
+ str = "zhangsanfeng";
+ }
+
+ public static void main(String[] args) {
+ Test3 test3 = new Test3();
+ int age = 10;
+ test3.changeValue1(age);
+ System.out.println("age ----->"+age);
+
+ Person person = new Person("lisi");
+ }
+
+}
diff --git a/cloud-gateway-gateway9527/src/test/java/TestTransferValue.java b/cloud-gateway-gateway9527/src/test/java/TestTransferValue.java
new file mode 100644
index 0000000000000000000000000000000000000000..f65fded514b0c3a2bc0cce45a55b460a995fd331
--- /dev/null
+++ b/cloud-gateway-gateway9527/src/test/java/TestTransferValue.java
@@ -0,0 +1,28 @@
+public class TestTransferValue {
+ public void changeValue1(int age) {
+ age = 30;
+ }
+
+ public void changeValue2(Person person) {
+ person.setName("XXX");
+ }
+
+ public void changeValue3(String str) {
+ str = "XXX";
+ }
+
+ public static void main(String[] args) {
+ final TestTransferValue testTransferValue = new TestTransferValue();
+ int age = 20;
+ testTransferValue.changeValue1(age);
+ System.out.println("age------------" + age);
+
+ final Person person = new Person("abc");
+ testTransferValue.changeValue2(person);
+ System.out.println("person------" + person.getName());
+
+ String str = "abc";
+ testTransferValue.changeValue3(str);
+ System.out.println("person------" + str);
+ }
+}
diff --git a/cloud-stream-rabbitmq-provider8801/cloud-stream-rabbitmq-provider8801.iml b/cloud-stream-rabbitmq-provider8801/cloud-stream-rabbitmq-provider8801.iml
new file mode 100644
index 0000000000000000000000000000000000000000..78b2cc53b203f0b97534bb1184cdc7b474339fb4
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/cloud-stream-rabbitmq-provider8801.iml
@@ -0,0 +1,2 @@
+
+
\ No newline at end of file
diff --git a/cloud-stream-rabbitmq-provider8801/pom.xml b/cloud-stream-rabbitmq-provider8801/pom.xml
new file mode 100644
index 0000000000000000000000000000000000000000..763979a07b0ac936d304fd6423e54f9fa66aa4fe
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/pom.xml
@@ -0,0 +1,48 @@
+
+
+
+ springcloud2021
+ com.atguigu.springcloud
+ 1.0-SNAPSHOT
+
+ 4.0.0
+
+ cloud-stream-rabbitmq-provider8801
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.springframework.cloud
+ spring-cloud-starter-netflix-eureka-client
+
+
+ org.springframework.cloud
+ spring-cloud-starter-stream-rabbit
+
+
+ org.springframework.boot
+ spring-boot-starter-actuator
+
+
+ org.springframework.boot
+ spring-boot-devtools
+ runtime
+ true
+
+
+ com.atguigu.springcloud
+ cloud-api-commons
+ 1.0-SNAPSHOT
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+
+
\ No newline at end of file
diff --git a/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/StreamMQMain8801.java b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/StreamMQMain8801.java
new file mode 100644
index 0000000000000000000000000000000000000000..178a4915e78289733a4f65c5870e9a3840d97ed0
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/StreamMQMain8801.java
@@ -0,0 +1,13 @@
+package com.atguigu.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class StreamMQMain8801 {
+ //1.先启动7001 2.再启动8801，连续多次访问http://localhost:8801/sendMessage
+ //查看http://localhost:15672下的Exchanges绑定的交换机信息
+ public static void main(String[] args) {
+ SpringApplication.run(StreamMQMain8801.class,args);
+ }
+}
diff --git a/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/controller/SendMessageController.java b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/controller/SendMessageController.java
new file mode 100644
index 0000000000000000000000000000000000000000..e87f18221d5853385281fab94ecde1130fea2575
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/controller/SendMessageController.java
@@ -0,0 +1,19 @@
+package com.atguigu.springcloud.controller;
+
+import com.atguigu.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("/sendMessage")
+ public String sendMessage(){
+ return messageProvider.send();
+ }
+
+}
+
diff --git a/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/IMessageProvider.java b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/IMessageProvider.java
new file mode 100644
index 0000000000000000000000000000000000000000..e6b7cceb4a779e4d7e3c0faeae34292b96e1abfc
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/IMessageProvider.java
@@ -0,0 +1,5 @@
+package com.atguigu.springcloud.service;
+
+public interface IMessageProvider {
+ String send();//消息发送接口
+}
diff --git a/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/impl/MessageProviderImpl.java b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/impl/MessageProviderImpl.java
new file mode 100644
index 0000000000000000000000000000000000000000..59882cec96ee3fa98a42cc58d8fbd85dd7c4f8f4
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/impl/MessageProviderImpl.java
@@ -0,0 +1,23 @@
+package com.atguigu.springcloud.service.impl;
+
+import com.atguigu.springcloud.service.IMessageProvider;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.messaging.Source;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.support.MessageBuilder;
+import javax.annotation.Resource;
+import java.util.UUID;
+
+@EnableBinding(Source.class)//定义消息的推送广告,此注解指信道channel和exchange绑定在一起
+public class MessageProviderImpl implements IMessageProvider {
+ @Resource
+ private MessageChannel output; //消息发送管道
+
+ @Override
+ public String send() {
+ String serial = UUID.randomUUID().toString();
+ output.send(MessageBuilder.withPayload(serial).build());
+ System.out.println("*****serial: " +serial);
+ return null;
+ }
+}
diff --git a/cloud-stream-rabbitmq-provider8801/src/main/resources/application.yml b/cloud-stream-rabbitmq-provider8801/src/main/resources/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..7de7ad19bb35b22dd163fbb16e9df4622218faaa
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/src/main/resources/application.yml
@@ -0,0 +1,35 @@
+server:
+ port: 8801
+spring:
+ application:
+ name: cloud-stream-provider
+ cloud:
+ stream:
+ binders: #需要绑定的rabbitmq的服务信息
+ defaultRabbit: #定义的名称，用于binding整合
+ type: rabbit #消息组件类型
+ environment: #环境配置
+ spring:
+ rabbitmq:
+ host: localhost
+ port: 5672
+ username: guest
+ password: guest
+ bindings: # 服务的整合处理
+ output: # 名字是一个通道的名称
+ destination: studyExchange # 表示要使用的Exchange名称定义
+ content-type: application/json # 设置消息类型，本次为json
+ binder: defaultRabbit #设置要绑定的消息服务的具体设置
+eureka:
+ client:
+ service-url:
+ defaultZone: http://localhost:7001/eureka
+ instance:
+ #renewal表示eureka client向eureka server发送心跳的频率，如果在指定时间内未收到心跳，则移除实例
+ lease-renewal-interval-in-seconds: 2 #设置心跳时间间隔，默认30秒
+ #expiration表示eureka server获取上一个心跳之后，等待下一个心跳的秒数，默认90S
+ #若不能在指定时间间隔内接收到实例，则移除此实例，并禁止此实例的流量
+ lease-expiration-duration-in-seconds: 5 #设置接收时间间隔
+
+ instance-id: send-8801.com
+ prefer-ip-address: true
\ No newline at end of file
diff --git a/cloud-stream-rabbitmq-provider8801/target/classes/application.yml b/cloud-stream-rabbitmq-provider8801/target/classes/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..7de7ad19bb35b22dd163fbb16e9df4622218faaa
--- /dev/null
+++ b/cloud-stream-rabbitmq-provider8801/target/classes/application.yml
@@ -0,0 +1,35 @@
+server:
+ port: 8801
+spring:
+ application:
+ name: cloud-stream-provider
+ cloud:
+ stream:
+ binders: #需要绑定的rabbitmq的服务信息
+ defaultRabbit: #定义的名称，用于binding整合
+ type: rabbit #消息组件类型
+ environment: #环境配置
+ spring:
+ rabbitmq:
+ host: localhost
+ port: 5672
+ username: guest
+ password: guest
+ bindings: # 服务的整合处理
+ output: # 名字是一个通道的名称
+ destination: studyExchange # 表示要使用的Exchange名称定义
+ content-type: application/json # 设置消息类型，本次为json
+ binder: defaultRabbit #设置要绑定的消息服务的具体设置
+eureka:
+ client:
+ service-url:
+ defaultZone: http://localhost:7001/eureka
+ instance:
+ #renewal表示eureka client向eureka server发送心跳的频率，如果在指定时间内未收到心跳，则移除实例
+ lease-renewal-interval-in-seconds: 2 #设置心跳时间间隔，默认30秒
+ #expiration表示eureka server获取上一个心跳之后，等待下一个心跳的秒数，默认90S
+ #若不能在指定时间间隔内接收到实例，则移除此实例，并禁止此实例的流量
+ lease-expiration-duration-in-seconds: 5 #设置接收时间间隔
+
+ instance-id: send-8801.com
+ prefer-ip-address: true
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index d1f2c78272f9a525c38f5ecb096bfdf54ec40559..f0c8b051bbbdadeebd81af14e43d3c0b715aac2a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -30,6 +30,7 @@
cloud-config-center-3344
cloud-config-client-3355
cloud-config-client-3366
+ cloud-stream-rabbitmq-provider8801