Thrift0.9.3 C++版代码阅读随笔——TNonblockingServer

0.一些参考资料

(参考资料1)对thrift的一个基本介绍可以参考:

http://wenku.baidu.com/link?url=LLL5H3qL4hJ3o6dfq0SBgztqtxYFR5vDyftwowKNRMWiIQ3t87mCu-GMZljxcZVryxxhqna1hM4eu3F7AyCMlC7fFy7yWl18IIl6nY7JKca

(参考资料2)thrift IDL定义可参考(就是定义结构化数据和服务的方法):

  http://diwakergupta.github.io/thrift-missing-guide/#_defining_services

1.基本使用方法

TNonblockingServer是thrift提供的一种多线程非阻塞IO服务。

之所以从这里开始读代码,是因为TServer(TNonblockingServer是TServer的一个子类实现)是框架中比较最贴近用户实现部分的,各部分的划分请参阅(参考资料1)哈。

先看基本的使用:

 1   // FooServing是我们自己定义的thrift服务
 2   // FooServingProcessor是由thrift自动生成的类
 3   // FooServingHandler是我们的业务实现类,90%的代码写在这个类中
 4   shared_ptr<FooServingHandler>
 5     handler(new FooServingHandler());
 6   shared_ptr<TProcessor>
 7     processor(new FooServingProcessor(handler));
 8
 9   shared_ptr<TProtocolFactory>
10     protocolFactory(new TBinaryProtocolFactory());
11
12   shared_ptr<PosixThreadFactory> threadFactory(new PosixThreadFactory());
13   shared_ptr<ThreadManager> threadManager =
14     ThreadManager::newSimpleThreadManager(thread_count);
15   threadManager->threadFactory(threadFactory);
16   threadManager->start();
17
18   TNonblockingServer server(processor,
19                             protocolFactory,
20                             port,
21                             threadManager);
22   server.setTaskExpireTime(expire_time);
23   server.serve();

当然TNonblockingServer的构造函数有多种实现,并不局限于以上的方式。handler实际上是我们实现的业务逻辑,processer是根据我们定义的服务(IDL文件)自动生成的处理类,它会调用我们的handler,而在server中会接收Client请求,将其转交processer处理。

2.serve函数

下面从TNonblockingServer的serve函数入手,继续看。

 1 void TNonblockingServer::serve() {
 2
 3   if (ioThreads_.empty())
 4     registerEvents(NULL);    // 初始化监听端口、创建ioThreads_、初始化ioThreadFactory_、初始化eventHandler_等
 5
 6   // Run the primary (listener) IO thread loop in our main thread; this will
 7   // only return when the server is shutting down.
 8   ioThreads_[0]->run();         // 这个是控制线程
 9
10   // Ensure all threads are finished before exiting serve()
11   for (uint32_t i = 0; i < ioThreads_.size(); ++i) {
12     ioThreads_[i]->join();
13     GlobalOutput.printf("TNonblocking: join done for IO thread #%d", i);
14   }
15 }

ioThreads_中的第一个线程是控制线程

未完待续。。。先回家过年啦

时间: 2024-10-11 18:28:08

Thrift0.9.3 C++版代码阅读随笔——TNonblockingServer的相关文章

【unix网络编程第三版】阅读笔记(五):I/O复用:select和poll函数

本博文主要针对UNP一书中的第六章内容来聊聊I/O复用技术以及其在网络编程中的实现 1. I/O复用技术 I/O多路复用是指内核一旦发现进程指定的一个或者多个I/O条件准备就绪,它就通知该进程.I/O复用适用于以下场合: (1) 当客户处理多个描述符(一般是交互式输入或网络套接字),必须适用I/O复用 (2) 当一个客户处理多个套接字时,这种情况很少见,但也可能出现 (3) 当一个TCP服务器既要处理监听套接字,又要处理已连接套接字,一般就要使用I/O复用 (4) 如果一个服务器既要适用TCP,

《代码阅读方法与实践》阅读笔记之二

时间过得真快,一转眼,10天就过去了,感觉上次写阅读笔记的场景仿佛还历历在目.<代码阅读方法与实践>这本书真的很难写笔记,本来我看这本书的名字还以为书里大概写的都是些代码阅读的简易方法,心想着这就好写笔记了,没想到竟然好多都是我们之前学过的东西,这倒让我有点无从下手了.大概像我们这些还没有太多经历的大学生,总是习惯于尽量避免自己的工作量,总是试图找到一些完成事情的捷径吧.总之,尽管我不想承认,但我自己心里很清楚,我就是这种人.下面开始言归正传,说说接下来的几章内容归纳. 这本书在前面已经分析了

