数据分页： $Data = M('Channel'); // 实例化Data数据模型 $content = $Data->page($page, 4)->select(); $totalCount = $Data->count...
分类：
其他好文 时间：
2015-03-06 16:56:41
阅读次数：
111
1.decode的用法：(select max(DECODE(logicSn,null,physicalid+1,logicSn+1)) from m_logic_channel where physicalid=#{physicalId}),2.nvl的用法：(select nvl(max(t.l...
分类：
数据库 时间：
2015-03-06 13:59:50
阅读次数：
154
HDFSEventSink用于把数据从channel中拿出来（主动pull的形式）然后放到hdfs中，HDFSEventSink在启动时会启动两个线程池callTimeoutPool和timedRollerPool，callTimeoutPool用于运行append/flush等操作hdfs的task（通过callWithTimeout方法调用，并实现timeout功能），用于运行..
分类：
Web程序 时间：
2015-03-06 06:24:34
阅读次数：
254
flume的主要组件包括：Source,SourceRunner,Interceptor,Channel,ChannelSelector，ChannelProcessor，Sink,SinkRunner,SinkProcessor,SinkSelector等工作流程包含两个部分：source->channel，数据由source写入channel，主动模式，主要步骤如下：一个SourceRunner包含一个So..
分类：
Web程序 时间：
2015-03-06 06:24:30
阅读次数：
217
remoting提供一种允许对象通过应用程序域去与另一对象进行交互的框架。如果要通过应用程序域进行通信，在remoting中要通过信道（channel）来实现。信道信道是跨越远程处理边界（应用程序域，进程，计算间之间）在应用程序之间传递消息的对象。信道可以在终结点监听入站消息，向基他终结点发送出站消...
分类：
Web程序 时间：
2015-03-05 10:36:10
阅读次数：
138
初识golang，这部分也不是很了解，百度了一下，做个小记录goroutine是golang用来做并发处理的，使用起来很简单 go func(){...}()，就是看起来随便用一般而容易go的滥用，所以使用时要仔细斟酌才好。channel 大约是用来在线程间传递数据的，主线程开通一个channel，...
分类：
其他好文 时间：
2015-03-04 14:32:48
阅读次数：
163
我们可以使用Channel来同步不同goroutines的执行。看下面的代码：package main import "fmt"import "time" //这个函数会在新的goroutine中运行，执行结束时会给done channel中传入值true//注意到中间有sleep了一秒func w...
分类：
其他好文 时间：
2015-03-04 11:01:13
阅读次数：
157
flume作为日志收集端，其本质上也是一个生产者消费者结构，source作为消息的producer，sink作为消息的consumer，中间的channel作消息的存储为了保证消息消费的正确性，flume使用了事务的机制，主要涉及的类：1）org.apache.flume.Transaction接口类，为访问channel提供事务的功..
分类：
Web程序 时间：
2015-03-04 06:22:18
阅读次数：
282
对于flume的监控，只需要监控channel的性能数据即可，source和sink的性能一部分可以从channel中表现出来。以MemoryChannel为例，在MemoryTransaction的构造函数中会实例化一个org.apache.flume.instrumentation.ChannelCounter对象publicMemoryTransaction(inttransCapacity,Ch..
分类：
Web程序 时间：
2015-03-04 06:22:07
阅读次数：
250
计时器用来定时执行任务，分享一段代码：package main import "time"import "fmt" func main() {//新建计时器，两秒以后触发，go触发计时器的方法比较特别，就是在计时器的channel中发送值timer1 := time.NewTimer(time.Se...
分类：
编程语言 时间：
2015-03-03 09:50:56
阅读次数：
147
