Skip to content

Commit 29b95e0

Browse files
salesonsaleson
committed
demo
1 parent f4e484f commit 29b95e0

File tree

3 files changed

+61
-46
lines changed

3 files changed

+61
-46
lines changed

‎spring-cloud-gray-samples/spring-cloud-gray-server-sample/pom.xml‎

Lines changed: 22 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -34,27 +34,37 @@
3434
<dependency>
3535
<groupId>cn.springcloud.gray</groupId>
3636
<artifactId>spring-cloud-starter-gray-server</artifactId>
37+
<!-- <exclusions>-->
38+
<!-- <exclusion>-->
39+
<!-- <artifactId>spring-cloud-gray-server-plugin-event-longpolling</artifactId>-->
40+
<!-- <groupId>cn.springcloud.gray</groupId>-->
41+
<!-- </exclusion>-->
42+
<!-- </exclusions>-->
3743
</dependency>
3844
<dependency>
3945
<groupId>cn.springcloud.gray</groupId>
4046
<artifactId>spring-cloud-gray-server-plugin-eureka</artifactId>
4147
</dependency>
4248

4349
<!-- nacos -->
44-
<!-- <dependency>-->
45-
<!-- <groupId>cn.springcloud.gray</groupId>-->
46-
<!-- <artifactId>spring-cloud-gray-server-plugin-nacos-discovery</artifactId>-->
47-
<!-- </dependency>-->
48-
<!-- <dependency>-->
49-
<!-- <groupId>com.alibaba.cloud</groupId>-->
50-
<!-- <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>-->
51-
<!-- </dependency>-->
50+
<!-- <dependency>-->
51+
<!-- <groupId>cn.springcloud.gray</groupId>-->
52+
<!-- <artifactId>spring-cloud-gray-server-plugin-nacos-discovery</artifactId>-->
53+
<!-- </dependency>-->
54+
<!-- <dependency>-->
55+
<!-- <groupId>com.alibaba.cloud</groupId>-->
56+
<!-- <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>-->
57+
<!-- </dependency>-->
5258

5359

54-
<!-- <dependency>-->
55-
<!-- <groupId>cn.springcloud.gray</groupId>-->
56-
<!-- <artifactId>spring-cloud-gray-server-plugin-event-stream</artifactId>-->
57-
<!-- </dependency>-->
60+
<!-- <dependency>-->
61+
<!-- <groupId>cn.springcloud.gray</groupId>-->
62+
<!-- <artifactId>spring-cloud-gray-server-plugin-event-stream</artifactId>-->
63+
<!-- </dependency>-->
64+
<!-- <dependency>-->
65+
<!-- <groupId>org.springframework.cloud</groupId>-->
66+
<!-- <artifactId>spring-cloud-starter-stream-rabbit</artifactId>-->
67+
<!-- </dependency>-->
5868

5969
</dependencies>
6070

‎spring-cloud-gray-samples/spring-cloud-gray-server-sample/src/main/resources/config/application.yml‎

Lines changed: 12 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -31,24 +31,18 @@ spring:
3131
server-addr: 127.0.0.1:8848
3232
stream:
3333
bindings:
34-
# GrayEventInput:
35-
# group: service-a
36-
# destination: test
37-
# consumer:
38-
# concurrency: 1 #并发数
39-
# max-attempts: 1
4034
GrayEventOutput:
4135
destination: gray_event
42-
# rabbit:
43-
# bindings:
44-
# GrayEventInput:
45-
# consumer:
46-
# maxConcurrency: 1 #并发数
47-
# prefetch: 1 #从mq一次获取消息的数量
48-
# requeueRejected: true #spring cloud stream 如果出现异常， 是否需要重新投递消息， false表示丢弃。 也有相应的Exception， true-MessageRejectedWhileStoppingException false-AmqpRejectAndDontRequeueException
49-
# auto-bind-dlq: true
50-
# acknowledgeMode: AUTO
51-
# acknowledgeMode: MANUAL
36+
rabbit:
37+
bindings:
38+
GrayEventInput:
39+
consumer:
40+
maxConcurrency: 1 #并发数
41+
prefetch: 1 #从mq一次获取消息的数量
42+
requeueRejected: true #spring cloud stream 如果出现异常， 是否需要重新投递消息， false表示丢弃。 也有相应的Exception， true-MessageRejectedWhileStoppingException false-AmqpRejectAndDontRequeueException
43+
auto-bind-dlq: true
44+
acknowledgeMode: AUTO
45+
acknowledgeMode: MANUAL
5246
eureka:
5347
client:
5448
register-with-eureka: true
@@ -60,6 +54,8 @@ eureka:
6054
gray:
6155
server:
6256
cluster:
57+
synchro:
58+
enable: false
6359
peerNodes:
6460
- host: localhost
6561
port: 20202

