@jonah 你的这个封装, 和我把 session id + event 事件 的解决方式, 是类似的, 不过有一点, 我的代码习惯用 C++11 智能指针管理, 不太想直接传递裸指针

@jonah Sorry, 我看懂你的意思了, 你是做了第二层封装, 把 session 对象和状态封装到一起了

@jonah 这个 demo 在同一时间, 只能读, 或者只能写, 要么写完了再读, 要么读完了再写. 在 bi-di stream 模型中, 我的需求是随机性有 N 个 request, 随机性有 M 个 reply, request 和 reply 没有任何关联

@jonah bi-di stream, 是指同时开启异步的读写, 你这个 demo 依然还是把读写线性化了

@jonah 再详细点说, 异步读和异步写都开启了, 这时候 completion queue 返回, 你可以根据返回的 tag 知道是哪个对象产生了事件, 可没有办法区分是读完成了, 还是写完成了

@jonah 如果先读再写, 或者先写再读, 所有的事件基于线性产生, 那这个 demo 的模型的确可以跑通, 虽然实现有点繁琐. 可我的目标是 bi-di stream, 这时候就不适用了

@jonah 读和写都是同步的, 不存在先后, 如果读写同步, 只能通过一个 completion queue 返回, 那你在对象成员里也没办法做区分了

@icylogic 这个官方 demo , 如果同时做异步读写, 那这个 demo 的模型就跑不通了, 因为无法区分读完成和写完成

@icylogic 这个 demo 我研究过了, 问题在于他没用 stream, 我的核心需求是实现 pubsub 模型, 所以必须用 stream, 基于一些设计, 还得是 bi-di stream

@icylogic 官方 demo 就是个指针, 我的问题是, 如果用返回值标识指针, 就没办法区分事件类型了, 比如异步读和异步写

@xkeyideal 我看了 java 和 golang 的 api, 实现都很简单易用, 唉

@codehz good idea.
可我刚刚发现自己转牛角尖了. 也许作者在设计这套 api 的时候, 就想让使用者每个 rpc 请求都有单独的 completion queue, 也就是最早的 "每个 tcp 连接 一个线程" 模型. 我 epoll 用惯了, 思维方式固化了, 老是想着限制线程数量,

问题已经解决了, 把笔记在这里贴一下吧:

conntrack 限制

所有在内核中由 Netfilter 的特定框架做的连接跟踪称作 conntrack （ connection tracking ）

达到最大限制后, 会报错
nf_conntrack: table full, dropping packet

查看当前系统设置最大连接数
cat /proc/sys/net/netfilter/nf_conntrack_max

查看连接跟踪有多少条目
cat /proc/sys/net/netfilter/nf_conntrack_count

vim /etc/sysctl.conf
net.nf_conntrack_max = 2000000

临时生效
sysctl -p

永久生效, 还需额外操作
http://xy.am/2015/04/26/nf-conntrack/
你只需要把 nf_conntrack 加到系统开机模块，就可以用 /etc/sysctl.conf 开机设置它了
echo "nf_conntrack" >> /etc/modules

@julyclyde 7*24 百万以上并发 tcp

把压测的模拟器都关掉, 一切恢复正常

这个想法在我脑海中很多年了

@msg7086 试了, 只收到一条消息: Healthcheck udp check, 然后就没有收到任何其他消息. 然后 slb 的状态一直显示 "异常" 不明白 阿里云怎么发现我作弊的

@leishi1313 公司莫名其妙的安全管理制度, 强制要求的