spring cloud stream 3.1.2 源码搭配rocketmq学习 (二)

现在我们从源码来分析(一)中所涉及的东西

提问

问一下自己想从源码中知道什么, 带着目的去看源码才容易搞懂.

从下述的代码中发现定义了一个Function的Bean和在yaml中定义了definition, 那么这两个定义的作用是什么呢? Function是怎么样去绑定、注册的呢?

带着问题我们就可以去找对应的实现.

@Beanpublic Function<Flux<Message<String>>, Mono<Void>> consumerEvent() { return flux -> flux.map(message -> {  System.out.println(message.getPayload());  return message; }).then();}
spring: cloud: stream:  function:  definition: consumerEvent

怎么找springboot项目的启动

首先我们看META-INF/spring.factories

org.springframework.boot.autoconfigure.EnableAutoConfigura:\(...省略一部分)org.springframework.cloud.stream.function.FunctionConfiguration

发现自动装载了一个FunctionConfiguration的类

进到这个类里面看, 发现他注册了一个functionBindingRegistrar的Bean.

看英文---(functionBindingRegistrar) 方法绑定注册, 这好像是我们想知道的东西.

那么接着往下看

functionBindingRegistrar

看传入的参数发现这个Bean是根据StreamFunctionProperties注册的一个的Bean.
// FunctionConfiguration#functionBindingRegistrar@Beanpublic InitializingBean functionBindingRegistrar(Environment environment, FunctionCatalog functionCatalog, StreamFunctionProperties streamFunctionProperties) { return new FunctionConfiguration.FunctionBindingRegistrar(functionCatalog, streamFunctionProperties);}

因为这个Bean是InitializingBean所以直接看afterPropertiesSet这个方法

看源码最重要就是抓住主线, 从源码中发现有这样的一段代码.

// 注册了一个Bean定义, functionBindableProxyDefinition.registry.registerBeanDefinition(name, functionBindableProxyDefinition);

咦? 那functionBindableProxyDefinition是一个什么东西呢??

往上找这个的赋值.

// 看到这行, 他是一个 BindableFunctionProxyFactoryfunctionBindableProxyDefinition = new RootBeanDefinition(BindableFunctionProxyFactory.class);// 为构造参数进行了赋值functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(functionDefinition);functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(this.inputCount);functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(this.outputCount);functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(this.streamFunctionProperties);

初始化了一个RootBeanDefinition, 并对构造函数进行呢相对应的赋值, 那参数从哪来的呢, 继续看源码.

// 这些参数怎么来的呢// 看到下面这些代码, 对于Function/Supplier/Consumer怎么区分的, 是不是有的清晰的认知FunctionInvocationWrapper function = (FunctionInvocationWrapper)this.functionCatalog.lookup(functionDefinition);Type functionType = function.getFunctionType();if (function.isSupplier()) { this.inputCount = 0; this.outputCount = this.getOutputCount(functionType, true);} else if (function.isConsumer()) { this.inputCount = FunctionTypeUtils.getInputCount(functionType); this.outputCount = 0;} else { this.inputCount = FunctionTypeUtils.getInputCount(functionType); this.outputCount = this.getOutputCount(functionType, false);}

看到上面这一段代码inputCount/outCount是计算出来的, 对于怎么区分Function/Supplier/Consumer是Input还是Output也有了一定的了解

那functionDefinition是什么呢

functionDefinition = var3[var5];

我们发现他是这样赋值的, 再往上看

sourceNames = this.filterEligibleFunctionDefinitions();var3 = sourceNames;var4 = sourceNames.length;

通过阅读发现filterEligibleFunctionDefinitions这个方法里对我们配置文件中Definition进行了解析处理, 并返回了合格的sourcesNames.

哦! 原来Definition的意义在这.

到此这个bean的注册就已经完成了,那就来看看BindableFunctionProxyFactory,
发现他又是一个InitializingBean, 所以上诉代码设置完初始化参数后, 在spring实例化Bean之后会调用afterPropertiesSet方法

public void afterPropertiesSet() { Assert.notEmpty(this.bindingTargetFactories, "'bindingTargetFactories' cannot be empty"); int i; if (this.inputCount > 0) {  for(i = 0; i < this.inputCount; ++i) {   this.createInput(this.buildInputNameForIndex(i));  } } if (this.outputCount > 0) {  for(i = 0; i < this.outputCount; ++i) {   this.createOutput(this.buildOutputNameForIndex(i));  } }}

然后看到这两个函数. 发现绑定名称原来是这样的.

private String buildInputNameForIndex(int index) { return this.functionDefinition.replace(",", "|").replace("|", "") + "-" + "in" + "-" + index;}private String buildOutputNameForIndex(int index) { return this.functionDefinition.replace(",", "|").replace("|", "") + "-" + "out" + "-" + index;}

以Input为例子, 我们看看createInput的方法.

先从简单的来看, 先不看pollable

this.inputHolders.put(name, new BoundTargetHolder(this.getBindingTargetFactory(SubscribableChannel.class).createInput(name), true));

