DELPHI版传奇引擎学习菜鸟篇(applem2)05

1-4是大概把GAMECENTER过了一遍,终于把消息机制入了一点门,接下来是服务端第一个服务的学习--DBServer.是一个数据库服务器,在学习这个单元的时候,发现了这个端的大概由来,不知道是哪个大牛反编译后重写的,看来之前我理解的是错误的,代码杂乱的原因不是没有考虑到正题设计,这是由DEDEDARK反编译的端,根据自己的经验补写的实现代码,不知道我这辈子能不能达到这样的水平,那得需要对汇编多熟悉才行啊.

function TFrmNewChr.sub_49BD60(var sChrName: string): Boolean;//反编译的函数
//0x0049BD60
begin
  Result := False;
  EdName.Text := '';
  Self.ShowModal;
  sChrName := Trim(EdName.Text);
  if sChrName <> '' then
    Result := True;
end;
//这个函数是增加新角色,能看到汇编代码痕迹,单元里边还有DEDEDARK的注释说明

4 DBServer

4.1 DBSMain.pas

先说主单元,这是整个传奇服务端的数据库服务器,这个单元结构还是比较清晰的,代码1500行左右,接口部分声明的新对象也不多,主要是VCL声明和过程,但是这个服务调用的其他模块较多,主要用于数据库(人物,物品,技能等)的处理.

unit DBSMain;

interface

uses
  Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
  StdCtrls, ExtCtrls, JSocket, Buttons, IniFiles, Menus, Grobal2, HumDB, DBShare,
  ComCtrls, ActnList, AppEvnts, DB, DBTables, Common;

type
  {定义服务器信息}
  TServerInfo = record
    nSckHandle: Integer;//socket句柄
    RecvBuff: PChar;    //接收数据缓冲区
    BuffLeng: Integer;  //缓冲区大小
    Socket: TCustomWinSocket;//这里直接继承的TCustomWinSocket,现在应该不用这样了
  end;

  pTServerInfo = ^TServerInfo;//定义为指针

  TFrmDBSrv = class(TForm)
    ServerSocket: TServerSocket;
    Timer1: TTimer;
    {.......中间的省略,都是VLC的声明}
    procedure X1Click(Sender: TObject);
    procedure N3Click(Sender: TObject);
    procedure F1Click(Sender: TObject);
    procedure T2Click(Sender: TObject);
    procedure MENU_MANAGE_TOOLClick(Sender: TObject);
  private
    n344: Integer;//这两个暂时还不知道
    n348: Integer;
    ServerList: TList; //服务器列表信息
    m_boRemoteClose: Boolean; //连接标志
    procedure ProcessServerPacket(ServerInfo: pTServerInfo);//数据包处理过程
    {发送数据}
    procedure SendSocket(Socket: TCustomWinSocket; SendBuff: PChar; BuffLen: Integer);
    {这是读取角色数据的过程,带有非法连接处理}
    procedure LoadHumanRcd(RecvBuff: PChar; BuffLen, QueryID: Integer; Socket: TCustomWinSocket);
    {角色退出时保存角色数据}
    procedure SaveHumanRcd(nRecog, QueryID: Integer; RecvBuff: PChar; BuffLen: Integer; Socket: TCustomWinSocket);
    {清理}
    procedure ClearSocket(Socket: TCustomWinSocket);
    {获取端口列表}
    procedure ShowModule();
    {加载物品数据库}
    function LoadItemsDB(): Integer;
    {加载技能数据库}
    function LoadMagicDB(): Integer;
  public
    {复制人物数据}
    function CopyHumData(sSrcChrName, sDestChrName, sUserId: string): Boolean;
    {删除人物数据}
    procedure DelHum(sChrName: string);
    {服务器消息处理函数,用于和其他进程通信}
    procedure MyMessage(var MsgData: TWmCopyData); message WM_COPYDATA;
  end;

var
  FrmDBSrv: TFrmDBSrv;

大部分的处理过程是针对SOCKET的编程和数据库的读写,开始我还觉得为什么不用大型数据库,看完之后,大概了解到传奇服务端数据本来就不多,这个服务端是为多机架设而写的,一般数据库,网关服务都在单独的服务器上,所以单个服务端最大在线一般不超过2000人,所以用小型的DBC2000还是足够的,大型数据库除非是专门的数据库服务器,那样会提高并发操作的效率,可是对于这套架构来说,无异于所有代码都需要重构了,先学习基本的数据处理方式,学到经验还可以用到多层数据库开发中,这也算一个捷径吧.

