lywsvip/SpringBoot-Labs
1
0
Fork 0
mirror of https://gitee.com/yudaocode/SpringBoot-Labs.git synced 2026-09-03 13:57:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加 spring cloud bus rocketmq 示例

Browse Source
This commit is contained in:
YunaiV
2020-04-09 09:11:06 +08:00
parent d9cfd3c515
commit cf5d92c90f
11 changed files with 41 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
labx-20/labx-19-sc-bus-kafka-demo-listener-actuator/pom.xml → labx-20/labx-20-sca-bus-rocketmq-demo-listener-actuator/pom.xml
View File

@@ -16,6 +16,7 @@
<maven.compiler.source>1.8</maven.compiler.source>
<spring.boot.version>2.2.4.RELEASE</spring.boot.version>
<spring.cloud.version>Hoxton.SR1</spring.cloud.version>
<spring.cloud.alibaba.version>2.2.0.RELEASE</spring.cloud.alibaba.version>
</properties>
<!--
@@ -38,6 +39,13 @@
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring.cloud.alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
@@ -48,9 +56,9 @@
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 引入基于 Kafka 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
<!-- 引入基于 RocketMQ 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-bus-rocketmq</artifactId>
</dependency>

2
labx-20/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/ListenerDemoApplication.java → labx-20/labx-20-sca-bus-rocketmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/listenerdemo/ListenerDemoApplication.java
View File

@@ -1,4 +1,4 @@
package cn.iocoder.springcloud.labx19.listenerdemo;
package cn.iocoder.springcloudalibaba.labx20.listenerdemo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

2
labx-20/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/event/UserRegisterEvent.java → labx-20/labx-20-sca-bus-rocketmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/listenerdemo/event/UserRegisterEvent.java
View File

@@ -1,4 +1,4 @@
package cn.iocoder.springcloud.labx19.publisherdemo.event;
package cn.iocoder.springcloudalibaba.labx20.listenerdemo.event;
import org.springframework.cloud.bus.event.RemoteApplicationEvent;

4
labx-20/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/listener/UserRegisterListener.java → labx-20/labx-20-sca-bus-rocketmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/listenerdemo/listener/UserRegisterListener.java
View File

@@ -1,6 +1,6 @@
package cn.iocoder.springcloud.labx19.listenerdemo.listener;
package cn.iocoder.springcloudalibaba.labx20.listenerdemo.listener;
import cn.iocoder.springcloud.labx19.listenerdemo.event.UserRegisterEvent;
import cn.iocoder.springcloudalibaba.labx20.listenerdemo.event.UserRegisterEvent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationListener;

8
labx-20/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/resources/application.yml → labx-20/labx-20-sca-bus-rocketmq-demo-listener-actuator/src/main/resources/application.yml
View File

@@ -2,13 +2,13 @@ spring:
application:
name: listener-demo
# Kafka 配置项，对应 KafkaProperties 配置类
rocketmq:
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址，可以设置多个，以逗号分隔
server:
port: 18080 # 随机端口，方便启动多个消费者
# rocketmq 配置项，对应 RocketMQProperties 配置类
rocketmq:
name-server: 127.0.0.1:9876 # RocketMQ Namesrv
management:
endpoints:
# Actuator HTTP 配置项，对应 WebEndpointProperties 配置类

12
labx-20/labx-19-sc-bus-kafka-demo-publisher-actuator/pom.xml → labx-20/labx-20-sca-bus-rocketmq-demo-publisher-actuator/pom.xml
View File

@@ -16,6 +16,7 @@
<maven.compiler.source>1.8</maven.compiler.source>
<spring.boot.version>2.2.4.RELEASE</spring.boot.version>
<spring.cloud.version>Hoxton.SR1</spring.cloud.version>
<spring.cloud.alibaba.version>2.2.0.RELEASE</spring.cloud.alibaba.version>
</properties>
<!--
@@ -38,6 +39,13 @@
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring.cloud.alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
@@ -48,9 +56,9 @@
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 引入基于 Kafka 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
<!-- 引入基于 RocketMQ 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-bus-rocketmq</artifactId>
</dependency>

2
labx-20/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/PublisherDemoApplication.java → labx-20/labx-20-sca-bus-rocketmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/publisherdemo/PublisherDemoApplication.java
View File

@@ -1,4 +1,4 @@
package cn.iocoder.springcloud.labx19.publisherdemo;
package cn.iocoder.springcloudalibaba.labx20.publisherdemo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

4
labx-20/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java → labx-20/labx-20-sca-bus-rocketmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/publisherdemo/controller/DemoController.java
View File

@@ -1,6 +1,6 @@
package cn.iocoder.springcloud.labx19.publisherdemo.controller;
package cn.iocoder.springcloudalibaba.labx20.publisherdemo.controller;
import cn.iocoder.springcloud.labx19.publisherdemo.event.UserRegisterEvent;
import cn.iocoder.springcloudalibaba.labx20.publisherdemo.event.UserRegisterEvent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

2
labx-20/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/event/UserRegisterEvent.java → labx-20/labx-20-sca-bus-rocketmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloudalibaba/labx20/publisherdemo/event/UserRegisterEvent.java
View File

@@ -1,4 +1,4 @@
package cn.iocoder.springcloud.labx19.listenerdemo.event;
package cn.iocoder.springcloudalibaba.labx20.publisherdemo.event;
import org.springframework.cloud.bus.event.RemoteApplicationEvent;

9
labx-20/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/resources/application.yml → labx-20/labx-20-sca-bus-rocketmq-demo-publisher-actuator/src/main/resources/application.yml
View File

@@ -1,10 +1,13 @@
server:
port: 8081
spring:
application:
name: publisher-demo
# Kafka 配置项，对应 KafkaProperties 配置类
rocketmq:
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址，可以设置多个，以逗号分隔
# rocketmq 配置项，对应 RocketMQProperties 配置类
rocketmq:
name-server: 127.0.0.1:9876 # RocketMQ Namesrv
management:
endpoints:

3
labx-20/pom.xml
View File

@@ -14,6 +14,9 @@
<modules>
<module>labx-20-sca-bus-rocketmq-demo-publisher</module>
<module>labx-20-sca-bus-rocketmq-demo-listener</module>
<module>labx-20-sca-bus-rocketmq-demo-publisher-actuator</module>
<module>labx-20-sca-bus-rocketmq-demo-listener-actuator</module>
</modules>
</project>