系统编程课上遇到的一个问题：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 今天主要分析如何使用快慢指针判断链表是否有环...快慢指针判断链表是否有环，代码其实非常清晰，但是理解背后的数学原理，才是真正写出代码的关键，也就说一旦理解原理，就会很自然的写出代码；相反，如果不理解，仅仅凭记忆，那么时间长了，就容易忘记，面试时就容易写错
一、环境准备 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
安装包准备 JDK1.8 : JDK1.8 kafka_2.12-2.6.0 : kafka_2.12-2.6.0 zookeeper-3.5.8 : zookeeper-3.5.8 kafka_...} 配置JAVA环境 tar -zxvf jdk-8u221-linux-x64.tar.gz -C /usr/local/ echo "export JAVA_HOME=/usr/local/jdk1.8.0.../zkServer.sh status 搭建Kafka集群 节点一 ##部署kafka服务 wget https://mirror.bit.edu.cn/apache/kafka/2.6.0/kafka.../kafka-server-start.sh -daemon /usr/local/kafka_2.12-2.6.0/config/server.properties jps 节点二 ##部署kafka...服务 wget https://mirror.bit.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz tar -zxvf kafka_2.12-2.6.0.
把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...如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
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检验（检验某月份与其余月份收益率是否存在显著差异），结果如下表所示。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
