设为首页收藏本站
切换到窄版

 找回密码
 注册
搜索
热搜: 超星 读书 找书
网上读书园地»论坛 › 资源共享区 › BT资源专区[关闭中] › SGIP的delphi原码
返回列表 发新帖
查看: 419|回复: 0

SGIP的delphi原码

[复制链接]
gznxlzyh 该用户已被删除
发表于 2006-6-7 01:05:07 | 显示全部楼层 |阅读模式
在网上找了好长时间，也没有发现有SGIP的例子，伤感之余，终于做了一个Delphi6.0的SGIP例子
包含了一个服务端和一个客户端，协议共用，服务端为非阻塞长连接，客户端为阻塞短连接，
程序写的很乱，风格也很差，希望高手多多指教　
（dulcet99@163.com,dulcet99@sina.com）

file://客户端
unit TestMain;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, ScktComp, StdCtrls, ExtCtrls, xy, winsock;
const
  FV_SNumber=3053112345;
  FV_LoginPass='hi';
  FV_LoginName='hi';
  FV_SPNumber='12345';
  T_Tel='13000000000';
  FV_corpID='12345';
  T_msg='我在天空写下你的名字，没有被风带走';
type
  TForm1 = class(TForm)
   Memo1: TMemo;
   Button1: TButton;
   ClientSocket1: TClientSocket;
   Button3: TButton;
   Button4: TButton;
   Button2: TButton;
   Button5: TButton;
   Button6: TButton;
   Button7: TButton;
   ServerSocket1: TServerSocket;
   panel1: TPanel;
   procedure Button2Click(Sender: TObject);
   procedure Button1Click(Sender: TObject);
   procedure Button6Click(Sender: TObject);
   procedure Button5Click(Sender: TObject);
   procedure Button3Click(Sender: TObject);
   procedure Button4Click(Sender: TObject);
   procedure ClientSocket1Read(Sender: TObject; Socket: TCustomWinSocket);
   procedure Button7Click(Sender: TObject);
   procedure ServerSocket1ClientRead(Sender: TObject;
    Socket: TCustomWinSocket);
  private
   { Private declarations }
  public
   { Public declarations }
   file://客户端协议定义
   sHead:          SGIPHead;     file://消息头定义
   sBind:          XBind;       file://连接请求验证
   sBind_Resp:      Bind_Resp;    file://响应连接请求验证
   sSubmit:        XSubmit;      file://SP->SMG提交短信
   sSubmit_Resp:     Submit_Resp;   file://SMG响应SP提交的短信状态
   sDeliver:        XDeliver;     file://SMG->SP提交短信
   sDeliver_Resp:    Deliver_Resp;  file://SP响应SMG提交的短信状态
   sReport:        XReport;      file://SMG->SP先前的短信状态
   sReport_Resp:     Report_Resp;   file://响应命令执行状况
   file://服务端协议定义
   cHead:          SGIPHead;     file://消息头定义
   cBind:          XBind;       file://连接请求验证
   cBind_Resp:      Bind_Resp;    file://响应连接请求验证
   cSubmit:        XSubmit;      file://SP->SMG提交短信
   cSubmit_Resp:     Submit_Resp;   file://SMG响应SP提交的短信状态
   cDeliver:        XDeliver;     file://SMG->SP提交短信
   cDeliver_Resp:    Deliver_Resp;  file://SP响应SMG提交的短信状态
   cReport:        XReport;      file://SMG->SP先前的短信状态
   cReport_Resp:     Report_Resp;   file://响应命令执行状况
  end;

var
  Form1: TForm1;

implementation

{$R *.dfm}

procedure TForm1.Button2Click(Sender: TObject);
begin
  ClientSocket1.Active:=false;
  if ClientSocket1.Active then
   memo1.Lines.Add('客户端关闭失败')
  else
   memo1.Lines.Add('客户端关闭成功');
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
  ClientSocket1.Active:=true;
  if ClientSocket1.Active then
   memo1.Lines.Add('客户端打开成功')
  else
   memo1.Lines.Add('客户端打开失败');
