拥有0000-未整理-等待研究标签的文章

封装一个阻塞队列，轻松实现排队执行任务功能！ - 掘金 - 很好，想法一致

前言个人觉得队列的使用在项目开发中挺多地方可以用到的，所以将如何封装一个队列的过程记录下来，总体来说难度并不大，但毕竟能力有限，如果各位有好的建议或意见欢迎提出来，如果本文能帮到你的话，记得点赞哦。 需求背景在项目开发中，会经常遇到一些需要排队执行的功能，比如发动态时上传多张图片，需要一张一张的上传，比如直播间动画连需发送或者收到消息需要展示时，需要一个一个动画去展示等等场景，这时候...
阅读全文

基于Canal和Kafka实现MySQL的Binlog近实时同步 - 掘金

前提近段时间，业务系统架构基本完备，数据层面的建设比较薄弱，因为笔者目前工作重心在于搭建一个小型的数据平台。优先级比较高的一个任务就是需要近实时同步业务系统的数据（包括保存、更新或者软删除）到一个另一个数据源，持久化之前需要清洗数据并且构建一个相对合理的便于后续业务数据统计、标签系统构建等扩展功能的数据模型。基于当前团队的资源和能力，优先调研了`Alibaba`开源中间件`Canal`的使用...
阅读全文

基于Canal和Kafka实现MySQL的Binlog近实时同步_Java笔记虾-CSDN博客

作者：Throwable juejin.im/post/5e6a6746f265da575c16d678前提近段时间，业务系统架构基本完备，数据层面的建设比较薄弱，因为笔者目前工作重心在于搭建一个小型的数据平台。优先级比较高的一个任务就是需要近实时同步业务系统的数据（包括保存、更新或者软删除）到一个另一个数据源，持久化之前需要清洗数据并且构建一个相对合理的便于后续业务数据...
阅读全文

Kafka 异步消息也会阻塞？记一次 Dubbo 频繁超时排查过程_Java极客技术-CSDN博客

线上某服务 A 调用服务 B 接口完成一次交易，一次晚上的生产变更之后，系统监控发现服务 B 接口频繁超时，后续甚至返回线程池耗尽错误 `Thread pool is EXHAUSTED`。因为服务 B 依赖外部接口，刚开始误以为外部接口延时导致，所以临时增加服务 B dubbo 线程池线程数量。配置变更之后，重启服务，服务恢复正常。一段时间之后，服务 B 再次返回线程池耗尽错误。这次深入排查问题...
阅读全文

仿kafka实现java版时间轮 - 简书

系统定时、超时在我们平时的项目开发中，会设置系统的超时时间，比如在http接口中设置超时时间，在定时调度中也会用到。在jdk的开发的实现Timer和ScheduledThreadPoolExecutor、DelayQueue定时调度中使用的是最小堆，我们知道最小堆的插入时间复杂度是log(n)。在kafka中，采用的是基于O(1)的时间轮算法，本节我们就使用java来模仿层级时间轮。 时...
阅读全文

Kafka（阻塞队列，Spring整合） - 零度以外的风景 - 博客园 - 没什么用，不过先存着吧

阻塞队列队列，先进先出的一种数据结构。阻塞队列其实也就是队列的一种特殊情况。举个例子来说明一下吧，我们去餐馆吃饭，一个接一个的下单，这时候就是一个普通的队列，万一这家店生意好，餐馆挤满了人，这时候肯定不能把顾客赶出去，于是餐馆就在旁边设置了一个休息等待区。这就是一个阻塞队列了。我们使用一张图来演示一下：从上面这张图我们会发现这样的规律：（1）当阻塞队列为空时，从队列中获取元素的操...
阅读全文

redis 延时任务 看一篇成高手系列2_hjm4702192的专栏-CSDN博客_redis延时任务

引言 在开发中，往往会遇到一些关于延时任务的需求。例如 生成订单30分钟未支付，则自动取消 生成订单60秒后,给用户发短信 对上述的任务，我们给一个专业的名字来形容，那就是延时任务。那么这里就会产生一个问题，这个延时任务和定时任务的区别究竟在哪里呢？一共有如下几点区别 1. 定时任务有明确的触发时间，延时任务没有 ...
阅读全文

生成订单30分钟未支付，则自动取消，该怎么实现？

在开发中，往往会遇到一些关于延时任务的需求。例如 生成订单30分钟未支付，则自动取消 生成订单60秒后,给用户发短信 对上述的任务，我们给一个专业的名字来形容，那就是延时任务。那么这里就会产生一个问题，这个延时任务和定时...
阅读全文

ALPN not available for JDK SSL/TLS engine · Issue #3387 · eclipse-vertx/vert.x

I created a simple grpc application with ssl on vertx but got error (my mac osx:v10.14.16, openssl : v1.1.1f, vertx 3.9.0) the sample code: VertxServer rpcServer = VertxServerBuilder. forAddress...
阅读全文

ServiceComb/CSE服务启动报告错误 ALPN not available_微服务技术与实践专栏-CSDN博客

问题背景和描述=======报告 ALPN not available 分两种场景：第一种场景：初始化 HTTP 2 Client 的时候。 CSE (ServiceComb Java Chassis) 默认会初始化 HTTP 2 Client，方便和启用了 HTTP 2 协议的 Provider 进行通信。 123456789101112...
阅读全文