kingston-csj / mmorpg Goto Github PK

@RequestMapping(module = Modules.PLAYER, cmd = PlayerService.CMD_REQ_LOGIN)
public void reqPlayerLogin(IoSession session, @MessageMeta ReqPlayerLogin request) {
	long playerId = request.getPlayerId();
	System.out.println("角色[" + playerId + "]登录");
	SessionManager.getInstance().registerSession(playerId, session);

	session.sendPacket(new ResPlayerLogin());
}

private Message readMessage(short module, short cmd, ByteBuf in) {
		Class<?> msgClazz = SpringContext.getMessageFactory().createMessage(module, cmd);
		try {
			Serializer messageCodec = Serializer.getSerializer(msgClazz);
			Message message = (Message) messageCodec.decode(in, msgClazz, null);
			return message;
		} catch (Exception e) {
			LoggerUtils.error("读取消息出错,模块号{}，类型{},异常{}", new Object[]{module, cmd ,e});
		}
		return null;
	}

@Override
	public Object decode(ByteBuf in, Class<?> type, Class<?> wrapper) {
		try {
			Object bean = type.newInstance();
			for (FieldCodecMeta fieldMeta:fieldsMeta) {
				Field field = fieldMeta.getField();
				Serializer fieldCodec = fieldMeta.getSerializer();
				Object value = fieldCodec.decode(in, fieldMeta.getType(), fieldMeta.getWrapper());
				field.set(bean, value);
			}
			return bean;
		}catch(Exception e) {
			e.printStackTrace();
		}
		return null;
	}

@Override
	public Object decode(ByteBuf in, Class<?> type, Class<?> wrapper) {
		try {
			Object bean = type.newInstance();
			for (FieldCodecMeta fieldMeta:fieldsMeta) {
				Field field = fieldMeta.getField();
				Serializer fieldCodec = fieldMeta.getSerializer();
				Object value = fieldCodec.decode(in, fieldMeta.getType(), fieldMeta.getWrapper());
				field.set(bean, value);
			}
                        //手动释放ByteBuf
                        ReferenceCountUtil.release(buf);
			return bean;
		}catch(Exception e) {
			e.printStackTrace();
		}
		return null;
	}