首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Jafka来源分析——Processor

Jafka Acceptor接受client而建立后的连接请求,Acceptor会将Socket连接交给Processor进行处理。...Processor通过下面的处理步骤进行client请求的处理: 1. 读取client请求。 2. 依据client请求类型的不同,调用对应的处理函数进行处理。...Processor读取client请求是一个比較有意思的事情,须要考虑两个方面的事情:第一,请求规则(Processor须要依照一定的规则进行请求的解析)。...Processor接收到Acceptor分配的socket连接后。会为socke连接建立一个BoundedByteBufferReceive并将其与socket连接进行绑定。...直到一次请求彻底读取完毕,详细过程如以下代码(Processor.read)所看到的: private void read(SelectionKey key) throws IOException {

58310

Apache NiFi 简介及Processor实战应用

3 NiFi Processer实战 说了那么多,介绍了NiFi的架构和Processor,那么说好的实战呢?那么,本文就以笔者的一个实际需求为例,进行Processor的实战。...能更好的支持远程操作的Processor为ExecuteProcess。...3.1 Processor的添加与配置 1. 点击“Add Processor”,选择ExecuteProcess后点击Add按钮完成添加,如下图。 2....3.3 运行状态监控 NiFi通过Rest API供开发者调度,这里我们用Processor API对运行状态进行监控(状态参数获取、Processor的启动与停止)。 1....Processor的启动与停止: NiFi的Processor启动停止通过其Put方法实现,Put最有效的作用是改变其运行状态,NiFi的Process总共有三种状态,即Running、Stopped和

7.2K100
领券