com.bitactor.framework.cloud.spring.controller.support

类 ControllerContext

java.lang.Object

com.bitactor.framework.cloud.spring.controller.support.ControllerContext

@Component
public class ControllerContext
extends Object

作者:

WXH

字段概要

字段

限定符和类型	字段和说明
private BitactorApplicationProperties	bitactorApplicationProperties
protected ConcurrentHashMap<Integer,MappingInfo>	COMMAND_ID_BY_APP_GROUP_JSON
protected ConcurrentHashMap<Integer,MappingInfo>	COMMAND_ID_BY_APP_GROUP_PROTO
private ConnectManager	connectManager
private List<ConnectorMsgHandler>	connectorMsgHandlers
protected ConcurrentHashMap<Integer,ControllerInvoker>	CONTROLLER_JSON_INVOKER_MAP
protected ConcurrentHashMap<Integer,ControllerInvoker>	CONTROLLER_PROTO_INVOKER_MAP
protected Set<String>	controllerList
private static com.bitactor.framework.core.logger.Logger	logger

构造器概要

构造器

构造器和说明
ControllerContext()

方法概要

限定符和类型	方法和说明
void	addControllerBean(Object bean) 添加rpc服务的bean类
private void	addControllerInvoker(ControllerInvoker invoker)
void	boundCommandIdToAppGroup(List<MappingInfo> mappingInfos)
void	boundCommandIdToAppGroup(MappingInfo mappingInfo) 添加controller 对应的commandId 的appGroup PROTO 类型请求
MessageBytes	buildErrorMessageByte(Throwable exception, int msgErrorType, ClientNetSession session, ProtocolType type, int msgId, int commandId) 构建错误响应
MappingInfo	buildMappingInfo(ControllerInvoker invoker) 构建MappingInfo
MappingReqParam	buildRequestMethodArgs(ClientNetSession session, Method method, BitactorRequestMapping mapping, byte[] msg) 构建 BitactorRequestMapping 方法参数
boolean	checkNeedAuth(ClientNetSession session) 检查权限
void	doConnectRequest(com.bitactor.framework.core.net.api.Channel channel, ClientNetSession session, MessageConnectorData messageMvcData) 处理请求
boolean	existInvoker(int commandId, ProtocolType protocolType) 是否存在 ControllerInvoker
boolean	existMapping(int commandId, ProtocolType protocolType) 是否存在可调用的mapping
ControllerInvoker	get(int commandId, ProtocolType protocolType) 获取对应命令id 的控制器调用者
MappingInfo	getBackendMapping(int commandId, ProtocolType protocolType) 通过CommandId获取 AppGroup= appName
BitactorApplicationProperties	getBitactorApplicationProperties()
ConcurrentHashMap<Integer,ControllerInvoker>	getControllerJsonInvoker()
Set<String>	getControllerList()
ConcurrentHashMap<Integer,ControllerInvoker>	getControllerProtoInvoker()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

private static final com.bitactor.framework.core.logger.Logger logger

COMMAND_ID_BY_APP_GROUP_JSON

protected final ConcurrentHashMap<Integer,MappingInfo> COMMAND_ID_BY_APP_GROUP_JSON

COMMAND_ID_BY_APP_GROUP_PROTO

protected final ConcurrentHashMap<Integer,MappingInfo> COMMAND_ID_BY_APP_GROUP_PROTO

CONTROLLER_JSON_INVOKER_MAP

protected final ConcurrentHashMap<Integer,ControllerInvoker> CONTROLLER_JSON_INVOKER_MAP

CONTROLLER_PROTO_INVOKER_MAP

protected final ConcurrentHashMap<Integer,ControllerInvoker> CONTROLLER_PROTO_INVOKER_MAP

controllerList

protected final Set<String> controllerList

connectorMsgHandlers

@Autowired(required=false)
private List<ConnectorMsgHandler> connectorMsgHandlers

connectManager

@Autowired(required=false)
private ConnectManager connectManager

bitactorApplicationProperties

@Autowired
private BitactorApplicationProperties bitactorApplicationProperties

构造器详细资料

ControllerContext

public ControllerContext()

方法详细资料

getBitactorApplicationProperties

public BitactorApplicationProperties getBitactorApplicationProperties()

getControllerList

public Set<String> getControllerList()

addControllerBean

public void addControllerBean(Object bean)

添加rpc服务的bean类

参数:

bean -

addControllerInvoker

private void addControllerInvoker(ControllerInvoker invoker)
                           throws IllegalAccessException

抛出:

IllegalAccessException

boundCommandIdToAppGroup

public void boundCommandIdToAppGroup(MappingInfo mappingInfo)

添加controller 对应的commandId 的appGroup PROTO 类型请求

参数:

mappingInfo -

boundCommandIdToAppGroup

public void boundCommandIdToAppGroup(List<MappingInfo> mappingInfos)

buildMappingInfo

public MappingInfo buildMappingInfo(ControllerInvoker invoker)

构建MappingInfo

参数:

invoker -

返回:

existInvoker

public boolean existInvoker(int commandId,
                            ProtocolType protocolType)

是否存在 ControllerInvoker

参数:

commandId -

protocolType -

返回:

get

public ControllerInvoker get(int commandId,
                             ProtocolType protocolType)

获取对应命令id 的控制器调用者

参数:

commandId - 命令id

返回:

ControllerInvoker

getBackendMapping

public MappingInfo getBackendMapping(int commandId,
                                     ProtocolType protocolType)

通过CommandId获取 AppGroup= appName

参数:

commandId -

protocolType -

返回:

existMapping

public boolean existMapping(int commandId,
                            ProtocolType protocolType)

是否存在可调用的mapping

参数:

commandId -

protocolType -

返回:

doConnectRequest

public void doConnectRequest(com.bitactor.framework.core.net.api.Channel channel,
                             ClientNetSession session,
                             MessageConnectorData messageMvcData)

处理请求

buildErrorMessageByte

public MessageBytes buildErrorMessageByte(Throwable exception,
                                          int msgErrorType,
                                          ClientNetSession session,
                                          ProtocolType type,
                                          int msgId,
                                          int commandId)

构建错误响应

参数:

exception -

msgErrorType -

session -

type -

msgId -

commandId -

返回:

checkNeedAuth

public boolean checkNeedAuth(ClientNetSession session)

检查权限

参数:

session -

返回:

buildRequestMethodArgs

public MappingReqParam buildRequestMethodArgs(ClientNetSession session,
                                              Method method,
                                              BitactorRequestMapping mapping,
                                              byte[] msg)
                                       throws Exception

构建 BitactorRequestMapping 方法参数

参数:

session -

method -

mapping -

msg -

返回:

抛出:

Throwable

Exception

getControllerJsonInvoker

public ConcurrentHashMap<Integer,ControllerInvoker> getControllerJsonInvoker()

getControllerProtoInvoker

public ConcurrentHashMap<Integer,ControllerInvoker> getControllerProtoInvoker()