1.安装jdk。 2.下载解压flume,修改bin/netcat-memory-logger.conf,内容如下: agent1.sources?=?sources1
agent1.channels?=?channels1?
agent1.sinks?=?sinks1
agent1.sources.sources1.type?=?netca...
分类:
Web程序 时间:
2015-09-24 17:54:37
阅读次数:
416
不管是数据的发送还是数据的接收,大体的流程我们基本上是都理了一下,还分析了数据收发过程中用的数据结构,接下来就看一些UDT中数据收发更精细的一些控制。 UDT数据收发的可靠性保障 来看一下UDT中数据收发的可...
分类:
其他好文 时间:
2015-09-23 21:18:53
阅读次数:
871
看了UDT中数据发送的部分之后,我们转换一个角度,来看一下接收端发生的故事。 如我们前面在 UDT协议实现分析——连接的建立 一文中看到的那样,CUDT在connect()的后半场,会通过调用CRcvQueue::removeConnector(...
分类:
其他好文 时间:
2015-09-21 21:28:04
阅读次数:
599
1介绍功能要求:1 选择用户界面以弹出框方式显示2 页面选项动态载入(部门及用户)3 保存勾选的用户实现分析:保存已选用户逻辑:删除原来已选择的用户记录列表(相当于清空操作)加入新选择用户记录列表页面1 保存共享文件// 保存共享文件 function shareFile(){ ...
分类:
其他好文 时间:
2015-09-18 21:48:34
阅读次数:
151
在前文中,我们有看到,数据发送的过程,大体是发送者CUDT将要发送的数据放进它的CSndBuffer m_pSndBuffer,并将它自己添加进它的CSndQueue m_pSndQueue的CSndUList m_pSndUList的堆里,后面CSndQueue m_pSndQue...
分类:
其他好文 时间:
2015-09-18 20:37:46
阅读次数:
1125
连接建立起来之后,我们就可以通过UDT Socket进行数据的收发了。先来看用来发送数据的几个函数。UDT提供了如下的几个函数用于不同目的下的数据发送: UDT_API int send(UDTSOCKET u, const char* buf, int len, ...
分类:
其他好文 时间:
2015-09-14 19:45:37
阅读次数:
193
UDT Server在执行UDT::listen()之后,就可以接受其它节点的连接请求了。这里我们研究一下UDT连接建立的过程。 连接的发起 来看连接的发起方。如前面我们看到的那样,UDT Client创建一个Socket,可以将该Socket绑定...
分类:
其他好文 时间:
2015-09-12 12:20:20
阅读次数:
1601
1.学习编译原理既掌握编译理论和方法方面的基本知识,而且也获得设计、实现、分析和移植编译程序方面的初步能力。知道程序编译器是怎么编译的,学好了以后可以开发编译器。学会使自己写的程序更优,提高程序的效率。告诉我们编译器是怎么在内存中为程序的函数(包括变量)分配空间的等等。 2.编译原理是计算机专业设置...
分类:
其他好文 时间:
2015-09-11 19:13:38
阅读次数:
149
Flume的安装与配置一、 资源下载资源地址:http://flume.apache.org/download.html程序地址:http://apache.fayea.com/flume/1.6.0/apache-flume-1.6.0-bin.tar.gz源码地址:http://mirrors....
分类:
Web程序 时间:
2015-09-10 17:19:06
阅读次数:
244
Spark Streaming 是Spark核心API的一个扩展,可以实现高吞吐量的、具备容错机制的实时流数据的处理。支持从多种数据源获取数据,包括Kafk、Flume、Twitter、ZeroMQ、Kinesis 以及TCP sockets,从数据源获取数据之后,可以使用诸如map、reduce、join和window等高级函数进行复杂算法的处理。最后还可以将处理结果存储到文件系统,数据库和现场仪表盘。...
分类:
其他好文 时间:
2015-09-10 11:10:49
阅读次数:
212