IO（BIO），NIO，AIO的深度解析和区别  IO  概念：Socket又称“套接字”，应用程序通常通过“套接字”向网络发出请求或者应答网络请求。 Socket和ServerSocket类库位于java.net包中，serverSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需

1. 使用命令hadoop namenode -format 对namenode进行格式化，报错如下所示：[hadoop@bj05-ops-photo04 bin]$ ./hadoop namenode -formatDEPRECATED: Use of this script to execute hdfs command is deprecated.Instead use the h...

1、集群部署完成之后，测试上传文件至hdfs时，报出 File /user/hdfs_test.txt._COPYING_ could only be replicated to 0 nodes instead of minReplication (=1)的异常信息。[hadoop@abcd08 chx]$ hadoop fs -put hdfs_test.txt /user14/11/3...

Springcloud配置优化方案1.解决Eureka注册服务慢的问题（1）调整客户端心跳时间instance: # 心跳时间，即服务续约间隔时间（缺省为30s） lease-renewal-interval-in-seconds: 5 # 发呆时间，即服务续约到期时间（缺省为90s） lease-expiration-duration-in-sec...

消息的文件存储机制前面我们知道了一个 topic 的多个 partition 在物理磁盘上的保存路径，那么我们再来分析日志的存储方式。通过如下命令找到对应 partition 下的日志内容[root@localhost ~]# ls /tmp/kafka-logs/firstTopic-1/00000000000000000000.index00000000000000000000...

关于消息分发kafka 消息分发策略消息是 kafka 中最基本的数据单元，在 kafka 中，一条消息由 key、value 两部分构成，在发送一条消息时，我们可以指定这个 key，那么 producer 会根据 key 和 partition 机制来判断当前这条消息应该发送并存储到哪个 partition 中。我们可以根据需要进行扩展 producer 的 partition 机制。...

1.在kafka集群中的topic存储旧数据总量过大时，要使用./kafka-topics.sh --zookeeper node1:2181 --delete --topic log4oa命令删除（特别注意：如果手动删除的话，要把涉及到kafka集群的topic的信息全部删除，例如storm整合kafka，zk中的topic的信息删除，否则会有问题）2.在删除kafka集群的topic时...

消息的保存路径消息发送端发送消息到 broker 上以后，消息是如何持久化的呢？那么接下来去分析下消息的存储，首先我们需要了解的是，kafka 是使用日志文件的方式来保存生产者和发送者的消息，每条消息都有一个 offset 值来表示它在分区中的偏移量。Kafka 中存储的一般都是海量的消息数据，为了避免日志文件过大，Log 并不是直接对应在一个磁盘上的日志文件，而是对应磁盘上的一个目录，这个目..

Spring 总共大约有 20 个模块，由 1300 多个不同的文件构成。而这些组件被分别整合在核心容器（Core Container）、AOP（Aspect Oriented Programming）和设备支持（Instrmentation）、数据访问 及集成（Data Access/Integeration）、Web、报文发送（Messaging）、Test，6 个模块集合中。以 下是 Spr

1.可以使用多少列创建索引？任何标准表最多可以创建16个索引列。2.索引的底层实现原理和优化B+树，经过优化的B+树主要是在所有的叶子结点中增加了指向下一个叶子节点的指针，因此InnoDB建议为大部分表使用默认自增的主键作为主索引。3.什么情况下设置了索引但无法使用1.以“%”开头的LIKE语句，模糊匹配2. OR语句前后没有同时使用索引3. 数据类型出现隐式转...