怎样用api来实现udp数据包的接收和发送??如果有这方面的资料请告诉小弟,万分感谢!

解决方案 »

  1.   

    还是用控件好些Indy的UDP很好的,你自己找他的Source看看就知道怎样用api来实现udp数据包的接收和发送了,控件内部都使用Winsock API的
      

  2.   

    program Server;{$APPTYPE CONSOLE}uses
      SysUtils,
      Winsock,
      Windows;type
      TParam=record
        TrdId:integer;
        Sckt:TSocket;
      end;function ChildThrd(p:Pointer):LongInt;stdcall;
    var
      PkLen:integer;
      ThreadId:integer;
      ASocket:TSocket;
      buf:array[0..63] of char;  
    begin
      Result:=0;
      ThreadId:=TParam(p^).TrdId;
      ASocket:=TParam(p^).Sckt;
      Writeln('Thread '+IntToStr(ThreadId)+' Create');  
      PkLen:=1;
      while PkLen>0 do
      begin
        PkLen:=Recv(ASocket,buf,SizeOf(buf),0);
        Write(buf[0]);
        if PkLen>0 then
        begin
          Send(ASocket,buf,PkLen,0);
        end;
      end;
      CloseSocket(ASocket);
      Dispose(p);
      Writeln('Socket'+IntToStr(ASocket)+' DisConnect');
    end;var
      MyWSA: WSAData;
      Svr,Clt: TSockAddr;
      NameLen:Integer;
      hSocket,s: TSocket;
      TimeOut:integer;
      ThreadCount:integer;
      hThread:Thandle;
      ThreadID:DWord;
      Param:^TParam;   
    begin
      If WSAStartup(MAKEWORD(2,2), MyWSA) <> 0 Then
      Begin
        WSACleanup;
        Writeln('WSAStartup() Fail');
        Exit;
      end;
      hSocket := Socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
      If hSocket = INVALID_SOCKET Then
      Begin
        WSACleanup;
        Writeln('Socket() Fail');
        Exit;
      End;
      Svr.sin_family := AF_INET;
      Svr.sin_port := htons(176);
      Svr.sin_addr.S_addr := inet_addr(PChar('127.0.0.1'));
      If Bind(hSocket, Svr, SizeOf(Svr)) = SOCKET_ERROR Then
      Begin
        CloseSocket(hSocket);
        WSACleanup;
        Writeln('Bind() Fail');
        Exit;
      end;
      if Listen(hSocket,256) = SOCKET_ERROR Then
      begin
        CloseSocket(hSocket);
        WSACleanup;
        Writeln('Listen() Fail');
        Exit;
      end;
      TimeOut:=3000;
      ThreadCount:=0;
      while true do
      begin
        NameLen:=SizeOf(Clt);
        s:=Accept(hSocket,@Clt,@NameLen);
        if s = SOCKET_ERROR Then
        begin
          CloseSocket(hSocket);
          WSACleanup;
          Writeln('Accept() Fail');
          Exit;
        end
        else
        begin
    //      CreateThread();
          Writeln('Socket '+IntToStr(s)+' Connect');
          if SetSockOpt(s,SOL_SOCKET,SO_RCVTIMEO,PChar(@TimeOut),SizeOf(TimeOut))=SOCKET_ERROR then
          begin
            CloseSocket(s);
            CloseSocket(hSocket);
            WSACleanup;
            Writeln('SetSockOpt() Fail');
            Exit;
          end;
          if SetSockOpt(s,SOL_SOCKET,SO_SNDTIMEO,PChar(@TimeOut),SizeOf(TimeOut))=SOCKET_ERROR then
          begin
            CloseSocket(s);
            CloseSocket(hSocket);
            WSACleanup;
            Writeln('SetSockOpt() Fail');
            Exit;
          end;
          new(Param);
          Param^.TrdId:=ThreadCount;
          Param^.Sckt:=s;
          hThread:=CreateThread(nil,0,@ChildThrd,Param,0,ThreadID);
          if hThread=0 then
          begin
            Writeln('CreateThread() Fail');
          end
          else
          begin
            Inc(ThreadCount);
          end;
        end;
      end;
      CloseSocket(hSocket);
      WSACleanup;
    end.
    这个源代码是什么意思,我看不懂,请帮我解释一下可以吗?
      

  3.   

    我来解释一下
    WSAStartup(MAKEWORD(2,2), MyWSA)//初始化
    Socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);//创建socket
    Bind(hSocket, Svr, SizeOf(Svr)) //绑定socket到指定地址svr
    Listen(hSocket,256)//开始侦听
    Accept(hSocket,@Clt,@NameLen);//接受一个连接
    SetSockOpt(s,SOL_SOCKET,SO_RCVTIMEO,PChar(@TimeOut),SizeOf(TimeOut))//设置接收超时
    SetSockOpt(s,SOL_SOCKET,SO_SNDTIMEO,PChar(@TimeOut),SizeOf(TimeOut))//设置发送超时
    send()//发送
    recv()//接收
    CloseSocket(hSocket);//关闭socket
    WSACleanup;//释放