P2P实例（delphi源码）

【实例截图】

【核心代码】

var
  addrRemote: TSockAddrIn;//接收到的主机信息
  addrPeer: TSockAddrIn;//通知打洞方的主机地址信息
  I,addrRemoteLen: Integer;
  buffer: array [0..1500] of byte;
  PacketHead:TPacketHead;//数据包头，有命令代码
  LoginPacket:TLoginPacket;
  PeerInfo:PPeerInfo;
  LogoutPacket:TLogoutPacket;
  PeerUserInfo:TPeerUserInfo;
  PeerUserInfoResp:TPeerUserInfoResp;
  RequstHole:TRequstHole;
  ActiveQueryPacket:TActiveQueryPacket;
begin
  case WSAGetSelectEvent(msg.LParam) of
    FD_READ:
    begin
      addrRemoteLen:=SizeOf(addrRemote);
      recvfrom(FSocket,buffer,1500,0,addrRemote,addrRemoteLen);
      Move(buffer,PacketHead,SizeOf(PacketHead));//从buffer中分离出包头
      case PacketHead.CMD of
        USERLOGIN://用户登录
        begin
          Move(buffer,LoginPacket,SizeOf(LoginPacket));
          GetMem(PeerInfo,SizeOf(TPeerInfo));
          StrCopy(PeerInfo^.UserName,LoginPacket.LoginName);
          PeerInfo^.addr.ip:=addrRemote.sin_addr.S_addr;
          PeerInfo^.addr.port:=addrRemote.sin_port;
          PeerInfo^.lastActiveTime:=GetTickCount;
          PeerList.Add(PeerInfo);
          RefreshOnlines;
          LoginPacket.Head.CMD:=USERLOGACK;
          LoginPacket.Ack:=True;
          sendto(FSocket,LoginPacket,SizeOf(TLoginPacket),0,addrRemote,SizeOf(addrRemote));
        end;
        USERLOGOUT:
        begin
          Move(buffer,LogoutPacket,SizeOf(LogoutPacket));
          for i:=PeerList.Count-1 downto 0 do
          begin
            if StrComp(PPeerInfo(PeerList.Items[i]).UserName,LogoutPacket.LogoutName)=0 then
            begin
              FreeMem(PPeerInfo(PeerList.Items[i]));
              PeerList.Delete(i);
            end
          end;
          RefreshOnlines;
          BroadcastOnlines;
        end;
        GETUSERLIST:
        begin
          BroadcastOnlines;
        end;
        P2PCONNECT:
        begin
          Move(buffer,PeerUserInfo,SizeOf(PeerUserInfo));
          for i:=PeerList.Count-1 downto 0 do
          begin
            if StrComp(PPeerInfo(PeerList.Items[i]).UserName,PeerUserInfo.nameB)=0 then
            begin
              PeerUserInfoResp.Head.CMD:=P2PCONNECTACK;
              StrPCopy(PeerUserInfoResp.name,PPeerInfo(PeerList.Items[i]).UserName);
              PeerUserInfoResp.PeerAddr.ip:=PPeerInfo(PeerList.Items[i]).addr.ip;
              PeerUserInfoResp.PeerAddr.port:=PPeerInfo(PeerList.Items[i]).addr.port;
              sendto(FSocket,PeerUserInfoResp,sizeof(PeerUserInfoResp),0,addrRemote,SizeOf(addrRemote));

              {向另一端B发送向clientA的打洞命令}
              addrPeer.sin_family:=AF_INET;
              addrPeer.sin_addr.S_addr:=PPeerInfo(PeerList.Items[i]).addr.ip;
              addrPeer.sin_port:=PPeerInfo(PeerList.Items[i]).addr.port;

              RequstHole.Head.CMD:=P2PCONNECT;
              StrPCopy(RequstHole.nameA,PeerUserInfo.nameA);
              RequstHole.PeerA.ip:=addrRemote.sin_addr.S_addr;
              RequstHole.PeerA.port:=addrRemote.sin_port;
              sendto(FSocket,RequstHole,sizeof(RequstHole),0,addrPeer,SizeOf(addrPeer));
              break;
            end
          end;
        end;
        USERACTIVEQUERYACK:
        begin
          Move(buffer,ActiveQueryPacket,SizeOf(ActiveQueryPacket));
          for i:=PeerList.Count-1 downto 0 do
          begin
            if StrComp(PPeerInfo(PeerList.Items[i]).UserName,ActiveQueryPacket.name)=0 then
            begin
              PPeerInfo(PeerList.Items[i]).lastActiveTime:=GetTickCount;
              Break;
            end
          end;
        end;
      end;
    end;
  end;