4.2 DBShare.pas

对于数据库服务器的共享数据单元倒没有什么特别的,主单元的数据处理函数一部分放在了这里,其他的大部分都是变量.

unit DBShare;

interface

uses
  Windows, Messages, Classes, SysUtils, StrUtils, JSocket, WinSock, IniFiles,
  Grobal2, MudUtil, Common;

const
  g_sUpDateTime = '修改日期: 2015/12/09';
  SIZEOFTHUMAN = 44145; //44032
type
  TGList = class(TList)
  private
    GLock: TRTLCriticalSection;
  public
    constructor Create;
    destructor Destroy; override;
    procedure Lock;
    procedure UnLock;
  end;

  TSockaddr = record   //用于攻击检测用的
    nIPaddr: Integer;
    dwStartAttackTick: LongWord;
    nAttackCount: Integer;
  end;

  pTSockaddr = ^TSockaddr;

  TCheckCode = record    //测试用的,正式端不包含
    dwThread0: LongWord;
  end;

  TGateInfo = record       //网关信息
    Socket: TCustomWinSocket;
    sGateaddr: string; //0x04
    sText: string; //0x08
    sSendMsg: string;
    UserList: TList; //0x0C
    dwTick10: LongWord; //0x10
    nGateID: Integer; //网关ID
  end;

  pTGateInfo = ^TGateInfo;

  TUserInfo = record          //角色信息
    sAccount: string; //0x00
    sUserIPaddr: string; //0x0B
    sGateIPaddr: string;
    sConnID: string; //0x20
    sSockIndex: string;
    nSessionID: Integer; //0x24
    Socket: TCustomWinSocket;
    boChrSelected: Boolean; //0x30
    boChrQueryed: Boolean; //0x31
    dwTick34: LongWord; //0x34
    dwChrTick: LongWord; //0x38
    nSelGateID: ShortInt; //角色网关ID
    nDataCount: Integer;
    boWaitMsg: Boolean;
    nWaitID: Integer;
    sCreateChrMsg: string;
  end;
  pTUserInfo = ^TUserInfo;

  TRouteInfo = record      //路由配置信息
    nGateCount: Integer;
    sSelGateIP: string[15];
    sGameGateIP: array[0..7] of string[15];
    nGameGatePort: array[0..7] of Integer;
  end;

  pTRouteInfo = ^TRouteInfo;

procedure LoadConfig();    //加载服务端设置

procedure LoadIPTable();   //从设置文件里边加载IP列表

function GetCodeMsgSize(X: Double): Integer; //取得消息编号

function InClearMakeIndexList(nIndex: Integer): Boolean; //

procedure WriteLogMsg(sMsg: string); //写入日志信息

function CheckServerIP(sIP: string): Boolean;  //监测连接IP的合法性

procedure SendGameCenterMsg(wIdent: Word; sSendMsg: string); //向引擎控制台发送消息

procedure MainOutMessage(sMsg: string);  //发送消息到主界面

function GetMagicName(wMagicId: Word): string; //获取技能名称

function GetStdItemName(nPosition: Integer): string;//取得物品名称

function CheckFiltrateUserName(sName: string): Boolean;//检查过滤角色

procedure LoadFiltrateName(); //读取过滤

function GetWaitMsgID(): Integer;//取得等待处理的消息编号

