Spring Cloud Stream是构建消息驱动的微服务应用程序的框架。Spring Cloud Stream基于Spring Boot建立独立的生产级Spring应用程序,并使用Spring Integration提供与消息代理的连接。了解springcloud架构可以加求求:三五三六二四七二五九。它提供了来自几家供应商的中间件的意见配置,介绍了持久发布订阅语义,消费者组和分区的概念。
您可以将@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(); } 复制代码
@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()); } } 复制代码
@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()); } } 复制代码
从现在开始,我这边会将近期研发的spring cloud微服务云架构的搭建过程和精髓记录下来,帮助更多有兴趣研发spring cloud框架的朋友,了解springcloud架构可以加求求:三五三六二四七二五九,大家来一起探讨spring cloud架构的搭建过程及如何运用于企业项目。
相关推荐
shopnc b2b2c 新版多用户商城系统源码 shopnc b2b2c 新版多用户商城系统源码 shopnc b2b2c 新版多用户商城系统源码 shopnc b2b2c 新版多用户商城系统源码
最新小京东二开版B2B2C多用户商城系统源码+拼团+砍价+批量上传+APP生成+运营版
仿京东商城B2B2C多用户商城源码+手机版+微信商城+微信三级分销 ecmall内核,仿京东商城B2B2C多用户商城源码+手机版+微信商城+微信三级分销 ecmall内核
【源码编号 : MF00001】JAVA多用户B2B2C商城系统源码
Mall4cloud商城系统 springcloud 电商商城系统 B2C商城 BBC商城 O2O商城 B2B2C商城 多语言商城 小程序商城 PC商城 H5商城 APP商城 Java商城 分销商城 多用户商城 uniapp商城 跨境电商商城 积分商城 会员商城
JAVA多用户B2B2C商城源码.rarJAVA多用户B2B2C商城源码.rarJAVA多用户B2B2C商城源码.rar
网站代码 -仿小京东商城,后台简单,亲测有效,无后门
1000块买的插件分享出来大家使用 Ecshop源代码支持最新版本2.7.3
JAVA多用户B2B2C商城系统源码 开发语言 : JAVA 数据库 : MySQL 开发工具 : Eclipse 源码类型 : WebForm 注意:不带技术支持,有帮助文件,虚拟商品,发货不退,看好再拍。 技术构架 开发语言: Java1.7 数 据 库...
注重系统易用性、功能性、扩展性,充分考虑大数据、大并发、系统安全、SEO功能,使得系统设计更加完善,更加高效稳定Shopping系统融合当前主流B2B2C、C2C购物平台,主要功能,同时推出自身特色功能,如:商城广告、...
DSMall商城系统是一套完善的B2B2C(多店铺商城)解决方案。系统使用国内优秀开源框架THinkPHP,H5端采用vue.js,前后端分离,基于PHP+MySQL开发,采用B/S架构,依据6年电商经验打造出的一套开源的B2B2C电子商务系统。
基于Spring Cloud的微服务分布式企业级B2B2C商城系统设计源码,该项目包含1562...该项目是一个基于Spring Cloud的微服务分布式企业级B2B2C商城系统设计源码,可能涉及用户界面设计、应用逻辑实现、数据存储等多个方面。
基于Spring Cloud微服务商城系统 分布式商城系统 企业级商城系统源码: 一个基于Spring Cloud、Nacos、Seata、Mysql、Redis、RocketMQ、canal、ElasticSearch、minio的微服务B2B2C电商商城系统,采用主流的互联网...
thinkphp 5.1开源商城系统,带移动端源代码,含微信支付、支付宝支付及可视化装修功能,是不可多得的好代码。
ShopNC B2B2C商城是ShopNC于2014年最新推出的【B2B2C】电商平台系统,采用PHP5+MySQL技术为基础,采用OOP(面向对象)方式进行核心框架搭建,结合MVC模式进行开发,可以支持Windows/Unix服务器环境,需PHP5.3及以上...
2018最新鸿宇小京东多用户B2B2C商城系统V7.9.9源码
汉潮B2B2C多用户商城系统是一个以PHP+MySQL进行开发的PHP多用户商城网站系统源码。
idea:在开发环境中跑项目,也就是我们在编码过程中的用的做多的方式 jar、war:线上、服务器上执行jar、war包的方式 maven插件方式:执行命令: mvn spring-boot:run 3、补充: mvn spring-boot:run报错找不到...
Net实战商用源码---ASP,NET多 用户B2B2C商城源码Net实战商用源码--
多用户啊商城系统