|
|
| 第1行: |
第1行: |
|
| |
|
| <div id="mainContent"> | | <div class="rich_media_wrp" id="img-content"> |
| <div class="forFlow"> | | = “女权”到底是什么权…… = |
| <div id="post_detail">
| | |
| <div id="topics"> | | <div class="rich_media_meta_list" id="meta_content"> |
| <div class="post">
| | <div class="profile_card_container" data-v-da33bb4f="" id="js_profile_qrcode" style="display: none;"> |
| = SpringCloudStream极简教程 = | | <div class="profile_card_wrap" data-v-da33bb4f=""> |
|
| | <div class="profile_card_info" data-v-da33bb4f=""> |
| <div class="postBody">
| | <div data-v-da33bb4f=""> 财书学浅 |
| <div class="blogpost-body" id="cnblogs_post_body"> | |
| <div class="current-collection"> | |
| <div class="current-collection-title">[[合集 - SpringBoot(20)]] | |
| </div> | | </div> |
| <div aria-roledescription="list" class="current-collection-links">[[1.SpringBoot整合XXLJob2023-10-10]][[2.SpringBoot集成海康网络设备SDK2023-03-24]][[3.SpringBoot程序预装载数据2022-04-28]][[4.SpringBoot整合Nacos自动刷新配置2022-01-28]][[5.SpringBoot集成Shiro2021-07-09]][[6.Spring Boot 统一RESTful接口响应和统一异常处理2020-09-17]][[7.Spring Boot Admin极简教程2020-09-04]][[8.Spring Boot集成Actuator2020-09-01]][[9.Spring Boot日志框架Slf4j+logback2020-09-01]][[10.Spring Boot接口设计2020-07-17]][[11.SpringBoot整合MinIO2023-09-13]][[12.SpringBoot如何缓存方法返回值?2023-10-24]][[13.SpringBoot对象拷贝2023-12-25]][[14.SpringBoot中Bean的条件装配01-26]][[15.SpringBoot使用git-commit-id-maven-plugin打包02-21]][[16.SpringBoot中bean的生命周期04-07]][[17.SpringCloud解决feign调用token丢失问题05-17]][[18.记录一次WhatTheFuck经历05-27]][[19.Guava中的Joiner和Splitter10-10]] | | <div class="profile_card_info_meta" data-v-da33bb4f=""> |
| <div aria-roledescription="listitem" class="current-collection-item current" data-serial="20">20.SpringCloudStream极简教程12-06
| | 只讲深度,不讲速度。冲破枷锁,探索真相。 |
| | |
| | |
| </div> | | </div> |
| </div>
| | 91篇原创内容 |
| <div class="current-collection-footer current-collection-collapse-button-wrapper">
| | |
| <div class="current-collection-collapse-button clickable">收起
| | |
| </div> | | </div> |
| </div> | | </div> |
| | </div> ''2020年09月05日 21:54'' |
| </div> | | </div> |
| == 简介 == | | <div class="rich_media_content js_underline_content |
|
| | " id="js_content" style=""> |
| Spring Cloud Stream 是一个轻量级消息驱动微服务框架,旨在简化与消息中间件(如 Kafka、RabbitMQ 等)的集成,支持消息的发布和订阅模式。它提供了一种基于 Spring 编程模型的方式(即自动依赖注入和强调通过注解来完成功能的封装),使得构建可扩展和灵活的消息驱动应用变得更加简单。
| | |
| | |
| | |
| | 关于女拳,已经成为和同性恋、少民、等西方文化埋得毒瘤一样在华夏播种发芽。形成一股庞大的恶势力。 |
| | |
| | |
| | 但是男的开这个话题不管说的再有道理,横竖都是被挨骂的结果。所以要让人听下去只能让同为女性的朋友来说比较好,分享一则有理有据的女权打脸文。 |
| | |
| | |
| | |
| | |
| | |
| | 作者:冷月髒花魂 |
| | |
| | |
| | 来源:天涯何处是炎黄 |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | 02 |
| | |
| | |
| | 女权是死亡陷阱 |
| | |
| | |
| | “女权主义”现在是个很时髦的东西,八成是几千年的封建社会把女人们压抑得过度,小脚老太太和童养媳的悲剧永远在上演'''(其实中国古代完全不是这种情况,小脚老太是满清搞出来的,才200年不到),'''于是最近10年造成了极大的反弹,反而一下子'''都得了被迫害妄想症,揭竿而起,唱着''''''“战士责任重妇女冤仇深”'''''',开始去搞女权了。''' |
| | |
| | |
| | |
| | |
| | |
| | 我倒是没深入研究过西方狗屁不通的女权主义的发展历史,但起码现在中国的舆论媒体市面上'''被高喊,被滥用,被主导'''的这种流行的这种女权主义本身就挺扯的,我也很了解。 |
| | |
| | |
| | 不管是人权,男权,还是女权,'''所指的“权”,本应是权利而非权力。''''''即自我独立选择,而非控制他人,迫害他人。''' |
| | |
| | |
| | |
| | |
| | |
| | '''然而现在的人群,莫名其妙的开始瞧不起那些嫁给男人生活的女人。'''从嫁入豪门的明星,到“出卖色相”的屌奴少妇,到赋闲在家的主妇,纷纷'''都被冠以“不独立”“不自强”“不自尊”、“不自爱”的罪名。''' |
| | |
| | |
| | |
| | |
| | |
| | 但事实上,'''自打人类种族的生存繁衍不再是一个危机,母系社会就已经结束了。''''''要论体力,精力,魄力,爆发力,多数女性都是弱者,如果不靠出卖色相和身体的话,女人获取物质的能力宏观上来讲永远是低于男人的。''' |
| | |
| | |
| | |
| | |
| | |
| | '''我说这话不是要侮辱女性,因为我本人就是一个女人,我只是在强调生物进化所导致的男女之间生理和心理上的客观差异性。''' |
| | |
| | |
| | |
| | |
| | |
| | '''否认由于自然进化导致男女性别之间在生理和心理上的巨大差异性,企图毕其功于一役,彻底抹杀这种差异性,要求女人事事像男人一样的标准,这就是女权主义者们最大的反动伪逻辑!''' |
| | |
| | |
| | |
| | |
| | |
| | '''要求所有女人都像男人一样去打拼,去赚钱,去加班,去应酬,去驰骋商海,去升官发财,这本身就是不合理的要求,那些真正做到和男人一样强大的女博士,女CEO,女政客永远是少数。''' |
| | |
| | |
| | |
| | |
| | |
| | '''很多女权主义者脸上贴金,裤裆里冒水的叫喊道:''''''女人是宇宙中最崇拜和平的物种!''''''女人统治世界,全球将立即世界大同!''' |
| | |
| | |
| | |
| | |
| | |
| | 稍微了解点真实的历史的都知道,这完全是在胡说八道。 |
| | |
| | |
| | |
| | |
| | |
| | '''欧洲最大国沙皇俄国,历史上发动战争最多的统治者是一个荡妇——叶卡特琳娜二世,英国历史上发动战争最多的国王也是一个女人——维多利亚女王,中国古代巅峰唐朝发动战争最多的统治者也是一个女人——武则天,人类历史统治期间,人民死于战乱最多的统治者是女人——慈禧太后,慈禧太后统治清朝48年间,高达2.8亿的中国人死于非命!''''''这个记录迄今空前绝后,远比两次世界大战死的人数还要多,还要残暴。''' |
| | |
| | |
| | |
| | |
| | |
| | '''女人天性爱好和平的鬼话,在历史事实面前啪啪啪打脸!''' |
| | |
| | |
| | |
| | |
| | |
| | '''我是女人,所以我最了解女人们的那点小心思:''''''女人们是最喜欢窝里斗,最善于嫉妒,最喜欢搬弄是非,最喜欢八卦,最喜欢工于心计,最喜欢打自己小算盘的一个神奇的物种。''' |
| | |
| | |
| | |
| | |
| | |
| | 俗话说,三个女人一台戏,大学寝室里面,每每传出宿舍女性成员各种勾心斗角,栽赃嫁祸,更不要说行走在社会上的特色女人了。 |
| | |
| | |
| | 武则天、慈禧、叶卡特琳娜二世之流永远是女性群体中的异类,而且她们还是被逼的。 |
| | |
| | |
| | |
| | |
| | |
| | 有些女权自媒体发布的内容,只能用'''丧尽天良,无端造谣,无事生非'''来形容,连我这个女性都看不下去啦。 |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | 03 |
| | |
| | |
| | 男女分工是自然选择的结果 |
| | |
| | |
| | '''女性之于男性的优势就在于细心,美貌,温柔,和坚韧,但这些在职场上却很难短期内换得巨大的财富。''' |
| | |
| | |
| | 如果一个姑娘生得沉鱼落雁,媚眼如丝,娇小可人,但学历和能力却较低,你偏让她放着豪门少奶奶的生活不过,反而要穿上职业装去跟男人抢饭碗,这是对人家姑娘的伤害。 |
| | |
| | |
| | |
| | |
| | |
| | '''因为生物进化的选择,已经从根本上决定了女性和男性是两种具有巨大区别的生物种类,现在女权主义者们,要求全部的女人要像男人一样去战斗,去工作,去拼命努力,高喊独立自由,先工作,先独立,才有尊严价值云云,是完全反自然、反人性、反社会、反人类的观点。''' |
| | |
| | |
| | |
| | |
| | |
| | '''鼓吹像男人一样去战斗!''''''去工作!''''''去挣钱!''''''去征服!''''''去独立自由!''''''这就是女权主义最大的邪恶之处!''' |
| | |
| | |
| | |
| | |
| | |
| | '''任何女人都有权利选择嫁给一个男人生活,只要这是她自主自愿的行为,又有什么不可。''''''况且,''''''凭什么经营家庭,经营好一个男人,一个孩子就不算是伟大的事业?''' |
| | |
| | |
| | |
| | |
| | |
| | 不要以为这口“软饭”谁都吃得起,'''这也需要非常强大的精神和肉体支撑。''''''很多女的却没有这个命!''' |
| | |
| | |
| | |
| | |
| | |
| | 很多女权主义者,'''自己的婚姻过得一塌糊涂,反过来报复社会,蛊惑更多的善良无知的女性''' |
| | |
| | |
| | |
| | |
| | |
| | 每每看到有女人为情自杀的新闻,公众的评论总是:这女人傻透了。而其实当一个姑娘真正刻骨铭心的爱着一个男人,将这份爱情视为信仰,当意识到这生命中最重要的部分即将无可挽回的失去,她选择将自己了结。 |
| | |
| | |
| | |
| | |
| | |
| | 这是一种理想主义,虽然不该被鼓励,但起码应该是被理解和尊重的。 |
| | |
| | |
| | 那些'''狭隘的“女权主义者”要求女性最大限度的实现自身价值,但她们心目中的价值无非就是收入,社会地位,以及让自己老公心甘情愿洗碗带孩子的能力,却从来没有想过有人可以通过对爱情的捍卫来让生命完满。''' |
| | |
| | |
| | |
| | |
| | |
| | 女权主义者们应该扪心自问一句:'''你在要求男人们无条件付出的时候,请问你自己能提供什么?''' |
| | |
| | |
| | |
| | |
| | |
| | 女权主义者们目光短浅,冷酷无情,'''她们说到底还是觉得男人更优秀,她们想让女人们像男人们一样优秀,于是恨不得把全世界的女人都变成男人。''' |
| | |
| | |
| | |
| | |
| | |
| | 实际上,正是这些'''女权主义者在否定女性的价值,是她们在亵渎和侮辱女性,'''但奇怪的是,这种女权主义竟然如同邪教一般蔓延开来,信徒众多,'''女人们竟然心甘情愿的在这种力量的趋势下让自己变得越发像一个爷们儿,女汉子,你们说,到底是谁傻透了?''' |
| | |
| | |
| | |
| | |
| | |
| | 所以,'''姑娘们,不要被时髦的东西蒙蔽了双眼,他们举着“消灭性别歧视”的大旗,其最终目的是消灭性别差异,他们只是在以维护女性的权利为名,而行伤害女性之实,她们不是女权主义者,她们是纳粹法西斯。''' |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | 04 |
| | |
| | |
| | 男人们才是唯一的顶梁柱 |
| | |
| | |
| | '''我是一个正常的女人,所以我拒绝被变成一个男人,我希望自己可以美丽,温柔,对爱情保持敬畏和信仰,我希望自己拥有无数的衣裙,高跟鞋和盆栽植物,我希望自己被自己所爱的男人保护、互相照顾包容扶持对方,不需早出晚归,日晒风吹,每天两个人陪着孩子可以做些家庭生活乐趣之事。''' |
| | |
| | |
| | |
| | |
| | |
| | '''这就是生活的美丽之处,但是女权主义者们不想让中国女人过上这种生活。''' |
| | |
| | |
| | 而至于女权主义者们,'''我也愿她们实现自己的终极理想,从生理和心理上全面消灭女性,雌雄同体自身繁殖,和谐稳定其乐融融,从此男人和男人们过着幸福的生活,女人和女人们在水深火热中挣扎堕落!''' |
| | |
| | |
| | |
| | |
| | |
| | 看看吧,'''古往今来,那些思考民族命运的人、有强烈改造社会意愿的人几乎都是男人,他们是中国的脊梁。''''''而''''''女人们基本上只对娱乐、八卦、美食、衣服、交媾、出轨、小三、东家长、西家短的故事感兴趣。''' |
| | |
| | |
| | 最近10年,由于女权主义的猖狂洗脑,导致'''很多中国女人是没有大的责任感的,她们非常精明却无大智慧;''''''极度地贪婪自私,完全以自我为中心。''''''她们中有几个有能力、有意愿担当社会的重任?''' |
| | |
| | |
| | |
| | |
| | |
| | 杜牧的'''商女不知亡国恨,隔江犹唱后庭花'''的遗训还在响彻云霄。 |
| | |
| | |
| | |
| | |
|
| |
|
|
| | 男性独立自主,利国利民,'''唯有一个男人的信仰与良知可以挽救这个垂死的民族。''' |
| === 特点 ===
| |
|
| |
| * 消息中间件支持:Spring Cloud Stream 支持多种消息中间件,包括 Kafka、RabbitMQ 等,用户可以通过简单的配置切换不同的消息系统而不需修改业务逻辑代码。
| |
| * 绑定模型:Spring Cloud Stream 通过“绑定”抽象层来简化与消息中间件的交互。开发者不需要直接处理底层的消息中间件,而是通过定义“绑定器”来与消息源(如 Kafka、RabbitMQ)进行通信。
| |
| * 消息驱动:提供了事件驱动和流处理的支持。
| |
| * 简化配置:通过 Spring Boot 的自动配置,Spring Cloud Stream 可以通过简单的属性配置来进行消息系统的连接和消息传递。
| |
| * 可扩展性:Spring Cloud Stream 支持开发者使用自定义的消息转换器、处理器等组件,使得消息传递过程能够根据具体业务需求进行灵活定制。
| |
| * 与 Spring Cloud 集成:在 Spring.io 中是SpringCloud下的顶级项目,可以与SpringCloud其它项目无缝集成,适用于微服务架构。
| |
|
| |
| == 核心模块 ==
| |
|
| |
| * Binder:用于实现消息系统的具体接入,例如 Kafka、RabbitMQ 等。
| |
| * Channel:消息的通道,通过 @StreamListener 注解来监听通道,接收和处理消息。消息生产者和消费者都是通过Channel来处理消息的。
| |
| * Producer & Consumer:生产者和消费者,分别负责消息的发布和订阅。Spring Cloud Stream 提供了注解 @Output 和 @Input 来标注消息通道的生产与消费。
| |
|
| |
| == 最佳实践 ==
| |
|
| |
| === pom ===
| |
|
| |
| <pre><code> <dependencyManagement>
| |
| <dependencies>
| |
| <dependency>
| |
| <groupId>org.springframework.boot</groupId>
| |
| <artifactId>spring-boot-dependencies</artifactId>
| |
| <version>2.7.6</version>
| |
| <type>pom</type>
| |
| <scope>import</scope>
| |
| </dependency>
| |
| <dependency>
| |
| <groupId>org.springframework.cloud</groupId>
| |
| <artifactId>spring-cloud-dependencies</artifactId>
| |
| <version>2021.0.6</version>
| |
| <type>pom</type>
| |
| <scope>import</scope>
| |
| </dependency>
| |
| </dependencies> </dependencyManagement> <dependencies>
| |
| <dependency>
| |
| <groupId>org.springframework.boot</groupId>
| |
| <artifactId>spring-boot-starter-web</artifactId>
| |
| <version>${spring-boot.version}</version>
| |
| </dependency>
| |
| <dependency>
| |
| <groupId>com.alibaba.cloud</groupId>
| |
| <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
| |
| <version>2021.0.6.2</version>
| |
| </dependency>
| |
| <!-- SpringCloud Alibaba Nacos Config -->
| |
| <dependency>
| |
| <groupId>com.alibaba.cloud</groupId>
| |
| <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
| |
| <version>2021.0.6.2</version>
| |
| </dependency>
| |
| <dependency>
| |
| <groupId>org.springframework.cloud</groupId>
| |
| <artifactId>spring-cloud-stream-binder-kafka</artifactId>
| |
| </dependency> </dependencies> </code>
| |
| </pre>
| |
|
| |
| * 核心依赖:spring-cloud-stream-binder-kafka
| |
| * 其中已经包含了 spring-kafka 这个依赖,无需重复引入
| |
| * 从其依赖关系来看,SpringCloudStream 的实现引用了 SpringIntegration 这个框架,这也是一个比较有趣的框架,是Spring的顶级框架,感兴趣的可以参看 [[SpringIntegration漫谈]] 了解 SpringIntegration 框架的设计立场和实现思路。
| |
|
| |
| === yml ===
| |
|
| |
| <pre><code> spring:
| |
| kafka:
| |
| consumer:
| |
| max-poll-records: 50
| |
| bootstrap-servers: 192.168.1.92:9092 </code>
| |
| </pre>
| |
|
| |
| * max-poll-records:指定消费者每次从 Kafka 拉取(poll)时能够获取的最大消息数量。
| |
| * bootstrap-servers:kafka的server端的连接地址。注意需要将kafka-server 的 server.properties 配置文件中的 listeners=PRIVATE://0.0.0.0:9092 并且 advertised.listeners=PRIVATE://192.168.1.92:9092 ,否则无法对外提供服务。
| |
|
| |
| === 定义消息通道 ===
| |
|
| |
| <pre><code> import org.springframework.cloud.stream.annotation.Input;
| |
| import org.springframework.cloud.stream.annotation.Output;
| |
| import org.springframework.messaging.MessageChannel;
| |
| import org.springframework.messaging.SubscribableChannel;
| |
|
| |
|
|
| |
|
| public interface AircraftChannel {
| |
|
| |
|
| /**
| |
| * kafka topic 名称
| |
| */
| |
| String TOPIC = KAFKA_TOPIC_NGH_AIRCRAFT;
| |
|
| |
| /**
| |
| * 定义消费者接收消息的通道
| |
| * @return
| |
| */
| |
| @Input(AircraftChannel.TOPIC)
| |
| SubscribableChannel input();
| |
|
| |
| /**
| |
| * 定义生产者发送消息的通道
| |
| * @return
| |
| */
| |
| @Output(AircraftChannel.TOPIC)
| |
| MessageChannel output();
| |
| }
| |
|
| |
|
|
| |
|
| </code>
| | 所以,'''中国之悲哀就是中国男人之悲哀。'''现在的社会现象是各种明星戏子等社会无赖,占据银屏,推想一下,在其他领域不也都是这些雄性和雌性垃圾占领着。 |
| </pre>
| |
|
| |
| * @Input: 使用input注解指定此方法来处理消息的接收
| |
| * @Output:使用output注解指定此方法来处理消息的发送
| |
| * 一个频道中可以定义多个input和output
| |
|
| |
| === 定义消息生产者 ===
| |
|
| |
| <pre><code> import com.nghsmart.nghaircraft.channel.AircraftChannel;
| |
| import lombok.AllArgsConstructor;
| |
| import lombok.extern.slf4j.Slf4j;
| |
| import org.springframework.cloud.stream.annotation.EnableBinding;
| |
| import org.springframework.messaging.support.MessageBuilder;
| |
|
| |
|
| @AllArgsConstructor @Slf4j @EnableBinding(AircraftChannel.class) public class AircraftProducer {
| |
|
| |
|
| private final AircraftChannel aircraftChannel;
| | 当女权主义者遍布神州大地,有脊梁的中国男人被消灭的消灭,被割阉的割阉,离走异国的挥身而去,'''总会有第一个中国男人站出来发声,我在等着。''' |
|
| |
| public void sendMessage(String message) {
| |
| boolean send = aircraftChannel.output().send(MessageBuilder.withPayload(message).build());
| |
| log.info("send message: {}", message);
| |
| }
| |
| }
| |
|
| |
|
|
| |
|
| </code>
| |
| </pre>
| |
|
| |
| * EnableBinding:此注解修饰的类会被Spring容器管理起来,其导入了@Configuration注解。
| |
| * EnableBinding 注解为 AircraftChannel.class 中的接口创建实现类,并通过Spring的自动配置,实现类会对接kafka的adapter,这样就实现了通道和kafkaServer的绑定
| |
| * send:通过注入频道并调用频道中output处理器的send方法将消息发送到kafakServer中的特定topic,即AircraftChannel.TOPIC
| |
|
| |
| === 定义消息消费者 ===
| |
|
| |
| <pre><code> import com.nghsmart.nghaircraft.channel.AircraftChannel;
| |
| import com.nghsmart.nghaircraft.config.RedisTemplateGeneric;
| |
| import com.nghsmart.nghaircraft.constant.RedisKeyEnum;
| |
| import lombok.AllArgsConstructor;
| |
| import lombok.extern.slf4j.Slf4j;
| |
| import org.springframework.cloud.stream.annotation.EnableBinding;
| |
| import org.springframework.cloud.stream.annotation.StreamListener;
| |
| import org.springframework.messaging.Message;
| |
|
| |
|
| @Slf4j @AllArgsConstructor @EnableBinding(AircraftChannel.class) public class AircraftConsumer {
| |
|
| |
|
| @StreamListener(AircraftChannel.TOPIC)
| |
| public void receiveMessage(Message<String> message) {
| |
| try {
| |
| log.debug("AircraftConsumer_Received_message: {}", message.getPayload());
| |
| //TODO 解析数据
| |
|
| |
| } catch (Exception e) {
| |
| log.error("AircraftConsumer_error,msg={}", e.getMessage());
| |
| e.printStackTrace();
| |
| }
| |
| }
| |
| }
| |
|
| |
|
| | '''中国的男人们该到了承担民族责任的时候了,中国的年轻女性已经被培养成社会化、商品化的奖励品,她们不会用自己的脑子想社会问题,她们只关心自己的所谓幸福生活,而且这种培养是由其女权主义和社会的资本钱权化共同完成的,也包括无数懦弱的随波逐流的中国男人被彻底吞噬。''' |
|
| |
|
| </code>
| |
| </pre>
| |
|
| |
| * EnableBinding:此注解修饰的类会被Spring容器管理起来,其导入了@Configuration注解。
| |
| * EnableBinding 注解为 AircraftChannel.class 中的接口创建实现类,并通过Spring的自动配置,实现类会对接kafka的adapter,这样就实现了通道和kafkaServer的绑定
| |
| * StreamListener:通过StreamListener注解为AircraftChannel.TOPIC这个topic创建监听,当kafkaAdapter接收到消息后,将触发回调,调用receiveMessage方法处理消息。
| |
|
| |
| === 定义Http接口 ===
| |
| <blockquote>
| |
| 通过请求接口,发送消息到 kafka
| |
|
| |
|
| </blockquote>
| |
| <pre><code> import lombok.RequiredArgsConstructor;
| |
| import lombok.extern.slf4j.Slf4j;
| |
| import org.springframework.core.io.DefaultResourceLoader;
| |
| import org.springframework.core.io.Resource;
| |
| import org.springframework.web.bind.annotation.GetMapping;
| |
| import org.springframework.web.bind.annotation.RequestMapping;
| |
| import org.springframework.web.bind.annotation.RestController;
| |
| import java.io.BufferedReader;
| |
| import java.io.IOException;
| |
| import java.io.InputStream;
| |
| import java.io.InputStreamReader;
| |
|
| |
|
| @Slf4j @RequiredArgsConstructor @RestController @RequestMapping("/test") public class TestController {
| |
|
| |
|
| private final AircraftProducer aircraftProducer;
| |
|
| |
| @GetMapping("/test1")
| |
| public String test1() {
| |
| aircraftProducer.sendMessage("test1");
| |
| return "test1";
| |
| }
| |
| }
| |
|
| |
|
| | '''不彻底打倒和消灭中国和世界的暗黑女权主义,铲除暗黑女权背后的世界民族暗黑资本的支持和控制,中国的未来就不会一帆风顺,前途就永远充满死亡陷阱。''' |
|
| |
|
| </code>
| |
| </pre>
| |
|
| |
| * 新建一个RESTFful接口用于测试消息的发送
| |
| * 通过注入AircraftProducer,调用其sendMessage 方法发送消息
| |
| * 消息发送出去之后,会被AircraftConsumer监听到,并回调到receiveMessage,可以通过观察log,查看消息的整个生命周期流转。
| |
|
| |
| == 总结 ==
| |
|
| |
| 本文介绍了 SpringCloudStream 这个框架的作用和相关生态,并编写了相应的代码示例作为 '''最佳实践''' 参考,代码示例会上传到我的代码仓库 [[SpringBoot漫谈]] 中(见引用),欢迎大家浏览、学习、交流。
| |
|
| |
|
|
| |
| 公众号: '''TechnologyRamble''',欢迎大家关注!!!
| |
|
| |
|
|
| |
| == 引用 ==
| |
|
| |
| * [[https://spring.io/projects/spring-cloud-stream#overview]]
| |
| * [[https://gitee.com/naylor_personal/ramble-spring-boot]]
| |
|
| |
| <div>
| |
| * [[简介]]
| |
| * [[特点]]
| |
| * [[核心模块]]
| |
| * [[最佳实践]]
| |
| * [[pom]]
| |
| * [[yml]]
| |
| * [[定义消息通道]]
| |
| * [[定义消息生产者]]
| |
| * [[定义消息消费者]]
| |
| * [[定义Http接口]]
| |
| * [[总结]]
| |
| * [[引用]]
| |
|
| |
| </div>
| |
| __EOF__
| |
|
| |
|
|
| |
| <div id="articleSuffix">
| |
| <div class="articleSuffix-left"> [[Image:20191223145109.png]]
| |
| </div>
| |
| <div class="articleSuffix-right"> '''本文作者:''' [[一颗苹果]] '''本文链接:''' [[https://www.cnblogs.com/Naylor/p/18590377]] '''关于博主:''' 评论和私信会在第一时间回复。或者[[直接私信]]我。 '''版权声明:''' 本博客所有文章除特别声明外,均采用 [[BY-NC-SA]] 许可协议。转载请注明出处! '''声援博主:''' 如果您觉得文章对您有帮助,可以点击文章右下角'''【】'''一下。
| |
| </div>
| |
| </div>
| |
| </div>
| |
| <div id="MySignature" role="contentinfo">
| |
| <div>
| |
| | |
|
| |
|
| </div>
| | '''打倒中国暗黑女权,已经到了必须要全面战斗的时候了!''' |
| <div>
| |
| 技术交流QQ群:1158377441
| |
|
| |
|
| </div>
| |
| <div>
| |
| 欢迎关注我的微信公众号【TechnologyRamble】,后续博文将在公众号首发:
| |
|
| |
|
| </div>
| |
| <div> [[Image:o_240521084523_2.png|TechnologyRamble]]
| |
| </div>
| |
| </div>
| |
| <div id="blog_post_info_block" role="contentinfo">
| |
| <div id="BlogCollection">
| |
| 合集:
| |
| [[SpringBoot]]
| |
| , [[极简教程]]
| |
| </div>
| |
| <div id="BlogPostCategory">
| |
| 分类:
| |
| [[Spring Cloud]]
| |
| , [[微服务]]
| |
| , [[极简教程]]
| |
| </div>
| |
| <div id="EntryTag">
| |
| 标签:
| |
| [[SpringCloudStream]]
| |
| , [[SpringIntegration]]
| |
| , [[kafka]]
| |
| </div>
| |
| <div id="blog_post_info">
| |
| <div id="green_channel"> 推荐该文 关注博主关注博主 收藏本文 分享微信
| |
| </div>
| |
| <div id="author_profile">
| |
| <div class="author_profile_info" id="author_profile_info"> [[Image:20191223145109.png|20191223145109.png]]
| |
| <div class="author_profile_info" id="author_profile_detail"> [[Naylor]] [[粉丝 - 64]] [[关注 - 176]]
| |
| </div>
| |
| </div>
| |
| </div>
| |
| <div id="div_digg">
| |
| <div class="diggit" onclick="votePost(18590377,'Digg')"> 0
| |
| </div>
| |
| <div class="buryit" onclick="votePost(18590377,'Bury')"> 0
| |
| </div>
| |
| </div>
| |
| </div>
| |
| <div id="post_next_prev"> [[«]] 上一篇: [[使用Nginx搭建流媒体服务器]]
| |
| </div>
| |
| </div>
| |
| </div>
| |
| <div class="postDesc" style="display: block;">posted @
| |
| 2024-12-06 11:41
| |
| [[Naylor]]
| |
| 阅读(71)
| |
| 评论(0)
| |
| [[编辑]]
| |
|
| |
|
| |
| </div>
| |
| </div>
| |
| </div>
| |
| </div>
| |
| <div class="commentform" id="comment_form">
| |
| <div id="comment_nav">
| |
| <div class="comment-nav-right"> [[刷新页面]][[返回顶部]]
| |
| </div>
| |
| </div>
| |
| <div id="comment_form_container">
| |
| <div id="commentform_title"> 发表评论 [[升级成为园子VIP会员]]
| |
| </div>
| |
| <div class="commentbox_main comment_textarea">
| |
| <div class="commentbox_title">
| |
| <div class="commentbox_title_left"> 编辑 预览
| |
| </div>
| |
| </div>
| |
| <div style="display:none"> cea86a70-79e4-4e09-8cc4-08d8d71b3f30
| |
| </div>
| |
| <div class="commentbox_footer"> 自动补全
| |
| </div>
| |
| </div>
| |
| [[我的博客]]
| |
|
| |
|
|
| |
| [Ctrl+Enter快捷键提交]
| |
|
| |
|
|
| |
| </div>
| |
| <div id="cnblogs_ch">[[【推荐】100%开源!大型工业跨平台软件C++源码提供,建模,组态!]]
| |
| [[【推荐】FFA 2024大会视频回放:Apache Flink 的过去、现在及未来]]
| |
| [[【推荐】抖音旗下AI助手豆包,你的智能百科全书,全免费不限次数]]
| |
| [[【推荐】轻量又高性能的 SSH 工具 IShell:AI 加持,快人一步]]
| |
| </div>
| |
| <div class="under-post-card" id="blog_c1"> [[]]
| |
| </div>
| |
| <div id="under_post_card1">
| |
| <div class="under-post-card"> '''编辑推荐:'''
| |
|
| |
|
| · [[.NET Core 锁(Lock)底层原理浅谈]]
| |
| · [[ASP.NET Core 9.0 中新增的MapStaticAssets() 中间件]]
| |
| · [[Asp.net MVC 中的 Http 管道事件为什么要以 Application_ 开头?]]
| |
| · [[.NET Core 异步(Async)底层原理浅谈]]
| |
| · [[什么是.NET的强类型字符串(Strongly typed string)?]]
| |
| </div>
| |
| </div>
| |
| <div class="under-post-card" id="cnblogs_c2"> [[]]
| |
| </div>
| |
| <div id="under_post_card2">
| |
| <div class="itnews under-post-card"> '''阅读排行:'''
| |
| · [[一个有趣的插件,让写代码变成打怪升级的游戏]]
| |
| · [[《熬夜整理》保姆级系列教程-玩转Wireshark抓包神器教程(8)-Wireshark的TCP包详]]
| |
| · [[构建你的.NET Aspire解决方案]]
| |
| · [[.NET Core 锁(Lock)底层原理浅谈]]
| |
| · [[技术项目文档书写规范指南]]
| |
| </div> | | </div> |
| </div>
| |
| <div class="under-post-card" id="HistoryToday"> '''历史上的今天:'''
| |
|
| |
| 2019-12-06 [[在ASP.NET 中调用 WebService 服务]]
| |
| </div>
| |
| </div>
| |
| </div>
| |
| </div> | | </div> |