spring cloud stream示例

太过爱你忘了你带给我的痛 2022-03-09 05:56 226阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDU5NjEx_size_16_color_FFFFFF_t_70][]

spring cloud stream可以用来简化消息中间件的使用

1，加上依赖

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-stream-rabbit</artifactId>

</dependency>

2，应用

public interface StreamClient \{

@Input("myMessage1")

SubscribableChannel input();

@Output("myMessage")

MessageChannel output();

\}

@Component

@EnableBinding(StreamClient.class)

@Slf4j

public class StreamReceiver \{

@StreamListener("myMessage")

public void process(Object message) \{

log.info("myMessage : \{\}", message );

\}

\}

@RestController

public class SendMessageController \{

@Autowired

private StreamClient streamClient;

@GetMapping("/sendMessage")

public void process() \{

String message ="now " + new Date();

streamClient.output().send(MessageBuilder.withPayload(message).build());

\}

\}

这样一访问 http://localhost:8090/sendMessage 就会在控制台打印：

myMessage1 : \[110, 111, 119, 32, 84, 117, 101, 32, 77, 97, 114, 32, 49, 50, 32, 49, 53, 58, 48, 48, 58, 53, 57, 32, 67, 83, 84, 32, 50, 48, 49, 57\]

3.消息的分组

如果启动了两个实例，这时候对第一个实例访问/sendMessage，两个实例都会收到消息，这是我们不想看到的，这时候在bootstrap.yml加入如下设置：

stream:

bindings:

myMessage:

group: order

这时候只有一个实例会收到消息，这就是所谓的消息的分组。如果加上content-type：

stream:

bindings:

myMessage:

group: order

content-type: application/json

那么就可以在消息队列中显示出具体内容。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDU5NjEx_size_16_color_FFFFFF_t_70]: /images/20220309/de8b60b077094a54b1991feb623dbd30.png

发表评论取消回复

表情：

评论列表（有 0 条评论，226人围观）

还没有评论，来说两句吧...

相关阅读

相关 Spring Cloud Stream详解

目录一、概述简介 1.1. cloud Stream是什么 1.2. 设计思想 1.3. 标

刺骨的言语ヽ痛彻心扉/ 2024年04月08日 11:26/ 0 赞/ 9 阅读

相关 spring-cloud-stream

为啥需要它？不同mq中间件实现不一样,当迁移mq的时候,这无异于是灾难. spring-cloud-stream就是抽象出一层绑定层,通过绑定层与外部代理连接

「爱情、让人受尽委屈。」/ 2022年12月26日 10:29/ 0 赞/ 84 阅读

相关 Spring Cloud Sleuth示例

Spring Cloud Sleuth 为 Spring Cloud实现了一个分布式链路跟踪解决方案。 Sleuth概念说明 span（跨度）：基本工作单元，用一

傷城~/ 2022年11月19日 07:42/ 0 赞/ 104 阅读

相关 Spring Cloud Stream + Kafka

> SpringCloudStream是一个构建消息驱动的微服务框架。SpringCloudStream构建在SpringBoot之上用以创建工业级的应用程序，并且Spring

以你之姓@/ 2022年06月12日 08:29/ 0 赞/ 146 阅读

相关 Spring Cloud Stream 消息驱动

1、什么是Spring Cloud Stream > Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于Spring Boo

短命女/ 2022年05月24日 13:52/ 0 赞/ 164 阅读

相关 spring cloud stream示例

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIy

太过爱你忘了你带给我的痛/ 2022年03月09日 05:56/ 0 赞/ 227 阅读

相关 Spring Cloud Stream消息总线

[Spring Cloud Stream消息总线][Spring Cloud Stream] Springcloud 里面对于MQ的整合一个是前一篇的消息总线一个是本文介

布满荆棘的人生/ 2022年01月28日 11:37/ 0 赞/ 214 阅读

相关 Spring cloud stream【消息分区】

在上篇文章中我们给大家介绍了Stream的消息分组，可以实现消息的重复消费的问题，但在某些场景下分组还不能满足我们的需求，比如，同时有多条同一个用户的数据，发送过来，我们需

- 日理万妓/ 2021年12月20日 06:23/ 0 赞/ 187 阅读

相关 Spring Cloud - 8 (Spring Cloud Stream)

Spring Cloud Stream -------------------- Kafka -------------------- 官方网页 [Apach

心已赠人/ 2021年11月16日 08:14/ 0 赞/ 159 阅读

相关 Spring Cloud 之 Stream.

一、简介 Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。 Spring Cloud Stream 为一些供应商的消息中间件产...

红太狼/ 2020年11月07日 01:11/ 0 赞/ 763 阅读