Sqoop 在hadoop和关系型数据库之间转换数据 Flume Flume是一个分布式的高可用的数据收集、聚集和移动的工具。通常用于从其他系统搜集数据，如web服务器产生的日志，通过Flume将日志写入到Hadoop的HDFS中 Canal 数据抽取是 ETL 流程的第一步。我们会将数据从 RDB ...
分类：
其他好文 时间：
2020-09-17 18:33:30
阅读次数：
37
java线程池 什么是线程池？ 线程池就是一个容器，把创建的若干个线程放入这个容器中，当处理任务需要运行线程时，线程池会将线程提交到任务队列中，处理完之后线程并不会被销毁，而是仍然处于线程中，等待下一任务，如果之后还有任务要使用这个线程，该线程会再次被提交到任务队列中。 使用线程池的优点 java中 ...
分类：
编程语言 时间：
2020-09-17 16:34:14
阅读次数：
22
基于NIO、NIO2、APR的http链接器支持的属性 属性 描述 默认值 acceptCount 当所有请求处理线程均被占用，等待请求队列的最大长度。当队列填满时，接收到的任何请求均会被拒绝 100 acceptorThreadCount 接收连接的线程数。对于多核服务器或者当前存在过多的非kee ...
分类：
Web程序 时间：
2020-09-17 16:03:53
阅读次数：
31
1 BOM：浏览器对象模型 2 load等页面全部加载完毕，包含页面dom元素，图片，flash，css等 3 window.onload = function(); // 当页面 DOM 结构中的 js、css、图片，以及 js 异步加载的 js、css 、图片都加载完成之后，才会触发 load ...
分类：
Web程序 时间：
2020-09-17 15:42:30
阅读次数：
31
消费者在消费消息的时候，可以根据业务场景来选择拒绝消息，通过参数设置是否让消息再次入队。拒绝消息的指令有俩，一个是basicNack，一个是basicReject，这两个区别是后者不能批量拒绝，只能单条拒绝。代码演示如下： 一个生产者，两个正常消费者，一个拒绝消息的消费者，三个消费者共同订阅一个队列 ...
分类：
其他好文 时间：
2020-09-17 14:11:23
阅读次数：
17
/** * 使用数组模拟队列 * @author Administrator */ public class ArrayQueueDemo { public static void main(String[] args) { ArrayQueue arrayQueue = new ArrayQueu ...
分类：
编程语言 时间：
2020-09-17 13:59:28
阅读次数：
24
1.kafka是一个分布式的消息队列，缓存系统，消息的发布和订阅系统。 2.始于Linkedin公司，开源于apache。 3.包含生产者，消费者，broker。 4.每秒支持百万消息处理。 5.支持多个生成者，多个消费者，多个broker 6.生成者产生数据，按topic分类数据，对数据进行分区， ...
分类：
其他好文 时间：
2020-09-17 13:42:05
阅读次数：
36
这种题目很容易就联想到独立算贡献，某条边的贡献就是他的权值和底下叶子节点的数量相关。 我们用优先队列的方法取最大，记得算大小的时候是按减一半的贡献再算 #include<bits/stdc++.h> using namespace std; typedef long long ll; typedef ...
分类：
其他好文 时间：
2020-09-17 13:36:21
阅读次数：
28
kafka是很流行的一款消息队列和流处理组件，其生态非常丰富，今天只简单介绍一下它的安装。 一. Zookeeper安装 kafka高度依赖于Zookeeper做集群协调和分布式存储，当然kafka社区正在逐渐去掉对Zookeeper的依赖，不过至今你还是需要Zookeeper。 下载清华镜像：ht ...
虚拟币交易所作为整个区块链行业发展过程中的资金与信息导流入口，也是数字加密资产市场价值迸发的助推动力，理应服务于广大投资者的根本利益，为优质区块链项目提供良好便捷的融资环。虚拟币交易所开发有哪些类型模式？1.币币交易：交易所开发V：jys-wu指虚拟货币之间（如用比特币购买以太币或反之）的交易。法币交易和币币交易可通过场外或场内的交易方式进行。2.场内交易：又称交易所交易；在虚拟货币交易平台上进行
分类：
其他好文 时间：
2020-09-17 13:07:34
阅读次数：
28
