JAVA 多用户商城系统b2b2c-Spring Cloud Stream 介绍

介绍Spring Cloud Stream

Spring Cloud Stream是构建消息驱动的微服务应用程序的框架。Spring Cloud Stream基于Spring Boot创建独立的生产级Spring应用程序，并使用Spring Integration提供与消息代理的链接。它提供了来自几家供应商的中间件的意见配置，介绍了持久发布订阅语义，消费者组和分区的概念。

您能够将@EnableBinding注释添加到应用程序，以便当即链接到消息代理，而且能够将@StreamListener添加到方法中，以使其接收流处理的事件。如下是接收外部消息的简单接收器应用程序。

@SpringBootApplication
@EnableBinding(Sink.class)
public class VoteRecordingSinkApplication {

  public static void main(String[] args) {
    SpringApplication.run(VoteRecordingSinkApplication.class, args);
  }

  @StreamListener(Sink.INPUT)
  public void processVote(Vote vote) {
      votingService.recordVote(vote);
  }
}

@EnableBinding注释须要一个或多个接口做为参数（在这种状况下，该参数是单个Sink接口）。接口声明输入和/或输出通道。Spring Cloud Stream提供了接口Source，Sink和Processor; 您还能够定义本身的界面。

如下是Sink接口的定义：

public interface Sink {
  String INPUT = "input";

  @Input(Sink.INPUT)
  SubscribableChannel input();
}

@Input注释标识输入通道，经过该输入通道接收到的消息进入应用程序; @Output注释标识输出通道，发布的消息将经过该通道离开应用程序。@Input和@Output注释可使用频道名称做为参数; 若是未提供名称，将使用注释方法的名称。

Spring Cloud Stream将为您建立一个界面的实现。您能够在应用程序中经过自动链接来使用它，以下面的测试用例示例。

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = VoteRecordingSinkApplication.class)
@WebAppConfiguration
@DirtiesContext
public class StreamApplicationTests {

  @Autowired
  private Sink sink;

  @Test
  public void contextLoads() {
    assertNotNull(this.sink.input());
  }
}

编程模型

Binder

Binder 是 Spring Cloud Stream 的一个抽象概念，是应用与消息中间件之间的粘合剂。
目前 Spring Cloud Stream 实现了 Kafka 和 Rabbit MQ 的binder。经过 binder ，能够很方便的链接中间件，能够动态的改变消息的destinations（对应于 Kafka 的topic，Rabbit MQ 的 exchanges），这些均可以经过外部配置项来作到。甚至能够任意的改变中间件的类型而不须要修改一行代码。

Publish-Subscribe

消息的发布（Publish）和订阅（Subscribe）是事件驱动的经典模式。Spring Cloud Stream 的数据交互也是基于这个思想。生产者把消息经过某个 topic 广播出去（Spring Cloud Stream 中的 destinations）。其余的微服务，经过订阅特定 topic 来获取广播出来的消息来触发业务的进行。

这种模式，极大的下降了生产者与消费者之间的耦合。即便有新的应用的引入，也不须要破坏当前系统的总体结构。

Consumer Groups

“Group”， Kafka 中的概念。Spring Cloud Stream 的这个分组概念的意思基本和 Kafka 一致。

微服务中动态的缩放同一个应用的数量以此来达到更高的处理能力是很是必须的。对于这种状况，同一个事件防止被重复消费，只要把这些应用放置于同一个 “group” 中，就可以保证消息只会被其中一个应用消费一次。

Message

Message，就是所说的消息体，用来承载传输的信息用的。Message分为两部分，header和payload。header是头部信息，用来存储传输的一些特性属性参数。payload是用来装载数据的，他能够携带的任何Object对象 不一样的对象在binder中传输 能够指定不一样的mini类型 具体参考

http://cloud.spring.io/spring...

能够经过application.yml中设置 输入input和输出output的mini类型

spring.cloud.stream.bindings..content-type

MessageChannel

消息管道，生产者生产一个消息到channel，消费者从channel消费一个消息，因此channel能够对消息组件解耦，而且提供一个方便的拦截功能和监控功能。
默认的通道

输入（SubscribableChannel）和输出通道（MessageChannel）参考 Processor接口

springcloudstream提供通道的定义 好比自定义经过可使用接口

public interface OrderChannel {

   String INPUT = "input_order";
   String OUTPUT="ouput_order";
   /**
    * input注解制定通道的名称  未来在yml中配置该通道的实际绑定的topic或者订阅组
    * @return
    */
   @Input(INPUT)
   SubscribableChannel orderInput();
   /**
    * output注解指定输出通道的名称
    * @return
    */
   @Output(OUTPUT)
   MessageChannel orderOutput();
}

如下 代码参考 Source Sink Processor接口 未来在yml关于该通道的配置既能够

spring: 
    cloud: 
        stream: 
            bindings: 
                通道名称: 
                    destination: mydest

电子商务社交平台源码请加企鹅求求：三五三六二四七二五九