var
  sDataDBFilePath: string = '.\DB\';
  nServerPort: Integer = 6000;
  sServerAddr: string = '0.0.0.0';
  g_nGatePort: Integer = 5100;
  g_sGateAddr: string = '0.0.0.0';
  nIDServerPort: Integer = 5600;
  sIDServerAddr: string = '127.0.0.1';
  g_nWaitMsgIndex: Integer = 0;
  g_boTestServer: Boolean = True;
  {以下暂时还不知道是干什么的,先不做猜测}
  HumDB_CS: TRTLCriticalSection; //0x004ADACC
  g_FiltrateUserName: TStringList;
  n4ADAE4: Integer;
  n4ADAE8: Integer;
  n4ADAEC: Integer;
  n4ADAF0: Integer;
  boDataDBReady: Boolean; //0x004ADAF4
  n4ADAFC: Integer;
  n4ADB00: Integer;
  n4ADB04: Integer;
  boHumDBReady: Boolean; //0x4ADB08
  n4ADBF4: Integer;
  n4ADBF8: Integer;
  n4ADBFC: Integer;
  n4ADC00: Integer;
  n4ADC04: Integer;
  boAutoClearDB: Boolean; //0x004ADC08
  g_nQueryChrCount: Integer; //0x004ADC0C
  nHackerNewChrCount: Integer; //0x004ADC10
  nHackerDelChrCount: Integer; //0x004ADC14
  nHackerSelChrCount: Integer; //0x004ADC18
  n4ADC1C: Integer;
  n4ADC20: Integer;
  n4ADC24: Integer;
  n4ADC28: Integer;
  n4ADC2C: Integer;
  n4ADB10: Integer;
  n4ADB14: Integer;
  n4ADB18: Integer;
  n4ADBB8: Integer;
  bo4ADB1C: Boolean;
  //以下是定义服务器设置变量
  sServerName: string = '新热血传奇';
  sConfFileName: string = '.\Dbsrc.ini';
  sConfClass: string = 'DBServer';
  sGateConfFileName: string = '.\!serverinfo.txt';
  sServerIPConfFileNmae: string = '.\!addrtable.txt';
  sFiltrateUserName: string = '.\FUserName.txt';
  sHeroDB: string = 'HeroDB';
  sMapFile: string;
  DenyChrNameList: TStringList;
  ServerIPList: TStringList;
  StdItemList: TList;
  MagicList: TList;
  g_SortMinLevel: Integer = 0;
  g_SortMaxLevel: Integer = 200;
  g_boAutoSort: Boolean = True;
  g_boSortClass: Boolean = False;
  g_btSortHour: Byte = 0;
  g_btSortMinute: Byte = 4;
  g_boArraySort: Boolean = False;
  g_boArraySortTime: LongWord;
  g_nClearRecordCount: Integer;
  g_nClearIndex: Integer; //0x324
  g_nClearCount: Integer; //0x328
  g_nClearItemIndexCount: Integer;
  boOpenDBBusy: Boolean; //0x350
  g_dwGameCenterHandle: THandle;
  g_boDynamicIPMode: Boolean = False;
  g_CheckCode: TCheckCode;
  g_ClearMakeIndex: TStringList;
  g_RouteInfo: array[0..19] of TRouteInfo;
  g_MainMsgList: TStringList;
  g_OutMessageCS: TRTLCriticalSection;
  ProcessHumanCriticalSection: TRTLCriticalSection;
  IDSocketConnected: Boolean;
  UserSocketClientConnected: Boolean;
  ServerSocketClientConnected: Boolean;
  DataManageSocketClientConnected: Boolean;
  ID_sRemoteAddress: string;
  User_sRemoteAddress: string;
  Server_sRemoteAddress: string;
  DataManage_sRemoteAddress: string;
  ID_nRemotePort: Integer;
  User_nRemotePort: Integer;
  Server_nRemotePort: Integer;
  DataManage_nRemotePort: Integer;
  dwKeepAliveTick: LongWord;
  dwKeepIDAliveTick: LongWord;
  dwKeepServerAliveTick: LongWord;

const
  tDBServer = 0;

implementation
{实现部分不是很复杂,就不再注释了,不过有的涉及到之前提到的,还有其他单元引用的}

uses
  DBSMain, HUtil32;

procedure LoadIPTable();
begin
  ServerIPList.Clear;
  try
    ServerIPList.LoadFromFile(sServerIPConfFileNmae);
  except
    MainOutMessage('加载IP列表文件 ' + sServerIPConfFileNmae + ' 出错！！！');
  end;
end;

function GetWaitMsgID(): Integer;
begin
  Inc(g_nWaitMsgIndex);
  if g_nWaitMsgIndex <= 0 then
    g_nWaitMsgIndex := 1;
  Result := g_nWaitMsgIndex;
end;

procedure LoadConfig();
var
  Conf: TIniFile;
