RSS
热门关键字： 　数据挖掘 　数据仓库 　人工智能 　搜索引擎 　数据挖掘导论
当前位置 :| 首页>编程技术>delphi编程技术>

SGIP的delphi原码

来源： 作者：unkonwn 时间：2005-09-03 点击：

在网上找了好长时间，也没有发现有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,PackSize:Longword;
  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,MessageSize:LongWord;
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("**********************bind数据接收错误*******************");
      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("**********************响应bind请求错误***********************");
      exit;
    end;
  end
  else
  if commandI=SGIP_DELIVER then
  begin
    memo1.Lines.Add("********************接收到SGIP_DELIVER请求********************");
    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("**********************SGIP_DELIVER数据接收错误*******************"); 数据挖掘研究院
      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("**********************响应SGIP_DELIVER请求错误***********************");
      exit;
    end;
  end
  else
  if commandI=SGIP_UNBIND then
  begin
    cHead.CommandId:=htonl(SGIP_UNBIND_RESP);
    cHead.MessageLength:=htonl(sizeof(cHead));
    memo1.Lines.Add("响应SGIP_UNBIND***************************"); 数据挖掘研究院
    RecvSize2:=Socket.SendBuf(cHead,sizeOf(cHead));
    if RecvSize2<>ntohl(cHead.MessageLength) then
    begin
      memo1.Lines.Add("**********************SGIP_UNBIND发送错误*****************");
      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("Recv message Error exit");
    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("read SMG message");
  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("Send SGIP_UNBIND_Resp Error")
    else
      memo1.Lines.Add("Send SGIP_UNBIND_Resp OK");
  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("send SGIP_Bind_Resp Error")
    else
      memo1.Lines.Add("Send SGIP_bind_Resp");
  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("send SGIP_DELIVER_RESP Error")
    else
      memo1.Lines.Add("Send SGIP_DELIVER_RESP OK");
    memo1.Lines.Add(ReDeliver.UserNumber);
    memo1.Lines.Add(ReDeliver.SPNumber);
    file://longI1:=ntohl(ReDeliver.MessageLength);
    file://memo1.Lines.Add(inttostr(longI1)+"   "+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("send SGIP_Bind_Resp Error")
    else
      memo1.Lines.Add("Send SGIP_bind_Resp");
    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:="eeGeneral";
    eeSend:   errorMsg:="eeSend";
    eeReceive:    errorMsg:="eeReceive";
    eeConnect:    errorMsg:="eeConnect";
    eeDisconnect: errorMsg:="eeDisconnect";
    eeAccept:     errorMsg:="eeAccept";
  end;
  ErrorCode:=0;
  Memo1.Lines.Add("Socket Error:"+errorMsg);
end; 数据挖掘研究院

end.

数据挖掘研究院

 

数据挖掘研究院

[数据挖掘工作交流] [数据挖掘研究院] [数据挖掘论坛] [数据挖掘实验室]
上一篇：IndyClient/Server程序示例
下一篇：SGIP的delphi原码
最新评论共有 0 位网友发表了评论
查看所有评论
发表评论
评论内容：不能超过250字，需审核，请自觉遵守互联网相关政策法规。
匿名?
热点关注
相关文章
关于我们 - 联系方式 - 版权申明 - 友情链接 - 交流空间 - 同徽科技
增值电信业务经营许可证编号：皖B2-20040042 文网文编号：[2005]027号