demo

Author: saleson

spring-cloud-gray-samples/spring-cloud-gray-apollo-config-sample/src/main/java/cn/springcloud/gray/apollo/sample/ApolloSampleApplication.java

@@ -2,6 +2,7 @@
 
 import com.ctrip.framework.apollo.spring.annotation.EnableApolloConfig;
 import org.slf4j.LoggerFactory;
+import org.springframework.boot.WebApplicationType;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@@ -20,7 +21,7 @@ public class ApolloSampleApplication {
     private static final org.slf4j.Logger log = LoggerFactory.getLogger(ApolloSampleApplication.class);
 
     public static void main(String[] args) throws UnknownHostException {
-        Environment env = new SpringApplicationBuilder(ApolloSampleApplication.class).web(true).run(args).getEnvironment();
+        Environment env = new SpringApplicationBuilder(ApolloSampleApplication.class).web(WebApplicationType.SERVLET).run(args).getEnvironment();
         log.info(
                 "\n----------------------------------------------------------\n\t"
                         + "Application '{}' is running! Access URLs:\n\t" + "Local: \t\thttp://127.0.0.1:{}\n\t"

spring-cloud-gray-samples/spring-cloud-gray-consumer-nacos-config-sample/src/main/java/cn/springcloud/gray/service/consumer/nacos/connfig/NacosConsumerApplication.java

@@ -1,6 +1,7 @@
 package cn.springcloud.gray.service.consumer.nacos.connfig;
 
 import org.slf4j.LoggerFactory;
+import org.springframework.boot.WebApplicationType;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@@ -18,7 +19,7 @@ public class NacosConsumerApplication {
     private static final org.slf4j.Logger log = LoggerFactory.getLogger(NacosConsumerApplication.class);
 
     public static void main(String[] args) throws UnknownHostException {
-        Environment env = new SpringApplicationBuilder(NacosConsumerApplication.class).web(true).run(args).getEnvironment();
+        Environment env = new SpringApplicationBuilder(NacosConsumerApplication.class).web(WebApplicationType.SERVLET).run(args).getEnvironment();
         log.info(
                 "\n----------------------------------------------------------\n\t"
                         + "Application '{}' is running! Access URLs:\n\t" + "Local: \t\thttp://127.0.0.1:{}\n\t"

spring-cloud-gray-samples/spring-cloud-gray-server2-sample/pom.xml

@@ -55,10 +55,10 @@
         <!--        </dependency>-->
 
 
-        <!--        <dependency>-->
-        <!--            <groupId>cn.springcloud.gray</groupId>-->
-        <!--            <artifactId>spring-cloud-gray-server-plugin-event-stream</artifactId>-->
-        <!--        </dependency>-->
+        <!--                <dependency>-->
+        <!--                    <groupId>org.springframework.cloud</groupId>-->
+        <!--                    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>-->
+        <!--                </dependency>-->
 
     </dependencies>
 

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

@@ -1,6 +1,8 @@
 server:
   port: 20203
 spring:
+  main:
+    allow-bean-definition-overriding: true
   application:
     name: gray-Server
 
@@ -31,24 +33,19 @@ spring:
         server-addr: 127.0.0.1:8848
     stream:
       bindings:
-        #        GrayEventInput:
-        #          group: service-a
-        #          destination: test
-        #          consumer:
-        #            concurrency: 1 #并发数
-        #            max-attempts: 1
         GrayEventOutput:
+          contentType: application/x-java-serialized-object
           destination: gray_event
-          #      rabbit:
-          #        bindings:
-          #          GrayEventInput:
-          #            consumer:
-          #              maxConcurrency: 1 #并发数
-          #              prefetch: 1 #从mq一次获取消息的数量
-          #              requeueRejected: true #spring cloud stream 如果出现异常， 是否需要重新投递消息， false表示丢弃。  也有相应的Exception， true-MessageRejectedWhileStoppingException false-AmqpRejectAndDontRequeueException
-          #              auto-bind-dlq: true
-          #              acknowledgeMode: AUTO
-#              acknowledgeMode: MANUAL
+          rabbit:
+            bindings:
+              GrayEventInput:
+                consumer:
+                  maxConcurrency: 1 #并发数
+                  prefetch: 1 #从mq一次获取消息的数量
+                  requeueRejected: true #spring cloud stream 如果出现异常， 是否需要重新投递消息， false表示丢弃。  也有相应的Exception， true-MessageRejectedWhileStoppingException false-AmqpRejectAndDontRequeueException
+                  auto-bind-dlq: true
+                acknowledgeMode: AUTO
+          acknowledgeMode: MANUAL
 eureka:
   client:
     register-with-eureka: true
@@ -60,7 +57,9 @@ eureka:
 gray:
   server:
     cluster:
-      peer-nodes:
+      #      synchro:
+      #        enable: false
+      peerNodes:
         - host: localhost
           port: 20202
         - host: localhost