微服务学习10——spring cloud stream

系统管理员 2022-02-16 02:44 151阅读 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/20220216/6898a7683cec441b8f5cc6dfb1db95c5.png

发表评论取消回复

表情：

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

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

相关阅读

相关 Spring Cloud与微服务学习总结（10）——Spring Cloud 常见优化项的总结

1. 用undertow替换tomcat，因为undertow是基于NIO非阻塞式请求。也可以用最新的tomcat8.5版本的NIO模式，当然使用场景也有区分，underto

布满荆棘的人生/ 2023年02月28日 15:26/ 0 赞/ 9 阅读

相关 Spring Cloud 学习（一）：微服务及Spring Cloud介绍

文章目录一、微服务介绍 1、什么是微服务？ 2、微服务优势 3、使用 Spring Cloud 的优势二、Spri

Love The Way You Lie/ 2023年01月12日 01:17/ 0 赞/ 182 阅读

相关 spring cloud 微服务

[https://blog.csdn.net/qq\_27384769/article/details/79439801][https_blog.csdn.net_qq_273

分手后的思念是犯贱/ 2022年03月17日 07:22/ 0 赞/ 289 阅读

相关【微服务架构 - 08 - Spring Cloud】10 服务监控系统

Spring Boot Admin 服务端 pom.xml 添加 `org.jolokia:jolokia-core`、`de.codecentric:spring

╰+哭是因爲堅強的太久メ/ 2022年03月12日 20:10/ 0 赞/ 206 阅读

相关 Spring Cloud - 微服务学习之Spring boot

[Spring Cloud][] 子项目 Spring Cloud [config][]：配置管理开发工具包，可以让你把配置放到远程服务器，目前支持本地存储、Git以及S

迈不过友情╰/ 2022年02月26日 08:50/ 0 赞/ 238 阅读

相关 SPRING CLOUD微服务实战笔记--消息驱动的微服务:Spring Cloud Stream

Spring Cloud Stream 快速入门核心概念绑定器发布-订阅模式消费组消息分区

刺骨的言语ヽ痛彻心扉/ 2022年02月25日 19:28/ 0 赞/ 384 阅读

相关微服务学习10——spring cloud stream

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIy

系统管理员/ 2022年02月16日 02:44/ 0 赞/ 152 阅读

相关 Spring Cloud Stream 构建消息驱动微服务使用

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

妖狐艹你老母/ 2022年01月31日 06:41/ 0 赞/ 315 阅读

相关 spring-cloud-stream消息驱动的微服务

Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于Spring Boot 来创建独立的、可用于生产的 Spring 应用程

r囧r小猫/ 2021年06月10日 20:40/ 0 赞/ 501 阅读

相关【微服务】Spring Cloud学习

Spring Cloud是一个基于Springboot实现的微服务架构开发工具。它为微服务架构中设计的配置管理、服务治理、断路器、智能路由、微代理、控制总线、全局锁、决策...

朱雀/ 2020年10月17日 14:16/ 0 赞/ 885 阅读