end;

procedure TForm1.Button6Click(Sender: TObject);
begin
  ServerSocket1.Active:=true;
  if ServerSocket1.Active then
   memo1.Lines.Add('服务端打开成功')
  else
   memo1.Lines.Add('服务端打开失败');
end;

procedure TForm1.Button5Click(Sender: TObject);
begin
  ServerSocket1.Active:=false;
  if ServerSocket1.Active then
   memo1.Lines.Add('服务端关闭失败')
  else
   memo1.Lines.Add('服务端关闭成功');
end;

procedure TForm1.Button3Click(Sender: TObject);
var
  FV_Date1_S,FV_Date2_S:string;
  str_i,SendSize:integer;
  stream1:TWinSocketStream;
  abc,bc:longword;
begin
   stream1:=TWinSocketStream.Create(ClientSocket1.Socket,30000);
   memo1.Lines.Add('-------------------向服务端发送BIND请求--------------------');
   if not ClientSocket1.Active then
   begin
    memo1.Lines.Add('客户端没有打开');
    exit;
   end;
   DateTimeToString(FV_Date1_S,'mmddhhnnss',now);
   DateTimeToString(FV_Date2_S,'zzz',now);
   FillChar(sBind,sizeof(sBind),0);
   FillChar(sHead,sizeof(sHead),0);
   str_i:=sizeof(sHead)+sizeof(sBind);
   sBind.LonginType:=1;
   strpcopy(sBind.LonginPass,FV_LoginPass);
   strpcopy(sBind.LonginName,FV_LoginName);
   abc:=htonl(FV_SNumber);
   sHead.MessageLength:=htonl(str_i);
   sHead.CommandId:=htonl(SGIP_Bind);
   sHead.SNumber1:=abc;
   sHead.SNumber2:=htonl(StrToInt(FV_Date1_S));
   sHead.SNumber3:=htonl(StrToInt(FV_Date2_S));
   stream1.WriteBuffer(sHead,sizeof(sHead));
   stream1.WriteBuffer(sBind,sizeof(sBind));
   memo1.Lines.Add('sHead.MessageLength    '+inttostr(ntohl(sHead.MessageLength)));
   memo1.Lines.Add('sHead.CommandId       '+inttostr(ntohl(sHead.CommandId)));
   bc:=ntohl(abc);
   memo1.Lines.Add('sHead.SNumber1        '+inttostr(bc));
   memo1.Lines.Add('sHead.SNumber2        '+inttostr(ntohl(sHead.SNumber2)));
   memo1.Lines.Add('sHead.SNumber3        '+inttostr(ntohl(sHead.SNumber3)));
   memo1.Lines.Add('sBind.LonginType      '+inttostr(sBind.LonginType));
   memo1.Lines.Add('sBind.LonginName      '+sBind.LonginName);
   memo1.Lines.Add('sBind.LonginPass      '+sBind.LonginPass);
   memo1.Lines.Add('------------------Bind请求已发送----------------------');
   if stream1.WaitForData(5000) then
   begin
    fillchar(cHead,sizeof(cHead),0);
    fillchar(cbind_resp,sizeof(cBind_Resp),0);
    stream1.ReadBuffer(cHead,sizeof(cHead));
    stream1.ReadBuffer(cBind_resp,sizeof(cBind_resp));
   end;
   memo1.Lines.Add('cHead.MessageLength    '+inttostr(ntohl(cHead.MessageLength)));
   bc:=ntohl(cHead.CommandId);
   memo1.Lines.Add('cHead.CommandId       '+inttostr(bc));
   bc:=ntohl(cHead.SNumber1);
   memo1.Lines.Add('cHead.SNumber1        '+inttostr(bc));
   memo1.Lines.Add('cHead.SNumber2        '+inttostr(ntohl(cHead.SNumber2)));
   memo1.Lines.Add('cHead.SNumber3        '+inttostr(ntohl(cHead.SNumber3)));
   memo1.Lines.Add('cBind.LonginType      '+inttostr(cBind_resp.Result));
   stream1.Free;
