怎样用api来实现udp数据包的接收和发送??如果有这方面的资料请告诉小弟,万分感谢!
解决方案 »
- delphi 利用Data Module 连接数据库相对路径问题?
- 如何短时间对大量的原始采集数据处理并存库?敬听各位指教!
- (█公布 在两个不同SOCKS代理服务器后面的局域网机器之间传递文件 原理█完整成熟的p2p软件源码(源代码完全是DELPHI的),谁要?█
- 散分
- DBGrid中字段值更新出错:'DataSet not in Edit or Insert mode' Waiting......
- 能不能在 win2000下调用RASAPI32.DLL进行拨号???
- 那位使用过厨房打印机,在线等候!
- 在过程或函数内部创建的对像,的生存期?
- 当点击CheckListBox的Checked的时候,如何判断当前是打勾还是取掉?
- 有个简单的问题,送送分也好
- 如何使用WM_RASDIALEVENT事件?
- 大家觉得做程序员到多大年龄就该转行了?
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.
这个源代码是什么意思,我看不懂,请帮我解释一下可以吗?
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;//释放