通过简单的python脚本，获取指定group的队列长度
分类：
其他好文 时间：
2020-09-23 23:30:54
阅读次数：
69
滑动平均滤波就是把连续取得的N个采样值看成一个队列，队列的长度固定为N，每次采样得到一个新数据放到队尾，并丢掉原来队首的一次数据，把队列中的N个数据进行平均运算，就可以获得新的滤波结果。 java代码实现： // N点滑动平均滤波器 public static float[] MovingAvera ...
分类：
其他好文 时间：
2020-09-23 23:24:36
阅读次数：
35
IO队列长度监控 #!/bin/bash io () { device_num=`iostat -x | egrep "^sd[a-z]"` | wc -l iostat -x 1 3 | egrep "^sa[a-z]" | tail -n +$((device_num+1)) | awk '{i ...
分类：
其他好文 时间：
2020-09-21 11:55:46
阅读次数：
45
Kafka是Apache下的一个子项目，是一个高性能跨语言分布式发布/订阅消息队列系统，吞吐速率非常快，可以作为Hadoop的日志收集。Kafka是一个完全的分布式系统，这一点依赖于Zookeeper的分布式实现。 本文为新手准备，从Kafka的一些术语概念方面去认识Kafka。 Broker Ka ...
分类：
其他好文 时间：
2020-09-18 17:19:41
阅读次数：
37
爱生活，爱编码，微信搜一搜【架构技术专栏】关注这个喜欢分享的地方。 本文 架构技术专栏 已收录，有各种视频、资料以及技术文章。 一、问题 今天有个小伙伴跑过来告诉我有个奇怪的问题需要协助下，问题确实也很奇怪。客户端调用RT比较高并伴随着间歇性异常Connection reset出现，而服务端CPU ...
分类：
其他好文 时间：
2020-09-18 12:08:59
阅读次数：
33
多任务和cpu时间片： 不过，cpu如何选择下一个要执行的进程，这是一件非常复杂的事情。在Linux上，决定下一个要运行的进程是通过"调度类"(调度程序) 来实现的。程序何时运行，由进程的优先级决定。除此之外，优先级还影响分配给进程的时间片长短。在Linux中，改变进程的nice值， 可以影响某类进... ...
分类：
系统相关 时间：
2020-09-18 03:00:11
阅读次数：
45
一、消息队列的特性 业务无关，一个具有普适性质的消息队列组件不需要考虑上层的业务模型，只做好消息的分发就可以了，上层业务的不同模块反而需要依赖消息队列所定义的规范进行通信。 FIFO，先投递先到达的保证是一个消息队列和一个buffer的本质区别。 容灾，对于普适的消息队列组件来说，节点的动态增删和消 ...
分类：
其他好文 时间：
2020-09-18 01:55:33
阅读次数：
32
概述秒杀系统的特征就是瞬间流量大、商品总是有限先到先得、有明确的开始和结束时间。方案秒杀的时候，先是要在后台设置秒杀库存，秒杀价格，秒杀开始时间和时间，需要参与秒杀的店铺，到了时间就开始进行秒杀，秒杀的时候，会有突发流量，系统如果设置不好，就会瘫痪，一般会进行限流，比如接入端限流，服务端限流，利用缓存、消息队列提高处理速度；其中一个最难处理的问题就是库存的扣减，防止超卖，防止超卖的方法有很多种,对
分类：
其他好文 时间：
2020-09-18 00:40:39
阅读次数：
33
现如今，Kafka已不再是一个单纯的消息队列系统。Kafka是一个分布式的流处理平台，被越来越多的公司使用，Kafka可以被用于高性能的数据管道，流处理分析，数据集成等场景。本文分享总结了几个Kafka常见的面试问题，希望对你有所帮助。主要包括以下内容：Kafka是如何保障数据不丢失的？如何解决Kafka数据丢失问题？Kafka可以保障永久不丢失数据吗？如何保障Kafka中的消息是有序的？如何确定
分类：
其他好文 时间：
2020-09-17 23:41:36
阅读次数：
33
package main import ( "crypto/rand" "fmt" "math/big" "strconv" "strings" "time" ) type task struct { id uint32 // 订单编号 callback chan int // 工厂编号 } con ...
分类：
其他好文 时间：
2020-09-17 23:14:01
阅读次数：
31