begin
  Conf := TIniFile.Create(sConfFileName);
  if Conf <> nil then
  begin
    sServerName := Conf.ReadString(sConfClass, 'ServerName', sServerName);
    nServerPort := Conf.ReadInteger(sConfClass, 'ServerPort', nServerPort);
    sServerAddr := Conf.ReadString(sConfClass, 'ServerAddr', sServerAddr);
    g_nGatePort := Conf.ReadInteger(sConfClass, 'GatePort', g_nGatePort);
    g_sGateAddr := Conf.ReadString(sConfClass, 'GateAddr', g_sGateAddr);
    sIDServerAddr := Conf.ReadString(sConfClass, 'IDSAddr', sIDServerAddr);
    nIDServerPort := Conf.ReadInteger(sConfClass, 'IDSPort', nIDServerPort);
    sHeroDB := Conf.ReadString(sConfClass, 'DBName', sHeroDB);
    sDataDBFilePath := Conf.ReadString(sConfClass, 'DBDir', sDataDBFilePath);
    g_boTestServer := not Conf.ReadBool(sConfClass, 'NotRepeatName', not g_boTestServer);
    g_boAutoSort := Conf.ReadBool(sConfClass, 'AutoSort', g_boAutoSort);
    g_boSortClass := Conf.ReadBool(sConfClass, 'SortClass', g_boSortClass);
    g_btSortHour := Conf.ReadInteger(sConfClass, 'SortHour', g_btSortHour);
    g_btSortMinute := Conf.ReadInteger(sConfClass, 'SortMinute', g_btSortMinute);
    g_SortMinLevel := Conf.ReadInteger(sConfClass, 'SortMinLevel', g_SortMinLevel);
    g_SortMaxLevel := Conf.ReadInteger(sConfClass, 'SortMaxLevel', g_SortMaxLevel);

    Conf.WriteString(sConfClass, 'ServerName', sServerName);
    Conf.WriteInteger(sConfClass, 'ServerPort', nServerPort);
    Conf.WriteString(sConfClass, 'ServerAddr', sServerAddr);
    Conf.WriteInteger(sConfClass, 'GatePort', g_nGatePort);
    Conf.WriteString(sConfClass, 'GateAddr', g_sGateAddr);
    Conf.WriteString(sConfClass, 'IDSAddr', sIDServerAddr);
    Conf.WriteInteger(sConfClass, 'IDSPort', nIDServerPort);
    Conf.WriteString(sConfClass, 'DBName', sHeroDB);
    Conf.WriteString(sConfClass, 'DBDir', sDataDBFilePath);
    Conf.WriteBool(sConfClass, 'AutoSort', g_boAutoSort);
    Conf.WriteBool(sConfClass, 'SortClass', g_boSortClass);
    Conf.WriteInteger(sConfClass, 'SortHour', g_btSortHour);
    Conf.WriteInteger(sConfClass, 'SortMinute', g_btSortMinute);
    Conf.WriteInteger(sConfClass, 'SortMinLevel', g_SortMinLevel);
    Conf.WriteInteger(sConfClass, 'SortMaxLevel', g_SortMaxLevel);
    Conf.WriteBool(sConfClass, 'NotRepeatName', not g_boTestServer);
    Conf.Free;
  end;
  LoadIPTable();
end;

function GetStdItemName(nPosition: Integer): string;
var
  StdItem: pTStdItem;
begin
  if (nPosition - 1 >= 0) and (nPosition < StdItemList.Count) then
  begin
    StdItem := StdItemList.Items[nPosition - 1];
    if StdItem <> nil then
    begin
      Result := StdItem.Name;
    end;
  end;
end;

function GetMagicName(wMagicId: Word): string;
var
  i: Integer;
  Magic: pTMagic;
begin
  for i := 0 to MagicList.Count - 1 do
  begin
    Magic := MagicList.Items[i];
    if Magic <> nil then
    begin
      if Magic.wMagicId = wMagicId then
      begin
        Result := Magic.sMagicName;
        break;
      end;
    end;
  end;
end;

function GetCodeMsgSize(X: Double): Integer;
begin
  if INT(X) < X then
    Result := TRUNC(X) + 1
  else
    Result := TRUNC(X)
end;

function InClearMakeIndexList(nIndex: Integer): Boolean;
var
  i: Integer;
begin
  Result := False;
  for i := 0 to g_ClearMakeIndex.Count - 1 do
  begin
    if nIndex = Integer(g_ClearMakeIndex.Objects[i]) then
    begin
      Result := True;
      break;
    end;
  end;
end;

procedure MainOutMessage(sMsg: string);
begin
  EnterCriticalSection(g_OutMessageCS);
  try
    g_MainMsgList.Add(sMsg);
  finally
    LeaveCriticalSection(g_OutMessageCS);
  end;
end;

procedure WriteLogMsg(sMsg: string);
begin

end;

