基于BrokerPattern服务器框架

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

RedRabbit

经典网游服务器架构

该图省略了专门用途的dbserver、guildserver等用于专门功能的server，该架构的优点有：

l LoginGate相当于DNS，可以动态的保证GameGate之间负载均衡。
l 由于Clientt的逻辑操作都是由GameServer处理的，而Client的消息请求都被GameGate转发到GameServer上，所以在不同的GameGate上的client仍能出现在相同的场景里。若在不同的场景，又可以将其分布在不公的GameServer处理，从而实现了GameServer的Scalability。
l GameServer一般是由C++与脚本结合实现的。由于数据都是在内存中处理而且大部分的IO操作（网络、数据库等）都被异步化，所以保证了非常高的实时性。

缺点是：

l 各个节点之间通过socket进行异步通信，测试过程叫复杂。
l 各个节点往往都需要交互，这时就涉及到了谁连谁的问题，理解和设计架构的网络拓扑也变得不太容易，相应的配置也会叫繁琐，排错的难度也较大。
l GameServer由于是C++主语言实现，不免会涉及到崩溃和内存泄露问题，采用C++与脚本结合很大程度上缓解了这个问题，实际上越来越多的逻辑操作都是放到脚本中实现。
l 由于该架构必须正确的配置连接关系，否则不能正常工作，对于运维而言也并不轻松。

讨论完经典网游的服务器架构，今天的主题也呼之欲出了，但在此之前，先说一下该架构的核心思想，如果你读过《面向模式的软件架构.第4卷,分布式计算的模式语言》你也许想到了BrokerPattern，其核心思想是通过Broker代理层，促使Server的位置对于Client保持透明，client通过Broker找到对应的Server处理请求，Serverr是如何分布的、数量多少，Client都不受影响。Broker可以存在两种模式，一种是类似于DNS提供的LookUp服务，它只是帮助Client定位到Server的位置，Client直接连接到Serverr进行通信。LoginGate扮演的就是这种Broker。另外一种Broker直接将Client请求投递给Serverr，GameGate就是扮演的这种Broker。总的来说BrokerPattern中，Broker具有如下功能：

l LookUp服务，帮助Client定位Server
l Route服务，实现Client和Server之间的消息转发
l 注册服务，Server必须要注册到Broker上这样Broker才能提供LookUp和Route功能。

BrokerPattern示意图：

所以今天的主题是如何利用BrokerPattern构建实时的服务器框架。

RedRabbit

目标：

l 节点之间通信采用异步消息、回调模式
l Server必须很容易注册到Broker上
l C++/EPOOL实现网络通信，保证实时性，支持逻辑层python实现，支持热更新
l 该框架能够容易的构建单个区组的构架
l 该框架支持跨区组通信，这也是Broker模式的优势，节点之间通信不需要知道对方的位置，只需要知道对方的名称

这个框架的名字叫RedRabbit。

FFRPC

首先介绍RedRabbit的通信组件ffrpc，ffrpc中有如下5种角色：

l BrokerMaster，负责管理所有的BrokerSlave，所有Slave需要注册到BrokerMaster上，BrokerMaster同步所有信息给所有节点。
l BrokerSlave负责转发Client和Service之间的消息。
l Client为调用Service接口的一方，它通过Broker于Service通信，Client不知道Service的具体位置，它只是知道当前与之通信的Service名称。
l Service提供给Client调用的接口，并把接口注册到Broker上，Service若调用了其他的Service的接口，则相对于其他Service其为Client角色。
l BrokerBridge负责桥接各个brokerMaster，每一个BrokerMaster负责一组服务，BrokerBridge使Client调用其他组接口和调用本组的接口一样容易，因为只需要指定对方服务名称即可。

各个角色示意图：

使用FFRPC实现的Echo服务实例代码：

http://www.cnblogs.com/zhiranok/archive/2013/06/06/ffrpc.html

RedRabbit中的其他组件Gate和Scene

Gate

外网接入的client有些特殊，需要一定的安全处理。Gate是专门用于接入外部Client的组件。Gate的作用有：

l Client的第一个消息必须为验证消息，Gate 并没有验证Client的能力，它调用Scene@0的接口处理
l Scene@0通过验证后将Client将被分配唯一的SessionId。
l Client的所有消息都被Gate转发到对应的Scene上，Scene可以控制Gate接口切换某个Client到其他Scene上
l Gate提供转发消息、多播、广播、断开连接等接口公scene调用。

需要特别指出的是，Gate和Scene只是RedRabbit的组件，RedRabbit通过制定不同的启动参数来确定开启哪些组件。示例：

