-
TcpConnection的peerAddress()和localAddress()成员函数分别返回对方和本地的地址(以InetAddress对象表示IP和port) -
TcpConnection::connected()返回一个bool值，表明目前链接是建立还是断开，1为链接，0为断开。 -
在
onConnection()中conn参数是TcpConnection对象的shared_ptr -
在
onMassage()中conn参数是收到数据的那个TCP链接，buf是以及收到的数据，buf的数据会积累，直到用户取走(retrieve)数据。time是epoll_wait()的返回时间，这个时间通常比read()发生的时间略早。 -
Buffer类通过
findCRLF和findEOL成员函数在readerable区域检索\r\n和EOL，返回检索到的地址
编译时应链接相应的静态库
-lmuduo_net
-lmuduo_base检查文件描述符及其状态
#通过port查找PID
ps -uax | grep port
或
lsof -i:port
| 方案 | 名称 | 接受新连接 | 网络IO | 计算任务 |
|---|---|---|---|---|
| 2 | thread-per-connection | 1个线程 | N线程 | 在网络线程中进行 |
| 5 | 单线程Reactor | 1个线程 | 在连接线程中进行 | 在连接线程中进行 |
| 8 | Reactor+线程池 | 1个线程 | 在连接线程中进行 | C线程 |
| 9 | one loop per thread | 1个线程 | C线程 | 在网络线程中进行 |
| 11 | one loop per thread +线程池 | 1个线程 | C线程 | C线程 |
N表示并发连接数目，C是与连接数无关，与CPU数目有关的常数
日志可输出到LOG_INFO
测试回射服务器echo(单线程):
本地运行，使用netcat或telnet进行测试：
nc localhost post #post：xxx
telnet localhost post #post: xxx
netcat和telnet是一款命令行网络工具，用来在两台机器之间建立TCP/UDP连接，并通过标准的输入输出进行数据的读写
用muduo实现最简单的7个figner服务端（见muduo/figner/）
Telnet测试：
在一个命令行窗口运行：
$ ./finger07.out另一个命令行窗口运行：
$ telnet localhost 1079
Trying ::1...
Connection failed: 拒绝连接Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
muduo
No such user
Connection closed by foreign host.再试一次：
$ telnet localhost 1079
Trying ::1...
Connection failed: 拒绝连接Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
schen
Happy and well
Connection closed by foreign host.muduo::implicit_cast<size_t>(kCells)) // 类型转换<目标类型>（被转换类型）// 设置内容作为成员变量。这个内容可以是任何数据，主要是用着一个临时存储作用。
conn->setContext();
//取出该成员变量
conn->getContext();muduo::net::Buffer->retrieve(kHeaderLen); // 从头部取走数据，删除取走部分并返回该部分编译porot文件:
protoc xxx.proto --cpp_out=./ #编译为 xxx 到 ./ 目录下（c++格式）编译源文件时需链接:
-lprotobuf接收双方在收到Protobuf二进制数据流之后，如何自动创建具体类型的Protobuf Message对象，并用收到的数据填充该Message对象（反序列化）？（即使proto文件更新，也会自动填入新的Message类型，不需要更新用户代码）
1.用DescriptorPool::gennerated_pool找到一个DescriptorPool对象，它包含了程序编译的时候所链接的全部Protobuf Message types。
2.根据type name用DescriptorPool::FindMessageTypeByName()查找Descriptor。
3.再用MessageFactory::generated_factory()找到MessageFactory对象，它能创建程序编译时候所链接的全部Protobuf Message types。
4.然后用MessageFactory::GetPrototype()找到具体Message type的default instance。
5.最后用prototype->New()创建对象。
示例如下：
Message* createMessage(const std::string& typeName){
Message* message = NULL;
const Descriptor* descriptor
= DescroptorPool::generated_pool()->FindMessageTypeByName(typeName);
if(descriptor){
const Message* prototype
= MessageFactory::generated_factory()->GetPrototype(descriptor);
if(prototype){
message = prototype->New();
}
}
return message;
}调用方式：
Message* newQuery = createMessage("muduo.Query"); //上述返回需要delete,muduo里不需要
assert(newQuery != NULL);
assert(typeid(*newQuery) == typeid(muduo::Query::default_instance()));
cout << "createMessage(\"muduo.Query\") = " << newQuery << endl;AtomicInt64 ，AtomicInt32为原子数据类型，线程安全
一种心跳机制
circular_buffer 中文意为环形缓冲区，这是一个固定大小的缓冲区，它被定义成一个环形，当缓冲区满了后，新来的数据会覆盖掉旧的数据。
unordered_set的hash会去重，所以疯狂echo并不会顶掉原有的bucket
主要由开启事件循环和检测访问事件循环是否正确。（one loop per thread）
主要函数：
loop()其中构造函数会记录当前线程信息，在loop()中会自动检测线程正确性
每个Channel对象只属于一个Evenloop，也只属于一个IO线程（不需加锁）。
每个Channel只负责一个fd的IO事件分发（回调），它不拥有该fd。
用户一般只使用（提供给chennel对象使用）：
set*CallBack()
enableReading()Channel class中的event_是它关心的事件，由用户设置，
revents_是活动事件，由EventLoop/Poller设置
Channel::handleEvent()由EventLoop::loop()调用，它会根据revents_的值调用不同的回调函数
ChannelMap是从fd到Channel*的映射
updateChannel()通过新Channel更新pollfds_列表
Poller class拥有并管理Channel的一个列表，pollfds_为监听的fd列表
Poller::poll()调用poll(2)来获取当前活动的IO事件，然后再用fillActiveChannels()遍历pollsds_，找出有活动事件的fd,把它对应的Channel填入activeChannels()
现在EventLoop::loop()有了真正的工作内容，它调用Poller::poll()获得当前活动事件的Channel列表，然后依次调用每个Channel的handleEvent()函数
该接口提供给EventLoop使用（封装为了runAt(),runAfter(),runEvery()）
该函数实现了在它的IO线程内执行某个用户任务回调，即EventLoop::runInLoop(const Functor &cb)
如果用户在当前IO线程调用这个函数，回调会同步进行，如果用户在其他线程调用runInLoop()，cb会被加入队列，等待IO线程唤醒。
由于IO线程平时阻塞在事件循环EventLoop::loop()的poll(2)调用中，为了让IO线程能立即执行用户回调，先把事件放入pendingFunctors_(一个函数列表)，然后在loop()循环中增加一行代码，调用doPendingFunctors()，它不是简单的在临界区依次调用Functor（vector的访问会阻塞其他线程，如添加新回调事件），而是把回调列表swap()到局部变量中。
该类用于accept新TCP连接。它供TcpServer使用。
Acceptor数据成员包括Socket，Channel等。
Acceptor的socket是listening socket即server socket。用其创建的acceptChannel_用于观察此socket上的readable事件，并回调Acceptor::handleRead()。该回调会用accept(2)来接受新连接。（用acceptChannel_.enableReading()开启观察，用户直接调用Acceptor::listen()即可，后者包含了前者）
Acceptor的构造函数和Acceptor::listen()调用socket(),bind(),listen()等一系列Socket API。
其中InetAddress class是对struct sockaddr_in的简单封装。
构造函数中的createNonblockingOrDie()用来创建非阻塞socket。
TcpServer class功能是管理accept(2)获得的TcpConnection。TcpServer是直接供用户使用的，用户只需要设置好callback,再调用start()即可。
TcpServer内部使用Acceptor来获得新连接的fd。它保存用户提供的Connection/Message Callback,在新建TcpConnection时会原样传给该TcpConnection。TcpServer持有目前存活的TcpConnection的shared_ptr（定义为TcpConnectionPtr）
新连接到达时，Acceptor回调newConnection()，后者会创建TcpConnection对象conn，把它加入ConnectionMap，设置好callback,再调用conn->connectionEstablished()，其中会回调用户提供的ConnectionCallBack
TcpConnection使用Channel来获得socket上的IO事件，它会自己处理writeable事件，而把readable事件通过MessageCallback传给客户。
TcpConnection拥有 TCP socket，它的析构函数会close(fd)，所以它表示的是“一次TCP连接”，一旦断开，这个对象就没用了。另外，TcpConnection没有发起连接的功能，其构造函数是已经建立好的socket fd。
Connector只负责建立socket连接，不负责创建TcpConnection对象
poll(2)返回值为整个文件描述符数组，用户需要遍历数组寻找哪些文件描述符上有IO事件，而epoll_wait(2)返回的是活动fd的列表。
-
// 基类 class Animal { // eat() 函数 // sleep() 函数 }; //派生类 class Dog : public Animal { // bark() 函数 };
-
在 c/c++ 中，为了解决一些频繁调用的小函数大量消耗栈空间（栈内存）的问题，特别的引入了
inline修饰符，表示为内联函数。用模板代替宏。
函数模板： template <typename type> ret-type func-name(parameter list) { // 函数的主体 } 类模板： template <class type> class class-name { } 实例化类模板：类模板名 <真实类型参数表>
在这里，
type是占位符类型名称，可以在类被实例化的时候进行指定。 -
mutable的作用有两点： （1）保持常量对象中大部分数据成员仍然是“只读”的情况下，实现对个别数据成员的修改； （2）使类的const函数可以修改对象的mutable数据成员。 -
在构建 shared_ptr 智能指针，可以明确其指向。例如：
std::shared_ptr<int> p3(new int(10));
由此，我们就成功构建了一个
shared_ptr智能指针，其指向一块存有 10 这个int类型数据的堆内存空间。weak_ptr是为了配合shared_ptr而引入的一种智能指针，它指向一个由shared_ptr管理的对象而不影响所指对象的生命周期，也就是将一个weak_ptr绑定到一个shared_ptr不会改变shared_ptr的引用计数。不论是否有weak_ptr指向，一旦最后一个指向对象的shared_ptr被销毁，对象就会被释放。当我们创建一个
weak_ptr时，需要用一个shared_ptr实例来初始化weak_ptr，由于是弱共享，weak_ptr的创建并不会影响shared_ptr的引用计数值。既然
weak_ptr并不改变其所共享的shared_ptr实例的引用计数，那就可能存在weak_ptr指向的对象被释放掉这种情况。这时，我们就不能使用weak_ptr直接访问对象。那么我们如何判断weak_ptr指向对象是否存在呢？C++中提供了lock函数来实现该功能。如果对象存在，lock()函数返回一个指向共享对象的shared_ptr，否则返回一个空shared_ptr。在初始化
shared_ptr智能指针时，还可以自定义所指堆内存的释放规则，这样当堆内存的引用计数为 0 时，会优先调用我们自定义的释放规则。std::shared_ptr<int> p7(new int[10], deleteInt); std::shared_ptr<int> p7(new int[10], [](int* p) {delete[]p; });
-
map对象是模板类，需要关键字和存储对象两个模板参数：
std:map<int, string> personnel;这样就定义了一个用
int作为索引,并拥有相关联的指向string的指针.vector属于顺序容器，其元素与存储位置与操作操作有关；set属于关联容器，其元素相当于键值。set能够保证它里面所有的元素都是不重复的 -
若p为智能指针对象(如：shared_ptr< int> p) p.reset(q) //q为智能指针要指向的新对象 p.reset(); //释放p中内置的指针指向的空间 p.reset(q.d); //将p中内置指针换为q，并且用d来释放p之前所指的空间
-
回调函数就是一个通过函数指针调用的函数。如果你把函数的指针（地址）作为参数传递给另一个函数，当这个指针被用来调用其所指向的函数时，我们就说这是回调函数。 回调函数不是由该函数的实现方直接调用，而是在特定的事件或条件发生时由另外的一方调用的，用于对该事件或条件进行响应。回调函数机制： 1、定义一个函数（普通函数即可）； 2、将此函数的地址注册给调用者； 3、特定的事件或条件发生时，调用者使用函数指针调用回调函数。
eg:
#include <iostream> #include <vector> using namespace std; class A { private: int a = 5; vector<void(*)(int)> funcs; public: void setA(int a_); void registerCallback(void(*p)(int)); }; void display(int a) { cout << "a=" << a << endl; } int main() { A a1; a1.registerCallback(display); a1.setA(7); system("pause"); return 0; } void A::setA(int a_) { a = a_; for (int i = 0; i < funcs.size(); ++i) { funcs[i](a); } } void A::registerCallback(void(*p)(int)) { funcs.push_back(p); }
这里用到了函数指针（即指向函数的指针），我们要监听
A类中的成员变量a，我们定义A类的时候就增加一个将来要监听a变量的函数指针列表，并增加一个registerCallback函数用于将来添加监听者，在a变化时将监听者列表里的所有监听者都调用一遍；在使用A类对象时，我们只要把一个返回类型、参数列表（签名）符合的函数添加为回调函数即可，如上面当我们运行a1.setA(7)改变a的值时，就会调用了回调函数display，这就差不多是事件监听的思想：首先订阅事件（如这里的把display函数注册为回调函数），然后当事件（这里是a的值变化了）发生 时，就会自动调用回调函数实现监听。 -
在
std::map<string, string>::iterator中，it->first是key,it->second是value -
string中： 函数assign()常用在给string类变量赋值. 函数erase()常用在处理删除字符串,返回删除后的字符串 -
void call(){ ::func(); // 外部的全局函数 func(); // 成员函数 }
-
类模版
std::function是一种通用、多态的函数封装。std::function的实例可以对任何可以调用的目标实体进行存储、复制、和调用操作，这些目标实体包括普通函数、Lambda表达式、函数指针、以及其它函数对象等。 -
C++ 11中对unordered_set描述大体如下： 无序集合容器（unordered_set）是一个存储唯一(unique，即无重复）的关联容器（Associative container），容器中的元素无特别的秩序关系，该容器允许基于值的快速元素检索，同时也支持正向迭代。
博客: https://www.cnblogs.com/fortunely/
常见IO模型参考:
https://blog.csdn.net/u013256816/article/details/115388239 https://www.cnblogs.com/yrxing/p/14143644.html
muduo线程池的one loop per thread:
Protocol Buffers C++:
https://blog.csdn.net/K346K346/article/details/51754431
长文梳理muduo: