首页
学习
活动
专区
工具
TVP
发布

RabbitMQ实战

专栏作者
67
文章
73818
阅读量
14
订阅数
Spring环境下获取CorrelationData,msgId的使用方法
通常情况下,对于投递到RabbitMQ的消息,我们一般都会指定一个唯一的msgId来标识一条消息,跟踪这条消息的状态。通常情况下,我们的代码都是这样的:
喜欢天文的pony站长
2022-01-11
8450
Kafka生产者对于消息顺序性的最佳实践
Kafka可以保证消息在一个Partition分区内的顺序性。如果生产者按照顺序发送消息,Kafka将按照这个顺序将消息写入分区,消费者也会按照同样的顺序来读取消息(通过自增偏移量)。 如何保证消息按
喜欢天文的pony站长
2021-12-06
6640
交换机间路由、绑定多个路由键,匿名队列等
原来交换机和交换机之间也能绑定,路由消息.... 绑定多个路由键,需要反复调用queueDeclare,但是却不会被识别为变更queue配置,也不会触发异常(在通常情况下,一个队列/交换机在定义之后,如果有配置变更也不允许修改其配置,必须删除后重新建)。 匿名队列,独占队列,自动删除 独占exclusive队列,只允许创建该队列的connection和channel连接,在channel和connection断开连接之后,独占队列将自动删除,队列内的消息也会丢失。 # 演示目标: 📷 target e-pr
喜欢天文的pony站长
2021-12-06
3820
使用docker-compose搭建zookeeper集群
# 技术 docker: https://www.docker.com docker-compose: https://docs.docker.com/compose/ zookeeper docker image: https://registry.hub.docker.com/_/zookeeper # 集群规划 创建包含3个(奇数个)实例的zookeeper集群。 通过docker-compose创建3个docker-zookeeper镜像,映射的宿主机端口分别为: 2081,2182,2183,集群
喜欢天文的pony站长
2021-08-13
1K0
zookeeper实现获取实例列表与动态感知服务上下线状态
ZK: 相当于是一个文件系统 + 通知机制(观察者模式) image.png # 过程 创建持久化的根节点 /server-pig 客户端监听/server-pig节点下的子节点的上线/下线,当有节点
喜欢天文的pony站长
2021-08-13
5940
《Spring 手撸专栏》第 9 章:虎行有雨,定义标记类型Aware接口,实现感知容器对象
大佬的代码,就像“赖蛤蟆泡青蛙,长的丑玩的花”:一个类实现了多个接口、继承的类又继承了其他类、接口还可以和接口继承、实现接口的抽象类再由类实现抽象类方法、类A继承的类B实现了类A实现的接口C,等等。
喜欢天文的pony站长
2021-08-13
4440
《Spring 手撸专栏》第 11 章:更上层楼,基于观察者实现,容器事件和事件监听器
摔杯为号、看我眼色行事、见南面火起,这是在嘎哈么?这其实是在通过事物传播进行解耦引线和炸弹,仅仅是这样的一个解耦,它放到了多少村夫莽汉,劫了法场,篡了兵权!
喜欢天文的pony站长
2021-08-13
3320
《Spring 手撸专栏》第 14 章:笑傲江湖,通过注解配置和包自动扫描的方式完成Bean对象的注册
你经历过618和双11吗?你加入过大促时候那么多复杂的营销活动赚几毛钱吗?你开发过连读明白玩法都需要一周但只使用3天的大促需求吗?有时候对于有些产品的需求真的是太复杂了,复杂到开发、测试都需要在整个过程中不断的学习最后才可能读懂产品为啥这样的玩,要是一个长期的活动可能也就算了,培养用户心智吗!但这一整套拉新、助力、激活、下单、投保、领券、消费、开红包等等一连串的骚操作下来,如果在线上只用3天呢,或者是只用1天,那TM连参与的用户都没弄明白呢,活动就结束了,最后能打来什么样好的数据呢?对于这样流程复杂,估计连羊毛党都看不上!!!
喜欢天文的pony站长
2021-08-13
4980
RabbitMQ消息路由失败的处理方案(回调与备份交换机AE)
我们知道,消息在RabbitMQ的整个生命周期是生产者投递消息到Exchange,Exchange根据路由键将消息路由到合适的Queue,Queue再将消息推(或消费者主动拉)给消费者。
喜欢天文的pony站长
2021-03-05
1.1K0
《Java 面经手册》PDF,全书 417 页 11.5 万字,完稿&发版!
持续坚持原创输出,点击蓝字关注我吧 作者:小傅哥 博客:https://bugstack.cn ❝沉淀、分享、成长,让自己和他人都能有所收获!? ❞ 目录 一、前言 二、简介 1. 适合人群 2.
喜欢天文的pony站长
2021-03-05
1.6K0
你可知道publisherReturns参数在spring-boot-starter-amqp中的作用?
众所周知,RabbitMQ在保证消息可靠投递的实现过程中有个参数mandatory。该参数的作用是,当消息的mandatory设置为true时,消息投递到Exchange之后,如果Exchange无法将该消息路由到任何一个队列,那么该消息将返回给生产者。当设置为false,RabbitMQ将直接丢弃该消息。
喜欢天文的pony站长
2021-03-05
1.7K0
Redis 日志篇:无畏宕机快速恢复的杀手锏
我们通常将 Redis 作为缓存使用,提高读取响应性能,一旦 Redis 宕机,内存中的数据全部丢失,假如现在直接访问数据库大量流量打到 MySQL 可能会带来更加严重的问题。
喜欢天文的pony站长
2021-03-05
4430
使用自动化插件release来管理maven项目的版本发布
在实际开发过程中,特别是现在推崇的敏捷开发,项目版本的发布非常频繁,有可能是一周就一个版本。对于多模块构建的项目,如何在发布时统一升级项目版本,如果都由人来操作,很容易就漏改某个模块的版本,导致出现问题。本文要介绍的就是使用Maven插件来统一管理这些模块的版本,规范化这一过程。
喜欢天文的pony站长
2020-12-18
3.6K0
微信小程序设置预览页面的三种方式
在开发微信小程序的过程中,我们需要实时预览代码呈现的效果。在默认的情况下,每次保存编译之后,展现的都是/pages/index/index页面,而不是我们期望预览的页面,需要手动进行点击跳转,影响开发效率。那么有没有方法可以将我们当前开发的页面设置为自动预览页呢?有多少种方法? 微信开发者工具设置预览页面的三种方式 (不推荐) 在app.json中设置pages属性数组的顺序,将需要预览的页面路径设置为第一个。 (不推荐) 在app.json中设置entryPagePath属性值为需要预览的页面路径。 (推
喜欢天文的pony站长
2020-12-18
2.6K0
【云+社区年度征文】使用自动化插件release来管理maven项目的版本发布
在实际开发过程中,特别是现在推崇的敏捷开发,项目版本的发布非常频繁,有可能是一周就一个版本。对于多模块构建的项目,如何在发布时统一升级项目版本,如果都由人来操作,很容易就漏改某个模块的版本,导致出现问题。
喜欢天文的pony站长
2020-12-17
5570
RestTemplate设置固定的url参数
在使用RestTemplate请求三方接口时:三方接口一般都要求在url后面拼接上固定的几个参数,一般如accessToken进行权限校验。而我们在开发时,请求这些地址,如何避免在url拼接acces
喜欢天文的pony站长
2020-11-09
2.5K0
Java8 Stream 自定义收集器Collector
在之前的例子中,我们都是使用Collectors的静态方法提供的CollectorImpl,为接口Collector<T, A, R>的一个实现类,为了自定义我们自己的Collector,先来分析一下Collector接口。
喜欢天文的pony站长
2020-10-09
1.7K0
Java8 Stream 基本类型特化流
一、 基本类型特化流(数值流) 在下面这段对流的操作的代码中,其实隐藏着一个问题: 装箱成本,每个原始类型都必须装箱成一个包装类型,如: Stream<Integer> integerStream = Stream.of(1, 2, 3); Integer sum = integerStream.reduce(0, Integer::sum); 为了避免不必要的拆箱和装箱,Java8引入了三个原始类型特化流接口: IntStream, LongStream和DoubleStream,将流中的元素特化为in
喜欢天文的pony站长
2020-10-09
1K0
Java8 Stream 创建流
创建流的方法有很多,常见的如: 从Collection集合创建 根据数值范围创建数值流 从一系列值 从数组 从文件 由函数来生成无限流 一、 从Collection集合 Stream<Integer> stream = new HashSet<Integer>() .stream(); Stream<String> stringStream = new ArrayList<String>() .stream(); 二、 根据数值范围创建数值流
喜欢天文的pony站长
2020-10-09
6310
Java8 Stream流的终端操作
而终端操作会消耗流,以产生一个最终结果,终端操作完成后,流就被消耗了,不可再调用相关操作流的方法。
喜欢天文的pony站长
2020-10-09
6640
点击加载更多
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档