消息重复消息问题解决：消费组

Author: dyc87112

2-Dalston版教程示例/README.md

@@ -38,14 +38,14 @@
 - [消息驱动的微服务（入门）](http://blog.didispace.com/spring-cloud-starter-dalston-7-1/)
 - [消息驱动的微服务（核心概念）](http://blog.didispace.com/spring-cloud-starter-dalston-7-2/)
 - [消息驱动的微服务（消费组）](http://blog.didispace.com/spring-cloud-starter-dalston-7-3/)
+- [消息驱动的微服务（消费组案例：解决消息重复消费）](http://blog.didispace.com/spring-cloud-starter-dalston-7-5/)
 - [消息驱动的微服务（消息分区）](http://blog.didispace.com/spring-cloud-starter-dalston-7-4/)
 - [分布式服务跟踪（入门）](http://blog.didispace.com/spring-cloud-starter-dalston-8-1/)
 - [分布式服务跟踪（跟踪原理）](http://blog.didispace.com/spring-cloud-starter-dalston-8-2/)
 - [分布式服务跟踪（整合logstash）](http://blog.didispace.com/spring-cloud-starter-dalston-8-3/)
 - [分布式服务跟踪（整合zipkin）](http://blog.didispace.com/spring-cloud-starter-dalston-8-4/)
 - [分布式服务跟踪（收集原理）](http://blog.didispace.com/spring-cloud-starter-dalston-8-5/)
 - [分布式服务跟踪（抽样收集）](http://blog.didispace.com/spring-cloud-starter-dalston-8-6/)
-- [Spring Cloud构建微服务架构：服务综合管理]
 
 ## 我的公众号
 

2-Dalston版教程示例/pom.xml

@@ -17,37 +17,45 @@
         <module>eureka-consumer</module>
         <module>consul-consumer</module>
 
+        <!--使用ribbon和feign调用服务接口-->
         <module>eureka-consumer-ribbon</module>
         <module>eureka-consumer-feign</module>
 
+        <!--分布式配置中心-->
         <module>config-server-git</module>
         <module>config-client</module>
 
+        <!--使用hystrix-->
         <module>eureka-consumer-ribbon-hystrix</module>
         <module>eureka-consumer-feign-hystrix</module>
 
         <module>hystrix-dashboard</module>
         <module>turbine</module>
         <module>turbine-amqp</module>
 
+        <!--使用feign-->
         <module>eureka-feign-api</module>
         <module>eureka-feign-client</module>
         <module>eureka-feign-consumer</module>
+        <!--使用feign上传文件-->
         <module>eureka-feign-upload-client</module>
         <module>eureka-feign-upload-server</module>
 
+        <!--hystrix请求合并-->
         <module>hystrix-collapser-provider</module>
         <module>hystrix-collapser-consumer</module>
 
+        <!--api网关-->
         <module>api-gateway</module>
         <module>api-gateway-with-eureka</module>
 
+        <!--使用spring cloud stream-->
         <module>stream-hello</module>
+        <module>stream-consumer-group</module> <!-- 负载均衡消费 -->
 
         <!--分布式跟踪-->
         <module>trace-1</module>
         <module>trace-2</module>
-
         <module>zipkin-server</module>
         <module>zipkin-server-stream</module>
 

2-Dalston版教程示例/stream-consumer-group/pom.xml

@@ -0,0 +1,57 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.didispace</groupId>
+	<artifactId>stream-consumer-group</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>1.5.9.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+		<java.version>1.8</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+		</dependency>
+	</dependencies>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.springframework.cloud</groupId>
+				<artifactId>spring-cloud-dependencies</artifactId>
+				<version>Dalston.SR4</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+</project>

2-Dalston版教程示例/stream-consumer-group/src/main/java/com/didispace/stream/ExampleApplication.java

@@ -0,0 +1,13 @@
+package com.didispace.stream;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ExampleApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ExampleApplication.class, args);
+    }
+
+}

2-Dalston版教程示例/stream-consumer-group/src/main/java/com/didispace/stream/ExampleBinder.java

@@ -0,0 +1,13 @@
+package com.didispace.stream;
+
+import org.springframework.cloud.stream.annotation.Input;
+import org.springframework.messaging.SubscribableChannel;
+
+interface ExampleBinder {
+
+    String NAME = "example-topic";
+
+    @Input(NAME)
+    SubscribableChannel input();
+
+}

2-Dalston版教程示例/stream-consumer-group/src/main/java/com/didispace/stream/ExampleReceiver.java

@@ -0,0 +1,18 @@
+package com.didispace.stream;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.StreamListener;
+
+@EnableBinding(ExampleBinder.class)
+public class ExampleReceiver {
+
+    private static Logger logger = LoggerFactory.getLogger(ExampleReceiver.class);
+
+    @StreamListener(ExampleBinder.NAME)
+    public void receive(String payload) {
+        logger.info("Received: " + payload);
+    }
+
+}

2-Dalston版教程示例/stream-consumer-group/src/main/resources/application.properties

@@ -0,0 +1,4 @@
+spring.application.name=stream-consumer-group
+server.port=0
+
+spring.cloud.stream.bindings.example-topic.group=aaa

2-Dalston版教程示例/stream-consumer-group/src/test/java/com/didispace/ExampleApplicationTests.java

@@ -0,0 +1,33 @@
+package com.didispace;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.Output;
+import org.springframework.integration.support.MessageBuilder;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@EnableBinding(value = {ExampleApplicationTests.ExampleBinder.class})
+public class ExampleApplicationTests {
+
+	@Autowired
+	private ExampleBinder exampleBinder;
+
+	@Test
+	public void exampleBinderTester() {
+        exampleBinder.output().send(MessageBuilder.withPayload("Produce a message from : http://blog.didispace.com").build());
+	}
+
+	public interface ExampleBinder {
+
+		String NAME = "example-topic";
+
+		@Output(NAME)
+		MessageChannel output();
+
+	}
+
+}