SubscribableChannel的createInput, 我们找到SubscribableChannelBindingTargetFactory#createInput的

public SubscribableChannel createInput(String name) { DirectWithAttributesChannel subscribableChannel = new DirectWithAttributesChannel(); subscribableChannel.setComponentName(name); subscribableChannel.setAttribute("type", "input"); this.messageChannelConfigurer.configureInputChannel(subscribableChannel, name); if (this.context != null && !this.context.containsBean(name)) {  this.context.registerBean(name, DirectWithAttributesChannel.class, () -> {   return subscribableChannel;  }, new BeanDefinitionCustomizer[0]); } return subscribableChannel;}

发现返回了DirectWithAttributesChannel的一个类, 并且把他注册成为了Bean.

后面把这个类封装在BoundTargetHolder中并放入inputHolders中就结束了Function注册的过程

总结

  1. 启动之后会注册一个FunctionBindingRegistrar的Bean, 在这个Bean中会读取配置文件找到对应的FunctionBean, 处理这个FunctionBean生成注册需要的参数并把这些内容构成一个functionBindableProxyDefinition的Bean.
  2. functionBindableProxyDefinition的Bean处理上述构造函数传入的参数并生成对应的Input/Output的Bean.

至此, funciton的注册就完成了吗. (不!). 其实还没有完成, 细心的朋友会发现 还有functionInitializer的Bean. 下一节我们来看看这个.

Wish. Do.









原文转载：http://www.shaoqun.com/a/764968.html

跨境电商：https://www.ikjzd.com/

徐家骏：https://www.ikjzd.com/w/1803

houzz：https://www.ikjzd.com/w/236


现在我们从源码来分析(一)中所涉及的东西提问问一下自己想从源码中知道什么,带着目的去看源码才容易搞懂.从下述的代码中发现定义了一个Function的Bean和在yaml中定义了definition,那么这两个定义的作用是什么呢?Function是怎么样去绑定、注册的呢?带着问题我们就可以去找对应的实现.@BeanpublicFunction<Flux<Message<String
hemingway：https://www.ikjzd.com/w/2344
敦煌网站：https://www.ikjzd.com/w/189
汇通天下物流：https://www.ikjzd.com/w/2055
天猫国际联合海关启动"仓内留样检"：https://www.ikjzd.com/articles/18175
初阶卖家必读：3个步骤，让您的亚马逊广告运营事半功倍!：https://www.ikjzd.com/articles/143206
"2018亚马逊全球开店卖家峰会"现场火爆体验盘点：https://www.ikjzd.com/articles/12575

Comments

Post a Comment

Popular posts from this blog

指纹浏览器定制开发全面助力企业安全与智能升级

在数字化时代，企业信息安全和智能化管理愈发成为商务发展的两大支柱。为适应这一趋势，指纹浏览器定制开发成为了企业安全和智能升级的最佳选择。让我们一同探索，如何通过指纹浏览器的二次开发、私有部署和AI智能等关键功能，助力企业迎接未来的挑战。 指纹浏览器二次开发：保障身份识别的极致体验 随着科技的不断进步，传统身份验证方式显得越来越脆弱。指纹浏览器的二次开发为企业带来了身份识别的极致体验，通过精准的生物特征验证，极大地提高了安全性。企业无需担忧密码泄漏或仿冒风险，真正实现了信息安全的无忧管理。 私有部署：数据安全掌握在自己手中 数据是企业最重要的资产之一，而私有部署则是最为可靠的数据保护手段之一。通过将指纹浏览器定制开发系统私有部署，企业能够完全掌握对敏感数据的访问和存储。这一层级的掌控，不仅提升了数据的安全性，同时也避免了因为云服务的共享带来的潜在风险。 原文转载： https://fashion.shaoqun.com/a/1585172.html 深圳巴厘岛海景酒店 ：https://www.vstour.cn/t/深圳巴厘岛海景酒店.html 深圳巴厘岛旅行团 ：https://www.vstour.cn/t/深圳巴厘岛旅行团.html 深圳巴厘岛旅游 ：https://www.vstour.cn/t/深圳巴厘岛旅游.html 深圳巴厘岛旅游报价 ：https://www.vstour.cn/t/深圳巴厘岛旅游报价.html 深圳巴厘岛旅游价格 ：https://www.vstour.cn/t/深圳巴厘岛旅游价格.html 深圳巴厘岛旅游团 ：https://www.vstour.cn/t/深圳巴厘岛旅游团.html 红海堵塞，海湾受益？ ：https://www.kjdsnews.com/a/1743053.html 一篇文章带你了解商标注册：尼加拉瓜 ：https://www.kjdsnews.com/a/1743054.html
Read more

跨境电商资讯：一文带你走进亚马逊19大海

