服务器运维外包的削峰配置错误,请运维检测配置
点击联系发帖人
时间：2016-06-05 00:12
后使用我的收藏没有帐号？
所属分类： &
查看: 7|回复: 1
dnf服务器的削峰配置错误，请运行维检测配置是什么意
发表于 3&分钟前
服务器的削峰配置错误，请运行维检测配置是什么意思
找手游 上18183
TA的勋章：
发表于 2&分钟前
这个你还是去te5DNF专区看吧，在攻略速递那边都写的很清楚，
指尖每日首次回帖可以赚5金币（）收起回复展开回复
找手游 上18183
不狂不男人！公测狂送mini4、海量千元京东卡大奖！赶紧来~
经常在论坛发帖，且发帖量较大（发帖量4000以上）后使用我的收藏没有帐号？
所属分类： &
查看: 3|回复: 1
dnf服务器的削峰配置错误 这个怎么搞？
发表于 3&分钟前
服务器的削峰配置错误 这个怎么搞？
找手游 上18183
TA的勋章：
发表于 1&分钟前
这个你还是去te5DNF专区看吧，在攻略速递那边都写的很清楚，
指尖每日首次回帖可以赚5金币（）收起回复展开回复
找手游 上18183
不狂不男人！公测狂送mini4、海量千元京东卡大奖！赶紧来~
经常在论坛发帖，且发帖量较大（发帖量4000以上）RHEL6配置简单LDAP服务器
RHEL6配置简单LDAP服务器
基于TLS加密和NFS的用户家目录自动挂载
实验说明：
在RHEL6.0中，使用开源的openldap套件，安装配置LDAP认证服务；并使用TLS加密认证；NFS共享用户家目录， autofs实现自动挂载。
实验环境：
利用教学使用的instructor服务器，提供dns、dhcp服务；
server5为独立的CA服务器，station.配置
为ldap服务器，desktop11为ldap客户端。
备注：简单实验，服务器可集中在1台，客户端1台，共2台即可。
实验拓朴：
实验步骤：
1.DNS做好域名解析，
2.ldap服务器的基本网络配置
3.安装LDAP相关软件：
主要有3个包：openldap、openldap-servers、openldap-clients
4.&配置LDAP的域信息，并测试！&
5.创建数据库文件（从模板复制产生）。并使用户ldap有权限。
6.启动LDAP服务，自动创建数据库文件。&
7.检查搜索域
8.创建待认证的用户。最后指定特定的家目录。如：/netdir/guests
9.安装迁移工具migrationtools，用来迁移系统用户为ldap用户。
这些 Perl 脚本的配置信息包含在 migrate_common.ph 文件的开头。对于我们来说，只需要修改命名前缀的变量来使用条目的识别名就足够了，如下所示：
10.创建认证账户文件
主要的概念：
dn：唯一区分名
dc：所属区域
ou：所属组织
cn/uid：全名/登录ID
① 运行脚本 migrate_base.pl，它会创建根项，并为 Hosts、Networks、Group 和 People 等创建低一级的组织单元，指定为base.ldif文件
② 创建用户数据库文件：最好先把要迁移为ldap用户先导出为独立文件。&
③ 创建组账户文件；④ 检查产生的三个文件。
重启sladp，迁移用户；&
如果出现错误：
ldap_bind: Invalid credentials
就表示你要么给出了错误的"cn="条目，要么给出了错误的密码
Enter LDAP
Password:(输入你刚才设置的密码)，正确之后会显示：
11.&打开服务器端防火墙tcp389端口&
12.用GUI界面查看LDAP用户
最好是：cd /var/www/html/目录，再下载phpldapadmin-1.2.2.tgz
(版本要新点的，不要下错啊！否则可能造成无法使用)
然后在客户机上打开浏览器&
登录的时候：DN框输入：cn=Manager,dc=domain11,dc=com，输入密码。
登录成功！列出目录用户
13.ldap客户端配置&(另启一台为客户端)
打开LDAP配置界面&
测试。这时还不能自动挂ldapuser的家目录，后面autofs再分析。
&检查/etc/openldap/ldap.conf&；/etc/nsswitch.conf；
&再次检查/etc/resolv.conf的配置是否发生变化；
关于sssd服务。这个服务不是必须的。
安装sssd包。将/etc/sssd/sssd.conf文件中的#enumerate=false，修改为：enumerate=true，这样修改完后，getent就会从LDAP查找账户信息。
14.实现TLS加密
① 搭建CA中心，安装openssl包，并配置：
② CA中心生成自已的私、公钥(证书)
③ ldap服务器生成私钥，并生成证书请求文件：&
④ CA中心签发证书，ldap服务器下载CA证书和自己的证书
⑤ ldap服务器安装证书
⑥ CA中心发布自已的公钥
TLSVerifyClient&&&&&&&&&
never &#永不对客户证书进行认证
附注：要启动TLS进行数据加密，server端即使不对客户端进行证书认证，也必须（required）配置以上项，否则TLS失败。
15.实现基于NFS的LDAP用户主目录
配置nfs服务器
如果不是on则远程用户无权限进入自己的目录。&
2) 配LDAP客户端。必须有第一节的目录，即：/netdir，其它可以没有！
3) 测试登录，有家目录了！
已投稿到：
以上网友发言只代表其个人观点，不代表新浪网的观点或立场。一致性哈希算法能够减少增减节点带来的memcache缓存失效带来的冲击。
下面是一个简单的java版实现算法，其中的哈希值算法没有实现，用HashFunction作为一个接口来提供自定义的hash值函数，大多数情况下我们可以使用md5。
import java.util.C
import java.util.SortedM
import java.util.TreeM
public class ConsistentHash&T& {
private final HashFunction hashF
private final int numberOfR
private final SortedMap&Integer, T& circle = new TreeMap&Integer, T&();
public ConsistentHash(HashFunction hashFunction, int numberOfReplicas,
Collection&T& nodes) {
this.hashFunction = hashF
this.numberOfReplicas = numberOfR
for (T node : nodes) {
add(node);
public void add(T node) {
for (int i = 0; i & numberOfR i++) {
circle.put(hashFunction.hash(node.toString() + i), node);
public void remove(T node) {
for (int i = 0; i & numberOfR i++) {
circle.remove(hashFunction.hash(node.toString() + i));
public T get(Object key) {
if (circle.isEmpty()) {
int hash = hashFunction.hash(key);
if (!circle.containsKey(hash)) {
SortedMap&Integer, T& tailMap = circle.tailMap(hash);
hash = tailMap.isEmpty() ? circle.firstKey() : tailMap.firstKey();
return circle.get(hash);
123456789101112131415161718192021222324252627282930313233343536373839404142434445
import java.util.Collection;import java.util.SortedMap;import java.util.TreeMap;&public class ConsistentHash&T& {& private final HashFunction hashFunction; private final int numberOfReplicas; private final SortedMap&Integer, T& circle = new TreeMap&Integer, T&();& public ConsistentHash(HashFunction hashFunction, int numberOfReplicas,&&&& Collection&T& nodes) {&& this.hashFunction = hashFunction;&& this.numberOfReplicas = numberOfReplicas;&&& for (T node : nodes) {&&&& add(node);&& } }& public void add(T node) {&& for (int i = 0; i & numberOfReplicas; i++) {&&&& circle.put(hashFunction.hash(node.toString() + i), node);&& } }& public void remove(T node) {&& for (int i = 0; i & numberOfReplicas; i++) {&&&& circle.remove(hashFunction.hash(node.toString() + i));&& } }& public T get(Object key) {&& if (circle.isEmpty()) {&&&& return null;&& }&& int hash = hashFunction.hash(key);&& if (!circle.containsKey(hash)) {&&&& SortedMap&Integer, T& tailMap = circle.tailMap(hash);&&&& hash = tailMap.isEmpty() ? circle.firstKey() : tailMap.firstKey();&& }&& return circle.get(hash); }&}
circle代表有一个有序整型map，表示要缓存的对象所对应hash值。
创建ConsistentHash对象时会同时创建虚拟节点。每个复制节点都是实用对象名和后缀结合的hash值。
缓存对象分布在每一个map中的节点上。
mac环境的配置方法和linux一样。
通过ulimit来设置是否生成core文件。
ulimit -c unlimited
生成core文件
ulimit -c 0
不生成core文件
core 文件存储位置 /core/core.pid
warnning 错误，没有处理switch中的枚举值。
在switch中添加default 和 可以解决这个问题。
想写一个爬虫去爬一些图片，发现python3的request封装的比较。遂决定要装一个python3。
mac下的神器就是brew，分分种完成各种软件包的安装。执行完之后报错了。
brew install python3
结果如下，从最后几行的输出判断是由于权限不足导致的。
==& Downloading https://www.python.org/ftp/python/3.4.3/Python-3.4.3.tar.xz
######################################################################## 100.0%
==& ./configure --prefix=/usr/local/Cellar/python3/3.4.3 --enable-ipv6 --datarootdir=/usr/local/Cellar/python3/3.4.3/share --datadir=/usr/local/Cellar/python
==& make install PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3
==& make frameworkinstallextras PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3/share/python3
==& Downloading https://pypi.python.org/packages/source/s/setuptools/setuptools-12.2.tar.gz
######################################################################## 100.0%
==& Downloading https://pypi.python.org/packages/source/p/pip/pip-6.0.8.tar.gz
######################################################################## 100.0%
==& Caveats
Pip has been installed. To update it
pip3 install --upgrade pip
You can install Python packages with
pip3 install &package&
They will install into the site-package directory
/usr/local/lib/python3.4/site-packages
See: /Homebrew/homebrew/blob/master/share/doc/homebrew/Homebrew-and-Python.md
.app bundles were installed.
Run `brew linkapps python3` to symlink these to /Applications.
Error: An unexpected error occurred during the `brew link` step
The formula built, but is not symlinked into /usr/local
Permission denied - /usr/local/Frameworks
Error: Permission denied - /usr/local/Frameworks
12345678910111213141516171819202122232425262728
==& Downloading https://www.python.org/ftp/python/3.4.3/Python-3.4.3.tar.xz######################################################################## 100.0%==& ./configure --prefix=/usr/local/Cellar/python3/3.4.3 --enable-ipv6 --datarootdir=/usr/local/Cellar/python3/3.4.3/share --datadir=/usr/local/Cellar/python==& make==& make install PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3==& make frameworkinstallextras PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3/share/python3==& Downloading https://pypi.python.org/packages/source/s/setuptools/setuptools-12.2.tar.gz######################################################################## 100.0%==& Downloading https://pypi.python.org/packages/source/p/pip/pip-6.0.8.tar.gz######################################################################## 100.0%==& CaveatsPip has been installed. To update it&&pip3 install --upgrade pip&You can install Python packages with&&pip3 install &package&&They will install into the site-package directory&&/usr/local/lib/python3.4/site-packages&See: https:///Homebrew/homebrew/blob/master/share/doc/homebrew/Homebrew-and-Python.md&.app bundles were installed.Run `brew linkapps python3` to symlink these to /Applications.Error: An unexpected error occurred during the `brew link` stepThe formula built, but is not symlinked into /usr/localPermission denied - /usr/local/FrameworksError: Permission denied - /usr/local/Frameworks
brew遇到问题排错步骤是：
sudo chown -R $(whoami):admin /usr/local
sudo chown -R $(whoami) /Library/Caches/Homebrew
brew doctor
brew prune
brew update
sudo chown -R $(whoami):admin /usr/localsudo chown -R $(whoami) /Library/Caches/Homebrewbrew doctor brew prunebrew update
brew linkapps python3
gcov 是 GNU 的代码覆盖率检查工具。它利用编译时的 -fprofile-arcs -ftest-coverage 和链接时的 -lgcov 选项参数生成 .gcno 文件进而通过这些文件统计覆盖率。不过高版本的 mac 使用 clang 编译器，不支持 -lgcov 选项生成 .gcno 文件。为了解决这个问题，我们可以使用-coverage参数来生成 .gcno 文件。例如：
我的g++ --version信息如下
Apple LLVM version 7.3.0 (clang-703.0.29)
Target: x86_64-apple-darwin15.4.0
Thread model: posix
使用-lgcov会报错
ld: library not found for -lgcov
可以使用-coverage选项替换-lgcov
clang -coverage test.c
gcov test.c
clang -coverage test.c./a.outgcov test.c
在C/C++中产生代码覆盖率的步骤包括如下几步：
一、设置编译参数
如下来设置Makefile中的编译参数以使之支持覆盖率产生：
ifeq ($(coverage), yes)
CXXFLAGS +=
这样，可以使用 make coverage=yes 来引入这些编译选项而不会影响到正常的编译，比如：
#make coverage=yes
这时候会产生.gcno文件。
二、运行测试程序
运行测试程序，会针对所有cpp源代码产生相应的.gcda文件。
三、获取覆盖率数据
获取覆盖率数据的方法很多种，这里介绍两种，分别产生txt和html数据：
1、使用gcov获取文本形式的覆盖率数据
使用gcc自带的覆盖率结果产生工具gcov能产生文本格式（.gcov）的覆盖率结果。
#gcov xxx.cpp
2、使用lcov获取html形式的覆盖率数据
使用IBM的lcov来产生html结果数据，具体如下：
#lcov -c -d ./ -
# -o cc_result
四、展示数据
将步骤三中产生的覆盖率数据文件放到Apached的htdocs目录下，就能通过浏览器来查看覆盖率结果了。
五、基本术语
1、行覆盖率（line coverage）
即源代码有效行数与被执行的代码行的比率。
2、分支覆盖率（branch coverage）
即有判定语句的地方都会出现2个分支，整个程序经过的分支与所有分支的比率是分支覆盖率。
3、增量覆盖率（incremental coverage）
即被执行的新增和修改的代码行数与新增和修改的代码总行数的比率。
gcov实际例子，通过运行gtest中的sample1.cc单元测试。
makefile文件的写法
GTEST_DIR = ..
USER_DIR = ../samples
CPPFLAGS += -isystem $(GTEST_DIR)/include
CXXFLAGS += -g -Wall -Wextra
ifeq ($(coverage), yes)
CXXFLAGS +=
TESTS = sample1_unittest
GTEST_HEADERS = $(GTEST_DIR)/include/gtest/*.h \
$(GTEST_DIR)/include/gtest/internal/*.h
all : $(TESTS)
rm -f $(TESTS) gtest.a gtest_main.a *.o *.gcno *.gcda *.gcov
GTEST_SRCS_ = $(GTEST_DIR)/src/*.cc $(GTEST_DIR)/src/*.h $(GTEST_HEADERS)
gtest-all.o : $(GTEST_SRCS_)
$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \
$(GTEST_DIR)/src/gtest-all.cc
gtest_main.o : $(GTEST_SRCS_)
$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \
$(GTEST_DIR)/src/gtest_main.cc
gtest.a : gtest-all.o
$(AR) $(ARFLAGS) $@ $^
gtest_main.a : gtest-all.o gtest_main.o
$(AR) $(ARFLAGS) $@ $^
sample1.o : $(USER_DIR)/sample1.cc $(USER_DIR)/sample1.h $(GTEST_HEADERS)
$(CXX) $(CPPFLAGS) $(CXXFLAGS)
-c $(USER_DIR)/sample1.cc
sample1_unittest.o : $(USER_DIR)/sample1_unittest.cc \
$(USER_DIR)/sample1.h $(GTEST_HEADERS)
$(CXX) $(CPPFLAGS) $(CXXFLAGS)
-c $(USER_DIR)/sample1_unittest.cc
sample1_unittest : sample1.o sample1_unittest.o gtest_main.a
$(CXX) $(CPPFLAGS) $(CXXFLAGS) -lpthread $^ -o $@
123456789101112131415161718192021222324252627282930313233343536373839404142434445
CXX = g++GTEST_DIR = ..USER_DIR = ../samplesCPPFLAGS += -isystem $(GTEST_DIR)/includeCXXFLAGS += -g -Wall -Wextra &ifeq ($(coverage), yes)&&&&CXXFLAGS +=&&-coverageendif&TESTS = sample1_unittest>EST_HEADERS = $(GTEST_DIR)/include/gtest/*.h \&&&&&&&&&&&&&&&&$(GTEST_DIR)/include/gtest/internal/*.h&all : $(TESTS)&clean :&&&&&&&&rm -f $(TESTS) gtest.a gtest_main.a *.o *.gcno *.gcda *.gcov>EST_SRCS_ = $(GTEST_DIR)/src/*.cc $(GTEST_DIR)/src/*.h $(GTEST_HEADERS)>est-all.o : $(GTEST_SRCS_)&&&&&&&&$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \&&&&&&&&&&&&$(GTEST_DIR)/src/gtest-all.cc>est_main.o : $(GTEST_SRCS_)&&&&&&&&$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \&&&&&&&&&&&&$(GTEST_DIR)/src/gtest_main.cc>est.a : gtest-all.o&&&&&&&&$(AR) $(ARFLAGS) $@ $^>est_main.a : gtest-all.o gtest_main.o&&&&&&&&$(AR) $(ARFLAGS) $@ $^&sample1.o : $(USER_DIR)/sample1.cc $(USER_DIR)/sample1.h $(GTEST_HEADERS)&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS)&&-c $(USER_DIR)/sample1.cc&sample1_unittest.o : $(USER_DIR)/sample1_unittest.cc \&&&&&&&&&&&&&&&&&&&& $(USER_DIR)/sample1.h $(GTEST_HEADERS)&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS)&&-c $(USER_DIR)/sample1_unittest.cc&sample1_unittest : sample1.o sample1_unittest.o gtest_main.a&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS) -lpthread $^ -o $@
make coverage=yes
g++ -isystem ../include -g -Wall -Wextra
-c ../samples/sample1.cc
g++ -isystem ../include -g -Wall -Wextra
-c ../samples/sample1_unittest.cc
g++ -isystem ../include -I.. -g -Wall -Wextra
-coverage -c \
../src/gtest-all.cc
g++ -isystem ../include -I.. -g -Wall -Wextra
-coverage -c \
../src/gtest_main.cc
ar rv gtest_main.a gtest-all.o gtest_main.o
ar: creating archive gtest_main.a
a - gtest-all.o
a - gtest_main.o
g++ -isystem ../include -g -Wall -Wextra
-coverage -lpthread sample1.o sample1_unittest.o gtest_main.a -o sample1_unittest
123456789101112
?&&make coverage=yesg++ -isystem ../include -g -Wall -Wextra&&-coverage&&-c ../samples/sample1.ccg++ -isystem ../include -g -Wall -Wextra&&-coverage&&-c ../samples/sample1_unittest.ccg++ -isystem ../include -I.. -g -Wall -Wextra&&-coverage -c \&&&&&&&&&&&&../src/gtest-all.ccg++ -isystem ../include -I.. -g -Wall -Wextra&&-coverage -c \&&&&&&&&&&&&../src/gtest_main.ccar rv gtest_main.a gtest-all.o gtest_main.oar: creating archive gtest_main.aa - gtest-all.oa - gtest_main.og++ -isystem ../include -g -Wall -Wextra&&-coverage -lpthread sample1.o sample1_unittest.o gtest_main.a -o sample1_unittest
编译完成后直接执行gcov命令，会报未执行，需要先执行可执行文件
? gcov sample1
File '../samples/sample1.cc'
Lines executed:0.00% of 13
../samples/sample1.cc:creating 'sample1.cc.gcov
? gcov sample1 File '../samples/sample1.cc'Lines executed:0.00% of 13../samples/sample1.cc:creating 'sample1.cc.gcov
执行可执行文件
? ./sample1_unittest
Running main() from gtest_main.cc
[==========] Running 6 tests from 2 test cases.
[----------] Global test environment set-up.
[----------] 3 tests from FactorialTest
] FactorialTest.Negative
OK ] FactorialTest.Negative (0 ms)
] FactorialTest.Zero
OK ] FactorialTest.Zero (0 ms)
] FactorialTest.Positive
OK ] FactorialTest.Positive (0 ms)
[----------] 3 tests from FactorialTest (0 ms total)
[----------] 3 tests from IsPrimeTest
] IsPrimeTest.Negative
OK ] IsPrimeTest.Negative (0 ms)
] IsPrimeTest.Trivial
OK ] IsPrimeTest.Trivial (0 ms)
] IsPrimeTest.Positive
OK ] IsPrimeTest.Positive (0 ms)
[----------] 3 tests from IsPrimeTest (0 ms total)
[----------] Global test environment tear-down
[==========] 6 tests from 2 test cases ran. (0 ms total)
] 6 tests.
12345678910111213141516171819202122232425
? ./sample1_unittest&& Running main() from gtest_main.cc[==========] Running 6 tests from 2 test cases.[----------] Global test environment set-up.[----------] 3 tests from FactorialTest[ RUN&&&&&&] FactorialTest.Negative[&&&&&& OK ] FactorialTest.Negative (0 ms)[ RUN&&&&&&] FactorialTest.Zero[&&&&&& OK ] FactorialTest.Zero (0 ms)[ RUN&&&&&&] FactorialTest.Positive[&&&&&& OK ] FactorialTest.Positive (0 ms)[----------] 3 tests from FactorialTest (0 ms total)&[----------] 3 tests from IsPrimeTest[ RUN&&&&&&] IsPrimeTest.Negative[&&&&&& OK ] IsPrimeTest.Negative (0 ms)[ RUN&&&&&&] IsPrimeTest.Trivial[&&&&&& OK ] IsPrimeTest.Trivial (0 ms)[ RUN&&&&&&] IsPrimeTest.Positive[&&&&&& OK ] IsPrimeTest.Positive (0 ms)[----------] 3 tests from IsPrimeTest (0 ms total)&[----------] Global test environment tear-down[==========] 6 tests from 2 test cases ran. (0 ms total)[&&PASSED&&] 6 tests.
使用gcov查看sample1.cc文件的覆盖率
gcov sample1
File '../samples/sample1.cc'
Lines executed:100.00% of 13
../samples/sample1.cc:creating 'sample1.cc.gcov'
?&&gcov sample1&&&&&&&& File '../samples/sample1.cc'Lines executed:100.00% of 13../samples/sample1.cc:creating 'sample1.cc.gcov'
表示：sample1.cc一共有13行（可执行代码），全部被执行，测试覆盖率100%。
具体哪些代码被测还可以看sample1.cc.gcov文件：
37:int Factorial(int n) {
int result = 1;
for (int i = 1; i &= i++) {
46:// Returns true iff n is a prime number.
47:bool IsPrime(int n) {
// Trivial case 1: small numbers
if (n &= 1)
// Trivial case 2: even numbers
if (n % 2 == 0) return n == 2;
// Now, we have that n is odd and n &= 3.
// Try to divide n by every odd number i, starting from 3
for (int i = 3; ; i += 2) {
// We only have to try i up to the squre root of n
if (i & n/i)
// Now, we have i &= n/i & n.
// If n is divisible by i, n is not prime.
if (n % i == 0)
// n has no integer factor in the range (1, n), and thus is prime.
1234567891011121314151617181920212223242526272829303132
&&&&&&&&-:&& 37:int Factorial(int n) {&&&&&&&&8:&& 38:&&int result = 1;&&&&&& 44:&& 39:&&for (int i = 1; i &= n; i++) {&&&&&& 14:&& 40:&&&&result *= i;&&&&&& 14:&& 41:&&}&&&&&&&&-:&& 42:&&&&&&&&8:&& 43:&&return result;&&&&&&&&-:&& 44:}&&&&&&&&-:&& 45:&&&&&&&&-:&& 46:// Returns true iff n is a prime number.&&&&&&&&-:&& 47:bool IsPrime(int n) {&&&&&&&&-:&& 48:&&// Trivial case 1: small numbers&&&&&& 16:&& 49:&&if (n &= 1) return false;&&&&&&&&-:&& 50:&&&&&&&&-:&& 51:&&// Trivial case 2: even numbers&&&&&&&&9:&& 52:&&if (n % 2 == 0) return n == 2;&&&&&&&&-:&& 53:&&&&&&&&-:&& 54:&&// Now, we have that n is odd and n &= 3.&&&&&&&&-:&& 55:&&&&&&&&-:&& 56:&&// Try to divide n by every odd number i, starting from 3&&&&&&&&4:&& 57:&&for (int i = 3; ; i += 2) {&&&&&&&&-:&& 58:&&&&// We only have to try i up to the squre root of n&&&&&&&&7:&& 59:&&&&if (i & n/i) break;&&&&&&&&-:&& 60:&&&&&&&&-:&& 61:&&&&// Now, we have i &= n/i & n.&&&&&&&&-:&& 62:&&&&// If n is divisible by i, n is not prime.&&&&&&&&1:&& 63:&&&&if (n % i == 0) return false;&&&&&&&&1:&& 64:&&}&&&&&&&&-:&& 65:&&&&&&&&-:&& 66:&&// n has no integer factor in the range (1, n), and thus is prime.&&&&&&&&3:&& 67:&&return true;&&&&&& 11:&& 68:}
-表示该行不可执行，数字1或其他表示该行被执行了多少次，#####表示代码没被执行。
对象创建的时候会调用构造函数来初始化对象，对象销毁的时候会调用析构函数。
普通的自动变量（local非static）包含构造函数和析构函数。
当进入变量作用域的时候构造函数被调用，当离开变量作用域的时候析构函数被调用。
当在tuxedo的环境中调用 tpreturn() 或者 tpforward() 函数时，编译器进行了一个non-local的goto (using longjmp(3))，导致自动变量的析构函数没有被调用。
为了避免这个问题，我们应该在服务体中调用直接调用 tpreturn() 或 tpforward()
(而不是在服务体调用的函数中调用这两个函数)。
1.服务体中不能包含包含析构函数的变量，特别是string变量，这些带析构函数的自动变量需要放到函数调用体中，这样当离开函数的作用域的时候，会析构这些变量。如果在服务体中有string变量，那么随着服务循环会有内存泄漏。
2.自动变量需要被嵌套在服务体函数中的大括号{}包围，大括号需要在调用tpreturn() 或 tpforward() 函数前结束。
#ifdef __cplusplus
extern "C"
#if defined(__STDC__) || defined(__cplusplus)
SERVICE(TPSVCINFO *rqst)
SERVICE(rqst)
TPSVCINFO *
tpreturn(TPFAIL, 0, 0, 0L, 0);
123456789101112131415
#ifdef __cplusplusextern "C"#endifvoid#if defined(__STDC__) || defined(__cplusplus)SERVICE(TPSVCINFO *rqst)#elseSERVICE(rqst)TPSVCINFO *rqst;#endif{&&&&string Message;&&&&...&&&&tpreturn(TPFAIL, 0, 0, 0L, 0);}
可以改为：
#ifdef __cplusplus
extern "C"
#if defined(__STDC__) || defined(__cplusplus)
SERVICE(TPSVCINFO *rqst)
SERVICE(rqst)
TPSVCINFO *
} while(0);
tpreturn(TPSUCCESS, 0,NULL, 0L, 0);
12345678910111213141516171819
#ifdef __cplusplusextern "C"#endifvoid#if defined(__STDC__) || defined(__cplusplus)SERVICE(TPSVCINFO *rqst)#elseSERVICE(rqst)TPSVCINFO *rqst;#endif{&&&&do&&&&{&&&&&&&&string Message;&&&&&&&&...&&&&&} while(0); &&&&tpreturn(TPSUCCESS, 0,NULL, 0L, 0);}
epoll是目前进行服务器端编程的普遍选择，好处很多，这里不再赘述，本文主要描述如何在c语言中使用epoll的完整样例程序。
首先介绍用到的数据结构和三个api说明，然后通过编写一个打印所有输入到socket的字符输出到终端的服务器端的程序来完成整个例子。
epoll_event是用来对要监控的socket描述, 它包括epoll_data_t和要监控的事件类型的(一个__uint32_t类型的events)。epoll_data_t里的fd是用来存储要监控的文件描述符。
events 结构体中第一个参数支持的事件类型
– EPOLLIN，读事件
– EPOLLOUT，写事件
– EPOLLPRI，带外数据，与select的异常事件集合对应
– EPOLLRDHUP，TCP连接对端至少写写半关闭
– EPOLLERR，错误事件
– EPOLLET，设置事件为边沿触发
– EPOLLONESHOT，只触发一次，事件自动被删除
epoll在一个文件描述符上只能有一个事件，在一个描述符上添加多个事件，会产生EEXIST的错误。同样，删除epoll的事件，只需描述符就够了
typedef union epoll_data
__uint32_t
__uint64_t
} epoll_data_t;
struct epoll_event
__uint32_ /* Epoll events */
epoll_data_
/* User data variable */
12345678910111213
typedef union epoll_data{&&void&&&&&&&&*ptr;&&int&&&&&&&&&&fd;&&__uint32_t&& u32;&&__uint64_t&& u64;} epoll_data_t;&struct epoll_event{&&__uint32_t&& events; /* Epoll events */&&epoll_data_t data;&& /* User data variable */};
使用epoll的三个api
头文件 /usr/include/sys/epoll.h
1. 生成一个epoll专用的文件描述符
如果调用成功返回0,不成功返回-1
int epoll_create(int size)
int epoll_create(int size)
epoll_create返回的是一个文件描述符，也就是说epoll是以特殊文件的方式体现给用户
__size提示操作系统，用户可能要使用多少个文件描述符，该参数已经废弃，填写一个大于0的正整数
2.用于控制某个文件描述符上的事件，可以注册事件，修改事件，删除事件。
如果调用成功返回0,不成功返回-1
int epoll_ctl(
//由 epoll_create 生成的epoll专用的文件描述符
//要进行的操作例如注册事件，可能的取值EPOLL_CTL_ADD 注册、
//EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除
//关联的文件描述符
struct epoll_event *event
//指向epoll_event的指针
int epoll_ctl(&&&&int epfd,&&&&&&&&&&&&&&&&&&&&//由 epoll_create 生成的epoll专用的文件描述符 &&&&int op,&&&&&&&&&&&&&&&&&&&&&&//要进行的操作例如注册事件，可能的取值EPOLL_CTL_ADD 注册、&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& //EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除 &&&&int fd,&&&&&&&&&&&&&&&&&&&&&&//关联的文件描述符 &&&&struct epoll_event *event&&&&//指向epoll_event的指针 &&&&)
3.用于轮询I/O事件的发生，返回发生事件数
int epoll_wait(
//由epoll_create 生成的epoll专用的文件描述符
struct epoll_event * events,//用于回传代处理事件的数组
int maxevents,
//每次能处理的事件数
int timeout
//等待I/O事件发生的超时值
//为0的时候表示马上返回，为-1的时候表示一直等下去，直到有事件
//为任意正整数的时候表示等这么长的时间，如果一直没有事件
//一般如果网络主循环是单独的线程的话，可以用-1来等，这样可以保证一些效率
//如果是和主逻辑在同一个线程的话，则可以用0来保证主循环的效率。
12345678910
int epoll_wait( &&&&int epfd,&&&&&&&&&&&&&&&&&& //由epoll_create 生成的epoll专用的文件描述符 &&&&struct epoll_event * events,//用于回传代处理事件的数组 &&&&int maxevents,&&&&&&&&&&&&&&//每次能处理的事件数 &&&&int timeout&&&&&&&&&&&&&&&& //等待I/O事件发生的超时值 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//为0的时候表示马上返回，为-1的时候表示一直等下去，直到有事件 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//为任意正整数的时候表示等这么长的时间，如果一直没有事件 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//一般如果网络主循环是单独的线程的话，可以用-1来等，这样可以保证一些效率 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//如果是和主逻辑在同一个线程的话，则可以用0来保证主循环的效率。 &&&&)
epoll的api使用方式
1.epoll_create 生成的epoll专用的文件描述符
2.使用epoll_ctl注册事件，修改事件，删除事件对应的文件描述符到epollfd指定的epoll内核事件表中
3.使用epoll_wait阻塞等待注册的文件描述符上可读事件的发生
4.当有新客户端的连接或者客户端的数据写入，返回需要处理的事件数目
epoll的两种模式：
1. 水平触发（LT）：使用此种模式，当数据可读的时候，epoll_wait()将会一直返回就绪事件。如果你没有处理完全部数据，并且再次在该epoll实例上调用epoll_wait()才监听描述符的时候，它将会再次返回就绪事件，因为有数据可读。ET只支持非阻塞socket。
2. 边缘触发（ET）：使用此种模式，只能获取一次就绪通知，如果没有处理完全部数据，并且再次调用epoll_wait()的时候，它将会阻塞，因为就绪事件已经释放出来了。
ET的效能更高，但是对程序员的要求也更高。在ET模式下，我们必须一次干净而彻底地处理完所有事件。LT两种模式的socket都支持。
1.创建并绑定服务器端socket
采用一种可移植的方式来生产socket，getaddrinfo返回对应的网卡信息，遍历对应的网络接口生成socket
成功返回socket文件描述符，失败返回-1
static int
create_and_bind (char *port)
struct addrinfo *result, *
memset (&hints, 0, sizeof (struct addrinfo));
hints.ai_family = AF_UNSPEC;
/* Return IPv4 and IPv6 choices */
hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */
hints.ai_flags = AI_PASSIVE;
/* All interfaces */
s = getaddrinfo (NULL, port, &hints, &result);
if (s != 0)
fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));
return -1;
for (rp = rp != NULL; rp = rp-&ai_next)
sfd = socket (rp-&ai_family, rp-&ai_socktype, rp-&ai_protocol);
if (sfd == -1)
s = bind (sfd, rp-&ai_addr, rp-&ai_addrlen);
if (s == 0)
/* We managed to bind successfully! */
close (sfd);
if (rp == NULL)
fprintf (stderr, "Could not bind\n");
return -1;
freeaddrinfo (result);
123456789101112131415161718192021222324252627282930313233343536373839404142434445
static intcreate_and_bind (char *port){&&struct addrinfo hints;&&struct addrinfo *result, *rp;&&int s, sfd;&&&memset (&hints, 0, sizeof (struct addrinfo));&&hints.ai_family = AF_UNSPEC;&&&& /* Return IPv4 and IPv6 choices */&&hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */&&hints.ai_flags = AI_PASSIVE;&&&& /* All interfaces */&&&s = getaddrinfo (NULL, port, &hints, &result);&&if (s != 0)&&&&{&&&&&&fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));&&&&&&return -1;&&&&}&&&for (rp = result; rp != NULL; rp = rp-&ai_next)&&&&{&&&&&&sfd = socket (rp-&ai_family, rp-&ai_socktype, rp-&ai_protocol);&&&&&&if (sfd == -1)&&&&&&&&continue;&&&&&&&s = bind (sfd, rp-&ai_addr, rp-&ai_addrlen);&&&&&&if (s == 0)&&&&&&&&{&&&&&&&&&&/* We managed to bind successfully! */&&&&&&&&&&break;&&&&&&&&}&&&&&&&close (sfd);&&&&}&&&if (rp == NULL)&&&&{&&&&&&fprintf (stderr, "Could not bind\n");&&&&&&return -1;&&&&}&&&freeaddrinfo (result);&&&return sfd;}
2.设置socket为非阻塞模式
通过在文件描述符上设置 O_NONBLOCK 表识来实现非阻塞socket
static int
make_socket_non_blocking (int sfd)
int flags,
flags = fcntl (sfd, F_GETFL, 0);
if (flags == -1)
perror ("fcntl");
return -1;
flags |= O_NONBLOCK;
s = fcntl (sfd, F_SETFL, flags);
if (s == -1)
perror ("fcntl");
return -1;
12345678910111213141516171819202122
static intmake_socket_non_blocking (int sfd){&&int flags, s;&&&flags = fcntl (sfd, F_GETFL, 0);&&if (flags == -1)&&&&{&&&&&&perror ("fcntl");&&&&&&return -1;&&&&}&&&flags |= O_NONBLOCK;&&s = fcntl (sfd, F_SETFL, flags);&&if (s == -1)&&&&{&&&&&&perror ("fcntl");&&&&&&return -1;&&&&}&&&return 0;}
3.event 循环处理
#define MAXEVENTS 64
main (int argc, char *argv[])
struct epoll_
struct epoll_event *
if (argc != 2)
fprintf (stderr, "Usage: %s [port]\n", argv[0]);
exit (EXIT_FAILURE);
sfd = create_and_bind (argv[1]);
if (sfd == -1)
s = make_socket_non_blocking (sfd);
if (s == -1)
s = listen (sfd, SOMAXCONN);
if (s == -1)
perror ("listen");
efd = epoll_create1 (0);
if (efd == -1)
perror ("epoll_create");
event.data.fd =
event.events = EPOLLIN | EPOLLET;
s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);
if (s == -1)
perror ("epoll_ctl");
/* Buffer where events are returned */
events = calloc (MAXEVENTS, sizeof event);
/* The event loop */
n = epoll_wait (efd, events, MAXEVENTS, -1);
for (i = 0; i & i++)
if ((events[i].events & EPOLLERR) ||
(events[i].events & EPOLLHUP) ||
(!(events[i].events & EPOLLIN)))
/* An error has occured on this fd, or the socket is not
ready for reading (why were we notified then?) */
fprintf (stderr, "epoll error\n");
close (events[i].data.fd);
else if (sfd == events[i].data.fd)
/* We have a notification on the listening socket, which
means one or more incoming connections. */
struct sockaddr in_
socklen_t in_
char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];
in_len = sizeof in_
infd = accept (sfd, &in_addr, &in_len);
if (infd == -1)
if ((errno == EAGAIN) ||
(errno == EWOULDBLOCK))
/* We have processed all incoming
connections. */
perror ("accept");
s = getnameinfo (&in_addr, in_len,
hbuf, sizeof hbuf,
sbuf, sizeof sbuf,
NI_NUMERICHOST | NI_NUMERICSERV);
if (s == 0)
printf("Accepted connection on descriptor %d "
"(host=%s, port=%s)\n", infd, hbuf, sbuf);
/* Make the incoming socket non-blocking and add it to the
list of fds to monitor. */
s = make_socket_non_blocking (infd);
if (s == -1)
event.data.fd =
event.events = EPOLLIN | EPOLLET;
s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);
if (s == -1)
perror ("epoll_ctl");
/* We have data on the fd waiting to be read. Read and
display it. We must read whatever data is available
completely, as we are running in edge-triggered mode
and won't get a notification again for the same
int done = 0;
char buf[512];
count = read (events[i].data.fd, buf, sizeof buf);
if (count == -1)
/* If errno == EAGAIN, that means we have read all
data. So go back to the main loop. */
if (errno != EAGAIN)
perror ("read");
else if (count == 0)
/* End of file. The remote has closed the
connection. */
/* Write the buffer to standard output */
s = write (1, buf, count);
if (s == -1)
perror ("write");
printf ("Closed connection on descriptor %d\n",
events[i].data.fd);
/* Closing the descriptor will make epoll remove it
from the set of descriptors which are monitored. */
close (events[i].data.fd);
free (events);
close (sfd);
return EXIT_SUCCESS;
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
#define MAXEVENTS 64&intmain (int argc, char *argv[]){&&int sfd, s;&&int efd;&&struct epoll_event event;&&struct epoll_event *events;&&&if (argc != 2)&&&&{&&&&&&fprintf (stderr, "Usage: %s [port]\n", argv[0]);&&&&&&exit (EXIT_FAILURE);&&&&}&&&sfd = create_and_bind (argv[1]);&&if (sfd == -1)&&&&abort ();&&&s = make_socket_non_blocking (sfd);&&if (s == -1)&&&&abort ();&&&s = listen (sfd, SOMAXCONN);&&if (s == -1)&&&&{&&&&&&perror ("listen");&&&&&&abort ();&&&&}&&&efd = epoll_create1 (0);&&if (efd == -1)&&&&{&&&&&&perror ("epoll_create");&&&&&&abort ();&&&&}&&&event.data.fd = sfd;&&event.events = EPOLLIN | EPOLLET;&&s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);&&if (s == -1)&&&&{&&&&&&perror ("epoll_ctl");&&&&&&abort ();&&&&}&&&/* Buffer where events are returned */&&events = calloc (MAXEVENTS, sizeof event);&&&/* The event loop */&&while (1)&&&&{&&&&&&int n, i;&&&&&&&n = epoll_wait (efd, events, MAXEVENTS, -1);&&&&&&for (i = 0; i & n; i++) { &&if ((events[i].events & EPOLLERR) ||&&&&&&&&&&&&&&(events[i].events & EPOLLHUP) ||&&&&&&&&&&&&&&(!(events[i].events & EPOLLIN))) &&&&{&&&&&&&&&&&&&&/* An error has occured on this fd, or the socket is not&&&&&&&&&&&&&&&& ready for reading (why were we notified then?) */ &&&&&&fprintf (stderr, "epoll error\n"); &&&&&&close (events[i].data.fd); &&&&&&continue; &&&&}& &&else if (sfd == events[i].data.fd) &&&&{&&&&&&&&&&&&&&/* We have a notification on the listening socket, which&&&&&&&&&&&&&&&& means one or more incoming connections. */&&&&&&&&&&&&&&while (1)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&struct sockaddr in_addr;&&&&&&&&&&&&&&&&&&socklen_t in_len;&&&&&&&&&&&&&&&&&&int infd;&&&&&&&&&&&&&&&&&&char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];&&&&&&&&&&&&&&&&&&&in_len = sizeof in_addr;&&&&&&&&&&&&&&&&&&infd = accept (sfd, &in_addr, &in_len);&&&&&&&&&&&&&&&&&&if (infd == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&if ((errno == EAGAIN) ||&&&&&&&&&&&&&&&&&&&&&&&&&&(errno == EWOULDBLOCK))&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&/* We have processed all incoming&&&&&&&&&&&&&&&&&&&&&&&&&&&& connections. */&&&&&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&&&else&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&perror ("accept");&&&&&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&s = getnameinfo (&in_addr, in_len,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& hbuf, sizeof hbuf,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& sbuf, sizeof sbuf,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& NI_NUMERICHOST | NI_NUMERICSERV);&&&&&&&&&&&&&&&&&&if (s == 0)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&printf("Accepted connection on descriptor %d "&&&&&&&&&&&&&&&&&&&&&&&&&&&& "(host=%s, port=%s)\n", infd, hbuf, sbuf);&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&/* Make the incoming socket non-blocking and add it to the&&&&&&&&&&&&&&&&&&&& list of fds to monitor. */&&&&&&&&&&&&&&&&&&s = make_socket_non_blocking (infd);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&event.data.fd = infd;&&&&&&&&&&&&&&&&&&event.events = EPOLLIN | EPOLLET;&&&&&&&&&&&&&&&&&&s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&perror ("epoll_ctl");&&&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&continue;&&&&&&&&&&&&}&&&&&&&&&&else&&&&&&&&&&&&{&&&&&&&&&&&&&&/* We have data on the fd waiting to be read. Read and&&&&&&&&&&&&&&&& display it. We must read whatever data is available&&&&&&&&&&&&&&&& completely, as we are running in edge-triggered mode&&&&&&&&&&&&&&&& and won't get a notification again for the same&&&&&&&&&&&&&&&& data. */&&&&&&&&&&&&&&int done = 0;&&&&&&&&&&&&&&&while (1)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&ssize_t count;&&&&&&&&&&&&&&&&&&char buf[512];&&&&&&&&&&&&&&&&&&&count = read (events[i].data.fd, buf, sizeof buf);&&&&&&&&&&&&&&&&&&if (count == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&/* If errno == EAGAIN, that means we have read all&&&&&&&&&&&&&&&&&&&&&&&& data. So go back to the main loop. */&&&&&&&&&&&&&&&&&&&&&&if (errno != EAGAIN)&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&perror ("read");&&&&&&&&&&&&&&&&&&&&&&&&&&done = 1;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&else if (count == 0)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&/* End of file. The remote has closed the&&&&&&&&&&&&&&&&&&&&&&&& connection. */&&&&&&&&&&&&&&&&&&&&&&done = 1;&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&/* Write the buffer to standard output */&&&&&&&&&&&&&&&&&&s = write (1, buf, count);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&perror ("write");&&&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&if (done)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&printf ("Closed connection on descriptor %d\n",&&&&&&&&&&&&&&&&&&&&&&&&&&events[i].data.fd);&&&&&&&&&&&&&&&&&&&/* Closing the descriptor will make epoll remove it&&&&&&&&&&&&&&&&&&&& from the set of descriptors which are monitored. */&&&&&&&&&&&&&&&&&&close (events[i].data.fd);&&&&&&&&&&&&&&&&}&&&&&&&&&&&&}&&&&&&&&}&&&&}&&&free (events);&&&close (sfd);&&&return EXIT_SUCCESS;}
main函数的流程是
1. create_and_bind创建服务器端的socket描述符
2. 设置描述符为非阻塞
3. 监听描述符
4. 创建epoll文件描述符efd
5. 使用边缘触发的方式添加sfd输入监听事件
最外层的while循环时主事件循环(event loop)。调用epoll_wait阻塞等待事件发生，当事件到达epoll_wait返回事件在事件参数中，一批epoll_event结构体。
epoll事件循环中epoll实例在建立新连接时候添加事件和当断开连接的时候删除事件。
当事件发生时，有如下几种方式
错误：当发生错误，或者不是可读事件通知时，简单关闭文件描述符，关闭文件描述符会自动从efd的监控集中删除。
新连接：当监听描述符可读时，表示有新的连接到达，accept()新连接，设置新连接描述符为非阻塞并添加到efd监控集中。
客户端数据：当任何一个客户端文件描述符可读，使用read()每次读区512字节循环读取。 因为我们需要读取当前所有可读区数据 ，当边缘触发的情况下不会再次通知可读。 读取到的数据调用write写到标准输出stdout (fd=1)。如果read(2)返回0，表示EOF并切可以关闭客户端连接。如果返回-1并且 errno设置为EAGAIN表示这个事件所有可读的数据读取完毕可以返回进入主事件循环。
就这样不断的循环，添加和删除文件描述符到efd的监控集中。
/blog/2/how-to-use-epoll-a-complete-example-in-c/
用 eclipse cdt 运行 gtest 在 console 的输出结果有有 shell 终端的颜色代码输出
Running main() from gmock_main.cc
[0;32m[==========] [mRunning 4 tests from 1 test case.
[0;32m[----------] [mGlobal test environment set-up.
[0;32m[----------] [m4 tests from PrimeFactors
[0;32m[ RUN
] [mPrimeFactors.1factor
OK ] [mPrimeFactors.1factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.2factor
OK ] [mPrimeFactors.2factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.3factor
OK ] [mPrimeFactors.3factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.4factor
OK ] [mPrimeFactors.4factor (0 ms)
[0;32m[----------] [m4 tests from PrimeFactors (0 ms total)
[0;32m[----------] [mGlobal test environment tear-down
[0;32m[==========] [m4 tests from 1 test case ran. (0 ms total)
] [m4 tests.
如何让 console 的输出和 shell 中的输出效果相同。
可以通过在 eclipse market 安装 ANSI escape 来解决。
gd 跳转到局部函数定义.
gD 跳转到全局函数定义.
g* 向下搜索光标所在单词 (
当光标在 'rain' 会查找 'rainbow').
g# 向上搜索光标所在单词
gg 跳转到第一行
G 跳转到最后一行
现在先抛出问题，假设有一个主数据中心在北京M，然后有成都A，上海B两个地方数据中心，现在的问题是，假设成都上海各自的数据中心有记录变更，需要先同步到主数据中心，主数据中心更新完成之后，在把最新的数据分发到上海，成都的地方数据中心A，地方数据中心更新数据，保持和主数据中心一致性（数据库结构完全一致）。数据更新的消息是通过一台中心的MQ进行转发。
先把问题简单化处理，假设A增加一条记录Message_A，发送到M，B增加一条记录 MESSAGE_B发送到M，都是通过MQ服务器进行转发，那么M系统接收到条消息，增加两条数据，那么M在把增加的消息群发给A，B，A和B找到自己缺失的数据，更新数据库。这样就完成了一个数据的同步。
从正常情况下来看，都没有问题，逻辑完全合理，但是请考虑以下三个问题
1 如何保证A-&M的消息，M一定接收到了，同样，如何保证M-&A的消息，M一定接收到了
2 如果数据需要一致性更新，比如A发送了三条消息给M，M要么全部保存，要么全部不保存，不能够只保存其中的几条记录。我们假设更新的数据是一条条发送的。
3 假设同时A发送了多条更新请求，如何保证顺序性要求？
这两个问题就是分布式环境下数据一致性的问题
对于第一个问题，比较好解决，我们先看看一个tcp/ip协议链接建立的过程
我们的思路可以从这个上面出发，在简化一下，就一个请求，一个应答。
简单的通信模型是这样的
A-&M : 你收到我的一条消息没有，消息的ID是12345
M-&A: 我收到了你的一条消息数据，消息数据是ID;12345
这样就一个请求，一个应答，就完成了一次可靠性的传输。如果A一致没有收到M的应答，就不断的重试。这个时候M就必须保证幂等性。不能重复的处理消息。那么最极端的情况是，怎么也收不到M的应答，这个时候是系统故障。自己检查一下吧。
这么设计就要求，A在发送消息的时候持久化这个消息的数据内容，然后不断的重试，一旦接收到M的应答，就删除这条消息。同样，M端也是一样的。不要相信MQ的持久化机制，不是很靠谱的。
那么M给A发送消息也采取类似的原理就可以了。
下面在看看第二个问题，如何保持数据的一致性更新，这个还是可以参考TCP/IP的协议。
首先A发送一条消息给M：我要发送一批消息数据给你，批次号是10000，数据是5条。
M发送一条消息给A：ok，我准备好了，批次号是10000，发送方你A
接着A发送5条消息给M，消息ID分别为1，2，3，4，5 ，批次号是10000，
紧接着，A发送一个信息给M：我已经完成5小消息的发送，你要提交数据更新了
接下来可能发送两种情况
1 那么M发送消息给A：ok，我收到了5条消息，开始提交数据
2 那么M也可以发送给A：我收到了5条消息，但是还缺少，请你重新发送，那么A就继续发送，直到A收到M成功的应答。
整个过程相当复杂。这个也就是数据一旦分布了，带来最大的问题就是数据一致性的问题。这个成本非常高。
对于第三个问题，这个就比较复杂了
这个最核心的问题就是消息的顺序性，我们只能在每个消息发一个消息的序列号，但是还是没有最好解决这个问题的办法。因为消息接收方不知道顺序。因为即使给他了序列号，也没有办法告诉他，这个应该何时处理。最好的办法是在第二种方式的基础作为一个批次来更新。
这个只是以最简单的例子来说明一下分布式系统的要保证数据一致性是一件代价很大的事情。当然有的博主会说，这个何必这么复杂，直接数据库同步不就可以了。这个例子当然是没有问题的，万一这个几个库的模型都不一样，我发送消息要处理的事情不一样的。怎么办？
在上文，简单的介绍了分布式数据的同步问题，上面的问题比较抽象，在目前的互联网应用中还很少见，这次在通过一个比较常见的例子，让大家更深入的了解一下分布式系统设计中关于数据一致性的问题
这次我们拿我们经常使用的功能来考虑吧，最近网购比较热门，就以京东为例的，我们来看看京东的一个简单的购物流程
用户在京东上下了一个订单，发现自己在京东的账户里面有余额，然后使用余额支付，支付成功之后，订单状态修改为支付成功，然后通知仓库发货。假设订单系统，支付系统，仓库系统是三个独立的应用，是独立部署的，系统之间通过远程服务调用。
订单的有三个状态：I:初始 P:已支付 W:已出库，订单金额100, 会员帐户余额200
如果整个流程比较顺利，正常情况下，订单的状态会变为I-&P-&W，会员帐户余额100，订单出库。
但是如果流程不顺利了？考虑以下几种情况
1：订单系统调用支付系统支付订单，支付成功，但是返回给订单系统数据超时，订单还是I（初始状态），但是此时会员帐户余额100,会员肯定会马上找京东骂京东，为啥不给老子发货，我都付钱了
2：订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
3：订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
对于问题一，我们来分析一下解决方案，能想到的解决方案如下
1 假设调用支付系统支付订单的时候先不扣钱，订单状态更新完成之后，在通知支付系统你扣钱
如果采用这种设计方案，那么在同一时刻，这个用户，又支付了另外一笔订单，订单价格200，顺利完成了整个订单支付流程，由于当前订单的状态已经变成了支付成功，但是实际用户已经没有钱支付了，这笔订单的状态就不一致了。即使用户在同一个时刻没有进行另外的订单支付行为，通知支付系统扣钱这个动作也有可能完不成，因为也有可能失败，反而增加了系统的复杂性。
2 订单系统自动发起重试，多重试几次，例如三次，直到扣款成功为止。
这个看起来也是不错的考虑，但是和解决方案一样，解决不了问题，还会带来新的问题，假设订单系统第一次调用支付系统成功，但是没有办法收到应答，订单系统又发起调用，完了，重复支付，一次订单支付了200。
假设支付系统正在发布，你重试多少次都一样，都会失败。这个时候用户在等待，你怎么处理？
3 在第二种方案的基础上，我们先解决订单的重复支付行为，我们需要在支付系统上对订单号进行控制，一笔订单如果已经支付成功，不能在进行支付。返回重复支付标识。那么订单系统根据返回的标识，更新订单状态。
接下来解决重试问题，我们假设应用上重试三次，如果三次都失败，先返回给用户提示支付结果未知。假设这个时候用户重新发起支付，订单系统调用支付系统，发现订单已经支付，那么继续下面的流程。如果会员没有发起支付，系统定时（一分钟一次）去核对订单状态，如果发现已经被支付，则继续后续的流程。
这种方案，用户体验非常差，告诉用户支付结果未知，用户一定会骂你，你丫咋回事情，我明明支付了，你告诉我未知。假设告诉用户支付失败，万一实际是成功的咋办。你告诉用户支付成功，万一支付失败咋办。
4 第三种方案能够解决订单和支付数据的一致性问题，但是用户体验非常差。当然这种情况比较可能是少数，可以牺牲这一部分的用户体验，我们还有没有更好的解决方案，既能照顾用户体验，又能够保证资金的安全性。
我们再回来看看第一种方案，我们先不扣钱，但是有木有办法让这一部分钱不让用户使用，对了，我们先把这一部分钱冻结起来，订单系统先调用支付系统成功的时候，支付系统先不扣钱，而是先把钱冻结起来，不让用户给其他订单支付，然后等订单系统把订单状态更新为支付成功的时候，再通知支付系统，你扣钱吧，这个时候支付系统扣钱，完成后续的操作。
看起来这个方案不错，我们仔细在分析一下流程，这个方案还存在什么问题，假设订单系统在调用支付系统冻结的时候，支付系统冻结成功，但是订单系统超时，这个时候返回给用户，告知用户支付失败，如果用户再次支付这笔订单，那么由于支付系统进行控制，告诉订单系统冻结成功，订单系统更新状态，然后通知支付系统，扣钱吧。如果这个时候通知失败，木有问题，反正钱都已经是冻结的了，用户不能用，我只要定时扫描订单和支付状态，进行扣钱而已。
那么如果变态的用户重新拍下来一笔订单,100块钱，对新的订单进行支付，这个时候由于先前那一笔订单的钱被冻结了，这个时候用户余额剩余100，冻结100，发现可用的余额足够，那就直接在对用户扣钱。这个时候余额剩余0，冻结100。先前那一笔怎么办，一个办法就是定时扫描，发现订单状态是初始的话，就对用户的支付余额进行解冻处理。这个时候用户的余额变成100，订单数据和支付数据又一致了。假设原先用户余额只有100，被冻结了，用户重新下单，支付的时候就失败了啊，的确会发生这一种情况，所以要尽可能的保证在第一次订单结果不明确的情况，尽早解冻用户余额，比如10秒之内。但是不管如何快速，总有数据不一致的时刻，这个是没有办法避免的。
第二种情况和第三种情况如何处理，下次在分析吧。
由于互联网目前越来越强调分布式架构，如果是交易类系统，面临的将会是分布式事务上的挑战。当然目前有很多开源的分布式事务产品，例如java JPA，但是这种解决方案的成本是非常高的，而且实现起来非常复杂，效率也比较低下。对于极端的情况：例如发布，故障的时候都是没有办法保证强一致性的。
在上文主要介绍了数据分布的情况下保证一致性的情况，在第二篇文章里面，我这里提出了三个问题
1.订单系统调用支付系统支付订单，支付成功，但是返回给订单系统数据超时，订单还是I（初始状态），但是此时会员帐户余额100,会员肯定会马上找京东骂京东，为啥不给老子发货，我都付钱了
2.订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
3.订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
重点分析解决了第一个的问题以及相应的方案，发现在数据分布的环境下，很难绝对的保证数据一致性（任何一段区间），但是有办法通过一种补偿机制，最终保证数据的一致性。
在下面在分析一下第二个问题
订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
通过在上一篇文章里面分析过，这个相对来说是比较简单的，我可以采取重试机制，如果发现通知仓库发货失败，就一致重试，
这里面有两种方式：
1 异步方式：通过类似MQ（消息通知）的机制，这个是异步的通知
2 同步调用：类似于远程过程调用
对于同步的调用的方式，比较简单，我们能够及时获取结果，对于异步的通知，就必须采用请求，应答的方式进行，这一点在（关于分布式系统的数据一致性问题(一)）里面有介绍。这里面就不再阐述。
来看看第三个问题
订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
我觉得这是一个很有意思的问题，我们还是考虑几种解决的方案
1 在会员下单的时刻，就告诉仓库，我要你把货物留下来，
2 在会员支付订单时候，在支付之前检查仓库有没有货，如果没有货，就告知会员木有货物了
3 如果会员支付成功，这个时候没有货了，就会退款给用户或者等待有货的时候在发货
正常情况，京东的仓库一般都是有货的，所以影响到的会员很少，但是在秒杀和营销的时候，这个时候就不一定了，我们考虑假设仓库有10台iphone
如果采用第一种方案，
1 在会员下单的时候，相当于库存就-1，那么用户恶意拍下来，没有去支付，就影响到了其他用户的购买。京东可以设置一个订单超时时间，如果这段时间内没有支付，就自动取消订单
2 在会员支付之前，检查仓库有货，这种方案了，对于用户体验不好，但是对于京东比较好，至少我东西都卖出去了。那些没有及时付款的用户，只能投诉了京东无故取消订单
3 第三种方案，这个方案体验更不好，而且用户感觉受到京东欺诈，但是对于京东来说，比第二种方案更有益，毕竟我还可以多卖出一点东西。
个人觉得，京东应该会采用第二种或者第三种方式来处理这类情况，我在微博上搜索了 “京东 无故取消订单”，发现果真和我预料的处理方式。不过至于这里的无故取消是不是技术上的原因我不知道，如果真的是技术上的原因，我觉得京东可以采用不同的处理方案。对于秒杀和促销商品，可以考虑第一种方案，大多数人都会直接付款，毕竟便宜啊，如果用户抢不到便宜的东西，抱怨当然很大了。这样可以照顾大多数用户的体验。对于一般的订单，可以采用第二种或者第三种方式，这种情况下，发生付款之后仓库没有货的情况会比较少，并且就算发生了，用户也会觉得无所谓，大不了退钱吗，这样就可以实现自己的利益最大化而最低程度的减少用户体验。
而铁道部在这个问题上，采用的是第一种方案，为什么和京东不一样，就是因为用户体验，如果用户把票都买了，你告诉我木有票了，旅客会杀人的。哈哈，不过铁道部不担心票卖不出去，第一种方案对他影响没有什么。
说了这么多，就是说 分布式环境下（数据分布）要任何时刻保证数据一致性是不可能的，只能采取妥协的方案来保证数据最终一致性。这个也就是著名的CAP定理。
在前面三篇文章中，介绍了关于分布式系统中数据一致性的问题，这一篇主要介绍CAP定理以及自己对CAP定理的了解。
CAP定理是2000年，由 Eric Brewer 提出来的
Brewer认为在分布式的环境下设计和部署系统时，有3个核心的需求，以一种特殊的关系存在。这里的分布式系统说的是在物理上分布的系统，比如我们常见的web系统。
这3个核心的需求是：Consistency，Availability和Partition Tolerance，赋予了该理论另外一个名字 － CAP。
Consistency：一致性，这个和数据库ACID的一致性类似，但这里关注的所有数据节点上的数据一致性和正确性，而数据库的ACID关注的是在在一个事务内，对数据的一些约束。
Availability：可用性，关注的在某个结点的数据是否可用，可以认为某一个节点的系统是否可用，通信故障除外。
Partition Tolerance：分区容忍性，是否可以对数据进行分区。这是考虑到性能和可伸缩性。
为什么不能完全保证这个三点了，个人觉得主要是因为一旦进行分区了，就说明了必须节点之间必须进行通信，涉及到通信，就无法确保在有限的时间内完成指定的行文，如果要求两个操作之间要完整的进行，因为涉及到通信，肯定存在某一个时刻只完成一部分的业务操作，在通信完成的这一段时间内，数据就是不一致性的。如果要求保证一致性，那么就必须在通信完成这一段时间内保护数据，使得任何访问这些数据的操作不可用。
如果想保证一致性和可用性，那么数据就不能够分区。一个简单的理解就是所有的数据就必须存放在一个数据库里面，不能进行数据库拆分。这个对于大数据量，高并发的互联网应用来说，是不可接受的。
我们可以拿一个简单的例子来说明：假设一个购物系统，卖家A和卖家B做了一笔交易100元，交易成功了，买家把钱给卖家。
这里面存在两张表的数据：Trade表Account表 ，涉及到三条数据Trade(100),Account A ,Account B
假设 trade表和account表在一个数据库，那么只需要使用数据库的事务，就可以保证一致性，同时不会影响可用性。但是随着交易量越来越大，我们可以考虑按照业务分库，把交易库和account库单独分开，这样就涉及到trade库和account库进行通信，也就是存在了分区，那么我们就不可能同时保证可用性和一致性。
我们假设初始状态
trade(buyer,seller,tradeNo,status) = trade(A,B,,I)
account(accountNo,balance) = account(A,300)
account(accountNo,balance) = account(B,10)
在理想情况下，我们期望的状态是
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(A,200)
account(accountNo,balance) = account(B,110)
但是考虑到一些异常情况
假设在trade(,S)更新完成之前，帐户A进行扣款之后，帐户A进行了另外一笔300款钱的交易，把钱消费了，那么就存在一个状态
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(A,0)
account(accountNo,balance) = account(B,10)
产生了数据不一致的状态
由于这个涉及到资金上的问题，对资金要求比较高，我们必须保证一致性，那么怎么办，只能在进行trade(A,B,)交易的时候，对于任何A的后续交易请求trade(A,X,X)，必须等到A完成之后，才能够进行处理，也就是说在进行trade(A,B,)的时候，Account(A)的数据是不可用的。
任何架构师在设计分布式的系统的时候，都必须在这三者之间进行取舍。首先就是是否选择分区，由于在一个数据分区内，根据数据库的ACID特性，是可以保证一致性的，不会存在可用性和一致性的问题，唯一需要考虑的就是性能问题。对于可用性和一致性，大多数应用就必须保证可用性，毕竟是互联网应用，牺牲了可用性，相当于间接的影响了用户体验，而唯一可以考虑就是一致性了。
牺牲一致性
对于牺牲一致性的情况最多的就是缓存和数据库的数据同步问题，我们把缓存看做一个数据分区节点，数据库看作另外一个节点，这两个节点之间的数据在任何时刻都无法保证一致性的。在web2.0这样的业务，开心网来举例子，访问一个用户的信息的时候，可以先访问缓存的数据，但是如果用户修改了自己的一些信息，首先修改的是数据库，然后在通知缓存进行更新，这段期间内就会导致的数据不一致，用户可能访问的是一个过期的缓存，而不是最新的数据。但是由于这些业务对一致性的要求比较高，不会带来太大的影响。
异常错误检测和补偿
还有一种牺牲一致性的方法就是通过一种错误补偿机制来进行，可以拿上面购物的例子来说，假设我们把业务逻辑顺序调整一下，先扣买家钱，然后更新交易状态，在把钱打给卖家
我们假设初始状态
account(accountNo,balance) = account(A,300)
account(accountNo,balance) = account(B,10)
trade(buyer,seller,tradeNo,status) = trade(A,B,,I)
那么有可能出现
account(accountNo,balance) = account(A,200)
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(B,10)
那么就出现了A扣款成功，交易状态也成功了，但是钱没有打给B，这个时候可以通过一个时候的异常恢复机制，把钱打给B，最终的情况保证了一致性，在一定时间内数据可能是不一致的，但是不会影响太大。
两阶段提交协议
当然，还有一种方式就是我另外一篇文章里面《X/Open DTP-分布式事务模型》里面说的，但是再第一阶段和第二阶段之间，数据也可不能是一致性的，也可能出现同样的情况导致异常。而且DTP的分布式事务模型 限制太多，例如必须有实现其功能的相关的容器支持，并且资源管理器也必须实现了XA规范。限制比较多。
国外有的架构师有两种方案去解决CAP的限制，但是也是比较适合特定的业务，而没有通用的解决方案，
探知分区-&分区内操作-&事后补偿
就是上面介绍的异常检测恢复机制，这种机制其实还是有限制，
首先对于分区检测操作，不同的业务涉及到的分区操作可能不一样
分区内操作限制：不同的业务对应的约束不一致
事后补偿：由于业务约束不一样，补偿方式也不一样。
所以这只能作为一种思想，不能做一个通用的解决方案
- 287,184 views - 226,263 views - 173,979 views - 136,018 views - 94,390 views - 87,028 views - 81,505 views - 80,155 views - 69,869 views - 59,239 views}
所属分类： &
查看: 7|回复: 1
dnf服务器的削峰配置错误，请运行维检测配置是什么意
发表于 3&分钟前
服务器的削峰配置错误，请运行维检测配置是什么意思
找手游 上18183
TA的勋章：
发表于 2&分钟前
这个你还是去te5DNF专区看吧，在攻略速递那边都写的很清楚，
指尖每日首次回帖可以赚5金币（）收起回复展开回复
找手游 上18183
不狂不男人！公测狂送mini4、海量千元京东卡大奖！赶紧来~
经常在论坛发帖，且发帖量较大（发帖量4000以上）后使用我的收藏没有帐号？
所属分类： &
查看: 3|回复: 1
dnf服务器的削峰配置错误 这个怎么搞？
发表于 3&分钟前
服务器的削峰配置错误 这个怎么搞？
找手游 上18183
TA的勋章：
发表于 1&分钟前
这个你还是去te5DNF专区看吧，在攻略速递那边都写的很清楚，
指尖每日首次回帖可以赚5金币（）收起回复展开回复
找手游 上18183
不狂不男人！公测狂送mini4、海量千元京东卡大奖！赶紧来~
经常在论坛发帖，且发帖量较大（发帖量4000以上）RHEL6配置简单LDAP服务器
RHEL6配置简单LDAP服务器
基于TLS加密和NFS的用户家目录自动挂载
实验说明：
在RHEL6.0中，使用开源的openldap套件，安装配置LDAP认证服务；并使用TLS加密认证；NFS共享用户家目录， autofs实现自动挂载。
实验环境：
利用教学使用的instructor服务器，提供dns、dhcp服务；
server5为独立的CA服务器，station.配置
为ldap服务器，desktop11为ldap客户端。
备注：简单实验，服务器可集中在1台，客户端1台，共2台即可。
实验拓朴：
实验步骤：
1.DNS做好域名解析，
2.ldap服务器的基本网络配置
3.安装LDAP相关软件：
主要有3个包：openldap、openldap-servers、openldap-clients
4.&配置LDAP的域信息，并测试！&
5.创建数据库文件（从模板复制产生）。并使用户ldap有权限。
6.启动LDAP服务，自动创建数据库文件。&
7.检查搜索域
8.创建待认证的用户。最后指定特定的家目录。如：/netdir/guests
9.安装迁移工具migrationtools，用来迁移系统用户为ldap用户。
这些 Perl 脚本的配置信息包含在 migrate_common.ph 文件的开头。对于我们来说，只需要修改命名前缀的变量来使用条目的识别名就足够了，如下所示：
10.创建认证账户文件
主要的概念：
dn：唯一区分名
dc：所属区域
ou：所属组织
cn/uid：全名/登录ID
① 运行脚本 migrate_base.pl，它会创建根项，并为 Hosts、Networks、Group 和 People 等创建低一级的组织单元，指定为base.ldif文件
② 创建用户数据库文件：最好先把要迁移为ldap用户先导出为独立文件。&
③ 创建组账户文件；④ 检查产生的三个文件。
重启sladp，迁移用户；&
如果出现错误：
ldap_bind: Invalid credentials
就表示你要么给出了错误的"cn="条目，要么给出了错误的密码
Enter LDAP
Password:(输入你刚才设置的密码)，正确之后会显示：
11.&打开服务器端防火墙tcp389端口&
12.用GUI界面查看LDAP用户
最好是：cd /var/www/html/目录，再下载phpldapadmin-1.2.2.tgz
(版本要新点的，不要下错啊！否则可能造成无法使用)
然后在客户机上打开浏览器&
登录的时候：DN框输入：cn=Manager,dc=domain11,dc=com，输入密码。
登录成功！列出目录用户
13.ldap客户端配置&(另启一台为客户端)
打开LDAP配置界面&
测试。这时还不能自动挂ldapuser的家目录，后面autofs再分析。
&检查/etc/openldap/ldap.conf&；/etc/nsswitch.conf；
&再次检查/etc/resolv.conf的配置是否发生变化；
关于sssd服务。这个服务不是必须的。
安装sssd包。将/etc/sssd/sssd.conf文件中的#enumerate=false，修改为：enumerate=true，这样修改完后，getent就会从LDAP查找账户信息。
14.实现TLS加密
① 搭建CA中心，安装openssl包，并配置：
② CA中心生成自已的私、公钥(证书)
③ ldap服务器生成私钥，并生成证书请求文件：&
④ CA中心签发证书，ldap服务器下载CA证书和自己的证书
⑤ ldap服务器安装证书
⑥ CA中心发布自已的公钥
TLSVerifyClient&&&&&&&&&
never &#永不对客户证书进行认证
附注：要启动TLS进行数据加密，server端即使不对客户端进行证书认证，也必须（required）配置以上项，否则TLS失败。
15.实现基于NFS的LDAP用户主目录
配置nfs服务器
如果不是on则远程用户无权限进入自己的目录。&
2) 配LDAP客户端。必须有第一节的目录，即：/netdir，其它可以没有！
3) 测试登录，有家目录了！
已投稿到：
以上网友发言只代表其个人观点，不代表新浪网的观点或立场。一致性哈希算法能够减少增减节点带来的memcache缓存失效带来的冲击。
下面是一个简单的java版实现算法，其中的哈希值算法没有实现，用HashFunction作为一个接口来提供自定义的hash值函数，大多数情况下我们可以使用md5。
import java.util.C
import java.util.SortedM
import java.util.TreeM
public class ConsistentHash&T& {
private final HashFunction hashF
private final int numberOfR
private final SortedMap&Integer, T& circle = new TreeMap&Integer, T&();
public ConsistentHash(HashFunction hashFunction, int numberOfReplicas,
Collection&T& nodes) {
this.hashFunction = hashF
this.numberOfReplicas = numberOfR
for (T node : nodes) {
add(node);
public void add(T node) {
for (int i = 0; i & numberOfR i++) {
circle.put(hashFunction.hash(node.toString() + i), node);
public void remove(T node) {
for (int i = 0; i & numberOfR i++) {
circle.remove(hashFunction.hash(node.toString() + i));
public T get(Object key) {
if (circle.isEmpty()) {
int hash = hashFunction.hash(key);
if (!circle.containsKey(hash)) {
SortedMap&Integer, T& tailMap = circle.tailMap(hash);
hash = tailMap.isEmpty() ? circle.firstKey() : tailMap.firstKey();
return circle.get(hash);
123456789101112131415161718192021222324252627282930313233343536373839404142434445
import java.util.Collection;import java.util.SortedMap;import java.util.TreeMap;&public class ConsistentHash&T& {& private final HashFunction hashFunction; private final int numberOfReplicas; private final SortedMap&Integer, T& circle = new TreeMap&Integer, T&();& public ConsistentHash(HashFunction hashFunction, int numberOfReplicas,&&&& Collection&T& nodes) {&& this.hashFunction = hashFunction;&& this.numberOfReplicas = numberOfReplicas;&&& for (T node : nodes) {&&&& add(node);&& } }& public void add(T node) {&& for (int i = 0; i & numberOfReplicas; i++) {&&&& circle.put(hashFunction.hash(node.toString() + i), node);&& } }& public void remove(T node) {&& for (int i = 0; i & numberOfReplicas; i++) {&&&& circle.remove(hashFunction.hash(node.toString() + i));&& } }& public T get(Object key) {&& if (circle.isEmpty()) {&&&& return null;&& }&& int hash = hashFunction.hash(key);&& if (!circle.containsKey(hash)) {&&&& SortedMap&Integer, T& tailMap = circle.tailMap(hash);&&&& hash = tailMap.isEmpty() ? circle.firstKey() : tailMap.firstKey();&& }&& return circle.get(hash); }&}
circle代表有一个有序整型map，表示要缓存的对象所对应hash值。
创建ConsistentHash对象时会同时创建虚拟节点。每个复制节点都是实用对象名和后缀结合的hash值。
缓存对象分布在每一个map中的节点上。
mac环境的配置方法和linux一样。
通过ulimit来设置是否生成core文件。
ulimit -c unlimited
生成core文件
ulimit -c 0
不生成core文件
core 文件存储位置 /core/core.pid
warnning 错误，没有处理switch中的枚举值。
在switch中添加default 和 可以解决这个问题。
想写一个爬虫去爬一些图片，发现python3的request封装的比较。遂决定要装一个python3。
mac下的神器就是brew，分分种完成各种软件包的安装。执行完之后报错了。
brew install python3
结果如下，从最后几行的输出判断是由于权限不足导致的。
==& Downloading https://www.python.org/ftp/python/3.4.3/Python-3.4.3.tar.xz
######################################################################## 100.0%
==& ./configure --prefix=/usr/local/Cellar/python3/3.4.3 --enable-ipv6 --datarootdir=/usr/local/Cellar/python3/3.4.3/share --datadir=/usr/local/Cellar/python
==& make install PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3
==& make frameworkinstallextras PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3/share/python3
==& Downloading https://pypi.python.org/packages/source/s/setuptools/setuptools-12.2.tar.gz
######################################################################## 100.0%
==& Downloading https://pypi.python.org/packages/source/p/pip/pip-6.0.8.tar.gz
######################################################################## 100.0%
==& Caveats
Pip has been installed. To update it
pip3 install --upgrade pip
You can install Python packages with
pip3 install &package&
They will install into the site-package directory
/usr/local/lib/python3.4/site-packages
See: /Homebrew/homebrew/blob/master/share/doc/homebrew/Homebrew-and-Python.md
.app bundles were installed.
Run `brew linkapps python3` to symlink these to /Applications.
Error: An unexpected error occurred during the `brew link` step
The formula built, but is not symlinked into /usr/local
Permission denied - /usr/local/Frameworks
Error: Permission denied - /usr/local/Frameworks
12345678910111213141516171819202122232425262728
==& Downloading https://www.python.org/ftp/python/3.4.3/Python-3.4.3.tar.xz######################################################################## 100.0%==& ./configure --prefix=/usr/local/Cellar/python3/3.4.3 --enable-ipv6 --datarootdir=/usr/local/Cellar/python3/3.4.3/share --datadir=/usr/local/Cellar/python==& make==& make install PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3==& make frameworkinstallextras PYTHONAPPSDIR=/usr/local/Cellar/python3/3.4.3/share/python3==& Downloading https://pypi.python.org/packages/source/s/setuptools/setuptools-12.2.tar.gz######################################################################## 100.0%==& Downloading https://pypi.python.org/packages/source/p/pip/pip-6.0.8.tar.gz######################################################################## 100.0%==& CaveatsPip has been installed. To update it&&pip3 install --upgrade pip&You can install Python packages with&&pip3 install &package&&They will install into the site-package directory&&/usr/local/lib/python3.4/site-packages&See: https:///Homebrew/homebrew/blob/master/share/doc/homebrew/Homebrew-and-Python.md&.app bundles were installed.Run `brew linkapps python3` to symlink these to /Applications.Error: An unexpected error occurred during the `brew link` stepThe formula built, but is not symlinked into /usr/localPermission denied - /usr/local/FrameworksError: Permission denied - /usr/local/Frameworks
brew遇到问题排错步骤是：
sudo chown -R $(whoami):admin /usr/local
sudo chown -R $(whoami) /Library/Caches/Homebrew
brew doctor
brew prune
brew update
sudo chown -R $(whoami):admin /usr/localsudo chown -R $(whoami) /Library/Caches/Homebrewbrew doctor brew prunebrew update
brew linkapps python3
gcov 是 GNU 的代码覆盖率检查工具。它利用编译时的 -fprofile-arcs -ftest-coverage 和链接时的 -lgcov 选项参数生成 .gcno 文件进而通过这些文件统计覆盖率。不过高版本的 mac 使用 clang 编译器，不支持 -lgcov 选项生成 .gcno 文件。为了解决这个问题，我们可以使用-coverage参数来生成 .gcno 文件。例如：
我的g++ --version信息如下
Apple LLVM version 7.3.0 (clang-703.0.29)
Target: x86_64-apple-darwin15.4.0
Thread model: posix
使用-lgcov会报错
ld: library not found for -lgcov
可以使用-coverage选项替换-lgcov
clang -coverage test.c
gcov test.c
clang -coverage test.c./a.outgcov test.c
在C/C++中产生代码覆盖率的步骤包括如下几步：
一、设置编译参数
如下来设置Makefile中的编译参数以使之支持覆盖率产生：
ifeq ($(coverage), yes)
CXXFLAGS +=
这样，可以使用 make coverage=yes 来引入这些编译选项而不会影响到正常的编译，比如：
#make coverage=yes
这时候会产生.gcno文件。
二、运行测试程序
运行测试程序，会针对所有cpp源代码产生相应的.gcda文件。
三、获取覆盖率数据
获取覆盖率数据的方法很多种，这里介绍两种，分别产生txt和html数据：
1、使用gcov获取文本形式的覆盖率数据
使用gcc自带的覆盖率结果产生工具gcov能产生文本格式（.gcov）的覆盖率结果。
#gcov xxx.cpp
2、使用lcov获取html形式的覆盖率数据
使用IBM的lcov来产生html结果数据，具体如下：
#lcov -c -d ./ -
# -o cc_result
四、展示数据
将步骤三中产生的覆盖率数据文件放到Apached的htdocs目录下，就能通过浏览器来查看覆盖率结果了。
五、基本术语
1、行覆盖率（line coverage）
即源代码有效行数与被执行的代码行的比率。
2、分支覆盖率（branch coverage）
即有判定语句的地方都会出现2个分支，整个程序经过的分支与所有分支的比率是分支覆盖率。
3、增量覆盖率（incremental coverage）
即被执行的新增和修改的代码行数与新增和修改的代码总行数的比率。
gcov实际例子，通过运行gtest中的sample1.cc单元测试。
makefile文件的写法
GTEST_DIR = ..
USER_DIR = ../samples
CPPFLAGS += -isystem $(GTEST_DIR)/include
CXXFLAGS += -g -Wall -Wextra
ifeq ($(coverage), yes)
CXXFLAGS +=
TESTS = sample1_unittest
GTEST_HEADERS = $(GTEST_DIR)/include/gtest/*.h \
$(GTEST_DIR)/include/gtest/internal/*.h
all : $(TESTS)
rm -f $(TESTS) gtest.a gtest_main.a *.o *.gcno *.gcda *.gcov
GTEST_SRCS_ = $(GTEST_DIR)/src/*.cc $(GTEST_DIR)/src/*.h $(GTEST_HEADERS)
gtest-all.o : $(GTEST_SRCS_)
$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \
$(GTEST_DIR)/src/gtest-all.cc
gtest_main.o : $(GTEST_SRCS_)
$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \
$(GTEST_DIR)/src/gtest_main.cc
gtest.a : gtest-all.o
$(AR) $(ARFLAGS) $@ $^
gtest_main.a : gtest-all.o gtest_main.o
$(AR) $(ARFLAGS) $@ $^
sample1.o : $(USER_DIR)/sample1.cc $(USER_DIR)/sample1.h $(GTEST_HEADERS)
$(CXX) $(CPPFLAGS) $(CXXFLAGS)
-c $(USER_DIR)/sample1.cc
sample1_unittest.o : $(USER_DIR)/sample1_unittest.cc \
$(USER_DIR)/sample1.h $(GTEST_HEADERS)
$(CXX) $(CPPFLAGS) $(CXXFLAGS)
-c $(USER_DIR)/sample1_unittest.cc
sample1_unittest : sample1.o sample1_unittest.o gtest_main.a
$(CXX) $(CPPFLAGS) $(CXXFLAGS) -lpthread $^ -o $@
123456789101112131415161718192021222324252627282930313233343536373839404142434445
CXX = g++GTEST_DIR = ..USER_DIR = ../samplesCPPFLAGS += -isystem $(GTEST_DIR)/includeCXXFLAGS += -g -Wall -Wextra &ifeq ($(coverage), yes)&&&&CXXFLAGS +=&&-coverageendif&TESTS = sample1_unittest>EST_HEADERS = $(GTEST_DIR)/include/gtest/*.h \&&&&&&&&&&&&&&&&$(GTEST_DIR)/include/gtest/internal/*.h&all : $(TESTS)&clean :&&&&&&&&rm -f $(TESTS) gtest.a gtest_main.a *.o *.gcno *.gcda *.gcov>EST_SRCS_ = $(GTEST_DIR)/src/*.cc $(GTEST_DIR)/src/*.h $(GTEST_HEADERS)>est-all.o : $(GTEST_SRCS_)&&&&&&&&$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \&&&&&&&&&&&&$(GTEST_DIR)/src/gtest-all.cc>est_main.o : $(GTEST_SRCS_)&&&&&&&&$(CXX) $(CPPFLAGS) -I$(GTEST_DIR) $(CXXFLAGS) -c \&&&&&&&&&&&&$(GTEST_DIR)/src/gtest_main.cc>est.a : gtest-all.o&&&&&&&&$(AR) $(ARFLAGS) $@ $^>est_main.a : gtest-all.o gtest_main.o&&&&&&&&$(AR) $(ARFLAGS) $@ $^&sample1.o : $(USER_DIR)/sample1.cc $(USER_DIR)/sample1.h $(GTEST_HEADERS)&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS)&&-c $(USER_DIR)/sample1.cc&sample1_unittest.o : $(USER_DIR)/sample1_unittest.cc \&&&&&&&&&&&&&&&&&&&& $(USER_DIR)/sample1.h $(GTEST_HEADERS)&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS)&&-c $(USER_DIR)/sample1_unittest.cc&sample1_unittest : sample1.o sample1_unittest.o gtest_main.a&&&&&&&&$(CXX) $(CPPFLAGS) $(CXXFLAGS) -lpthread $^ -o $@
make coverage=yes
g++ -isystem ../include -g -Wall -Wextra
-c ../samples/sample1.cc
g++ -isystem ../include -g -Wall -Wextra
-c ../samples/sample1_unittest.cc
g++ -isystem ../include -I.. -g -Wall -Wextra
-coverage -c \
../src/gtest-all.cc
g++ -isystem ../include -I.. -g -Wall -Wextra
-coverage -c \
../src/gtest_main.cc
ar rv gtest_main.a gtest-all.o gtest_main.o
ar: creating archive gtest_main.a
a - gtest-all.o
a - gtest_main.o
g++ -isystem ../include -g -Wall -Wextra
-coverage -lpthread sample1.o sample1_unittest.o gtest_main.a -o sample1_unittest
123456789101112
?&&make coverage=yesg++ -isystem ../include -g -Wall -Wextra&&-coverage&&-c ../samples/sample1.ccg++ -isystem ../include -g -Wall -Wextra&&-coverage&&-c ../samples/sample1_unittest.ccg++ -isystem ../include -I.. -g -Wall -Wextra&&-coverage -c \&&&&&&&&&&&&../src/gtest-all.ccg++ -isystem ../include -I.. -g -Wall -Wextra&&-coverage -c \&&&&&&&&&&&&../src/gtest_main.ccar rv gtest_main.a gtest-all.o gtest_main.oar: creating archive gtest_main.aa - gtest-all.oa - gtest_main.og++ -isystem ../include -g -Wall -Wextra&&-coverage -lpthread sample1.o sample1_unittest.o gtest_main.a -o sample1_unittest
编译完成后直接执行gcov命令，会报未执行，需要先执行可执行文件
? gcov sample1
File '../samples/sample1.cc'
Lines executed:0.00% of 13
../samples/sample1.cc:creating 'sample1.cc.gcov
? gcov sample1 File '../samples/sample1.cc'Lines executed:0.00% of 13../samples/sample1.cc:creating 'sample1.cc.gcov
执行可执行文件
? ./sample1_unittest
Running main() from gtest_main.cc
[==========] Running 6 tests from 2 test cases.
[----------] Global test environment set-up.
[----------] 3 tests from FactorialTest
] FactorialTest.Negative
OK ] FactorialTest.Negative (0 ms)
] FactorialTest.Zero
OK ] FactorialTest.Zero (0 ms)
] FactorialTest.Positive
OK ] FactorialTest.Positive (0 ms)
[----------] 3 tests from FactorialTest (0 ms total)
[----------] 3 tests from IsPrimeTest
] IsPrimeTest.Negative
OK ] IsPrimeTest.Negative (0 ms)
] IsPrimeTest.Trivial
OK ] IsPrimeTest.Trivial (0 ms)
] IsPrimeTest.Positive
OK ] IsPrimeTest.Positive (0 ms)
[----------] 3 tests from IsPrimeTest (0 ms total)
[----------] Global test environment tear-down
[==========] 6 tests from 2 test cases ran. (0 ms total)
] 6 tests.
12345678910111213141516171819202122232425
? ./sample1_unittest&& Running main() from gtest_main.cc[==========] Running 6 tests from 2 test cases.[----------] Global test environment set-up.[----------] 3 tests from FactorialTest[ RUN&&&&&&] FactorialTest.Negative[&&&&&& OK ] FactorialTest.Negative (0 ms)[ RUN&&&&&&] FactorialTest.Zero[&&&&&& OK ] FactorialTest.Zero (0 ms)[ RUN&&&&&&] FactorialTest.Positive[&&&&&& OK ] FactorialTest.Positive (0 ms)[----------] 3 tests from FactorialTest (0 ms total)&[----------] 3 tests from IsPrimeTest[ RUN&&&&&&] IsPrimeTest.Negative[&&&&&& OK ] IsPrimeTest.Negative (0 ms)[ RUN&&&&&&] IsPrimeTest.Trivial[&&&&&& OK ] IsPrimeTest.Trivial (0 ms)[ RUN&&&&&&] IsPrimeTest.Positive[&&&&&& OK ] IsPrimeTest.Positive (0 ms)[----------] 3 tests from IsPrimeTest (0 ms total)&[----------] Global test environment tear-down[==========] 6 tests from 2 test cases ran. (0 ms total)[&&PASSED&&] 6 tests.
使用gcov查看sample1.cc文件的覆盖率
gcov sample1
File '../samples/sample1.cc'
Lines executed:100.00% of 13
../samples/sample1.cc:creating 'sample1.cc.gcov'
?&&gcov sample1&&&&&&&& File '../samples/sample1.cc'Lines executed:100.00% of 13../samples/sample1.cc:creating 'sample1.cc.gcov'
表示：sample1.cc一共有13行（可执行代码），全部被执行，测试覆盖率100%。
具体哪些代码被测还可以看sample1.cc.gcov文件：
37:int Factorial(int n) {
int result = 1;
for (int i = 1; i &= i++) {
46:// Returns true iff n is a prime number.
47:bool IsPrime(int n) {
// Trivial case 1: small numbers
if (n &= 1)
// Trivial case 2: even numbers
if (n % 2 == 0) return n == 2;
// Now, we have that n is odd and n &= 3.
// Try to divide n by every odd number i, starting from 3
for (int i = 3; ; i += 2) {
// We only have to try i up to the squre root of n
if (i & n/i)
// Now, we have i &= n/i & n.
// If n is divisible by i, n is not prime.
if (n % i == 0)
// n has no integer factor in the range (1, n), and thus is prime.
1234567891011121314151617181920212223242526272829303132
&&&&&&&&-:&& 37:int Factorial(int n) {&&&&&&&&8:&& 38:&&int result = 1;&&&&&& 44:&& 39:&&for (int i = 1; i &= n; i++) {&&&&&& 14:&& 40:&&&&result *= i;&&&&&& 14:&& 41:&&}&&&&&&&&-:&& 42:&&&&&&&&8:&& 43:&&return result;&&&&&&&&-:&& 44:}&&&&&&&&-:&& 45:&&&&&&&&-:&& 46:// Returns true iff n is a prime number.&&&&&&&&-:&& 47:bool IsPrime(int n) {&&&&&&&&-:&& 48:&&// Trivial case 1: small numbers&&&&&& 16:&& 49:&&if (n &= 1) return false;&&&&&&&&-:&& 50:&&&&&&&&-:&& 51:&&// Trivial case 2: even numbers&&&&&&&&9:&& 52:&&if (n % 2 == 0) return n == 2;&&&&&&&&-:&& 53:&&&&&&&&-:&& 54:&&// Now, we have that n is odd and n &= 3.&&&&&&&&-:&& 55:&&&&&&&&-:&& 56:&&// Try to divide n by every odd number i, starting from 3&&&&&&&&4:&& 57:&&for (int i = 3; ; i += 2) {&&&&&&&&-:&& 58:&&&&// We only have to try i up to the squre root of n&&&&&&&&7:&& 59:&&&&if (i & n/i) break;&&&&&&&&-:&& 60:&&&&&&&&-:&& 61:&&&&// Now, we have i &= n/i & n.&&&&&&&&-:&& 62:&&&&// If n is divisible by i, n is not prime.&&&&&&&&1:&& 63:&&&&if (n % i == 0) return false;&&&&&&&&1:&& 64:&&}&&&&&&&&-:&& 65:&&&&&&&&-:&& 66:&&// n has no integer factor in the range (1, n), and thus is prime.&&&&&&&&3:&& 67:&&return true;&&&&&& 11:&& 68:}
-表示该行不可执行，数字1或其他表示该行被执行了多少次，#####表示代码没被执行。
对象创建的时候会调用构造函数来初始化对象，对象销毁的时候会调用析构函数。
普通的自动变量（local非static）包含构造函数和析构函数。
当进入变量作用域的时候构造函数被调用，当离开变量作用域的时候析构函数被调用。
当在tuxedo的环境中调用 tpreturn() 或者 tpforward() 函数时，编译器进行了一个non-local的goto (using longjmp(3))，导致自动变量的析构函数没有被调用。
为了避免这个问题，我们应该在服务体中调用直接调用 tpreturn() 或 tpforward()
(而不是在服务体调用的函数中调用这两个函数)。
1.服务体中不能包含包含析构函数的变量，特别是string变量，这些带析构函数的自动变量需要放到函数调用体中，这样当离开函数的作用域的时候，会析构这些变量。如果在服务体中有string变量，那么随着服务循环会有内存泄漏。
2.自动变量需要被嵌套在服务体函数中的大括号{}包围，大括号需要在调用tpreturn() 或 tpforward() 函数前结束。
#ifdef __cplusplus
extern "C"
#if defined(__STDC__) || defined(__cplusplus)
SERVICE(TPSVCINFO *rqst)
SERVICE(rqst)
TPSVCINFO *
tpreturn(TPFAIL, 0, 0, 0L, 0);
123456789101112131415
#ifdef __cplusplusextern "C"#endifvoid#if defined(__STDC__) || defined(__cplusplus)SERVICE(TPSVCINFO *rqst)#elseSERVICE(rqst)TPSVCINFO *rqst;#endif{&&&&string Message;&&&&...&&&&tpreturn(TPFAIL, 0, 0, 0L, 0);}
可以改为：
#ifdef __cplusplus
extern "C"
#if defined(__STDC__) || defined(__cplusplus)
SERVICE(TPSVCINFO *rqst)
SERVICE(rqst)
TPSVCINFO *
} while(0);
tpreturn(TPSUCCESS, 0,NULL, 0L, 0);
12345678910111213141516171819
#ifdef __cplusplusextern "C"#endifvoid#if defined(__STDC__) || defined(__cplusplus)SERVICE(TPSVCINFO *rqst)#elseSERVICE(rqst)TPSVCINFO *rqst;#endif{&&&&do&&&&{&&&&&&&&string Message;&&&&&&&&...&&&&&} while(0); &&&&tpreturn(TPSUCCESS, 0,NULL, 0L, 0);}
epoll是目前进行服务器端编程的普遍选择，好处很多，这里不再赘述，本文主要描述如何在c语言中使用epoll的完整样例程序。
首先介绍用到的数据结构和三个api说明，然后通过编写一个打印所有输入到socket的字符输出到终端的服务器端的程序来完成整个例子。
epoll_event是用来对要监控的socket描述, 它包括epoll_data_t和要监控的事件类型的(一个__uint32_t类型的events)。epoll_data_t里的fd是用来存储要监控的文件描述符。
events 结构体中第一个参数支持的事件类型
– EPOLLIN，读事件
– EPOLLOUT，写事件
– EPOLLPRI，带外数据，与select的异常事件集合对应
– EPOLLRDHUP，TCP连接对端至少写写半关闭
– EPOLLERR，错误事件
– EPOLLET，设置事件为边沿触发
– EPOLLONESHOT，只触发一次，事件自动被删除
epoll在一个文件描述符上只能有一个事件，在一个描述符上添加多个事件，会产生EEXIST的错误。同样，删除epoll的事件，只需描述符就够了
typedef union epoll_data
__uint32_t
__uint64_t
} epoll_data_t;
struct epoll_event
__uint32_ /* Epoll events */
epoll_data_
/* User data variable */
12345678910111213
typedef union epoll_data{&&void&&&&&&&&*ptr;&&int&&&&&&&&&&fd;&&__uint32_t&& u32;&&__uint64_t&& u64;} epoll_data_t;&struct epoll_event{&&__uint32_t&& events; /* Epoll events */&&epoll_data_t data;&& /* User data variable */};
使用epoll的三个api
头文件 /usr/include/sys/epoll.h
1. 生成一个epoll专用的文件描述符
如果调用成功返回0,不成功返回-1
int epoll_create(int size)
int epoll_create(int size)
epoll_create返回的是一个文件描述符，也就是说epoll是以特殊文件的方式体现给用户
__size提示操作系统，用户可能要使用多少个文件描述符，该参数已经废弃，填写一个大于0的正整数
2.用于控制某个文件描述符上的事件，可以注册事件，修改事件，删除事件。
如果调用成功返回0,不成功返回-1
int epoll_ctl(
//由 epoll_create 生成的epoll专用的文件描述符
//要进行的操作例如注册事件，可能的取值EPOLL_CTL_ADD 注册、
//EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除
//关联的文件描述符
struct epoll_event *event
//指向epoll_event的指针
int epoll_ctl(&&&&int epfd,&&&&&&&&&&&&&&&&&&&&//由 epoll_create 生成的epoll专用的文件描述符 &&&&int op,&&&&&&&&&&&&&&&&&&&&&&//要进行的操作例如注册事件，可能的取值EPOLL_CTL_ADD 注册、&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& //EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除 &&&&int fd,&&&&&&&&&&&&&&&&&&&&&&//关联的文件描述符 &&&&struct epoll_event *event&&&&//指向epoll_event的指针 &&&&)
3.用于轮询I/O事件的发生，返回发生事件数
int epoll_wait(
//由epoll_create 生成的epoll专用的文件描述符
struct epoll_event * events,//用于回传代处理事件的数组
int maxevents,
//每次能处理的事件数
int timeout
//等待I/O事件发生的超时值
//为0的时候表示马上返回，为-1的时候表示一直等下去，直到有事件
//为任意正整数的时候表示等这么长的时间，如果一直没有事件
//一般如果网络主循环是单独的线程的话，可以用-1来等，这样可以保证一些效率
//如果是和主逻辑在同一个线程的话，则可以用0来保证主循环的效率。
12345678910
int epoll_wait( &&&&int epfd,&&&&&&&&&&&&&&&&&& //由epoll_create 生成的epoll专用的文件描述符 &&&&struct epoll_event * events,//用于回传代处理事件的数组 &&&&int maxevents,&&&&&&&&&&&&&&//每次能处理的事件数 &&&&int timeout&&&&&&&&&&&&&&&& //等待I/O事件发生的超时值 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//为0的时候表示马上返回，为-1的时候表示一直等下去，直到有事件 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//为任意正整数的时候表示等这么长的时间，如果一直没有事件 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//一般如果网络主循环是单独的线程的话，可以用-1来等，这样可以保证一些效率 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&//如果是和主逻辑在同一个线程的话，则可以用0来保证主循环的效率。 &&&&)
epoll的api使用方式
1.epoll_create 生成的epoll专用的文件描述符
2.使用epoll_ctl注册事件，修改事件，删除事件对应的文件描述符到epollfd指定的epoll内核事件表中
3.使用epoll_wait阻塞等待注册的文件描述符上可读事件的发生
4.当有新客户端的连接或者客户端的数据写入，返回需要处理的事件数目
epoll的两种模式：
1. 水平触发（LT）：使用此种模式，当数据可读的时候，epoll_wait()将会一直返回就绪事件。如果你没有处理完全部数据，并且再次在该epoll实例上调用epoll_wait()才监听描述符的时候，它将会再次返回就绪事件，因为有数据可读。ET只支持非阻塞socket。
2. 边缘触发（ET）：使用此种模式，只能获取一次就绪通知，如果没有处理完全部数据，并且再次调用epoll_wait()的时候，它将会阻塞，因为就绪事件已经释放出来了。
ET的效能更高，但是对程序员的要求也更高。在ET模式下，我们必须一次干净而彻底地处理完所有事件。LT两种模式的socket都支持。
1.创建并绑定服务器端socket
采用一种可移植的方式来生产socket，getaddrinfo返回对应的网卡信息，遍历对应的网络接口生成socket
成功返回socket文件描述符，失败返回-1
static int
create_and_bind (char *port)
struct addrinfo *result, *
memset (&hints, 0, sizeof (struct addrinfo));
hints.ai_family = AF_UNSPEC;
/* Return IPv4 and IPv6 choices */
hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */
hints.ai_flags = AI_PASSIVE;
/* All interfaces */
s = getaddrinfo (NULL, port, &hints, &result);
if (s != 0)
fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));
return -1;
for (rp = rp != NULL; rp = rp-&ai_next)
sfd = socket (rp-&ai_family, rp-&ai_socktype, rp-&ai_protocol);
if (sfd == -1)
s = bind (sfd, rp-&ai_addr, rp-&ai_addrlen);
if (s == 0)
/* We managed to bind successfully! */
close (sfd);
if (rp == NULL)
fprintf (stderr, "Could not bind\n");
return -1;
freeaddrinfo (result);
123456789101112131415161718192021222324252627282930313233343536373839404142434445
static intcreate_and_bind (char *port){&&struct addrinfo hints;&&struct addrinfo *result, *rp;&&int s, sfd;&&&memset (&hints, 0, sizeof (struct addrinfo));&&hints.ai_family = AF_UNSPEC;&&&& /* Return IPv4 and IPv6 choices */&&hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */&&hints.ai_flags = AI_PASSIVE;&&&& /* All interfaces */&&&s = getaddrinfo (NULL, port, &hints, &result);&&if (s != 0)&&&&{&&&&&&fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));&&&&&&return -1;&&&&}&&&for (rp = result; rp != NULL; rp = rp-&ai_next)&&&&{&&&&&&sfd = socket (rp-&ai_family, rp-&ai_socktype, rp-&ai_protocol);&&&&&&if (sfd == -1)&&&&&&&&continue;&&&&&&&s = bind (sfd, rp-&ai_addr, rp-&ai_addrlen);&&&&&&if (s == 0)&&&&&&&&{&&&&&&&&&&/* We managed to bind successfully! */&&&&&&&&&&break;&&&&&&&&}&&&&&&&close (sfd);&&&&}&&&if (rp == NULL)&&&&{&&&&&&fprintf (stderr, "Could not bind\n");&&&&&&return -1;&&&&}&&&freeaddrinfo (result);&&&return sfd;}
2.设置socket为非阻塞模式
通过在文件描述符上设置 O_NONBLOCK 表识来实现非阻塞socket
static int
make_socket_non_blocking (int sfd)
int flags,
flags = fcntl (sfd, F_GETFL, 0);
if (flags == -1)
perror ("fcntl");
return -1;
flags |= O_NONBLOCK;
s = fcntl (sfd, F_SETFL, flags);
if (s == -1)
perror ("fcntl");
return -1;
12345678910111213141516171819202122
static intmake_socket_non_blocking (int sfd){&&int flags, s;&&&flags = fcntl (sfd, F_GETFL, 0);&&if (flags == -1)&&&&{&&&&&&perror ("fcntl");&&&&&&return -1;&&&&}&&&flags |= O_NONBLOCK;&&s = fcntl (sfd, F_SETFL, flags);&&if (s == -1)&&&&{&&&&&&perror ("fcntl");&&&&&&return -1;&&&&}&&&return 0;}
3.event 循环处理
#define MAXEVENTS 64
main (int argc, char *argv[])
struct epoll_
struct epoll_event *
if (argc != 2)
fprintf (stderr, "Usage: %s [port]\n", argv[0]);
exit (EXIT_FAILURE);
sfd = create_and_bind (argv[1]);
if (sfd == -1)
s = make_socket_non_blocking (sfd);
if (s == -1)
s = listen (sfd, SOMAXCONN);
if (s == -1)
perror ("listen");
efd = epoll_create1 (0);
if (efd == -1)
perror ("epoll_create");
event.data.fd =
event.events = EPOLLIN | EPOLLET;
s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);
if (s == -1)
perror ("epoll_ctl");
/* Buffer where events are returned */
events = calloc (MAXEVENTS, sizeof event);
/* The event loop */
n = epoll_wait (efd, events, MAXEVENTS, -1);
for (i = 0; i & i++)
if ((events[i].events & EPOLLERR) ||
(events[i].events & EPOLLHUP) ||
(!(events[i].events & EPOLLIN)))
/* An error has occured on this fd, or the socket is not
ready for reading (why were we notified then?) */
fprintf (stderr, "epoll error\n");
close (events[i].data.fd);
else if (sfd == events[i].data.fd)
/* We have a notification on the listening socket, which
means one or more incoming connections. */
struct sockaddr in_
socklen_t in_
char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];
in_len = sizeof in_
infd = accept (sfd, &in_addr, &in_len);
if (infd == -1)
if ((errno == EAGAIN) ||
(errno == EWOULDBLOCK))
/* We have processed all incoming
connections. */
perror ("accept");
s = getnameinfo (&in_addr, in_len,
hbuf, sizeof hbuf,
sbuf, sizeof sbuf,
NI_NUMERICHOST | NI_NUMERICSERV);
if (s == 0)
printf("Accepted connection on descriptor %d "
"(host=%s, port=%s)\n", infd, hbuf, sbuf);
/* Make the incoming socket non-blocking and add it to the
list of fds to monitor. */
s = make_socket_non_blocking (infd);
if (s == -1)
event.data.fd =
event.events = EPOLLIN | EPOLLET;
s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);
if (s == -1)
perror ("epoll_ctl");
/* We have data on the fd waiting to be read. Read and
display it. We must read whatever data is available
completely, as we are running in edge-triggered mode
and won't get a notification again for the same
int done = 0;
char buf[512];
count = read (events[i].data.fd, buf, sizeof buf);
if (count == -1)
/* If errno == EAGAIN, that means we have read all
data. So go back to the main loop. */
if (errno != EAGAIN)
perror ("read");
else if (count == 0)
/* End of file. The remote has closed the
connection. */
/* Write the buffer to standard output */
s = write (1, buf, count);
if (s == -1)
perror ("write");
printf ("Closed connection on descriptor %d\n",
events[i].data.fd);
/* Closing the descriptor will make epoll remove it
from the set of descriptors which are monitored. */
close (events[i].data.fd);
free (events);
close (sfd);
return EXIT_SUCCESS;
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
#define MAXEVENTS 64&intmain (int argc, char *argv[]){&&int sfd, s;&&int efd;&&struct epoll_event event;&&struct epoll_event *events;&&&if (argc != 2)&&&&{&&&&&&fprintf (stderr, "Usage: %s [port]\n", argv[0]);&&&&&&exit (EXIT_FAILURE);&&&&}&&&sfd = create_and_bind (argv[1]);&&if (sfd == -1)&&&&abort ();&&&s = make_socket_non_blocking (sfd);&&if (s == -1)&&&&abort ();&&&s = listen (sfd, SOMAXCONN);&&if (s == -1)&&&&{&&&&&&perror ("listen");&&&&&&abort ();&&&&}&&&efd = epoll_create1 (0);&&if (efd == -1)&&&&{&&&&&&perror ("epoll_create");&&&&&&abort ();&&&&}&&&event.data.fd = sfd;&&event.events = EPOLLIN | EPOLLET;&&s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);&&if (s == -1)&&&&{&&&&&&perror ("epoll_ctl");&&&&&&abort ();&&&&}&&&/* Buffer where events are returned */&&events = calloc (MAXEVENTS, sizeof event);&&&/* The event loop */&&while (1)&&&&{&&&&&&int n, i;&&&&&&&n = epoll_wait (efd, events, MAXEVENTS, -1);&&&&&&for (i = 0; i & n; i++) { &&if ((events[i].events & EPOLLERR) ||&&&&&&&&&&&&&&(events[i].events & EPOLLHUP) ||&&&&&&&&&&&&&&(!(events[i].events & EPOLLIN))) &&&&{&&&&&&&&&&&&&&/* An error has occured on this fd, or the socket is not&&&&&&&&&&&&&&&& ready for reading (why were we notified then?) */ &&&&&&fprintf (stderr, "epoll error\n"); &&&&&&close (events[i].data.fd); &&&&&&continue; &&&&}& &&else if (sfd == events[i].data.fd) &&&&{&&&&&&&&&&&&&&/* We have a notification on the listening socket, which&&&&&&&&&&&&&&&& means one or more incoming connections. */&&&&&&&&&&&&&&while (1)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&struct sockaddr in_addr;&&&&&&&&&&&&&&&&&&socklen_t in_len;&&&&&&&&&&&&&&&&&&int infd;&&&&&&&&&&&&&&&&&&char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];&&&&&&&&&&&&&&&&&&&in_len = sizeof in_addr;&&&&&&&&&&&&&&&&&&infd = accept (sfd, &in_addr, &in_len);&&&&&&&&&&&&&&&&&&if (infd == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&if ((errno == EAGAIN) ||&&&&&&&&&&&&&&&&&&&&&&&&&&(errno == EWOULDBLOCK))&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&/* We have processed all incoming&&&&&&&&&&&&&&&&&&&&&&&&&&&& connections. */&&&&&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&&&else&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&perror ("accept");&&&&&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&s = getnameinfo (&in_addr, in_len,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& hbuf, sizeof hbuf,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& sbuf, sizeof sbuf,&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& NI_NUMERICHOST | NI_NUMERICSERV);&&&&&&&&&&&&&&&&&&if (s == 0)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&printf("Accepted connection on descriptor %d "&&&&&&&&&&&&&&&&&&&&&&&&&&&& "(host=%s, port=%s)\n", infd, hbuf, sbuf);&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&/* Make the incoming socket non-blocking and add it to the&&&&&&&&&&&&&&&&&&&& list of fds to monitor. */&&&&&&&&&&&&&&&&&&s = make_socket_non_blocking (infd);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&event.data.fd = infd;&&&&&&&&&&&&&&&&&&event.events = EPOLLIN | EPOLLET;&&&&&&&&&&&&&&&&&&s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&perror ("epoll_ctl");&&&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&continue;&&&&&&&&&&&&}&&&&&&&&&&else&&&&&&&&&&&&{&&&&&&&&&&&&&&/* We have data on the fd waiting to be read. Read and&&&&&&&&&&&&&&&& display it. We must read whatever data is available&&&&&&&&&&&&&&&& completely, as we are running in edge-triggered mode&&&&&&&&&&&&&&&& and won't get a notification again for the same&&&&&&&&&&&&&&&& data. */&&&&&&&&&&&&&&int done = 0;&&&&&&&&&&&&&&&while (1)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&ssize_t count;&&&&&&&&&&&&&&&&&&char buf[512];&&&&&&&&&&&&&&&&&&&count = read (events[i].data.fd, buf, sizeof buf);&&&&&&&&&&&&&&&&&&if (count == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&/* If errno == EAGAIN, that means we have read all&&&&&&&&&&&&&&&&&&&&&&&& data. So go back to the main loop. */&&&&&&&&&&&&&&&&&&&&&&if (errno != EAGAIN)&&&&&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&&&&&perror ("read");&&&&&&&&&&&&&&&&&&&&&&&&&&done = 1;&&&&&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&else if (count == 0)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&/* End of file. The remote has closed the&&&&&&&&&&&&&&&&&&&&&&&& connection. */&&&&&&&&&&&&&&&&&&&&&&done = 1;&&&&&&&&&&&&&&&&&&&&&&break;&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&&&&/* Write the buffer to standard output */&&&&&&&&&&&&&&&&&&s = write (1, buf, count);&&&&&&&&&&&&&&&&&&if (s == -1)&&&&&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&&&&&perror ("write");&&&&&&&&&&&&&&&&&&&&&&abort ();&&&&&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&&}&&&&&&&&&&&&&&&if (done)&&&&&&&&&&&&&&&&{&&&&&&&&&&&&&&&&&&printf ("Closed connection on descriptor %d\n",&&&&&&&&&&&&&&&&&&&&&&&&&&events[i].data.fd);&&&&&&&&&&&&&&&&&&&/* Closing the descriptor will make epoll remove it&&&&&&&&&&&&&&&&&&&& from the set of descriptors which are monitored. */&&&&&&&&&&&&&&&&&&close (events[i].data.fd);&&&&&&&&&&&&&&&&}&&&&&&&&&&&&}&&&&&&&&}&&&&}&&&free (events);&&&close (sfd);&&&return EXIT_SUCCESS;}
main函数的流程是
1. create_and_bind创建服务器端的socket描述符
2. 设置描述符为非阻塞
3. 监听描述符
4. 创建epoll文件描述符efd
5. 使用边缘触发的方式添加sfd输入监听事件
最外层的while循环时主事件循环(event loop)。调用epoll_wait阻塞等待事件发生，当事件到达epoll_wait返回事件在事件参数中，一批epoll_event结构体。
epoll事件循环中epoll实例在建立新连接时候添加事件和当断开连接的时候删除事件。
当事件发生时，有如下几种方式
错误：当发生错误，或者不是可读事件通知时，简单关闭文件描述符，关闭文件描述符会自动从efd的监控集中删除。
新连接：当监听描述符可读时，表示有新的连接到达，accept()新连接，设置新连接描述符为非阻塞并添加到efd监控集中。
客户端数据：当任何一个客户端文件描述符可读，使用read()每次读区512字节循环读取。 因为我们需要读取当前所有可读区数据 ，当边缘触发的情况下不会再次通知可读。 读取到的数据调用write写到标准输出stdout (fd=1)。如果read(2)返回0，表示EOF并切可以关闭客户端连接。如果返回-1并且 errno设置为EAGAIN表示这个事件所有可读的数据读取完毕可以返回进入主事件循环。
就这样不断的循环，添加和删除文件描述符到efd的监控集中。
/blog/2/how-to-use-epoll-a-complete-example-in-c/
用 eclipse cdt 运行 gtest 在 console 的输出结果有有 shell 终端的颜色代码输出
Running main() from gmock_main.cc
[0;32m[==========] [mRunning 4 tests from 1 test case.
[0;32m[----------] [mGlobal test environment set-up.
[0;32m[----------] [m4 tests from PrimeFactors
[0;32m[ RUN
] [mPrimeFactors.1factor
OK ] [mPrimeFactors.1factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.2factor
OK ] [mPrimeFactors.2factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.3factor
OK ] [mPrimeFactors.3factor (0 ms)
[0;32m[ RUN
] [mPrimeFactors.4factor
OK ] [mPrimeFactors.4factor (0 ms)
[0;32m[----------] [m4 tests from PrimeFactors (0 ms total)
[0;32m[----------] [mGlobal test environment tear-down
[0;32m[==========] [m4 tests from 1 test case ran. (0 ms total)
] [m4 tests.
如何让 console 的输出和 shell 中的输出效果相同。
可以通过在 eclipse market 安装 ANSI escape 来解决。
gd 跳转到局部函数定义.
gD 跳转到全局函数定义.
g* 向下搜索光标所在单词 (
当光标在 'rain' 会查找 'rainbow').
g# 向上搜索光标所在单词
gg 跳转到第一行
G 跳转到最后一行
现在先抛出问题，假设有一个主数据中心在北京M，然后有成都A，上海B两个地方数据中心，现在的问题是，假设成都上海各自的数据中心有记录变更，需要先同步到主数据中心，主数据中心更新完成之后，在把最新的数据分发到上海，成都的地方数据中心A，地方数据中心更新数据，保持和主数据中心一致性（数据库结构完全一致）。数据更新的消息是通过一台中心的MQ进行转发。
先把问题简单化处理，假设A增加一条记录Message_A，发送到M，B增加一条记录 MESSAGE_B发送到M，都是通过MQ服务器进行转发，那么M系统接收到条消息，增加两条数据，那么M在把增加的消息群发给A，B，A和B找到自己缺失的数据，更新数据库。这样就完成了一个数据的同步。
从正常情况下来看，都没有问题，逻辑完全合理，但是请考虑以下三个问题
1 如何保证A-&M的消息，M一定接收到了，同样，如何保证M-&A的消息，M一定接收到了
2 如果数据需要一致性更新，比如A发送了三条消息给M，M要么全部保存，要么全部不保存，不能够只保存其中的几条记录。我们假设更新的数据是一条条发送的。
3 假设同时A发送了多条更新请求，如何保证顺序性要求？
这两个问题就是分布式环境下数据一致性的问题
对于第一个问题，比较好解决，我们先看看一个tcp/ip协议链接建立的过程
我们的思路可以从这个上面出发，在简化一下，就一个请求，一个应答。
简单的通信模型是这样的
A-&M : 你收到我的一条消息没有，消息的ID是12345
M-&A: 我收到了你的一条消息数据，消息数据是ID;12345
这样就一个请求，一个应答，就完成了一次可靠性的传输。如果A一致没有收到M的应答，就不断的重试。这个时候M就必须保证幂等性。不能重复的处理消息。那么最极端的情况是，怎么也收不到M的应答，这个时候是系统故障。自己检查一下吧。
这么设计就要求，A在发送消息的时候持久化这个消息的数据内容，然后不断的重试，一旦接收到M的应答，就删除这条消息。同样，M端也是一样的。不要相信MQ的持久化机制，不是很靠谱的。
那么M给A发送消息也采取类似的原理就可以了。
下面在看看第二个问题，如何保持数据的一致性更新，这个还是可以参考TCP/IP的协议。
首先A发送一条消息给M：我要发送一批消息数据给你，批次号是10000，数据是5条。
M发送一条消息给A：ok，我准备好了，批次号是10000，发送方你A
接着A发送5条消息给M，消息ID分别为1，2，3，4，5 ，批次号是10000，
紧接着，A发送一个信息给M：我已经完成5小消息的发送，你要提交数据更新了
接下来可能发送两种情况
1 那么M发送消息给A：ok，我收到了5条消息，开始提交数据
2 那么M也可以发送给A：我收到了5条消息，但是还缺少，请你重新发送，那么A就继续发送，直到A收到M成功的应答。
整个过程相当复杂。这个也就是数据一旦分布了，带来最大的问题就是数据一致性的问题。这个成本非常高。
对于第三个问题，这个就比较复杂了
这个最核心的问题就是消息的顺序性，我们只能在每个消息发一个消息的序列号，但是还是没有最好解决这个问题的办法。因为消息接收方不知道顺序。因为即使给他了序列号，也没有办法告诉他，这个应该何时处理。最好的办法是在第二种方式的基础作为一个批次来更新。
这个只是以最简单的例子来说明一下分布式系统的要保证数据一致性是一件代价很大的事情。当然有的博主会说，这个何必这么复杂，直接数据库同步不就可以了。这个例子当然是没有问题的，万一这个几个库的模型都不一样，我发送消息要处理的事情不一样的。怎么办？
在上文，简单的介绍了分布式数据的同步问题，上面的问题比较抽象，在目前的互联网应用中还很少见，这次在通过一个比较常见的例子，让大家更深入的了解一下分布式系统设计中关于数据一致性的问题
这次我们拿我们经常使用的功能来考虑吧，最近网购比较热门，就以京东为例的，我们来看看京东的一个简单的购物流程
用户在京东上下了一个订单，发现自己在京东的账户里面有余额，然后使用余额支付，支付成功之后，订单状态修改为支付成功，然后通知仓库发货。假设订单系统，支付系统，仓库系统是三个独立的应用，是独立部署的，系统之间通过远程服务调用。
订单的有三个状态：I:初始 P:已支付 W:已出库，订单金额100, 会员帐户余额200
如果整个流程比较顺利，正常情况下，订单的状态会变为I-&P-&W，会员帐户余额100，订单出库。
但是如果流程不顺利了？考虑以下几种情况
1：订单系统调用支付系统支付订单，支付成功，但是返回给订单系统数据超时，订单还是I（初始状态），但是此时会员帐户余额100,会员肯定会马上找京东骂京东，为啥不给老子发货，我都付钱了
2：订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
3：订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
对于问题一，我们来分析一下解决方案，能想到的解决方案如下
1 假设调用支付系统支付订单的时候先不扣钱，订单状态更新完成之后，在通知支付系统你扣钱
如果采用这种设计方案，那么在同一时刻，这个用户，又支付了另外一笔订单，订单价格200，顺利完成了整个订单支付流程，由于当前订单的状态已经变成了支付成功，但是实际用户已经没有钱支付了，这笔订单的状态就不一致了。即使用户在同一个时刻没有进行另外的订单支付行为，通知支付系统扣钱这个动作也有可能完不成，因为也有可能失败，反而增加了系统的复杂性。
2 订单系统自动发起重试，多重试几次，例如三次，直到扣款成功为止。
这个看起来也是不错的考虑，但是和解决方案一样，解决不了问题，还会带来新的问题，假设订单系统第一次调用支付系统成功，但是没有办法收到应答，订单系统又发起调用，完了，重复支付，一次订单支付了200。
假设支付系统正在发布，你重试多少次都一样，都会失败。这个时候用户在等待，你怎么处理？
3 在第二种方案的基础上，我们先解决订单的重复支付行为，我们需要在支付系统上对订单号进行控制，一笔订单如果已经支付成功，不能在进行支付。返回重复支付标识。那么订单系统根据返回的标识，更新订单状态。
接下来解决重试问题，我们假设应用上重试三次，如果三次都失败，先返回给用户提示支付结果未知。假设这个时候用户重新发起支付，订单系统调用支付系统，发现订单已经支付，那么继续下面的流程。如果会员没有发起支付，系统定时（一分钟一次）去核对订单状态，如果发现已经被支付，则继续后续的流程。
这种方案，用户体验非常差，告诉用户支付结果未知，用户一定会骂你，你丫咋回事情，我明明支付了，你告诉我未知。假设告诉用户支付失败，万一实际是成功的咋办。你告诉用户支付成功，万一支付失败咋办。
4 第三种方案能够解决订单和支付数据的一致性问题，但是用户体验非常差。当然这种情况比较可能是少数，可以牺牲这一部分的用户体验，我们还有没有更好的解决方案，既能照顾用户体验，又能够保证资金的安全性。
我们再回来看看第一种方案，我们先不扣钱，但是有木有办法让这一部分钱不让用户使用，对了，我们先把这一部分钱冻结起来，订单系统先调用支付系统成功的时候，支付系统先不扣钱，而是先把钱冻结起来，不让用户给其他订单支付，然后等订单系统把订单状态更新为支付成功的时候，再通知支付系统，你扣钱吧，这个时候支付系统扣钱，完成后续的操作。
看起来这个方案不错，我们仔细在分析一下流程，这个方案还存在什么问题，假设订单系统在调用支付系统冻结的时候，支付系统冻结成功，但是订单系统超时，这个时候返回给用户，告知用户支付失败，如果用户再次支付这笔订单，那么由于支付系统进行控制，告诉订单系统冻结成功，订单系统更新状态，然后通知支付系统，扣钱吧。如果这个时候通知失败，木有问题，反正钱都已经是冻结的了，用户不能用，我只要定时扫描订单和支付状态，进行扣钱而已。
那么如果变态的用户重新拍下来一笔订单,100块钱，对新的订单进行支付，这个时候由于先前那一笔订单的钱被冻结了，这个时候用户余额剩余100，冻结100，发现可用的余额足够，那就直接在对用户扣钱。这个时候余额剩余0，冻结100。先前那一笔怎么办，一个办法就是定时扫描，发现订单状态是初始的话，就对用户的支付余额进行解冻处理。这个时候用户的余额变成100，订单数据和支付数据又一致了。假设原先用户余额只有100，被冻结了，用户重新下单，支付的时候就失败了啊，的确会发生这一种情况，所以要尽可能的保证在第一次订单结果不明确的情况，尽早解冻用户余额，比如10秒之内。但是不管如何快速，总有数据不一致的时刻，这个是没有办法避免的。
第二种情况和第三种情况如何处理，下次在分析吧。
由于互联网目前越来越强调分布式架构，如果是交易类系统，面临的将会是分布式事务上的挑战。当然目前有很多开源的分布式事务产品，例如java JPA，但是这种解决方案的成本是非常高的，而且实现起来非常复杂，效率也比较低下。对于极端的情况：例如发布，故障的时候都是没有办法保证强一致性的。
在上文主要介绍了数据分布的情况下保证一致性的情况，在第二篇文章里面，我这里提出了三个问题
1.订单系统调用支付系统支付订单，支付成功，但是返回给订单系统数据超时，订单还是I（初始状态），但是此时会员帐户余额100,会员肯定会马上找京东骂京东，为啥不给老子发货，我都付钱了
2.订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
3.订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
重点分析解决了第一个的问题以及相应的方案，发现在数据分布的环境下，很难绝对的保证数据一致性（任何一段区间），但是有办法通过一种补偿机制，最终保证数据的一致性。
在下面在分析一下第二个问题
订单系统调用支付系统成功，状态也已经更新成功，但是通知仓库发货失败，这个时候订单是P（已支付）状态，此时会员帐户余额是100,但是仓库不会发货。会员也要骂京东。
通过在上一篇文章里面分析过，这个相对来说是比较简单的，我可以采取重试机制，如果发现通知仓库发货失败，就一致重试，
这里面有两种方式：
1 异步方式：通过类似MQ（消息通知）的机制，这个是异步的通知
2 同步调用：类似于远程过程调用
对于同步的调用的方式，比较简单，我们能够及时获取结果，对于异步的通知，就必须采用请求，应答的方式进行，这一点在（关于分布式系统的数据一致性问题(一)）里面有介绍。这里面就不再阐述。
来看看第三个问题
订单系统调用支付系统成功，状态也已经更新成功，然后通知仓库发货，仓库告诉订单系统，没有货了。这个时候数据状态和第二种情况一样。
我觉得这是一个很有意思的问题，我们还是考虑几种解决的方案
1 在会员下单的时刻，就告诉仓库，我要你把货物留下来，
2 在会员支付订单时候，在支付之前检查仓库有没有货，如果没有货，就告知会员木有货物了
3 如果会员支付成功，这个时候没有货了，就会退款给用户或者等待有货的时候在发货
正常情况，京东的仓库一般都是有货的，所以影响到的会员很少，但是在秒杀和营销的时候，这个时候就不一定了，我们考虑假设仓库有10台iphone
如果采用第一种方案，
1 在会员下单的时候，相当于库存就-1，那么用户恶意拍下来，没有去支付，就影响到了其他用户的购买。京东可以设置一个订单超时时间，如果这段时间内没有支付，就自动取消订单
2 在会员支付之前，检查仓库有货，这种方案了，对于用户体验不好，但是对于京东比较好，至少我东西都卖出去了。那些没有及时付款的用户，只能投诉了京东无故取消订单
3 第三种方案，这个方案体验更不好，而且用户感觉受到京东欺诈，但是对于京东来说，比第二种方案更有益，毕竟我还可以多卖出一点东西。
个人觉得，京东应该会采用第二种或者第三种方式来处理这类情况，我在微博上搜索了 “京东 无故取消订单”，发现果真和我预料的处理方式。不过至于这里的无故取消是不是技术上的原因我不知道，如果真的是技术上的原因，我觉得京东可以采用不同的处理方案。对于秒杀和促销商品，可以考虑第一种方案，大多数人都会直接付款，毕竟便宜啊，如果用户抢不到便宜的东西，抱怨当然很大了。这样可以照顾大多数用户的体验。对于一般的订单，可以采用第二种或者第三种方式，这种情况下，发生付款之后仓库没有货的情况会比较少，并且就算发生了，用户也会觉得无所谓，大不了退钱吗，这样就可以实现自己的利益最大化而最低程度的减少用户体验。
而铁道部在这个问题上，采用的是第一种方案，为什么和京东不一样，就是因为用户体验，如果用户把票都买了，你告诉我木有票了，旅客会杀人的。哈哈，不过铁道部不担心票卖不出去，第一种方案对他影响没有什么。
说了这么多，就是说 分布式环境下（数据分布）要任何时刻保证数据一致性是不可能的，只能采取妥协的方案来保证数据最终一致性。这个也就是著名的CAP定理。
在前面三篇文章中，介绍了关于分布式系统中数据一致性的问题，这一篇主要介绍CAP定理以及自己对CAP定理的了解。
CAP定理是2000年，由 Eric Brewer 提出来的
Brewer认为在分布式的环境下设计和部署系统时，有3个核心的需求，以一种特殊的关系存在。这里的分布式系统说的是在物理上分布的系统，比如我们常见的web系统。
这3个核心的需求是：Consistency，Availability和Partition Tolerance，赋予了该理论另外一个名字 － CAP。
Consistency：一致性，这个和数据库ACID的一致性类似，但这里关注的所有数据节点上的数据一致性和正确性，而数据库的ACID关注的是在在一个事务内，对数据的一些约束。
Availability：可用性，关注的在某个结点的数据是否可用，可以认为某一个节点的系统是否可用，通信故障除外。
Partition Tolerance：分区容忍性，是否可以对数据进行分区。这是考虑到性能和可伸缩性。
为什么不能完全保证这个三点了，个人觉得主要是因为一旦进行分区了，就说明了必须节点之间必须进行通信，涉及到通信，就无法确保在有限的时间内完成指定的行文，如果要求两个操作之间要完整的进行，因为涉及到通信，肯定存在某一个时刻只完成一部分的业务操作，在通信完成的这一段时间内，数据就是不一致性的。如果要求保证一致性，那么就必须在通信完成这一段时间内保护数据，使得任何访问这些数据的操作不可用。
如果想保证一致性和可用性，那么数据就不能够分区。一个简单的理解就是所有的数据就必须存放在一个数据库里面，不能进行数据库拆分。这个对于大数据量，高并发的互联网应用来说，是不可接受的。
我们可以拿一个简单的例子来说明：假设一个购物系统，卖家A和卖家B做了一笔交易100元，交易成功了，买家把钱给卖家。
这里面存在两张表的数据：Trade表Account表 ，涉及到三条数据Trade(100),Account A ,Account B
假设 trade表和account表在一个数据库，那么只需要使用数据库的事务，就可以保证一致性，同时不会影响可用性。但是随着交易量越来越大，我们可以考虑按照业务分库，把交易库和account库单独分开，这样就涉及到trade库和account库进行通信，也就是存在了分区，那么我们就不可能同时保证可用性和一致性。
我们假设初始状态
trade(buyer,seller,tradeNo,status) = trade(A,B,,I)
account(accountNo,balance) = account(A,300)
account(accountNo,balance) = account(B,10)
在理想情况下，我们期望的状态是
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(A,200)
account(accountNo,balance) = account(B,110)
但是考虑到一些异常情况
假设在trade(,S)更新完成之前，帐户A进行扣款之后，帐户A进行了另外一笔300款钱的交易，把钱消费了，那么就存在一个状态
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(A,0)
account(accountNo,balance) = account(B,10)
产生了数据不一致的状态
由于这个涉及到资金上的问题，对资金要求比较高，我们必须保证一致性，那么怎么办，只能在进行trade(A,B,)交易的时候，对于任何A的后续交易请求trade(A,X,X)，必须等到A完成之后，才能够进行处理，也就是说在进行trade(A,B,)的时候，Account(A)的数据是不可用的。
任何架构师在设计分布式的系统的时候，都必须在这三者之间进行取舍。首先就是是否选择分区，由于在一个数据分区内，根据数据库的ACID特性，是可以保证一致性的，不会存在可用性和一致性的问题，唯一需要考虑的就是性能问题。对于可用性和一致性，大多数应用就必须保证可用性，毕竟是互联网应用，牺牲了可用性，相当于间接的影响了用户体验，而唯一可以考虑就是一致性了。
牺牲一致性
对于牺牲一致性的情况最多的就是缓存和数据库的数据同步问题，我们把缓存看做一个数据分区节点，数据库看作另外一个节点，这两个节点之间的数据在任何时刻都无法保证一致性的。在web2.0这样的业务，开心网来举例子，访问一个用户的信息的时候，可以先访问缓存的数据，但是如果用户修改了自己的一些信息，首先修改的是数据库，然后在通知缓存进行更新，这段期间内就会导致的数据不一致，用户可能访问的是一个过期的缓存，而不是最新的数据。但是由于这些业务对一致性的要求比较高，不会带来太大的影响。
异常错误检测和补偿
还有一种牺牲一致性的方法就是通过一种错误补偿机制来进行，可以拿上面购物的例子来说，假设我们把业务逻辑顺序调整一下，先扣买家钱，然后更新交易状态，在把钱打给卖家
我们假设初始状态
account(accountNo,balance) = account(A,300)
account(accountNo,balance) = account(B,10)
trade(buyer,seller,tradeNo,status) = trade(A,B,,I)
那么有可能出现
account(accountNo,balance) = account(A,200)
trade(buyer,seller,tradeNo,status) = trade(A,B,,S)
account(accountNo,balance) = account(B,10)
那么就出现了A扣款成功，交易状态也成功了，但是钱没有打给B，这个时候可以通过一个时候的异常恢复机制，把钱打给B，最终的情况保证了一致性，在一定时间内数据可能是不一致的，但是不会影响太大。
两阶段提交协议
当然，还有一种方式就是我另外一篇文章里面《X/Open DTP-分布式事务模型》里面说的，但是再第一阶段和第二阶段之间，数据也可不能是一致性的，也可能出现同样的情况导致异常。而且DTP的分布式事务模型 限制太多，例如必须有实现其功能的相关的容器支持，并且资源管理器也必须实现了XA规范。限制比较多。
国外有的架构师有两种方案去解决CAP的限制，但是也是比较适合特定的业务，而没有通用的解决方案，
探知分区-&分区内操作-&事后补偿
就是上面介绍的异常检测恢复机制，这种机制其实还是有限制，
首先对于分区检测操作，不同的业务涉及到的分区操作可能不一样
分区内操作限制：不同的业务对应的约束不一致
事后补偿：由于业务约束不一样，补偿方式也不一样。
所以这只能作为一种思想，不能做一个通用的解决方案
- 287,184 views - 226,263 views - 173,979 views - 136,018 views - 94,390 views - 87,028 views - 81,505 views - 80,155 views - 69,869 views - 59,239 views}
我要回帖
更多关于 linux服务器运维手册 的文章
更多推荐
- ·instax富士拍立得mini25使用教程相机怎么照完不出相纸？
- ·格力空调怎么定时关机云佳空调能不能同时设置定时开机关机？
- ·Pazuzu灵异事件与电影《驱魔电影原型人》
- ·这三位全部演员名字分别叫什么名子？
- ·哆啦a梦初次见面在第几集中的情节忘了是哪一季哪一集？
- ·服务器500错误的削峰配置错误，怎么办
- ·登录地下城与勇士登录闪退出现肖峰配置错误 什么意思
- ·永康人才网驾驶员招聘车床师傅招聘
- ·windows7下载了一下夜光时钟屏保钟做屏保,要怎么设置，话说放C盘windows/32下面，可是我的还
- ·新泰市卫生局泉沟镇卫生室无线密码
- ·谁有昨晚的快乐大本营1080p资源百度资源，我想要谢谢（ps:不要回答让我下载芒果TV）
- ·欧豪制作手机主题的软件什么软件可以设置
- ·放大器坏了会不会引起皮带输送机正反转称反转或自动运行失效
- ·这个程序哪里错了？ 写一个c语言判断素数数的函数，在主函数中输入一个整数，输出是否是素数的信息。
- ·前女友怀孕了了我的孩子我叫她打，她不打，她一气之下把我qq删除了什么意
- ·求一款安卓的，局域网路由器怎么设置语音聊天软件，(两个手机只在一个路由器上无线连接着，路由器并没有连接互联网)
- ·中兴nx507j线刷什么开红外
- ·手机丫f和移动数据流量标准资费同时开在用时用的是移动流量吗？
- ·到车后视仪时好,时坏,那出问题了
- ·主机开机后电脑开了显示器没反应应，还滴滴响，跟唱歌一样……
- ·服务器运维外包的削峰配置错误,请运维检测配置
- ·怎样在微信怎样转发朋友圈的微信做广告
- ·手机系统升级刚升级玩着玩着屏幕就会变大是咋会是呀用什么不会变大下什么软件呢
- ·这个杀手不太冷2百度云
- ·荣事达电压力锅说明书脑压力锅50_90A90多少钱
- ·想知道世爵娱乐平台稳不稳定会不会掉线
- ·我想问一下我这lingo线性规划程序程序哪里出问题了
- ·原来百度贴吧热议在网页显示有本贴吧热议更新帖 热议帖 现在怎么没啦
- ·在肯教网注册用户时，需要填写什么陌陌资料个性填写？
- ·男生把女生经常给男生点赞的qq号删了 转天还经常往女生经常给男生点赞这里看
- ·vb验证角谷猜想被证明了吗想
- ·非敞口管理费要素管理,可修改的要素包括
- ·ER(+)10%,PR(—),CerbB-2:1(+),Ki-67(+-)85%PR单什么意思思
- ·怎么用bios重装系统统失败后开不了机，乱弄了bios就变成这样了。怎么可以弄好，求啊。
- ·在网上买为什么打印机会卡纸便宜吗？
- ·武汉御庭园南湖江南庭园中通快递
