diff --git a/.gitignore b/.gitignore index b91e21329b36ba83f8ddf6bde99e411209042f5b..b7ec3808ad3263e034de9367b825c1f5a4b8e77c 100644 --- a/.gitignore +++ b/.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 diff --git a/README.md b/README.md index 00bd66d072e1391ffcaa6ba514b08a203d90ecbf..4c8af6340b5ff42fd3f3083e4d2cdae806dea147 100644 --- a/README.md +++ b/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） | diff --git a/cloud-consumer-order80/pom.xml b/cloud-consumer-order80/pom.xml index 696a5c7ff9295feb189b71e2b2d5713a000d5835..40089f50b92d83858175e8bed6c0b7bdd58872db 100644 --- a/cloud-consumer-order80/pom.xml +++ b/cloud-consumer-order80/pom.xml @@ -13,6 +13,12 @@ cloud-consumer-order80 + + + + org.springframework.cloud + spring-cloud-starter-zipkin + org.springframework.cloud diff --git a/cloud-consumer-order80/src/main/java/com/lcry/springcloud/config/ApplicationContextConfig.java b/cloud-consumer-order80/src/main/java/com/lcry/springcloud/config/ApplicationContextConfig.java index b4bfecde452b0cc95b3640a6f42a109966d6fbac..a3e808e5798e7e75a62bb2e92775ccf0aa14c36f 100644 --- a/cloud-consumer-order80/src/main/java/com/lcry/springcloud/config/ApplicationContextConfig.java +++ b/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中 - //@LoadBalanced //使用此注解赋予RestTemplate负载均衡的能力，测试自定义算法注释掉 + @LoadBalanced //使用此注解赋予RestTemplate负载均衡的能力，测试自定义算法注释掉 public RestTemplate getRestTemplate() { return new RestTemplate(); } diff --git a/cloud-consumer-order80/src/main/java/com/lcry/springcloud/controller/OrderController.java b/cloud-consumer-order80/src/main/java/com/lcry/springcloud/controller/OrderController.java index 800da7c937cbd1e335a4ef893ee8bd273e7500d2..8ec96dcff541b7f2a21c164aadeb9290691235bb 100644 --- a/cloud-consumer-order80/src/main/java/com/lcry/springcloud/controller/OrderController.java +++ b/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; + } + } diff --git a/cloud-consumer-order80/src/main/resources/application.yml b/cloud-consumer-order80/src/main/resources/application.yml index d102d923c0918f94a4a28ecb0fda38004dffa679..b0b6d1edc41241871a78e81fd8a56419edd41b82 100644 --- a/cloud-consumer-order80/src/main/resources/application.yml +++ b/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: diff --git a/cloud-provider-payment8001/pom.xml b/cloud-provider-payment8001/pom.xml index 50dd9d60e7806227c99083fa817f460e99542d25..9186ec1a6bfe8459bec7426c384cdd5ca8f1ae3b 100644 --- a/cloud-provider-payment8001/pom.xml +++ b/cloud-provider-payment8001/pom.xml @@ -13,6 +13,12 @@ cloud-provider-payment8001 + + + + org.springframework.cloud + spring-cloud-starter-zipkin + org.springframework.cloud diff --git a/cloud-provider-payment8001/src/main/java/com/lcry/springcloud/controller/PaymentController.java b/cloud-provider-payment8001/src/main/java/com/lcry/springcloud/controller/PaymentController.java index c05286e8051befee51d1256ec6a7870b647ff0e7..7d7c189ac6e48e8eddd3fc61added788b19b9721 100644 --- a/cloud-provider-payment8001/src/main/java/com/lcry/springcloud/controller/PaymentController.java +++ b/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哈哈~"; + } } diff --git a/cloud-provider-payment8001/src/main/resources/application.yml b/cloud-provider-payment8001/src/main/resources/application.yml index bc330b0d7fb93433e5174450b07462e8b4296f11..0a3d941aa313b20a151c96a5b14c8a48ed9e5dfa 100644 --- a/cloud-provider-payment8001/src/main/resources/application.yml +++ b/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驱动包 diff --git a/cloud-stream-consumer-rabbitmq8802/pom.xml b/cloud-stream-consumer-rabbitmq8802/pom.xml new file mode 100644 index 0000000000000000000000000000000000000000..16a1abbc3269990fa1d53cb51efc66a80e482228 --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8802/pom.xml @@ -0,0 +1,51 @@ + + + + 2020SpringCloud + com.lcry + 1.0-SNAPSHOT + + 4.0.0 + + + cloud-stream-consumer-rabbitmq8802 + + + + org.springframework.cloud + spring-cloud-starter-stream-rabbit + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + org.springframework.boot + spring-boot-starter-actuator + + + + org.springframework.boot + spring-boot-devtools + runtime + true + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + + diff --git a/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/StreamMQMain8802.java b/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/StreamMQMain8802.java new file mode 100644 index 0000000000000000000000000000000000000000..18fde2a25789a6dcf74992c150fd87817322064a --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/StreamMQMain8802.java @@ -0,0 +1,16 @@ +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); + } +} diff --git a/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java b/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java new file mode 100644 index 0000000000000000000000000000000000000000..4e2858e12d0deb6b92034dc10ce3d27e79b35eda --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8802/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java @@ -0,0 +1,22 @@ +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 message) { + System.out.println("消费者1号,----->接受到的消息: " + message.getPayload() + "\t port: " + serverPort); + } +} diff --git a/cloud-stream-consumer-rabbitmq8802/src/main/resources/application.yml b/cloud-stream-consumer-rabbitmq8802/src/main/resources/application.yml new file mode 100644 index 0000000000000000000000000000000000000000..4015b052789bd6f5913ed521067ba565bdfbba2b --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8802/src/main/resources/application.yml @@ -0,0 +1,34 @@ +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 diff --git a/cloud-stream-consumer-rabbitmq8803/pom.xml b/cloud-stream-consumer-rabbitmq8803/pom.xml new file mode 100644 index 0000000000000000000000000000000000000000..426890cfa67bb09a6746dd7a9861d2dfc8385917 --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8803/pom.xml @@ -0,0 +1,51 @@ + + + + 2020SpringCloud + com.lcry + 1.0-SNAPSHOT + + 4.0.0 + + cloud-stream-consumer-rabbitmq8803 + + + + + org.springframework.cloud + spring-cloud-starter-stream-rabbit + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + org.springframework.boot + spring-boot-starter-actuator + + + + org.springframework.boot + spring-boot-devtools + runtime + true + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + + diff --git a/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/StreamMQMain8803.java b/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/StreamMQMain8803.java new file mode 100644 index 0000000000000000000000000000000000000000..ecdd4b5d7cc3e2525d2982d9bfdac46cb29c7a77 --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/StreamMQMain8803.java @@ -0,0 +1,16 @@ +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); + } +} diff --git a/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java b/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java new file mode 100644 index 0000000000000000000000000000000000000000..5faa6dd66bab5b056800b545357f40570d425c12 --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8803/src/main/java/com/lcry/springcloud/controller/ReceiveMessageListenerController.java @@ -0,0 +1,25 @@ +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 message) { + System.out.println("消费者2号,----->接受到的消息: " + message.getPayload() + "\t port: " + serverPort); + } +} diff --git a/cloud-stream-consumer-rabbitmq8803/src/main/resources/application.yml b/cloud-stream-consumer-rabbitmq8803/src/main/resources/application.yml new file mode 100644 index 0000000000000000000000000000000000000000..487f25412446ce6c79e87f3c41e459c799d3c67a --- /dev/null +++ b/cloud-stream-consumer-rabbitmq8803/src/main/resources/application.yml @@ -0,0 +1,34 @@ +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 diff --git a/cloud-stream-provider-rabbitmq8801/pom.xml b/cloud-stream-provider-rabbitmq8801/pom.xml new file mode 100644 index 0000000000000000000000000000000000000000..c9b9f9aec08ed2476828c6959de31ba93949cd5f --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/pom.xml @@ -0,0 +1,52 @@ + + + + 2020SpringCloud + com.lcry + 1.0-SNAPSHOT + + 4.0.0 + + + cloud-stream-provider-rabbitmq8801 + + + + org.springframework.cloud + spring-cloud-starter-stream-rabbit + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter-actuator + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + + org.springframework.boot + spring-boot-devtools + runtime + true + + + org.projectlombok + lombok + true + + + org.springframework.boot + spring-boot-starter-test + test + + + + + diff --git a/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/StreamMQMain8801.java b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/StreamMQMain8801.java new file mode 100644 index 0000000000000000000000000000000000000000..973a105a3cbe3b8bdf2bf69d0c2e7d1f7977def1 --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/StreamMQMain8801.java @@ -0,0 +1,14 @@ +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); + } +} diff --git a/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/controller/SendMessageController.java b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/controller/SendMessageController.java new file mode 100644 index 0000000000000000000000000000000000000000..20f187977b92434740527e3a99ab901066cfb41a --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/controller/SendMessageController.java @@ -0,0 +1,23 @@ +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(); + } + +} diff --git a/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/IMessageProvider.java b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/IMessageProvider.java new file mode 100644 index 0000000000000000000000000000000000000000..4375d469d6f8532917099c8aad7ed26c37a32714 --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/IMessageProvider.java @@ -0,0 +1,10 @@ +package com.lcry.springcloud.service; + +/** + * @auther zzyy + * @create 2020-02-22 10:55 + */ +public interface IMessageProvider +{ + public String send(); +} diff --git a/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/impl/MessageProviderImpl.java b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/impl/MessageProviderImpl.java new file mode 100644 index 0000000000000000000000000000000000000000..61565ab093d261b06c4b106aecc20094227b6ad2 --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/src/main/java/com/lcry/springcloud/service/impl/MessageProviderImpl.java @@ -0,0 +1,29 @@ +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; + } +} diff --git a/cloud-stream-provider-rabbitmq8801/src/main/resources/application.yml b/cloud-stream-provider-rabbitmq8801/src/main/resources/application.yml new file mode 100644 index 0000000000000000000000000000000000000000..80483898697b4099f4f950baafbeb051352a1ec5 --- /dev/null +++ b/cloud-stream-provider-rabbitmq8801/src/main/resources/application.yml @@ -0,0 +1,39 @@ +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地址 + + + + + + diff --git a/pom.xml b/pom.xml index 87e87c33baf356c9e85b4cfca8ec61058436ea5c..1301413bff232958eec2b8dda5c755fbc690f821 100644 --- a/pom.xml +++ b/pom.xml @@ -26,6 +26,9 @@ cloud-config-center-3344 cloud-config-client-3355 cloud-config-client-3356 + cloud-stream-provider-rabbitmq8801 + cloud-stream-consumer-rabbitmq8802 + cloud-stream-consumer-rabbitmq8803 pom