l ./app_redrabbit -gate gate@0 -broker tcp://127.0.0.1:10241 -gate_listen tcp://121.199.21.238:10242
l -gate 表示gate的名称，scene通过名称调用其接口

l -gate_listen表示gate监听的ip、port
l -brkoker表示作为BrokerMaster启动，一组服务中必须有一个BrokerMaster，如果Broker和Client和Service在同一进程中，Broker专门做了优化，消息会直接从内存间实现传递，避免了网络转发的开销。

Scene

在RedRabbit中的所有Service都是运行在Scene组件之下的。Scene提供了通用的接口，可以和Gate和其他Scene通信，并把接口导入到了python中。Scene接收的Client的请求都交由Python处理，所以可以用Scene+Python实现GameServer、DbServer等各种专用的服务器。Scene组件提供的功能有：

l 验证Client有效性，scene@0必须提供此接口
l 处理Client Enter消息，Scene第一次进入该Scene，触发此事件
l 处理Client Offline消息，Client下线，触发此事件
l Scene提供转发、多播、广播、关闭连接等接口给python
l Scene提供定时器接口给python
l Scene提供异步操作Mysql、Sqlite的接口，采用异步加回调，从而避免阻塞主线程
l Scene提供了一套消息派发框架，支持client和python通信的协议包括json、thrift、protobuf。

使用RedRabbit构建的聊天室demo示例：

http://ffown.sinaapp.com/flash/

修改名称，点击flash的连接按钮，进入聊天室发消息，右侧的python脚本为服务器python的实现，修改右侧脚本点保存按钮，在flash中输入reload即可实现热更新!!!!

该聊天室服务器启动的参数是:

./app_redrabbit -gate gate@0 -broker tcp://127.0.0.1:10241 -gate_listen tcp://121.199.21.238:10242 -python_path ./ -scene scene@0

该示例中把gate和scene启动到了一个服务器程序上，实际上通过调整参数，二者可以启动到不同进程中，RedRabbit通过参数开启组件，而组件之间是通过Broker建立联系的。

对应的python代码：

# coding=UTF-8
import os
import time
import ffextdef GetNowTime():
return time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))class player_mgr_t(object):
def __init__(self):
self.all_players = {}
def get(self, session_id_):
return self.all_players.get(session_id_)
def remove(self, session_id_):
del self.all_players[session_id_]
def add(self, session_id_, player):
self.all_players[session_id_] = player
def size(self):
return len(self.all_players)
def idlist(self):
return self.all_players.keys()class player_t(object):
def __init__(self, session_id_):
self.session_id = session_id_;
def id():
return self.session_id#这个修饰器的意思是注册process_chat函数接收cmd=1的消息
@ffext.session_call(1)
def process_chat(session_id, msg):
content = msg[0]
if content == 'reload':
os.system('./update_code.sh')
ret = ffext.reload('main')#重载此脚本
ffext.broadcast_msg_session(1, ' main.py已完成重载'\
'%s'%(str(ret)))
return print("process_chat session_id=%s content=%s"%(session_id, content)) ret = '[%s %s]:%s'%(session_id, GetNowTime(), content)
ffext.broadcast_msg_session(1, ret)#这个修饰器的意思是注册下面函数处理验证client账号密码，
#session_key为账号密码组合体，client第一个包必为登陆包
@ffext.session_verify_callback
def my_session_verify(session_key, online_time, ip, gate_name):
return [session_key]#需要返回数组，验证成功，第一个元素为分配的id，
#第二个元素可以不设置，若设置gate会返回给client，login gate的时候
#需要第二个元素返回分配的game gate#此修饰器的作用是注册下面函数处理用户下线
@ffext.session_offline_callback
def my_session_offline(session_id, online_time):
content = '[%s %s] offline '%(session_id, GetNowTime())
ffext.broadcast_msg_session(1, content)
ffext.singleton(player_mgr_t).remove(session_id)
ffext.broadcast_msg_session(1, '当前在线:')
ffext.broadcast_msg_session(1, ffext.singleton(player_mgr_t).idlist())#此修饰器的作用是注册下面函数处理client切换到此场景服务器
@ffext.session_enter_callback
def my_session_enter(session_id, from_scene, extra_data):
#单播接口
ffext.send_msg_session(session_id, 1, '测试单播接口！欢迎你！'\
'')
content = '[%s %s] online '%(session_id, GetNowTime())
ffext.broadcast_msg_session(1, content)
player = player_t(session_id)
ffext.singleton(player_mgr_t).add(session_id, player)
ffext.broadcast_msg_session(1, '当前在线:')
ffext.broadcast_msg_session(1, ffext.singleton(player_mgr_t).idlist())print("loading.......")