Spring Cloud Eureka 服务消费者
参考《spring cloud 微服务实战》 现在已经构建了服务注册中心和服务提供中心，下面就来构建服务消费者： 服务消费者主要完成：发现服务和消费服务。其中服务的发现主要由Eureka的客户端完成，而消费的任务由Ribbon完成。 Ribbon是一个基于HTTP ...
原文：spring-cloud-stream-rabbit的一个topic对应多组消费者实例
一 概述 Spring Cloud Stream is a framework for building message driven microservice applications. 这是来自官方文档对spring cloud sream的介绍，大致可以理解为Spring Cloud Stream 是一个构建消息驱动微服务的框架，该项目用于代理消息队列的集成过程。避免业务与具体的mq产品有深 ...
2020-12-30 23:32 0 947 推荐指数：
相关推荐
Spring Cloud Stream如何处理消息重复消费？
最近收到好几个类似的问题：使用Spring Cloud Stream操作RabbitMQ或Kafka的时候，出现消息重复消费的问题。通过沟通与排查下来主要还是用户对消费组的认识不够。其实，在之前的博文以及《Spring Cloud微服务实战》一书中都有提到关于消费组的概念以及作用 ...
Spring Cloud Stream如何消费自己生产的消息？
在上一篇《Spring Cloud Stream如何处理消息重复消费》中，我们通过消费组的配置解决了多实例部署情况下消息重复消费这一入门时的常见问题。本文将继续说说在另外一个被经常问到的问题：如果微服务生产的消息自己也想要消费一份，应该如何实现呢？ 常见错误 在放出标准答案前，先放出一个常见 ...
【RocketMQ】同一个项目中，同一个topic，可以存在多个消费者么？
(String topic, String subExpression, MessageListener lis ...
Spring Cloud Stream消费失败后的处理策略（一）：自动重试
之前写了几篇关于Spring Cloud Stream使用中的常见问题，比如： 如何处理消息重复消费 如何消费自己生产的消息 下面几天就集中来详细聊聊，当消息消费失败之后该如何处理的几种方式。不过不论哪种方式，都需要与具体业务结合，解决不同业务场景可能出现的问题。 今天第一节 ...
RocketMQ同一个消费者唯一Topic多个tag踩坑经历
最近做的项目的一个版本需求中，需要用到MQ,对数据记录进行异步落库，这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封装的，然后加上自己的东西，形成个性化的开发，且安全性高。这里就不多透露相关公司的信息啦，我就叫 ...
kafka消费者如何才能从头开始消费某个topic的全量数据
消费者要从头开始消费某个topic的全量数据，需要满足2个条件（spring-kafka）： 对应的spring-kafka消费者客户端配置参数为： 注意：从kafka-0.9版本及以后，kafka的消费者组和offset信息就不存zookeeper ...
kafka消费者如何才能从头开始消费某个topic的全量数据
消费者要从头开始消费某个topic的全量数据，需要满足2个条件（spring-kafka）： 对应的spring-kafka消费者客户端配置参数为： 注意：从kafka-0.9版本及以后，kafka的消费者组和offset信息就不存zookeeper ...