end;

procedure TForm1.Button4Click(Sender: TObject);
file://type
  {abc=packed record
   head:SGIPHead;
   submit:xSubmit;
  end;}
var
  FV_Date1_S,FV_Date2_S:string;
  i,SendSize:integer;
  file://xxx:abc;
  stream2:twinsocketstream;
  abc,bc:longword;
  line1,line2:longword;
begin
  stream2:=twinsocketstream.Create(clientsocket1.Socket,5000);
  SendSize:=0;
  memo1.Lines.Add('-------------------------submit--------------------------');
  if not ClientSocket1.Active then
  begin
   memo1.Lines.Add('-------------------客户端没有打开，submit失败-------------');
   exit;
  end;
  DateTimeToString(FV_Date1_S,'mmddhhnnss',now);
  DateTimeToString(FV_Date2_S,'zzz',now);
  FillChar(sSubmit,sizeof(sSubmit),0);
  FillChar(sHead,sizeof(sHead),0);
  with ssubmit do
  begin
   strpcopy(SPNumber,'4488');//;
   ChargeNumber      :='8613188890924';
   UserCount        :=1;          file://1-100
   {for i:=1 to UserCount do
   begin
    file://strpcopy(UserNumber[i-1].TelN,'8613065073355');//+T_Tel);//       :array of TelCount;  file://长度为UserCount
    UserNumber[i-1].TelN:='8613011725853';
   end;}
   UserNumber:='8613188890924';
   CorpID:='41027';//CorpID:='4488';//strpcopy(CorpID,FV_corpID);
   ServiceType:='4488';//FV_SPNumber);//'4488';
   FeeType         :=1;
   FeeValue        :='0';
   GivenValue       :='0';
   AgentFlag        :=0;
   MOrelatetoMTFlag   :=2;
   Priority        :=0;
   ExpireTime       :=';
   ScheduleTime      :=';
   ReportFlag       :=1;
   TP_pid          :=0;
   tp_udhi         :=0;
   MessageCoding     :=15;
   MessageType      :=0;
   MessageLength     :=htonl(161);
   strpcopy(MessageContent,T_msg);  file://长度为  MessageLength;
   file://Reserve         :=';
  end;
  {line1:=sizeof(sHead);
  line2:=sizeof(sSubmit);}
  with sHead do
  begin
   abc:=htonl(FV_SNumber);
   MessageLength:=htonl(sizeof(sHead)+sizeof(sSubmit)-3);
   CommandId:=htonl(SGIP_Submit);
   SNumber1:=abc;
   SNumber2:=htonl(StrToInt(FV_Date1_S));
   SNumber3:=htonl(StrToInt(FV_Date2_S));
  end;
  line1:=stream2.Write(shead,sizeof(shead));
  line2:=stream2.Write(sSubmit,sizeof(sSubmit)-3);
  if stream2.WaitForData(5000) then
  begin
   fillchar(cHead,sizeof(cHead),0);
   fillchar(cSubmit_Resp,sizeof(cSubmit_Resp),0);
   memo1.Lines.Add('read submit Head ..............');
   try
    stream2.ReadBuffer(cHead,sizeof(cHead));
    stream2.ReadBuffer(cSubmit_Resp,sizeof(cSubmit_Resp));
   except
    on e:exception do
    memo1.Lines.Add(e.Message);
   end;
   memo1.Lines.Add('read submit csubmit_resp ..............');
   file://stream2.ReadBuffer(cBind_Resp,sizeof(cBind_resp));
  end;
  stream2.Free;
end;

procedure TForm1.ClientSocket1Read(Sender: TObject;
  Socket: TCustomWinSocket);
var
  commandI,PackSizeongword;
  Recv1I,Recv2I:integer;
