From d1fdf736c99b3e509980a64d87638fcb3778c54d Mon Sep 17 00:00:00 2001
From: root <1019758997@qq.com>
Date: Sat, 28 Aug 2021 11:02:26 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E7=BC=96=E5=86=99=E7=9A=84?=
=?UTF-8?q?=E4=BB=A3=E7=A0=81=20Signed-off-by:=20root=20<1019758997@qq.com?=
=?UTF-8?q?>?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.idea/compiler.xml | 1 +
.idea/encodings.xml | 1 +
.idea/workspace.xml | 582 +++++++++++-------
cloud-config-center-3344/pom.xml | 1 +
.../springcloud/ConfigCenterMain3344.java | 4 +
.../src/main/resources/application.yml | 3 +-
.../target/classes/application.yml | 3 +-
.../springcloud/ConfigClientMain3366.java | 2 +-
.../target/classes/bootstrap.yml | 28 +
.../atguigu/springcloud/OrderFeignMain80.java | 4 +
.../service/PaymentFeignService.java | 3 +-
.../src/test/java/TestEquals.java | 9 +
.../src/test/java/Person.java | 29 +
.../src/test/java/StringTest.java | 19 +
.../src/test/java/Test2.java | 44 ++
.../src/test/java/Test3.java | 21 +
.../src/test/java/TestTransferValue.java | 28 +
.../cloud-stream-rabbitmq-provider8801.iml | 2 +
cloud-stream-rabbitmq-provider8801/pom.xml | 48 ++
.../atguigu/springcloud/StreamMQMain8801.java | 13 +
.../controller/SendMessageController.java | 19 +
.../springcloud/service/IMessageProvider.java | 5 +
.../service/impl/MessageProviderImpl.java | 23 +
.../src/main/resources/application.yml | 35 ++
.../target/classes/application.yml | 35 ++
pom.xml | 1 +
26 files changed, 752 insertions(+), 211 deletions(-)
create mode 100644 cloud-config-client-3366/target/classes/bootstrap.yml
create mode 100644 cloud-consumer-order80/src/test/java/TestEquals.java
create mode 100644 cloud-gateway-gateway9527/src/test/java/Person.java
create mode 100644 cloud-gateway-gateway9527/src/test/java/StringTest.java
create mode 100644 cloud-gateway-gateway9527/src/test/java/Test2.java
create mode 100644 cloud-gateway-gateway9527/src/test/java/Test3.java
create mode 100644 cloud-gateway-gateway9527/src/test/java/TestTransferValue.java
create mode 100644 cloud-stream-rabbitmq-provider8801/cloud-stream-rabbitmq-provider8801.iml
create mode 100644 cloud-stream-rabbitmq-provider8801/pom.xml
create mode 100644 cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/StreamMQMain8801.java
create mode 100644 cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/controller/SendMessageController.java
create mode 100644 cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/IMessageProvider.java
create mode 100644 cloud-stream-rabbitmq-provider8801/src/main/java/com/atguigu/springcloud/service/impl/MessageProviderImpl.java
create mode 100644 cloud-stream-rabbitmq-provider8801/src/main/resources/application.yml
create mode 100644 cloud-stream-rabbitmq-provider8801/target/classes/application.yml
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 98fd433..78b4474 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -25,6 +25,7 @@
+
diff --git a/.idea/encodings.xml b/.idea/encodings.xml
index b785667..be0a86f 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 ee819d7..2f99f33 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 a402bca..25ecaad 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 a721cc8..ea176a6 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 7f6dd5f..1749cba 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 7f6dd5f..1749cba 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 f3d66fb..2b0adae 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 0000000..5026c48
--- /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 9ef0629..d1e0aa0 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 84be372..f894eee 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 0000000..2a38885
--- /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 0000000..9014906
--- /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 0000000..57660fd
--- /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 0000000..bb63ad6
--- /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 0000000..ba5703d
--- /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 0000000..f65fded
--- /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 0000000..78b2cc5
--- /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 0000000..763979a
--- /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 0000000..178a491
--- /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 0000000..e87f182
--- /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 0000000..e6b7cce
--- /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 0000000..59882ce
--- /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 0000000..7de7ad1
--- /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 0000000..7de7ad1
--- /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 d1f2c78..f0c8b05 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
--
Gitee