码迷，mamicode.com
首页 > 移动开发 > 详细

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

时间：2015-12-19 13:41:09      阅读：330      评论：0      收藏：0      [点我收藏+]

标签：

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(∩_∩)…

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

标签：

原文地址：http://www.cnblogs.com/iicc/p/5058927.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！