网络游戏服务器的主要作用是模拟整个游戏世界，客户端用过网络连接把一些信息数据发给服务器，在操作合法的情况下，更新服务器上该客户端对应的player实体、所在场景等，并把这些操作及其影响广播出去。让别的客户端能显示这些操作。
在这个模拟过程中，需要解决的一个重要问题是：多长时间处理（更新）一次该服务器上的待处理事件，体现在实际开发中，这就是一个服务器端的心跳设计问题（tick）。
在网络游戏服务器端的心跳设计里主要面临以下几个问题：
1. 心跳函数的处理间隔往往是固定的，因为需要模拟现实世界中时间的性质，不能让游戏世界表现得忽快忽慢。但处理间隔固定不代表一定要和真实时间一致，有可能有快放慢放的需求。
2. 固定间隔的心跳，间隔多少长？50ms，100ms，500ms？
3. 由于服务器每次心跳处理的事件数量和复杂度不一样，每次处理所需的时间也会不同，服务器繁忙时和闲置时相差很远，应该使用什么策略来应对？
4. 编码实现时应该怎么设计？是和游戏主循环在同一个线程里，还是把心跳写到一个单独的timer线程里，或者干脆做成一台心跳服务器（心跳指令定期通过tcp发出，或者通过同步卡），逻辑服务器都由心跳服务器控制tick的频率。
5. 心跳必须和逻辑程序写在一个进程空间里吗？有没有以独立运行的心跳服务？
为了解决以上问题，本文将对心跳进行分类，从不同角度进行讨论。
一、按照策略分类
就心跳间隔策略而言，现在的网游服务器端主要分为两种。分别是固定tick时间和固定sleep时间，可以通过下图进行具体的说明：
图1-1
如上图1-1中，画出两种间隔策略的示意图，渐变颜色的横条代表时间，tick1、tick2代表程序两次不同的更新操作，run1、run2代表在心跳函数里处理更新操作所需的时间，sleep1、sleep2代表让出cpu时间片的时间。
（1）固定tick时间：顾名思义就是指程序每次心跳的时间都是等长的、固定的。如图中的“图a”，tick1和tick2的时间是相等的，如果实际执行的比上次执行时间长（run2 > run1），则sleep2 < sleep1，同时满足等式：tick1 = tick2 = run1 sleep1 = run2 sleep2
（2）固定sleep时间：每次心跳，更新操作执行完成后，sleep固定的时间。如图中的“图b”，sleep1 = sleep2，run1和run2不一定相等，同时满足等式：tick1 = run1 sleep1，tick2 = run2 sleep2
下面结合具体的代码对比说明这两种策略
1.1 固定tick时间
使用固定tick时间的心跳策略的一大好处就是，在负荷不高的情况下，由于相邻两次tick的时间一定，所以开始执行run1到开始执行run2的时间间隔一定。tick时间固定带来的另一个好处就是容易实现逻辑服务器运行时快放慢放功能（见？？），当然固定tick时间同样带来一些问题，如下图：
图1-2
如图1-2，在负荷不高的情况下，心跳函数可以按照上图中“图a”的时间线正常的运行，如果在服务器运行的过程中遇到一些突发事件（开新服、做活动、大世界内大范围的帮战），会导致服务器cpu负荷变高，从而使得一次tick无法处理完当前所有事件，出现“图b”中的情况run1 > tick1，这时sleep1不管取什么值都不能满足等式tick1 = run1 sleep1，
这样一来就带来第一个问题：高负荷情况下如何保证cpu能充分利用的情况下，tick1和tick2两次心跳互相不干扰？伴随而来的另一个问题是tick时间设为多长才能满足低负荷时固定间隔的要求，同时不能经常出现“图b”的情况？
下面结合实例讲解固定tick时间的心跳如何编写，以及如何处理以上两个问题。
mangos-zero
mangos-zero项目中的逻辑服务进程mangosd的心跳函数采用如图1-2中的“图c”的方法，当更新的处理时间run1大于固定大小的tick时间时，下一个tick到来时不sleep直接执行run2，实现代码如下：
1: /// heartbeat for the world
2: void worldrunnable::run()
3: {
4: ///- init new sql thread for the world database
5: worlddatabase.threadstart(); // let thread do safe mysql requests (one connection call enough)
6: sworld.initresultqueue();
7:
8: uint32 realcurrtime = 0;
9: uint32 realprevtime = worldtimer::tick();
10:
11: uint32 prevsleeptime = 0; // used for balanced full tick time length near world_sleep_const
12:
13: ///- while we have not world::m_stopevent, update the world
14: while (!world::isstopped())
15: {
16: world::m_worldloopcounter;
17: realcurrtime = worldtimer::getmstime(); //----------------（1）
18:
19: uint32 diff = worldtimer::tick(); //--------------（2）
20:
21: sworld.update( diff ); //--------------（3）
22: realprevtime = realcurrtime;
23:
24: // diff (d0) include time of previous sleep (d0) tick time (t0)
25: // we want that next d1 t1 == world_sleep_const
26: // we can't know next t1 and then can use (t0 d1) == world_sleep_const requirement
27: // d1 = world_sleep_const - t0 = world_sleep_const - (d0 - d0) = world_sleep_const d0 - d0
28: if (diff <= world_sleep_const prevsleeptime) //----------------（4）
29: {
30: prevsleeptime = world_sleep_const prevsleeptime-diff;
31: ace_based::thread::sleep(prevsleeptime);
32: }
33: else
34: prevsleeptime = 0;
35:
36: #ifdef win32
37: if (m_servicestatus == 0) world::stopnow(shutdown_exit_code);
38: while (m_servicestatus == 2) sleep(1000);
39: #endif
40: }
41:
42: sworld.kickall(); // save and kick all players
43: sworld.updatesessions( 1 ); // real players unload required updatesessions call
44:
45: // unload battleground templates before different singletons destroyed
46: sbattlegroundmgr.deleteallbattlegrounds();
47:
48: sworldsocketmgr->stopnetwork();
49:
50: smapmgr.unloadall(); // unload all grids (including locked in memory)
51:
52: ///- end the database thread
53: worlddatabase.threadend(); // free mysql thread resources
54: }
以上代码是游戏世界的主循环，看while循环里的代码，主要干下面几件事：
（1）从worldtimer::getmstime()得到一个uint32的值realcurrtime，realcurrtime是循环的（到增加到0xffffffff后，在增加就变成0），表示当前时间，单位是毫秒，是一个相对前一次tick的时间。
（2）使用worldtimer::tick();计算上次tick到这次tick的时间差diff，该值理论上等于realcurrtime – realprevtime
（3）sworld.update( diff );就是tick里的处理函数，游戏逻辑在这里得到更新处理。
（4）这里就是图1-2中的“图c”所描述的，如果运行时间大于固定的tick时间，则不sleep继续占用cpu来处理更新，直到能在一个tick处理所有操作为止，这个时候才会sleep让出cpu时间片。
（5）world_sleep_const就是固定的tick的时间长度，在这里是50ms
总结：现在可以回答本节前面的两个问题：在高负荷情况下mangos采用图1-2中“图c”的方式提高服务器的响应速度，每个tick时间长度为50ms，也就是每秒钟更新20次，能满足更新的需求。
timer_thread
出于模块化的考虑，固定tick时间策略还有一种实现方式：使用单独的线程做timer，周期性产生心跳信号或者心跳task。工作原理如下图：
图1-3
图1-3也是比较常见的设计方案，服务器进程采用多线程方式，主循环线程、timer线程及其他非工作线程向任务队列（task queue）中添加task，而工作线程不断的从任务队列中取出任务执行相应的处理。这里提到的timer thread就是用来产生心跳任务的，timer thread会每隔50ms产生一个heartbeat task放入任务队列中。一般来说队列中的heartbeat task的数量会远远大于其他task，所以这种策略也可以称为固定tick时间的心跳策略。在服务器高负荷运行的情况下，近似于mangos所采用的图1-2中“图c”的方式进行处理。多个worker thread的情况下，还需要对heartbeat task加锁。
1.2固定sleep时间
固定sleep也是一种比较常见的心跳函数间隔处理策略，如下图，每次心跳处理函数执行完毕后sleep固定长度时间。
图1-4
如图1-4，sleep1 = sleep2，run1和run2不一定相等，同时满足等式：tick1 = run1 sleep1，tick2 = run2 sleep2。下面结合实例进行说明：
天龙
根据网上流出的天龙源代码，gameserver工程的主循环至线程的心跳函数的调用过程如下：
1: bool server::loop( )
2: {
3: ........
4:
5: ret = g_pthreadmanager->start( ) ;//--------（1）
6:
7: ........
8:
9: return true ;
10: }
11: |
12: |
13: \|/
14: bool threadmanager::start( )
15: {
16: ........
17:
18: bool ret ;
19: m_pserverthread->start() ; //--------（2）
20: mysleep( 500 ) ;
21: ret = m_pthreadpool->start( ) ;
22:
23: ........
24: }
25: |
26: |
27: \|/
28: void thread::start ()
29: {
30: ........
31:
32: #if defined(__linux__)
33: pthread_create( &m_tid, null , mythreadprocess ,this );
34: #elif defined(__windows__)
35: m_hthread = ::createthread( null, 0, mythreadprocess ,this, 0, &m_tid ) ;
36: #endif
37:
38: ........
39: }
40: |
41: |
42: \|/
43: void serverthread::run( )
44: {
45: ........
46:
47: _my_try
48: {
49: g_pservermanager->m_threadid = gettid() ;
50:
51: while( isactive() )
52: {
53: if( g_pservermanager )
54: {
55: bool ret = g_pservermanager->tick( ) ; //--------（3）
56: assert( ret ) ;
57: }
58:
59: ........
60: }
61: }
62: _my_catch
63: {
64: ........
65: }
66:
67: ........
68: }
如上，主循环启动一个“用来处理服务器之间数据通讯的线程”m_pserverthread，以及一个线程池m_pthreadpool。首先看m_pserverthread的run ()函数，调用g_pservermanager->tick ()函数，代码如下：
1: bool servermanager::tick( )
2: {
3: ........
4:
5: bool ret ;
6:
7: _my_try
8: {
9: ret = select( ) ; //--------（1）
10: assert( ret ) ;
11: }
12: _my_catch
13: {
14: savecodelog( ) ;
15: }
16:
17: ........
18: }
19: |
20: |
21: \|/
22: bool servermanager::select( )
23: {
24: __enter_function
25:
26: mysleep(50) ; //--------（2）
27: if( m_maxfd==invalid_socket && m_minfd==invalid_socket )
28: {
29: return true ;
30: }
31:
32: m_timeout[select_use].tv_sec = m_timeout[select_bak].tv_sec;
33: m_timeout[select_use].tv_usec = m_timeout[select_bak].tv_usec;
34:
35: m_readfds[select_use] = m_readfds[select_bak];
36: m_writefds[select_use] = m_writefds[select_bak];
37: m_exceptfds[select_use] = m_exceptfds[select_bak];
38:
39: _my_try
40: {
41: int iret = socketapi::select_ex( (int)m_maxfd 1 ,
42: &m_readfds[select_use] ,
43: &m_writefds[select_use] ,
44: &m_exceptfds[select_use] ,
45: &m_timeout[select_use] ) ;//--------（3）
46: if( iret==socket_error )
47: {
48: assert(false) ;
49: }
50: }
51: _my_catch
52: {
53: log::savelog( server_logfile,"error: servermanager::select( )..." ) ;
54: }
55:
56: return true ;
57:
58: __leave_function
59:
60: return false ;
61:
62: }
如上，在tick ()函数里首先调用servermanager::select ()，在select函数中（2）调用mysleep(50)让出cpu时间片50ms，然后给select_ex设置100us的超时，可以认为每次执行完处理后，会固定sleep 50ms。
再来看看threadpool里线程的tick函数
1: bool scene::tick( )
2: {
3: ........
4:
5: //网络处理
6: _my_try
7: {
8: ret = m_psceneplayermanager->select( ) ;//--------（1）
9: assert( ret ) ;
10: }
11: _my_catch
12: {
13: savecodelog( ) ;
14: }
15:
16: ........
17: }
18: |
19: |
20: \|/
21: bool sceneplayermanager::select( )
22: {
23: {
24: mysleep( 50 ) ; //--------（2）
25: }
26:
27: if( m_maxfd==invalid_socket && m_minfd==invalid_socket )
28: return true ;
29:
30: m_timeout[select_use].tv_sec = m_timeout[select_bak].tv_sec;
31: m_timeout[select_use].tv_usec = m_timeout[select_bak].tv_usec;
32:
33: m_readfds[select_use] = m_readfds[select_bak];
34: m_writefds[select_use] = m_writefds[select_bak];
35: m_exceptfds[select_use] = m_exceptfds[select_bak];
36:
37: _my_try
38: {
39: int ret = socketapi::select_ex( (int)m_maxfd 1 ,
40: &m_readfds[select_use] ,
41: &m_writefds[select_use] ,
42: &m_exceptfds[select_use] ,
43: &m_timeout[select_use] ) ;//--------（3）
44: if( ret == socket_error )
45: {
46: assert(false) ;
47: }
48: }
49: _my_catch
50: {
51: savecodelog( ) ;
52: }
53:
54: ........
55: }
根据以上代码中的（1）、（2）、（3）可以看到场景的tick函数中采用同样的方法，每次调用时先调用mysleep(50)让出cpu时间片50ms，然后再执行相应的处理代码。
总结：
（a）固定sleep时间在高负荷情况下，由于每次都会强制让出cpu时间片，会不会导致响应不及时？
（b）在每次运行执行处理函数的时间比较稳当的情况下，这种策略还是能提供比较稳定的tick间隔。
（c）这样的设计目前为止本人还没有看出有什么好处？请各位博友指教。
二、按照物理位置分类
按照物理位置分类，分为两种，一种是运行在同一物理主机上，另一种是运行在不同的物理主机上。该分类是受到云风一篇blog的启发（见《心跳服务器》）。
（1）心跳服务和逻辑程序运行在同一物理主机上：据我所知，大部分的网游服务器程序都采用这种方式，而且心跳服务往往和逻辑程序写在同一个进程里。心跳服务和逻辑程序不在一个进程里，但运行在同一物理主机上的情况本人没有见过，也不敢妄加臆断。
（2）心跳服务运行在一台独立的物理主机上：（a）按照云风的说法，这样做最大的好处就是方便实现服务器的快放慢放功能，从而很容易重现bug。博文中指出使用使用10hz的心跳间隔，以局域网内0.1~0.2ms的ping值，不知道能不能容忍？而且使用tcp连接，多两次网络io，不知道效率如何？（b）另一种独立的心跳服务器是本人读研时参与过的大屏幕显示同步时遇到的，当时一块大屏幕有24台主机，每台主机负责绘制图像中的一块区域。使用一台单独的心跳服务器，用同步卡向着24台主机的串口周期性的发信号，这24台主机收到从串口来的心跳信号后，同时开始绘制这一帧。不过据说精确度有待提高………
三、总结
综上所述，最常见的心跳服务是这样设计的：使用固定tick时间策略，与逻辑处理程序写在同一个进程里，tick时间50ms，100ms。