系统编程课上遇到的一个问题：Linux下，如果一个 pthread_create 创建的线程没有被 pthread_join 回收，是否会和僵尸进程一样，产生“僵尸线程”？...由此猜测有可能是两种可能性中的一种： 内核可能对线程 task 有一定的特殊照顾/特殊处理，使得线程的 task 会在退出时自动 reap，而进程则等待父进程回收。...我们想要从中找到这个逻辑：exit 的时候，内核根据什么决定是否直接 reap 掉 task。...这实际上正是我们要找的「exit 决定是否直接 reap 掉 task」的决策过程的一部分。猜测对于线程 task 是否自动 reap 的决策逻辑也是在相同的位置或附近。...结论 对于 Linux 平台上的 pthread 线程，在子线程比父线程先退出且没被 JOIN 的情况下，不会产生和传统意义上的僵尸进程类似的“僵尸线程”（即 ps 不会看到有 defunct 的线程
在过去的几年中，Apache Kafka 的功能和覆盖范围已经有了很大的提高。...（2）流处理 有了一个健壮、可扩展的消息系统，如果能方便的对消息数据流进行处理就更好了。...Stream API 可以轻松实现： 无状态操作，例如信息流的过滤和转换 有状态操作，例如在一个时间窗口内的连接、聚合操作 流处理的示例代码 从输入流读取文本，对每个单词进行计数，然后把计数结果写到输出流...可以使用kafka对网站行为（页面浏览、搜索等用户产生的行为）进行跟踪和分析，事实上，这才是kafka的初始应用场景，LinkedIn 开发 kafka 时就是为了干这个。...比如你有大量的位置数据，需要实时处理，来跟踪车辆路径、距离等等。
1、检测是否有安装redis-cli和redis-server; [root@localhost bin]# whereis redis-cli redis-cli: /usr/bin/redis-cli
比如在众多的大学课程中，有些课有先修课，我们可以将其抽象为拓扑排序，有向边(v, w)表明课程v必须安排在w之前，否则课程w就无法进行。...虽然有圈图没有拓扑序列，但是我们可以利用拓扑排序的算法来判断一个有向图是否有圈。 算法描述如下： 1. 将所有入度为0的顶点放入队列； 2....否则，说明总 有顶点入度不为0，没有放入队列中，即该有向图有圈。...DFS 关于DFS的介绍请戳我，通过稍微修改DFS，利用递归的特点，也可以判断有向图是否有圈。...\n"); } return 0; } 上述利用DFS判断有向图是否有圈实际上是利用了深度优先生成树的性质：有向图无圈当且仅当其深度优先生成树没有回退边， 而上述算法中的vis[graph
虽然公司有运维，但也不能啥都靠他们，万一哪天环境出问题了，你不能一上来就找运维吧，丢脸脸~ 今天分享一套从零开始搭建一套kafka集群的笔记，我几乎帮你踩了所有的坑，你只需按步骤来，有手就行...如果没装，出门右转，先把jdk搞完再回来接着看，linux安装jdk环境 ---- 搭建zookeeper集群 虽然kafka 0.5.x 以上版本已经集成了zk，但我们最好还是单独部署一套...，两个原因 1、kafka自带的zk是单机的，修改配置也能改成集群，但是有风险，搞不好把kafka改坏了 2、讲道理，虽然kafka依赖zk，但是这毕竟是两个组件，独立出来当然更好，我们应该降低耦合度...kafka服务 cd /opt/kafka/kafka_2.11-1.0.0 ....如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
今天来安装kafka 安装kafka前台必须安装zookeeper 一、安装kafka 下载kafka两种方式 1、手动下载 下载地址：http://kafka.apache.org.../bin/bash #启动zookeeper /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-start.sh /DATA/kafka/kafka_2.12.../DATA/kafka/kafka_2.12-2.0.0/config/server.properties & 关闭命令： 关闭kafka： 在kafka目录下执行 ....如果进入死循环有两种解决办法： 1、重启服务 shutdown -h 10 #计算机将于10分钟后关闭，且会显示在登录用户的当前屏幕中 shutdown -h now...终、、 ---- 以上就是linux安装kafka方法，有什么问题可以联系我哈。 ---- 感谢一路支持我的人。。。。。
判断一个单向链表是否有环。（指向表头结点的指针为head） 方法一： （1）用两个指针p1和p2分别指向表头结点，即p1=p2=head （2）p1和p2分别采用1和2作为步长遍历该链表。...（注意，p2应该检查当前结点的下一个结点是否为NULL） （3）如果p1或者p2遇到了NULL，则证明该链表没有环；若p1和p2在某时刻指向同一结点，则说明该链表有环。...(fast == NULL || fast -> next == NULL); } （4）若该表有环， （a）设从表头结点（包括）开始到环开始的结点（不包括）共 有l1个结点；设从环开始结点（包括）到它们相遇的结点...更多解法请见：http://topic.csdn.net/t/20040906/09/3343269.html# 扩展问题： 判断两个单链表是否相交，如果相交，给出相交的第一个点（两个链表都不存在环）。...比较好的方法有两个： 一、将其中一个链表首尾相连，检测另外一个链表是否存在环，如果存在，则两个链表相交，而检测出来的依赖环入口即为相交的第一个点。
根据业务场景选择是否增加该配置。 ? 发送完消息消费者会变成感叹号哦！点击查看输入内容已经打印控制台证明消费成功。...如果进入死循环有两种解决办法： 1、重启服务 shutdown -h 10 #计算机将于10分钟后关闭，且会显示在登录用户的当前屏幕中 shutdown -h now #计算机会立刻关机...segment没有达到log.segment.bytes设置的大小，也会强制新建一个segment 会被 topic创建时的指定参数覆盖 log.roll.hours =24*7 ## 日志清理策略 选择有：..."数据可靠性"与"性能"之间做必要的权衡. ## 如果此值过大,将会导致每次"fsync"的时间较长(IO阻塞) ## 如果此值过小,将会导致"fsync"的次数较多,这也意味着整体的client请求有一定的延迟...## 消息的压缩模式，默认是none，可以有gzip和snappy compression.codec = none ## 可以针对默写特定的topic进行压缩 compressed.topics
import java.util.Scanner; import java.util.HashMap; public class Main { publ...
因为有内存对齐的存在，编译器使用了内存对齐，那么最后的大小结果就会不一样。至于为什么要做对齐，主要考虑下面两个原因： 平台（移植性） 不是所有的硬件平台都能够访问任意地址上的任意数据。...On non-Linux ARM, the 64-bit functions use instructions unavailable before the ARMv6k core....79:11: struct of size 48 bytes could be of size 40 bytes (maligned) type SASL struct { ^ 提示有一处
操作一：定义了两个变量来记录，A一个一次走一步，B一个一次走两步，如果有环B必然会追上A。如果无环B必然会先遍历完。
Day 40：判断链表是否有环 1 链表有环是什么意思？ 在判断是否有环前，需要先知道什么是链表中的环？ 如下所示的链表有5个节点组成，框内的数字代表编号，也可理解为节点的地址。...所以，研究如何判断链表是否有环，是一个非常有意义的课题，也是面试中常考的。...2 如何判断链表是否有环 通过哈希的方法，代码比较好理解： class Solution(object): def hasCycle(self, head): s = set()...return True s.add(tmp) tmp = tmp.next return False 今天主要分析如何使用快慢指针判断链表是否有环...快慢指针判断链表是否有环，代码其实非常清晰，但是理解背后的数学原理，才是真正写出代码的关键，也就说一旦理解原理，就会很自然的写出代码；相反，如果不理解，仅仅凭记忆，那么时间长了，就容易忘记，面试时就容易写错
把kafka解压到linux去配置文件中配置环境 配置kafka文件内容 进入kafka/config目录修改server.properties 文件 修改broker.id= id...先要三台机器都启动zookeeper集群 把kafka分发到另外几台机器中 环境也要进行分发 把另外几台机器的ip 和id修改成相应的ip即可 修改完后直接启动服务即可 kafka-server-start.sh...kafka/config/server.properties & kafka测试创建主题 kafka-topics.sh --create --zookeeper hadoop2:2181 --replication-factor...1 --partitions 1 --topic lol 查看当前所有列表 kafka-topics.sh --zookeeper hadoop3:2181 -list 启动生产者 bin/kafka-console-producer.sh...如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
一、环境准备 jdk下载地址链接：jdk 1.8，提取码: dv5h zookeeper下载地址链接：zookeeper3.4.14 ，提取码: 3dch kafka下载地址链接：kafka2.12...，提取码: 61bc 1.1 Java环境为前提 1.1.1 上传jdk-8u261-linux-x64.rpm到服务器并安装 1.1.2 配置环境变量 至此，jdk安装成功。...1.3 Kafka 的安装与配置 1.3.1 上传kafka_2.12-1.0.2.tgz到服务器并解压 1.3.2 配置环境变量并生效 1.3.3 配置/opt/kafka_2.12-1.0.2.../config中的server.properties文件 配置kafka存储持久化数据目录 创建上述持久化数据目录 1.4 启动Kafka 进入Kafka安装的根目录，执行如下命令：...1.5 重新开一个窗口，查看Zookeeper的节点 1.6 此时Kafka是前台模式启动，要停止，使用Ctrl+C 如果要后台启动，使用命令： 查看Kafka的后台进程： 停止后台运行的Kafka
Kafka集群搭建与配置 准备工作 安装java环境 搭建zookeeper集群 搭建kafka集群 1....安装JAVA环境 在每台主机下执行下面步骤： 将安装包移到/usr/local目录下 mv jdk-8u162-linux-x64.tar.gz /usr/local 解压文件 tar -zxvf jdk...-8u162-linux-x64.tar.gz 重命名文件夹为java mv jdk-8u162-linux-x64 java 用vim打开/etc/profile文件(Linux下配置系统环境变量的文件...配置环境变量 最后，需要让该环境变量生效，执行如下代码： source /etc/profile 检验JAVA是否安装成功 >echo $JAVA_HOME ; # 检验变量值 >java -version...，在文件末尾添加kafka环境变量 #set kafka environment export KAFKA_HOME=/usr/local/kafka PATH={KAFKA_HOME}/bin:PATH
问题 “把 Kafka 作为长期存储有问题吗？”...这些长期存储的场景都是真实可行的，因为 Kafka 就是这么设计的 数据在 Kafka 中是持久化到硬盘的，有数据检查，有多副本来容错，并且持续累加的数据不会使性能变慢 实际应用案例中，已经有存储 PB...形式运行，可以弹性的扩展和缩减，有容错复制系统，具有高可用性 kafka 允许实时的数据流处理，而不是一次处理一条消息 kafka 已经不是一个传统的消息队列，而应该归类到“流处理平台” Kafka...答案是不会，主要原因有2个： 数据库主要是关于查询的，kafka 是顺序读写机制，如果加入随机访问机制，对 kafka 没有什么好处 kafka 的发展目标不在于成为第1001个数据库，而是要成为主流的流数据处理平台...，成为现代数字业务中的核心系统 小结 kafka 已经不是一个简单的消息系统，kafka 在不断壮大，有 connector 可以方便的连接其他系统，有 stream api 进行流计算，最近又推出 KSQL
消息队列 kafka可以很好的替代一些传统的消息系统，kafka具有更好的吞吐量，内置的分区使kafka具有更好的容错和伸缩性，这些特性使它可以替代传统的消息系统，成为大型消息处理应用的首选方案。...中：客户端—>应用—>kafka SpringBoot中默认使用的是logback，所以要在引入SpringBoot的jar包时排除掉logback的jar包 日志消息发送有同步和异步两种方式，由KafkaAppender...--kafka topic--> <!...var kafka = require('kafka-node'), Producer = kafka.Producer, client = new kafka.KafkaClient...如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
kafka作为一个消息流处理平台。很多开发人员都作它作为一个生产&消费的中间件，并没有细细去思考kafka可以在哪些应用场景中使用，下面根据我的经验，总结下kafka可以应用在以下场景中。...我日常需要将多台服务器上的日志集中收集到一个点上，通过logstash进行扫描并发到kafka队列中，然后通过消费者程序进行消费写到hbase或者es中。...当我们面对很多平台或组件的日志时，需要将这些平台或组件的日志统一起来，可以通过kafka统一起来，再分类处理，毕竟kafka是将数据进行字节流处理，不关注数据格式。...流处理 这种用法我暂时也没有用过，这种是在kafka2.0的版本才出现的，对于这种处理目前我还是使用flink或者spark进行处理，有机会可以尝试下是否具有较高的可用性，毕竟这可以减少组件的维护同时提高数据处理能力...如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
获得投资经验有四种方法：实践、历史、理论和统计。大多数人是通过第一种，即实际操作，这是最重要的经验获取方法。...（2）A股市场是否存在“月份效应”呢，如“1月效应”？ （3）如何利用Python可视化工具对指数进行图谱分析？...从1993年至2018年，上证指数有13年是下跌的，另外13年是上涨的，很fair哦，看来上证指数是属天秤座的。...有实证研究表明，美国股票市场表现为“1月效应”，即1月份的平均收益率为正，且显著高于其他月份的平均收益。...各个月历史收益率的单样本t检验（检验均值是否异于0）、双样本t检验（检验某月份与其余月份收益率是否存在显著差异），结果如下表所示。
今天来看个需求，如何判断 Activity 上面是否有弹窗，当然，简单的方式肯定有，例如在 Dialog show 的时候记录一下，但这种方式不够优雅，我们需要一款更通用的判断方式。...所以，我们只需要判断在 mView 集合中，两个 activity 之间是否有存在其他的 View，如果有，那就是有弹窗，开发步骤为： registerActivityLifecycleCallbacks...获取所有 Activity 的实例 传入想判断是否有弹窗的目标 Activity 实例，并获取该实例的 DecorView 拿到所有 Activity 实例的 DecorView 集合 遍历 mView...那有没有一种方法，可以直接遍历 mView 集合就能找到目标 Activity 是否有弹窗呢？还真有，那就是 AppToken。...第一种方案会判断失败，因为这时候的弹窗 View 在第一个 Activity 与 第二个 Activity 之间，所以，第二个 Activity 无法通过区间的方式判断到是否有弹窗 第二种方案判断成功
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