Linux - Unix环境高级编程(第三版) 代码编译

Unix环境高级编程(第三版) 代码编译 本文地址:http://blog.csdn.net/caroline_wendy 时间:2014.10.2 1. 下载代码:http://www.apuebook.com/code3e.html 2. 安装依赖库:sudo apt-get install libbsd-dev  3. 进入下载目录make 4. 复制头文件和动态链接库 sudo cp ./include/apue.h /usr/include/ sudo cp ./lib/libapue

Linux版EPUB阅读器

Linux版EPUB阅读器 本文导航 -1. Calibre09% -2. FBReader23% -3. Cool Reader33% -4. Okular44% -5. pPub51% -6. epub63% -7. Sigil74% 如果说用平板电脑看书尚属主流的话,那么在电脑上读书就非常少见了.专注阅读16世纪的书是非常困难的了,没人希望后台蹦出QQ聊天窗口.但是如果你非要在电脑上打开电子书的话,那么你需要一个电子书阅读软件.大多数出版物支持使用EPUB格式的电子书(电子出版物).幸运的

代码阅读问题

---恢复内容开始--- 下面列举阅读代码过程中遇到的问题和相应的资料查询: 1.namespace的用途:http://www.kuqin.com/language/20080107/3532.html 2.enum 的用途:http://pcedu.pconline.com.cn/empolder/gj/c/0502/562347.html 3.SFML:http://www.sfml-dev.org/ 4.双冒号的用法:http://blog.csdn.net/zimingjushi/ar

《逻辑思维简易入门》(第2版) 阅读笔记二

<逻辑思维简易入门>(第2版) 阅读笔记二 本周阅读的是<逻辑思维简易入门>的第三章,也就是说,本书的第一部分就已经读完了. 第三章.信念的优点 信念和负信念是人们在接受一个事物时一种心理态度,延伸来说也就是对事物的认知态度.因为我们在研究 逻辑思维的时候,都有一个前提:“以正常情况以及说话者真诚”,所以有人如果对于一件事物不做回应,我们可以认为这是一种既不相信,也不怀疑的的态度. 信念的优缺点有很多,在书中主要介绍了下面几种: 1.准确性 好的信念实在准确的表达事实,同样真的信念

代码阅读方法与实践(三)

我们分析的许多系统都遵循一种简单的“主程序和子例程”结构.常见的.重要的结构可以归类为少数迥然相异的构架类型:集中式储存库.数据流.面向对象或分层构架.这些构架类型常常结合成一个层次结构用来控制大型系统的复杂性.接下来我们将独立的分析每种构架类型,但是一个系统可以同时展示出多种不同的构架类型.以不同的方式检查同一个系统.分许系统的不同部分.或使用不同级别的分解,都有可能发现不同的架构类型. 集中式储存库的构架模型依赖于一个中心过程或数据结构,他在系统中担任控制或信息的集线器.即使不需要数据库提供

《代码阅读方法与实践》阅读笔记三

之前已经看完了<代码阅读方法与实践>的前六章,基本上也就是看得比较粗略,没有很精细的阅读,上节课听到老师说的“学术交流会”还是很紧张的,挺害怕被问到问题,结果回答不出来可怎么办啊,不仅丢人,分也送给别人了啊,这可怎么破啊.所以呢,我打算近期再看一遍,不管有没有用,算是给自己加点自信吧. 第七章,讲的是编程规范和约定,主要就是文件的命名及组织.缩进.编排.命名约定.编程实践.过程规范之类的,其实这一章也不用我做过多的介绍,因为大家应该都有听各科老师讲过好几遍了,道理大家都懂,但是大家除了在理论上

《代码阅读方法与实践之读书笔记之一》

阅读代码是程序员的基本技能,同时也是软件开发.维护.演进.审查和重用过程中不可或缺的组成部分.<代码阅读方法与实践之读书笔记之一>这本书围绕代码阅读,详细论述了相关的知识与技能.我希望通过仔细阅读并学习本书,可以快速地提高我的代码阅读的技能与技巧,进而从现有的优秀代码.算法.构架.设计中汲取营养,提高自身的开发与设计能力.此次读了此书的前四章,以下是我从中汲取到的宝贵养分: 从第一章<导论>一节中我体会到了我们要养成一个经常花时间阅读别人编写的高品质代码的习惯,因为阅读高品质的代码