begin
  FillChar(sHead,sizeof(sHead),0);
  FillChar(sBind,sizeof(sBind),0);
  Recv1I:=socket.ReceiveBuf(sHead,sizeof(sHead));
  commandI:=ntohl(sHead.CommandId);
  PackSize:=ntohl(sHead.MessageLength);
  if commandI=SGIP_UNBIND_RESP then
  begin
   memo1.Lines.Add('------------------接收到SGIP_UNBIND_RESP请求------------------');
   exit;
  end;
  Recv2I:=socket.ReceiveBuf(sBind,sizeof(sBind));
  if commandI=SGIP_BIND_RESP then
   memo1.Lines.Add('---------------------SGIP_BIND_RESP------------------')
  else
  if commandI=SGIP_SUBMIT_RESP then
   memo1.Lines.Add('---------------------SGIP_SUBMIT_RESP----------------')
  else
   memo1.Lines.Add('---------------------'+inttostr(commandI)+'------------------');
  memo1.Lines.Add('MessageLength      '+inttostr(ntohl(sHead.MessageLength)));
  memo1.Lines.Add('CommandId        '+inttostr(commandI));
  memo1.Lines.Add('SNumber          '+inttostr(ntohl(sHead.SNumber1))+' '+
      inttostr(ntohl(sHead.SNumber2))+' '+inttostr(ntohl(sHead.SNumber3)));
  memo1.Lines.Add('Result          '+inttostr(sBind_Resp.Result));
  memo1.Lines.add('------------------end SGIP_UNBIND_RESP-------------------');
end;

procedure TForm1.Button7Click(Sender: TObject);
var
  FV_Date1_S,FV_Date2_S:string;
  stream3:TWinSocketStream;
begin
  Stream3:=TWinSocketStream.Create(clientSocket1.Socket,5000);
  memo1.Lines.Add('-------------------向服务端发送UnBIND请求--------------------');
  if not ClientSocket1.Active then
  begin
   memo1.Lines.Add('客户端没有打开');
   stream3.free;
   exit;
  end;
  DateTimeToString(FV_Date1_S,'mmddhhnnss',now);
  DateTimeToString(FV_Date2_S,'zzz',now);
  FillChar(sHead,sizeof(sHead),0);
  sHead.MessageLength:=htonl(sizeof(sHead));
  sHead.CommandId:=htonl(SGIP_UNBIND);
  sHead.SNumber1:=htonl(FV_SNumber);
  sHead.SNumber2:=htonl(StrToInt(FV_Date1_S));
  sHead.SNumber3:=htonl(StrToInt(FV_Date2_S));
  stream3.Write(sHead,20);
  FillChar(sHead,20,0);
  if stream3.WaitForData(5000) then
  begin
   stream3.ReadBuffer(sHead,20);
  end;
  stream3.Free;
end;

procedure TForm1.ServerSocket1ClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
  var
   RecvSize1,RecvSize2,DeSize:integer;
   commandI,MessageSizeongWord;
