首页 > TAG信息列表 > poller

Castled 源码解析 - connector 模块connector以及poller说明

connector 属于Castled 一个比较核心的东西,包含了核心部分的datawarehouse数据poll 处理,同时也包含了对于不同外部服务集成的处理 当然才代码中我们也可以看到一部分基于stream 的处理(文件,jdbc,s3.。。。),auth部分基于了oauth目前更多是关注认证,但是没有授权的处理 以下主要说明下

muduo学习简单介绍

介绍 muduo 网络库,是陈硕大神发布在github上的一个c++项目。几乎没有引用第三方库,手动封装了系统api,非常适合不希望仅仅成为简单api调用员的programmer学习。使用cmake编译,同时可以顺便掌握cmake使用。总之我非常推荐后端程序员可以学习一下,尤其是c++程序员,无论是对底层

搜狗workflow项目研究(十)http server(2)

2021SC@SDUSC 本周主要研究server的启动。 在构造了一个server后,start: int WFServerBase::start(int family, const char *host, unsigned short port, const char *cert_file, const char *key_file) { struct addrinfo hints = { .ai_flags = AI_PASSIVE, // key

(P26)muduo_base库源码分析

文章目录 1.muduo网络库的类图2.时序图 1.muduo网络库的类图 类图如下: 解释如下: 灰色是内部类,对外不可见; 白色是外部类,对外可见; EventLoop类 EventLoop是对事件循环的抽象; Poller类,PollPoller类,EPollPoller类 (1)下面的三个是muduo唯一使用面向对象编程思想的地方,下

springMvc笔记-Filter

本笔记基于springBoot 2.3.3版本 一般我们平常如果要使用Filter,会用到如下代码。 @Configuration @ConditionalOnClass(CoreFilter.class) public class CoreFilterAutoConfiguration { @Bean public FilterRegistrationBean coreFilterAutoConfig() { FilterR

tomcat nio读写数据处理流程

前置知识 了解tomcat nio处理流程之前需要了解一下IO多路复用和Reactor模型。下图是主从Reactor多线程模型的设计图,mainReactor负责接收连接,subReactor负载读写数据,工作线程池负责编解码和计算,tomcat的架构模型和下图类似,但是有点区别。      Tomcat Nio网络模型 这个图中的名

tomcat中poller,accepter的作用

org.apache.tomcat.util.net.NioEndpoint.Poller#Poller 1.处理队列中的事件,放到selector中 for (int i = 0, size = events.size(); i < size && (pe = events.poll()) != null; i++ ) { result = true; NioChannel channel = pe.getSock

走进JavaWeb技术世界8:浅析Tomcat9请求处理流程与启动部署过程

本系列文章将整理到我在GitHub上的《Java面试指南》仓库,更多精彩内容请到我的仓库里查看 https://github.com/h2pl/Java-Tutorial 喜欢的话麻烦点下Star哈 文章首发于我的个人博客: www.how2playlife.com 本文是微信公众号【Java技术江湖】的《走进JavaWeb技术世界》其中一篇,本

Muduo源码Poller类 + EpollPoller类详解

  简介          Poller class 是IO multiplexing的封装。在muduo中它是一个抽象类,因为muduo同时支持poll和epoll两种IO multiplexing机制。Poller是EventLoop的间接成员,只供其owner EventLoop在IO线程中调用,因此无需加锁。其生命周期和EvenLoop相等。Poller并不拥有Chan

6张时序图,谈谈Tomcat请求处理流程

很多东西在时序图中体现的已经非常清楚了,没有必要再一步一步的作介绍,本文以图为主,然后对部分内容加以简单解释。绘制图形使用的工具是 PlantUML + Visual Studio Code + PlantUML Extension本文对 Tomcat 的介绍以 Tomcat-9.0.0.M22 为标准。Tomcat-9.0.0.M22 是 Tomcat 目前最新的

6张图说清楚Tomcat原理及请求流程

前言很多东西在时序图中体现的已经非常清楚了,没有必要再一步一步的作介绍,本文以图为主,然后对部分内容加以简单解释。绘制图形使用的工具是 PlantUML + Visual Studio Code + PlantUML Extension本文对 Tomcat 的介绍以 Tomcat-9.0.0.M22 为标准。Tomcat-9.0.0.M22 是 Tomcat 目前最

zeromq源码分析笔记之线程间收发命令(2)

原文链接:https://www.cnblogs.com/zengzy/p/5132437.html 在zeromq源码分析笔记之架构说到了zmq的整体架构,可以看到线程间通信包括两类,一类是用于收发命令,告知对象该调用什么方法去做什么事情,命令的结构由command_t结构体确定;另一类是socket_base_t

Spring集成轮询器以错误的时间间隔触发

代码:https://github.com/giuliopulina/spring-integration-poller 尝试使用Spring集成创建jdbc轮询器时遇到问题. 当我用新数据提供表时,处理速度比预期慢:一切正常,除了每隔60秒触发一次轮询,我无法理解为什么. 2015-05-27 10:50:40,234 DEBUG ExpressionEvaluatingSqlParameterSourc

Tomcat NIO 模型的实现

Tomcat 对 BIO 和 NIO 两种模型都进行了实现,其中 BIO 的实现理解起来比较简单,而 NIO 的实现就比较复杂了,并且它跟常用的 Reactor 模型也略有不同,具体设计如下: 可以看出多了一个 BlockPoller 的设计,这是因为在 Servlet 规范中 ServletInputStream 和 ServletOutputStream 是

zmq Poller

1.注册socket到poller中 poller = zmq.Poller() poller.register(frontend, zmq.POLLIN) # receive worker message poller.register(receiver, zmq.POLLIN) # put message to client     2.接受消息时依据socket标识来判断是该哪个socket接受消息 while True: if socks.g

深入理解SPDK 之二: 消息和无锁队列

并发理论 期望: 随着硬件的线性增加,性能也线性增加; 传统 锁 的优点: 无锁 到有锁 扩展的方便; 锁直接加在共享数据的前面; 缺点:随着系统内线程的增加,数据和临界段的竞争越来越激烈,而且多个线程可能处于不同物理core,频繁竞争导致剧烈的L1 cache 失效。 SPDK的做法:各管各妈;你看我