概念1、group：组内只有1个实例消费。如果不设置group，则stream会自动为每个实例创建匿名且独立的group——于是每个实例都会消费组内单次只有1个实例消费，并且会轮询负载均衡。通常，在将应用程序绑定到给定目标时，最好始终指定consumergroup2、destinationbinder：与外部消息系统通信的组件，为构造Binding提供了2个方法，分别是bindConsumer和b
分类：
编程语言 时间：
2019-08-11 23:36:54
阅读次数：
203
应用处理当消费者在处理接收到的消息时，有可能会由于某些原因而抛出异常。若希望对抛出来的异常进行处理的话，就需要采取一些异常处理手段，异常处理的方式可分为三种：应用层面的处理、系统层面的处理以及通过RetryTemplate进行处理。本小节先来介绍较为常用的应用层面的异常处理方式，该方式又细分为局部处理和全局处理。局部处理Stream相关的配置内容如下：spring:cloud:stream:roc
分类：
编程语言 时间：
2019-08-11 23:33:08
阅读次数：
675
spring cloud的hystrix还有一个配搭的库hystrix dashboard,它是hystrix的一款监控工具,能直观的显示hystrix响应信息,请求成功率等.但是hystrix dashboard只能查看单机和集群的信息,如果需要将多台的信息汇总起来的话就需要使用turbine. ...
分类：
编程语言 时间：
2019-08-11 22:47:03
阅读次数：
130
消息过滤消息过滤是指消费者不希望消费topic里的所有消息，而是只消费部分特定的消息。从topic中挑选出这些特定的消息，就是所谓的消息过滤。通过消息过滤可以实现消息的分流处理，例如生产者生产的消息，header可能都是不尽相同的，这样我们就可以编写两个或多个消费者，对不同header的消息进行针对性的处理。SpringCloudStream实现消息过滤的方式主要有三种，一是使用@StreamLi
分类：
编程语言 时间：
2019-08-11 18:59:07
阅读次数：
167
The base URL for the API is: https://api.cloud.nalantis.com/api/ The OpenAPI documentation is available in YAML or JSON format at: (please note: for v ...
【 前情提要 】Spring Boot Actuator 提供了对单个 Spring Boot 应用的监控，信息包含应用状态、内存、线程、堆栈等，比较全面的监控了 Spring Boot 应用的整个生命周期。但是这样监控也有一些问题：第一，所有的监控都需要调用固定的接口来查看，如果全面查看应用状态需 ...
分类：
编程语言 时间：
2019-08-11 11:17:14
阅读次数：
110
》》spring cloud集成zookeeper例子：https://www.cnblogs.com/li-zhan/p/9401692.html ZooKeeper 和 Eureka 的区别 鉴于服务发现对服务化架构的重要性，Dubbo 实践通常以 ZooKeeper 为注册中心（Dubbo 原 ...
分类：
其他好文 时间：
2019-08-11 00:21:57
阅读次数：
132
[Spring cloud 一步步实现广告系统] 16. 增量投送到kafka
分类：
编程语言 时间：
2019-08-10 23:11:57
阅读次数：
233
[Spring cloud 一步步实现广告系统] 15. 监听Binlog 增量索引准备
分类：
编程语言 时间：
2019-08-10 09:26:31
阅读次数：
75
如何优雅地使用腾讯云COS .NET篇 代码下载地址 https://github.com/whuanle/txypx20190809 前提 创建子账号 打开 https://console.cloud.tencent.com/cam 创建子用户，设置子账号策略为 ，或者参考https://clou ...
分类：
Web程序 时间：
2019-08-10 00:07:28
阅读次数：
450