Image
随着全球电商行业的迅速发展，许多品牌逐渐将目光投向海外市场，寻找新的业务增长点。亚马逊作为全球最大的电商平台之一，拥有众多海外站点，为卖家提供了广阔的发展空间和优质的服务。然而，当卖家们面对海外众多不同的站点，它们的区别是什么？该选红海站点还是蓝海站点？如何才能选择适合自己的平台？这些都让许多卖家感到非常迷惑，不知所措。 别着急！接下来就让小编带大家一起了解亚马逊各大海外站点的机会优势，并分享几位卖家的实战经验，助您选好出海站点，赢在起跑线！ 目前，亚马逊在全球拥有19大海外站点，覆盖北美、拉丁美洲、欧洲、亚洲、大洋洲等多个地区，帮助卖家触达数亿消费者。这些站点各有"特长"，您可以结合自身业务、资金情况和发展需求等因素，Pick适合自己的出海站点，及时把握海外商机！ 01老牌成熟站点，新手出海首选！ 目前，亚马逊在北美地区拥有美国站和加拿大站两大站点。北美站的整体成熟度和服务完善性让许多卖家将它作为开拓生意的首站。 从宏观环境来看，北美站可谓实力超群： ●体量庞大，消费潜力高 作为亚马逊全球最大海外站点，消费实力强劲，两大站点囊括3.7亿+人口，人红利充足，Prime会员占比高； ●品类齐全，细分赛道机会多 加拿大站选品文化接近美国，选品空间广阔，有利于卖家挖掘不同品类商机! 对于新手来说，亚马逊北美站拥有多重优势助力启航： ●配套完善，服务齐全 作为最早开设的站点，亚马逊服务支持齐全，新卖家上手更轻松 ●物流便捷，配送无阻 您可使用亚马逊远程物流配送计划(NARF)，将美国站FBA库存直接配送给加拿大买家，无需将库存事先运送到加拿大，助您轻松拓展北美地区商业版图! 该计划具有以下4大优势： ●利用美国FBA库存，为加拿大的Prime买家提供免费配送服务； ●由亚马逊处理跨境配送事宜，让配送流程更简单便捷； ●进口税费和相关费用由买家支付，无需卖家承担； ●退货直接退回美国，省心省力。 如果您想坐拥巨大流量，触达更多、更广泛的消费者；如果您的选品种类丰富齐全，希望同时布局多种品类赛道……那么北美站是您不该犹豫的首选! 02高潜消费增长能力，业务拓展不二之选！ 在拉丁美洲，除了已对卖家开放的墨西哥站之外，亚马逊巴西站也于2023年12月正式对中国卖家开放，不少北美站卖家已抢先拓展生意版图，吃到了"第一只螃蟹"! 结合宏观发展趋势...
Read more

利用 Google 购物广告促进销量的初学者指南

您需要更多客户。 并且，您需要 以可接受的成本获取它们 。因为，如果你不能做这两件事呢？ ……好吧， 我们别去那里了 。 首先，如何获得更多客户？ 嗯，一种行之有效的方法是 Google Shopping 。 这一领先的电子商务流量来源 占 电子商务 网站整体销售额的 16% 以上。 那是 巨大的。 但是，当您考虑到Google每秒处理超过 40,000 个搜索查询 时，这也就不足为奇了。 不过，这还不是全部…… 2018 年，在美国电子商务领域，Google 购物广告占 零售搜索广告支出的 76.4% ，占所有付费搜索点击次数的 85.3%。 另一方面，文字广告仅吸引了 23.6% 的零售搜索广告支出和 14.7% 的付费搜索点击次数。 由于 Google 努力通过富媒体广告格式提高知名度，投资 Google Shopping 广告系列已成为零售搜索行业的主要趋势。 但是，您能否使用 Google 购物以可接受的成本获取客户，从而为您带来利润？ 一言以蔽之？ 是的 。 OMG Commerce首席执行官 Brett Curry 去年 管理的广告活动平均 广告支出回报率 (ROAS) 为 300-600% 。 您愿意花 1美元获得 3 至 6 美元的销售额吗？ 我愿意打赌你会的。 你是怎么做到的？ 在本文中，您将准确了解 Google 购物是什么、它的工作原理以及如何开始您的第一个广告系列。 好吧，系好安全带 。 Fansgurus是一个社交媒体营销在线平包含了Facebook，Instagram，Twitter，Pinterest，YouTube，Tiktok，telegram，虾皮等等海外社交媒体，并提供增粉、点赞、转发、评论浏览量直播间在线，网站引流等数据服务。快速体验： zllp.myyfrs.ciwi._okgyw?fyuokfj 什么是谷歌购物？ Google 购物广告也称为产品详情广告或 PLA。而且，当用户在 Google 上搜索产品时，它们就会显示。 它们出现 在搜索结果的顶部或页面的右上角： Google 购物广告也可以 在"购物"标签下找到。 这些广告如此有效的 部分原因 是它们位于搜索结果顶部的显着位置。 那么，Google 购物广告包含哪些内容？ 简而言之， 消费者熟悉的5 个关键组件： 产品图片 产品名称 价格 卖家姓...
Read more