function CheckServerIP(sIP: string): Boolean;
var
  i: Integer;
begin
  Result := False;
  for i := 0 to ServerIPList.Count - 1 do
  begin
    if CompareText(sIP, ServerIPList.Strings[i]) = 0 then
    begin
      Result := True;
      break;
    end;
  end;
end;

procedure SendGameCenterMsg(wIdent: Word; sSendMsg: string);
var
  SendData: TCopyDataStruct;
  nParam: Integer;
begin
  nParam := MakeLong(Word(tDBServer), wIdent);
  SendData.cbData := Length(sSendMsg) + 1;
  GetMem(SendData.lpData, SendData.cbData);
  StrCopy(SendData.lpData, PChar(sSendMsg));
  SendMessage(g_dwGameCenterHandle, WM_COPYDATA, nParam, Cardinal(@SendData));
  FreeMem(SendData.lpData);
end;

function CheckFiltrateUserName(sName: string): Boolean;
var
  i: integer;
begin
  Result := False;
  for I := 0 to g_FiltrateUserName.Count - 1 do
  begin
    if AnsiContainsText(sName, g_FiltrateUserName.Strings[I]) then
    begin
      Result := True;
      break;
    end;
  end;
end;

constructor TGList.Create;
begin
  inherited Create;
  InitializeCriticalSection(GLock);
end;

destructor TGList.Destroy;
begin
  DeleteCriticalSection(GLock);
  inherited;
end;

procedure TGList.Lock;
begin
  EnterCriticalSection(GLock);
end;

procedure TGList.UnLock;
begin
  LeaveCriticalSection(GLock);
end;

procedure LoadFiltrateName();
var
  i: Integer;
  TempList: TStringList;
  sStr: string;
begin
  g_FiltrateUserName.Clear;
  TempList := TStringList.Create;
  TempList.Clear;
  try
    if FileExists(sFiltrateUserName) then
    begin
      TempList.LoadFromFile(sFiltrateUserName);
      for i := 0 to TempList.Count - 1 do
      begin
        sStr := TempList.Strings[I];
        if (Length(sStr) > 0) and (sStr[1] <> ';') then
          g_FiltrateUserName.Add(sStr);
      end;
    end
    else
    begin
      TempList.Add(';创建人物过滤字符，一行一个过滤');
      TempList.SaveToFile(sFiltrateUserName);
    end;
  finally
    TempList.Free;
  end;
end;

initialization
begin
  InitializeCriticalSection(g_OutMessageCS);
  InitializeCriticalSection(HumDB_CS);
  g_MainMsgList := TStringList.Create;
  DenyChrNameList := TStringList.Create;
  ServerIPList := TStringList.Create;
  g_ClearMakeIndex := TStringList.Create;
  StdItemList := TList.Create;
  MagicList := TList.Create;
  g_FiltrateUserName := TStringList.Create;
end;

finalization
begin
  DeleteCriticalSection(HumDB_CS);
  DeleteCriticalSection(g_OutMessageCS);
  DenyChrNameList.Free;
  ServerIPList.Free;
  g_ClearMakeIndex.Free;
  g_MainMsgList.Free;
  StdItemList.Free;
  MagicList.Free;
  g_FiltrateUserName.Free;
end;

end.

接下来还有一个人物数据单元HUMDB.pas,需要先把之前的复习几遍才能去看,因为涉及到数据文件的读写,对于文件的学习需求马上就到来了,这些代码我都新建一个程序把它们一点一点敲进去编译一遍,然后再去看源代码的大概结构和关系,这样学习很费时间,但是我觉得比我一下子去学习若干基础性的东西要理解的快一点,当把整个服务端都初步过了一遍后,我会回头将记下来的需要巩固的基础性东西都重新练习即便,我发现,在写第一遍的时候是模棱两可,第二遍就不知不觉知道了某些对象和函数到底是干什么用的,第三遍的时候我大概能想到通过自己的方式去实现一些函数和过程,甚至可以增加和去掉某些不需要的结构变量,程序的功能正常运行,也许更改的东西不合理,但是锻炼了我的动手能力,对我的水平来说,光看一些优秀的代码我是学不到东西的,因为不动手,我看十几遍也不知道那到底要表达什么.

我学习的时候一般都开两个DELPHI窗口,不知道有没有什么更好的办法,同时开两个代码提示就看不到了,不过这倒是提高了我的打字速度O(∩_∩)…