定时说说取消发送

1. 主要把这几个对象给你对应上，后面看源码就不会太吃力了：

2. 博主当年早期是用quartz来实现的(实习那会的事)，简单介绍一下

3. 因为我们已经知道wheel.length是2的n次方。

4. 上面其实就是维护或者判断当前HashedWheelTimer的状态，从源码中我们知道状态有三个取值：

5. 参与同学按照当日打卡任务完成打卡，保证打卡内容真实有效，发现弄虚作假的取消资格；

1. TCP是全双工的，在接收方返回ACK的时候，同时还需要向对方传输一些数据，这时候可以将数据和ACK报文合并成一个分组，称之为捎带技术

2. 其实用定时任务，确实有点问题，原本业务系统希望10分钟后，如果订单未支付，就马上取消订单，并释放商品库存。但是一旦数据量大的话，就会加长获取未支付订单数据的时间，部分订单就做不到10分钟后取消了，可能是15分钟，20分钟之类的。这样的话，库存就无法及时得到释放，也就会影响成单数。而利用延迟消息，则理论上是可以做到按照设定的时间，进行订单取消操作的。

3. 运行完后，可以看到如下信息：

4. 这也是Dubbo引入时间轮之后进行的优化。

5. Redis主从握手流程，你真的了解了吗？

1. 可选择“立即发送”或“删除”，如果想要立即发送，就点击“立即发送”。

2. 如何感知网络拥塞？我们可以通过丢包率来判断，根据对应的公式，算出网络拥塞下的发送速率该有多大，进而求出当前的滑动窗口大小。

3. 大家一般都能想到JDK里面提供的ScheduledExecutorService和Timer这两个类。

4. 是的，这就是我当时看源码的一个疑问。

5. 那么System.nanoTime()+unit.toNanos(delay)就是这个任务需要被触发的纳秒数。

6. 如果startTime等于即没有被初始化的话，就调用CountDownLatch的await等待一下下。

7. 点赞和在看就是最大的支持❤️

8. 后台回复关键词计算机网络获取今日推荐资料

9. (233期)Java8stream处理List集合的相同部分(交集)、去重！

10. (1)由于使用Redis作为消息通道，消息都存储在Redis中。如果发送程序或者任务处理程序挂了，重启之后，还有重新处理数据的可能性。

1. 如果成功了就调用remove方法移除这个请求，没有成功的会抛出异常，打印日志，然后等待下次再次重试。

2. 那么问题就来了。假设这个时候我有一个需要在800秒之后执行的任务，应该是怎么样的呢？

3. 接下来分析bucket.expireTimeouts(deadline)这一行代码。

4. 接收方窗口=发送方窗口=N。

5. 到了群发时刻，消息状态变更为“发送中”，群发操作开始执行。成功群发的消息进入已群发消息列表。

6. (263期)存ip地址用什么数据类型比较好?

7. 先说明一下，为了方便我截图，下面的部分截图我是移动了源码的位置，所以可能和你看源码的时候有点不一样。

8. 看第52行，它是5秒。

9. 时间轮在Dubbo里面有好几次使用，比如心跳包的发送、请求调用超时时间的检测、还有集群容错策略里面。

10. #你好，今天#Day2:……。@材料学院自律中心

1. 请看标号为②的retryFailed方法：

2. 要我赶紧上时间轮的源码。

3. (232期)面试官：如何保护SpringBoot配置文件敏感信息？

4. 也就是说要让下面标号为③的地方，多睡1ms。

5. 这也是我在源码注释里面提到的，时间轮里面数组的大小必须是2的n次方。

6. (1)需要额外进行redis维护

7. 在Netty里面，有个老哥发现时间轮并没有用上了，甚至想把它给干掉：

8. 每一次快速重试都会降为一半。

9. 所以Rdt0新机制就是采用了差错控制编码进行差错检测

10. 第一个划线的地方大概意思是说当线程调用Thread.sleep方法的时候，JVM会进行一个特殊的调用，将中断周期设置为1ms。

1. 好，那么问题来了，怎么防止内存溢出呢？

2. 干的就是“定时重发”这事：

3. 该方案使用redis的KeyspaceNotifications，中文翻译就是键空间机制，就是利用该机制可以在key失效之后，提供一个回调，实际上是redis会给客户端发送一个消息。是需要redis版本8以上。

4. 所以方法进来第一行就是计算下一个时刻的纳秒值是啥。

5. 有的同学看到这里可能着急了：不是说讲时间轮吗，怎么又开始撸源码了呀？

6. 如果当前指针指在1上面，我有一个任务需要4秒以后执行，那么这个执行的线程回调或者消息将会被放在5上。那如果需要在20秒之后执行怎么办，由于这个环形结构槽数只到如果要20秒，指针需要多转2圈。位置是在2圈之后的5上面(20%8+1)

7. 所以rdt0做的工作就是封装和解封装

8. 操作骚，速度快，逼格高。

9. startTime我们前面分析了，其实初始化的时候也是System.nanoTime()，初始化完成后就是一个固定值了。含义是worker线程启动的时间点。

10. 推荐下自己做的Springboot的实战项目：

1. 当然了，MQ的延迟队列也可以，但是不是本文的讨论范围。