Documentation ¶
Overview ¶
Package server micserver中的ROC调用发生时,处理调用以及返回值。
Package server micserver中管理与其他服务器连接的管理器
Index ¶
- Variables
- type ROCServer
- func (rocServer *ROCServer) GetROC(objtype roc.ObjType) *roc.ROC
- func (rocServer *ROCServer) GetROCCachedLocation(objType roc.ObjType, objID string) string
- func (rocServer *ROCServer) Init(server *Server)
- func (rocServer *ROCServer) NewROC(objtype roc.ObjType) *roc.ROC
- func (rocServer *ROCServer) OnROCObjAdd(obj roc.IObj)
- func (rocServer *ROCServer) OnROCObjDel(obj roc.IObj)
- func (rocServer *ROCServer) ROCCallBlock(callpath *roc.Path, callarg []byte) ([]byte, error)
- func (rocServer *ROCServer) ROCCallNR(callpath *roc.Path, callarg []byte) error
- func (rocServer *ROCServer) RandomROCCachedByType(objType roc.ObjType) string
- func (rocServer *ROCServer) RangeROCCachedByType(objType roc.ObjType, f func(id string, location string) bool)
- type Server
- func (s *Server) BindSubnet(subnetAddrMap map[string]string)
- func (s *Server) BroadcastModuleCmd(msgstr msg.IMsgStruct)
- func (s *Server) DeleteSession(uuid string)
- func (s *Server) DoSendBytesToClient(fromserver string, gateid string, to string, msgid uint16, data []byte) error
- func (s *Server) ForwardClientMsgToModule(fromconn *connect.Client, to string, msgid uint16, data []byte)
- func (s *Server) GetBalanceModuleID(moduletype string) string
- func (s *Server) GetClient(tmpid string) *connect.Client
- func (s *Server) GetSession(uuid string) *session.Session
- func (s *Server) HookGate(gateHook gatebase.GateHook)
- func (s *Server) HookServer(serverHook serverbase.ServerHook)
- func (s *Server) Init(moduleid string)
- func (s *Server) InitGate(gateaddr string)
- func (s *Server) InitSubnet(conf *conf.ModuleConfig)
- func (s *Server) MustUpdateSessionFromMap(uuid string, data map[string]string)
- func (s *Server) RangeClient(f func(tmpid string, client *connect.Client) bool)
- func (s *Server) ReqCloseConnect(gateid string, connectid string)
- func (s *Server) SInnerCloseSessionConnect(gateid string, connectid string)
- func (s *Server) SInnerSendClientMsg(gateid string, connectid string, msgid uint16, data []byte)
- func (s *Server) SInnerSendModuleMsg(to string, msgstr msg.IMsgStruct)
- func (s *Server) SendBytesToClient(gateid string, to string, msgid uint16, data []byte) error
- func (s *Server) SendModuleMsg(to string, msgstr msg.IMsgStruct)
- func (s *Server) SetLogger(source *log.Logger)
- func (s *Server) Stop()
- func (s *Server) UpdateSessionUUID(uuid string, session *session.Session)
Constants ¶
This section is empty.
Variables ¶
var (
ErrTargetClientDontExist = errors.New("target client does not exist")
)
服务的错误定义
Functions ¶
This section is empty.
Types ¶
type ROCServer ¶
ROCServer ROC服务
func (*ROCServer) GetROCCachedLocation ¶
GetROCCachedLocation 获取ROC缓存中的位置信息 返回目标ROC对象所在的moduleid
func (*ROCServer) OnROCObjAdd ¶
OnROCObjAdd 当ROC对象发生注册行为时
func (*ROCServer) OnROCObjDel ¶
OnROCObjDel 当ROC对象发生注册行为时
func (*ROCServer) ROCCallBlock ¶
ROCCallBlock 有返回值的RPC调用
func (*ROCServer) RandomROCCachedByType ¶
RandomROCCachedByType 随机获取本地缓存的ROC对象,返回该对象的ID,限制目标对象必须本module可以访问
type Server ¶
type Server struct { *log.Logger // event libs ROCServer // contains filtered or unexported fields }
Server 一个Module就是一个Server
func (*Server) BindSubnet ¶
BindSubnet 尝试连接本服务子网中的其他服务器
func (*Server) BroadcastModuleCmd ¶
func (s *Server) BroadcastModuleCmd(msgstr msg.IMsgStruct)
BroadcastModuleCmd 广播一个消息到连接到本服务器的所有服务器
func (*Server) DeleteSession ¶
DeleteSession 删除本地维护的 session
func (*Server) DoSendBytesToClient ¶
func (s *Server) DoSendBytesToClient(fromserver string, gateid string, to string, msgid uint16, data []byte) error
DoSendBytesToClient 发送一个消息到连接到本服务器的客户端
func (*Server) ForwardClientMsgToModule ¶
func (s *Server) ForwardClientMsgToModule(fromconn *connect.Client, to string, msgid uint16, data []byte)
ForwardClientMsgToModule 转发一个客户端消息到另一个服务器
func (*Server) GetBalanceModuleID ¶
GetBalanceModuleID 获取一个均衡的负载服务器
func (*Server) GetSession ¶
GetSession 获取本地维护的 session
func (*Server) HookServer ¶
func (s *Server) HookServer(serverHook serverbase.ServerHook)
HookServer 设置本服务的服务事件监听者
func (*Server) InitSubnet ¶
func (s *Server) InitSubnet(conf *conf.ModuleConfig)
InitSubnet 初始化本服务的子网管理器
func (*Server) MustUpdateSessionFromMap ¶
MustUpdateSessionFromMap 更新本地的Session,如果没有的话注册它
func (*Server) RangeClient ¶
RangeClient 获取一个客户端连接
func (*Server) ReqCloseConnect ¶
ReqCloseConnect 请求关闭远程瞪的目标客户端连接
func (*Server) SInnerCloseSessionConnect ¶
SInnerCloseSessionConnect 断开一个客户端连接,仅框架内使用
func (*Server) SInnerSendClientMsg ¶
SInnerSendClientMsg 发送一个服务器消息到另一个服务器,仅框架内使用
func (*Server) SInnerSendModuleMsg ¶
func (s *Server) SInnerSendModuleMsg(to string, msgstr msg.IMsgStruct)
SInnerSendModuleMsg 发送一个服务器消息到另一个服务器,仅框架内使用
func (*Server) SendBytesToClient ¶
SendBytesToClient 发送一个消息到客户端
func (*Server) SendModuleMsg ¶
func (s *Server) SendModuleMsg( to string, msgstr msg.IMsgStruct)
SendModuleMsg 发送一个服务器消息到另一个服务器
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package base 服务的基本接口
|
Package base 服务的基本接口 |
Package gate gateway基础模块
|
Package gate gateway基础模块 |
base
Package base 网关的基本接口
|
Package base 网关的基本接口 |
Package subnet micserver中的子网信息,管理了所有模块间的连接
|
Package subnet micserver中的子网信息,管理了所有模块间的连接 |
base
Package base 服务器子网基础
|
Package base 服务器子网基础 |
serconfs
Package serconfs 连接到本模块的服务器配置信息管理器
|
Package serconfs 连接到本模块的服务器配置信息管理器 |