‎spring-cloud-gray-samples/spring-cloud-gray-service-b-sample/pom.xml‎

Lines changed: 27 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -48,30 +48,39 @@
4848
<dependency>
4949
<groupId>cn.springcloud.gray</groupId>
5050
<artifactId>spring-cloud-starter-gray-client</artifactId>
51-
<!-- <exclusions>-->
52-
<!-- <exclusion>-->
53-
<!-- <groupId>cn.springcloud.gray</groupId>-->
54-
<!-- <artifactId>spring-cloud-gray-plugin-eureka</artifactId>-->
55-
<!-- </exclusion>-->
56-
<!-- </exclusions>-->
51+
<!-- <exclusions>-->
52+
<!-- <exclusion>-->
53+
<!-- <artifactId>spring-cloud-gray-plugin-event-longpolling</artifactId>-->
54+
<!-- <groupId>cn.springcloud.gray</groupId>-->
55+
<!-- </exclusion>-->
56+
<!-- <exclusion>-->
57+
<!-- <groupId>cn.springcloud.gray</groupId>-->
58+
<!-- <artifactId>spring-cloud-gray-plugin-eureka</artifactId>-->
59+
<!-- </exclusion>-->
60+
<!-- </exclusions>-->
5761
</dependency>
5862

59-
<!-- <dependency>-->
60-
<!-- <groupId>com.alibaba.cloud</groupId>-->
61-
<!-- <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>-->
62-
<!-- </dependency>-->
63-
<!-- <dependency>-->
64-
<!-- <groupId>cn.springcloud.gray</groupId>-->
65-
<!-- <artifactId>spring-cloud-gray-plugin-ribbon-nacos-discovery</artifactId>-->
66-
<!-- </dependency>-->
63+
<!-- <dependency>-->
64+
<!-- <groupId>com.alibaba.cloud</groupId>-->
65+
<!-- <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>-->
66+
<!-- </dependency>-->
67+
<!-- <dependency>-->
68+
<!-- <groupId>cn.springcloud.gray</groupId>-->
69+
<!-- <artifactId>spring-cloud-gray-plugin-ribbon-nacos-discovery</artifactId>-->
70+
<!-- </dependency>-->
6771
<dependency>
6872
<groupId>cn.springcloud.gray</groupId>
6973
<artifactId>spring-cloud-gray-plugin-feign</artifactId>
7074
</dependency>
71-
<!-- <dependency>-->
72-
<!-- <groupId>cn.springcloud.gray</groupId>-->
73-
<!-- <artifactId>spring-cloud-gray-plugin-event-stream</artifactId>-->
74-
<!-- </dependency>-->
75+
76+
<!-- <dependency>-->
77+
<!-- <groupId>cn.springcloud.gray</groupId>-->
78+
<!-- <artifactId>spring-cloud-gray-plugin-event-stream</artifactId>-->
79+
<!-- </dependency>-->
80+
<!-- <dependency>-->
81+
<!-- <groupId>org.springframework.cloud</groupId>-->
82+
<!-- <artifactId>spring-cloud-starter-stream-rabbit</artifactId>-->
83+
<!-- </dependency>-->
7584
</dependencies>
7685

7786
<build>

0 commit comments

Comments
 (0)