end;

【源码目录】

P2P实例
├── Client
│   ├── Client.dpr
│   ├── Client.dproj
│   ├── Client.dproj.local
│   ├── Client.identcache
│   ├── Client.res
│   ├── Debug
│   │   └── Win32
│   │       ├── uClientMain.dcu
│   │       └── uProtocol.dcu
│   ├── ProjectGroup1.groupproj
│   ├── ProjectGroup1.groupproj.local
│   ├── __history
│   │   ├── Client.dpr.~1~
│   │   ├── Client.dpr.~2~
│   │   ├── uClientMain.dfm.~13~
│   │   ├── uClientMain.dfm.~14~
│   │   ├── uClientMain.dfm.~15~
│   │   ├── uClientMain.dfm.~16~
│   │   ├── uClientMain.dfm.~17~
│   │   ├── uClientMain.dfm.~18~
│   │   ├── uClientMain.dfm.~19~
│   │   ├── uClientMain.dfm.~20~
│   │   ├── uClientMain.dfm.~21~
│   │   ├── uClientMain.dfm.~22~
│   │   ├── uClientMain.pas.~38~
│   │   ├── uClientMain.pas.~39~
│   │   ├── uClientMain.pas.~40~
│   │   ├── uClientMain.pas.~41~
│   │   ├── uClientMain.pas.~42~
│   │   ├── uClientMain.pas.~43~
│   │   ├── uClientMain.pas.~44~
│   │   ├── uClientMain.pas.~45~
│   │   ├── uClientMain.pas.~46~
│   │   └── uClientMain.pas.~47~
│   ├── uClientMain.dfm
│   └── uClientMain.pas
├── Server
│   ├── Debug
│   │   └── Win32
│   │       ├── uFrmMain.dcu
│   │       └── uProtocol.dcu
│   ├── P2PServer.dpr
│   ├── P2PServer.dproj
│   ├── P2PServer.dproj.local
│   ├── P2PServer.identcache
│   ├── P2PServer.res
│   ├── __history
│   │   ├── P2PServer.dpr.~1~
│   │   ├── P2PServer.dpr.~2~
│   │   ├── uFrmMain.dfm.~1~
│   │   ├── uFrmMain.dfm.~2~
│   │   ├── uFrmMain.dfm.~3~
│   │   ├── uFrmMain.dfm.~4~
│   │   ├── uFrmMain.dfm.~5~
│   │   ├── uFrmMain.pas.~66~
│   │   ├── uFrmMain.pas.~67~
│   │   ├── uFrmMain.pas.~68~
│   │   ├── uFrmMain.pas.~69~
│   │   ├── uFrmMain.pas.~70~
│   │   ├── uFrmMain.pas.~71~
│   │   ├── uFrmMain.pas.~72~
│   │   ├── uFrmMain.pas.~73~
│   │   ├── uFrmMain.pas.~74~
│   │   └── uFrmMain.pas.~75~
│   ├── uFrmMain.dfm
│   └── uFrmMain.pas
├── __history
│   ├── uProtocol.pas.~14~
│   ├── uProtocol.pas.~15~
│   ├── uProtocol.pas.~16~
│   ├── uProtocol.pas.~17~
│   ├── uProtocol.pas.~18~
│   ├── uProtocol.pas.~19~
│   ├── uProtocol.pas.~20~
│   ├── uProtocol.pas.~21~
│   ├── uProtocol.pas.~22~
│   └── uProtocol.pas.~23~
└── uProtocol.pas
9 directories, 70 files