【例子介绍】含服务器端以及客户端
【相关图片】
【源码结构】
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
评论