begin
  RecvSize1:=0;
  RecvSize2:=0;
  FillChar(cHead,SizeOf(cHead),0);

  RecvSize1:=socket.ReceiveBuf(cHead,SizeOf(cHead));
  commandI:=ntohl(cHead.CommandId);
  MessageSize:=ntohl(cHead.MessageLength);
  if commandI=SGIP_BIND then
  begin
   memo1.Lines.Add('*********************接收到Bind请求*********************');
   FillChar(cBind,SizeOf(cBind),0);
   FillChar(cBind_Resp,SizeOf(cBind_Resp),0);
   RecvSize2:=Socket.ReceiveBuf(cBind,MessageSize-RecvSize1);
   if (RecvSize2+RecvSize1)<>MessageSize then
   begin
    memo1.Lines.Add(&#39;**********************bind数据接收错误*******************&#39;);
    exit;
   end;
   RecvSize2:=0;RecvSize1:=0;
   cHead.CommandId:=htonl(SGIP_BIND_RESP);
   cHead.MessageLength:=htonl(sizeof(cHead)+sizeof(cBind_Resp));
   cBind_Resp.Result:=0;
   RecvSize1:=Socket.SendBuf(cHead,SizeOf(cHead));
   RecvSize2:=Socket.SendBuf(cBind_Resp,SizeOf(cBind_Resp));
   if (RecvSize1+RecvSize2)<>ntohl(cHead.MessageLength) then
   begin
    memo1.Lines.Add(&#39;**********************响应bind请求错误***********************&#39;);
    exit;
   end;
  end
  else
  if commandI=SGIP_DELIVER then
  begin
   memo1.Lines.Add(&#39;********************接收到SGIP_DELIVER请求********************&#39;);
   DeSize:=SizeOf(cDeliver);
   FillChar(cDeliver,SizeOf(cDeliver),0);
   FillChar(cDeliver_Resp,SizeOf(cDeliver_Resp),0);
   RecvSize2:=Socket.ReceiveBuf(cDeliver,MessageSize-RecvSize1);
   if (RecvSize2+RecvSize1)<>MessageSize then
   begin
    memo1.Lines.Add(&#39;**********************SGIP_DELIVER数据接收错误*******************&#39;);
    exit;
   end;
   RecvSize2:=0;RecvSize1:=0;
   cHead.CommandId:=htonl(SGIP_DELIVER_RESP);
   cHead.MessageLength:=htonl(sizeof(cHead)+sizeof(cDeliver_Resp));
   cDeliver_Resp.Result:=0;
   RecvSize1:=Socket.SendBuf(cHead,SizeOf(cHead));
   RecvSize2:=Socket.SendBuf(cDeliver_Resp,SizeOf(cDeliver_Resp));
   if (RecvSize1+RecvSize2)<>ntohl(cHead.MessageLength) then
   begin
    memo1.Lines.Add(&#39;**********************响应SGIP_DELIVER请求错误***********************&#39;);
    exit;
   end;
  end
  else
  if commandI=SGIP_UNBIND then
  begin
   cHead.CommandId:=htonl(SGIP_UNBIND_RESP);
   cHead.MessageLength:=htonl(sizeof(cHead));
   memo1.Lines.Add(&#39;响应SGIP_UNBIND***************************&#39;);
   RecvSize2:=Socket.SendBuf(cHead,sizeOf(cHead));
   if RecvSize2<>ntohl(cHead.MessageLength) then
   begin
    memo1.Lines.Add(&#39;**********************SGIP_UNBIND发送错误*****************&#39;);
    exit;
   end;
  end
  else
  begin
  end;
end;
end.





//..............................................................
file://协议
unit xy;

interface
uses
  SysUtils;
const                          
  SGIP_BIND         =$1;        file://对客户端验证
  SGIP_BIND_RESP =$80000001;    file://服务端返回验证请求
  SGIP_UNBIND      =$2;        file://断开连接
  SGIP_UNBIND_RESP    =$80000002;    file://返回断开连接状态
  SGIP_SUBMIT      =$3;        file://向SMG提交MT短消息
  SGIP_SUBMIT_RESP    =$80000003;    file://返回SP提交MT短消息状态
  SGIP_DELIVER      =$4;        file://SMG向SP发送一条MO短消息
  SGIP_DELIVER_RESP    =$80000004;    file://返回SMG状态
  SGIP_REPORT      =$5;        file://向SP发送一条先前的submit命令的当前状态
  SGIP_REPORT_RESP =$80000005;    file://响应SMG状态
  file://以下协议对SP无用
  SGIP_ADDSP      =$6;        //
  SGIP_ADDSP_RESP =$80000006;    //
  SGIP_MODIFYSP      =$7;        //
  SGIP_MODIFYSP_RESP =$80000007;    //
  SGIP_DELETESP      =$8;        //
  SGIP_DELETESP_RESP =$80000008;    //
  SGIP_QUERYROUTE =$9;        //
  SGIP_QUERYROUTE_RESP =$80000009;    //
  SGIP_ADDTELESEG =$a;        //
  SGIP_ADDTELESEG_RESP =$8000000a;    //
  SGIP_MODIFYTELESEG =$b;        //
  SGIP_MODIFYTELESEG_RESP =$8000000b;    //
  SGIP_DELETETELESEG =$c;              //
  SGIP_DELETETELESEG_RESP =$8000000c;    //
  SGIP_ADDSMG      =$d;        //
  SGIP_ADDSMG_RESP =$8000000d;    //
  SGIP_MODIFYSMG =$e;        //
  SGIP_MODIFYSMG_RESP =$0000000e;    //
  SGIP_DELETESMG =$f;        //
  SGIP_DELETESMG_RESP =$8000000f;    //
  SGIP_CHECKUSER =$10;        //
  SGIP_CHECKUSER_RESP =$80000010;    //
  SGIP_USERRPT      =$11;        //
  SGIP_USERRPT_RESP =$80000011;    //
  SGIP_TRACE      =$1000;      //
  SGIP_TRACE_RESP =$80001000;    //
type
  TEMPTY=Record file://空纪录
  end;
  file://消息头
  SGIPHead=Record
   MessageLength     :longword;          file://消息的总长度(字节)
   CommandId        :longword;          file://命令ID
   SNumber1,SNumber2,SNumber3:longword;      file://序列号
  end;
  file://消息体
  XBind=Record                   //
   LonginType       :byte;
   LonginPass       :array[0..15] of char;
   LonginName       :array[0..15] of char;
   Reserve         :array[0..7] of char;
  end;
  Bind_Resp=Record
   Result          :byte;
   Reserve         :array[0..7] of char;
  end;
  //
  Unbind=TEMPTY;
  Unbind_Resp=TEMPTY;
  //
  TelCount=record              file://手机号码
   TelN  :array[0..20] of char;
  end;
  XSubmit=Record
   SPNumber        :array[0..20] of char;
   ChargeNumber      :array[0..20] of char;
   UserCount        :byte;          file://1-100
   UserNumber       :array[0..20] of char;//TelCount;  file://长度为UserCount
   CorpID          :array[0..4] of char;
   ServiceType      :array[0..9] of char;
   FeeType         :byte;
   FeeValue        :array[0..5] of char;
   GivenValue       :array[0..5] of char;
   AgentFlag        :byte;
   MOrelatetoMTFlag   :byte;
   Priority        :byte;
   ExpireTime       :array[0..15] of char;
   ScheduleTime      :array[0..15] of char;
   ReportFlag       :byte;
   TP_pid          :byte;
   TP_udhi         :byte;
   MessageCoding     :byte;
   MessageType      :byte;
   MessageLength     :longword;
   MessageContent    :array[0..160] of char;  file://长度为  MessageLength;
   Reserve         :array[0..7] of char;
  end;
  Submit_Resp=Record
   Result          :byte;
   Reserve         :array[0..7] of char;
  end;
  //
  XDeliver=Record
   UserNumber       :array[0..20] of char;
   SPNumber        :array[0..27] of char;
   {TP_pid          :byte;
   TP_udhi         :byte;
   MessageCoding     :byte;
   MessageLength     :longword;}
   MessageContent    :array[0..254] of char;  file://长度为  MessageLength;
   Reserver        :array[0..7] of char;
  end;
  Deliver_Resp=Record
   Result          :byte;
   Reserve         :array[0..7] of char;
  end;

  //
  XReport=Record
   SubSequNumber1,SubSequNumber2,SubSequNumber3      :longword;
   ReportType       :byte;
   UserNumber       :array[0..20] of char;
   State          :byte;
   ErrorCode        :byte;
   Reserve         :array[0..7] of char;
  end;
  Report_Resp=Record
   Result          :byte;
   Reserve         :array[0..7] of char;
  end;

implementation
end.


file://、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、//
服务端
unit main;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, xy, ScktComp, StdCtrls,winsock;

type
  
  TForm1 = class(TForm)
   Memo1: TMemo;
   ServerSocket1: TServerSocket;
   procedure ServerSocket1ClientRead(Sender: TObject;
    Socket: TCustomWinSocket);
   procedure ServerSocket1ClientError(Sender: TObject;
    Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
    var ErrorCode: Integer);
  private
   { Private declarations }
  public
   { Public declarations }
  end;
var
  Form1: TForm1;

implementation

{$R *.dfm}

procedure TForm1.ServerSocket1ClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
  type
   SendPack = packed record
    head:  SGIPHead;
    resp:  Bind_Resp;
   end;
  var
   ReHead:SGIPHead;
   sresp:Bind_Resp;
   ReBind:xBind;
   ReDeliver:XDeliver;
   ReReport:XReport;
   i1,i2:integer;
   str:string;
   S_Number1,S_Number2,S_Number3,longI1:longword;
   s_Pack:SendPack;
begin
  fillchar(sresp,sizeof(sresp),0);
  fillchar(ReHead,sizeof(ReHead),0);
  i1:=Socket.ReceiveBuf(ReHead,sizeof(ReHead));
  if i1<>sizeof(ReHead) then
  begin
   memo1.Lines.Add(&#39;Recv message Error exit&#39;);
   exit;
  end;
  S_Number1:=ReHead.SNumber1;
  S_Number2:=ReHead.SNumber2;
  S_Number3:=ReHead.SNumber3;
  ReHead.MessageLength:=ntohl(ReHead.MessageLength);
  ReHead.CommandId:=ntohl(ReHead.CommandId);
  ReHead.SNumber1:=ntohl(ReHead.SNumber1);
  ReHead.SNumber2:=ntohl(ReHead.SNumber2);
  ReHead.SNumber3:=ntohl(ReHead.SNumber3);
  memo1.Lines.Add(&#39;read SMG message&#39;);
  memo1.Lines.Add(inttostr(ReHead.MessageLength));
  memo1.Lines.Add(inttostr(ReHead.CommandId));
  memo1.Lines.Add(inttostr(ReHead.SNumber1));
  memo1.Lines.Add(inttostr(ReHead.SNumber2));
  memo1.Lines.Add(inttostr(ReHead.SNumber3));
  if ReHead.CommandId=SGIP_UNBIND then
  begin        file://断开连接
   FillChar(ReHead,SizeOf(ReHead),0);
   ReHead.MessageLength:=htonl(SizeOf(ReHead));
   ReHead.CommandId:=htonl(SGIP_UNBIND_RESP);
   ReHead.SNumber1:=S_Number1;
   ReHead.SNumber2:=S_Number2;
   ReHead.SNumber3:=S_Number3;
   i1:=socket.SendBuf(ReHead,sizeof(ReHead));
   if i1<>sizeof(ReHead) then
    memo1.Lines.Add(&#39;Send SGIP_UNBIND_Resp Error&#39;)
   else
    memo1.Lines.Add(&#39;Send SGIP_UNBIND_Resp OK&#39;);
  end
  else if ReHead.CommandId=SGIP_BIND then
  begin        file://SMG向SP发送一条MO短消息
   FillChar(s_Pack,SizeOf(s_Pack),0);
   FillChar(ReBind,SizeOf(ReBind),0);
   socket.ReceiveBuf(ReBind,SizeOf(ReBind));
   s_Pack.head.MessageLength:=htonl(SizeOf(s_Pack));
   s_Pack.head.CommandId:=htonl(SGIP_BIND_RESP);
   s_Pack.head.SNumber1:=S_Number1;
   s_Pack.head.SNumber2:=S_Number2;
   s_Pack.head.SNumber3:=S_Number3;
   s_Pack.resp.Result:=0;
   i1:=socket.SendBuf(s_Pack,SizeOf(s_Pack));
   if i1<>SizeOf(s_Pack) then
    memo1.Lines.Add(&#39;send SGIP_Bind_Resp Error&#39;)
   else
    memo1.Lines.Add(&#39;Send SGIP_bind_Resp&#39;);
  end
  else if ReHead.CommandId=SGIP_DELIVER then
  begin
   FillChar(s_Pack,SizeOf(s_Pack),0);
   FillChar(ReDeliver,SizeOf(ReDeliver),0);
   Socket.ReceiveBuf(ReDeliver,SizeOf(ReDeliver));
   s_Pack.head.MessageLength:=htonl(SizeOf(s_Pack));
   s_Pack.head.CommandId:=htonl(SGIP_DELIVER_RESP);
   s_Pack.head.SNumber1:=S_Number1;
   s_Pack.head.SNumber2:=S_Number2;
   s_Pack.head.SNumber3:=S_Number3;
   s_Pack.resp.Result:=0;
   if socket.SendBuf(s_Pack,SizeOf(s_Pack)) <>SizeOf(s_Pack) then
    memo1.Lines.Add(&#39;send SGIP_DELIVER_RESP Error&#39;)
   else
    memo1.Lines.Add(&#39;Send SGIP_DELIVER_RESP OK&#39;);
   memo1.Lines.Add(ReDeliver.UserNumber);
   memo1.Lines.Add(ReDeliver.SPNumber);
   file://longI1:=ntohl(ReDeliver.MessageLength);
   file://memo1.Lines.Add(inttostr(longI1)+&#39;  &#39;+inttostr(ReDeliver.MessageLength));
   memo1.Lines.Add(ReDeliver.MessageContent);
  end
  else  if ReHead.CommandId=SGIP_REPORT then
  begin
   FillChar(s_Pack,SizeOf(s_Pack),0);
   FillChar(ReReport,SizeOf(ReReport),0);
   Socket.ReceiveBuf(ReReport,SizeOf(ReReport));
   s_Pack.head.MessageLength:=htonl(SizeOf(s_Pack));
   s_Pack.head.CommandId:=htonl(SGIP_REPORT_RESP);
   s_Pack.head.SNumber1:=S_Number1;
   s_Pack.head.SNumber2:=S_Number2;
   s_Pack.head.SNumber3:=S_Number3;
   s_Pack.resp.Result:=0;
   if socket.SendBuf(s_Pack,SizeOf(s_Pack)) <>SizeOf(s_Pack) then
    memo1.Lines.Add(&#39;send SGIP_Bind_Resp Error&#39;)
   else
    memo1.Lines.Add(&#39;Send SGIP_bind_Resp&#39;);
   memo1.Lines.Add(ReReport.UserNumber);
   memo1.Lines.Add(inttostr(ReReport.State));
  end;
end;


procedure TForm1.ServerSocket1ClientError(Sender: TObject;
  Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
  var ErrorCode: Integer);
var
  errorMsg:string;
begin
  case ErrorEvent of
   eeGeneral:   errorMsg:=&#39;eeGeneral&#39;;
   eeSend:  errorMsg:=&#39;eeSend&#39;;
   eeReceive:   errorMsg:=&#39;eeReceive&#39;;
   eeConnect:   errorMsg:=&#39;eeConnect&#39;;
   eeDisconnect: errorMsg:=&#39;eeDisconnect&#39;;
   eeAccept:    errorMsg:=&#39;eeAccept&#39;;
  end;
  ErrorCode:=0;
  Memo1.Lines.Add(&#39;Socket Error:&#39;+errorMsg);
end;

end.
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

Archiver|手机版|小黑屋|网上读书园地

GMT+8, 2024-10-13 16:20 , Processed in 0.238723 second(s), 6 queries , Redis On.

Powered by Discuz! X3.5

© 2001-2024 Discuz! Team.

快速回复 返回顶部 返回列表