还是关于完成端口！我的工作线程好象没工作！高手帮我看看！ ( 积分: 50 )

  • 主题发起人 主题发起人 fire.bruin
  • 开始时间 开始时间
F

fire.bruin

Unregistered / Unconfirmed
GUEST, unregistred user!
=============程序入口===========
unit ServerMain;
.....略...
interface
var
IOCP : Cardinal;

.....略...


procedure TForm_Server.FormCreate(Sender: TObject);
begin
ReadIpAndPort(DBServerIP,DBServerPort);
server_ip.IPString:=DBServerIP;
server_port.Text:=inttostr(DBServerPort);
end;

procedure TForm_Server.okClick(Sender: TObject);
var
InternetAddr: TSockAddrIn;
ListenSocket: TSOCKET;
sc: pinteger;
ThreadHandle: THandle;
SystemInfo: SYSTEM_INFO;
i: integer;
Ret, ThreadID: DWORD;
wsaData: TWSADATA;
begin
WriteIpAndPort(server_ip.IPString,strtoint(server_port.Text));
WSAStartup(MakeWord(2,2), wsaData);
IOCP := CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0);
GetSystemInfo(SystemInfo);
for i:=0 to SystemInfo.dwNumberOfProcessors * 2 - 1 do
begin
ThreadHandle := CreateThread(Nil, 0, @WorkThread, @IOCP, 0, ThreadID);
CloseHandle(ThreadHandle);
end;
ListenSocket := WSASocket(AF_INET, SOCK_STREAM, 0, nil, 0, WSA_FLAG_OVERLAPPED);
InternetAddr.sin_family := AF_INET;
InternetAddr.sin_addr.s_addr := htonl(INADDR_ANY);
InternetAddr.sin_port := htons(strtoint(server_port.Text));
bind(ListenSocket, @InternetAddr, sizeof(InternetAddr))
Listen(ListenSocket, 5)
new(sc);
sc^ := ListenSocket;
ThreadHandle := CreateThread(nil, 0, @AcceptThread, sc, 0, ThreadID);
end;

end.

=========线程处理========================

unit ServerThread;

interface

uses
Classes,Windows,SyncObjs,Dialogs,winsock2,StdCtrls,SysUtils,Controls,ServerPublic;

const
BUFFER_SIZE =4096;
PORT_ADD = 51937;

Type
TSocketStatus = (ssAccept, ssSend, ssRecv, ssClose, ssStop);
PPerHandleData = ^TPerHandleData;
TPerHandleData = record
Overlapped: OVERLAPPED;
wsaBuffer: TWSABUF;
Statu: TSocketStatus;
Socket: TSocket;
Buffer: array[0..BUFFER_SIZE - 1] of char;
end;

var
IOCP : cardinal;
Clients : Integer;

procedure WorkThread(CompletionPortID: pointer); stdcall;
procedure AcceptThread(p: pointer); stdcall; //接受连接

implementation

procedure WorkThread(CompletionPortID: pointer); stdcall;
var
CompletionPort : cardinal;
TransBytes : DWORD;
PerData : PPerHandleData;
begin
CompletionPort := cardinal(CompletionPortID^);
while true do
begin
if GetQueuedCompletionStatus(CompletionPort,TransBytes,DWORD(PerData),POverlapped(PerData),INFINITE) = false then
begin
Clients:=Clients-1;
exit;
end;
if TransBytes = 0 then //如果接收的字节是0，说明接收失败
begin
CloseSocket(PerData^.Socket);
Clients:=Clients-1;
end;
case perdata.Statu of
ssAccept:
begin
Clients-1;
end;
ssRecv:
begin
Clients-1;
// showmessage(PerData.Buffer);
end;
ssSend:
begin
end;
ssClose:
begin
Clients:=Clients-1;
end;
ssStop:
begin
Clients:=Clients-1;
end;
end;


end;

end;

procedure AcceptThread(p: pointer); stdcall; //接受连接
var
AcceptSocket, Listen : TSocket;
sc : pinteger;
Flags, SendvBytes : DWord;
PerHandleData : PPerHandleData;
begin
Clients:=0;
sc:=p;
Listen:=sc^;
while true do
begin
AcceptSocket := WSAAccept(Listen, nil, nil, nil, 0);
CreateIoCompletionPort(
AcceptSocket, //与完成端口关联的套接字句柄
IOCP, //已建立的完成端口对象的句柄
AcceptSocket, //发生收发操作的套接字(也可以传递一个记录指针),
0);
new(PerHandleData);
FillChar(PerHandleData.Overlapped, sizeof(Overlapped), 0);
FillChar(PerHandleData.Buffer, BUFFER_SIZE, 0);
PerHandleData.Socket := AcceptSocket;
PerHandleData.wsaBuffer.len :=BUFFER_SIZE;
PerHandleData.wsaBuffer.buf:=@PerHandleData.BUFFER;
PerHandleData^.Statu := ssRecv;
flags := 0;
WSARecv(AcceptSocket, @PerHandleData^.wsaBuffer, 1, @SendvBytes, @flags, @PerHandleData^.Overlapped, nil);
Clients:=Clients+1;
end;

end;

end.
 
=============程序入口===========
unit ServerMain;
.....略...
interface
var
IOCP : Cardinal;

.....略...


procedure TForm_Server.FormCreate(Sender: TObject);
begin
ReadIpAndPort(DBServerIP,DBServerPort);
server_ip.IPString:=DBServerIP;
server_port.Text:=inttostr(DBServerPort);
end;

procedure TForm_Server.okClick(Sender: TObject);
var
InternetAddr: TSockAddrIn;
ListenSocket: TSOCKET;
sc: pinteger;
ThreadHandle: THandle;
SystemInfo: SYSTEM_INFO;
i: integer;
Ret, ThreadID: DWORD;
wsaData: TWSADATA;
begin
WriteIpAndPort(server_ip.IPString,strtoint(server_port.Text));
WSAStartup(MakeWord(2,2), wsaData);
IOCP := CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0);
GetSystemInfo(SystemInfo);
for i:=0 to SystemInfo.dwNumberOfProcessors * 2 - 1 do
begin
ThreadHandle := CreateThread(Nil, 0, @WorkThread, @IOCP, 0, ThreadID);
CloseHandle(ThreadHandle);
end;
ListenSocket := WSASocket(AF_INET, SOCK_STREAM, 0, nil, 0, WSA_FLAG_OVERLAPPED);
InternetAddr.sin_family := AF_INET;
InternetAddr.sin_addr.s_addr := htonl(INADDR_ANY);
InternetAddr.sin_port := htons(strtoint(server_port.Text));
bind(ListenSocket, @InternetAddr, sizeof(InternetAddr))
Listen(ListenSocket, 5)
new(sc);
sc^ := ListenSocket;
ThreadHandle := CreateThread(nil, 0, @AcceptThread, sc, 0, ThreadID);
end;

end.

=========线程处理========================

unit ServerThread;

interface

uses
Classes,Windows,SyncObjs,Dialogs,winsock2,StdCtrls,SysUtils,Controls,ServerPublic;

const
BUFFER_SIZE =4096;
PORT_ADD = 51937;

Type
TSocketStatus = (ssAccept, ssSend, ssRecv, ssClose, ssStop);
PPerHandleData = ^TPerHandleData;
TPerHandleData = record
Overlapped: OVERLAPPED;
wsaBuffer: TWSABUF;
Statu: TSocketStatus;
Socket: TSocket;
Buffer: array[0..BUFFER_SIZE - 1] of char;
end;

var
IOCP : cardinal;
Clients : Integer;

procedure WorkThread(CompletionPortID: pointer); stdcall;
procedure AcceptThread(p: pointer); stdcall; //接受连接

implementation

procedure WorkThread(CompletionPortID: pointer); stdcall;
var
CompletionPort : cardinal;
TransBytes : DWORD;
PerData : PPerHandleData;
begin
CompletionPort := cardinal(CompletionPortID^);
while true do
begin
if GetQueuedCompletionStatus(CompletionPort,TransBytes,DWORD(PerData),POverlapped(PerData),INFINITE) = false then
begin
Clients:=Clients-1;
exit;
end;
if TransBytes = 0 then //如果接收的字节是0，说明接收失败
begin
CloseSocket(PerData^.Socket);
Clients:=Clients-1;
end;
case perdata.Statu of
ssAccept:
begin
Clients-1;
end;
ssRecv:
begin
Clients-1;
// showmessage(PerData.Buffer);
end;
ssSend:
begin
end;
ssClose:
begin
Clients:=Clients-1;
end;
ssStop:
begin
Clients:=Clients-1;
end;
end;


end;

end;

procedure AcceptThread(p: pointer); stdcall; //接受连接
var
AcceptSocket, Listen : TSocket;
sc : pinteger;
Flags, SendvBytes : DWord;
PerHandleData : PPerHandleData;
begin
Clients:=0;
sc:=p;
Listen:=sc^;
while true do
begin
AcceptSocket := WSAAccept(Listen, nil, nil, nil, 0);
CreateIoCompletionPort(
AcceptSocket, //与完成端口关联的套接字句柄
IOCP, //已建立的完成端口对象的句柄
AcceptSocket, //发生收发操作的套接字(也可以传递一个记录指针),
0);
new(PerHandleData);
FillChar(PerHandleData.Overlapped, sizeof(Overlapped), 0);
FillChar(PerHandleData.Buffer, BUFFER_SIZE, 0);
PerHandleData.Socket := AcceptSocket;
PerHandleData.wsaBuffer.len :=BUFFER_SIZE;
PerHandleData.wsaBuffer.buf:=@PerHandleData.BUFFER;
PerHandleData^.Statu := ssRecv;
flags := 0;
WSARecv(AcceptSocket, @PerHandleData^.wsaBuffer, 1, @SendvBytes, @flags, @PerHandleData^.Overlapped, nil);
Clients:=Clients+1;
end;

end;

end.
 
完成断口 我也关注这样的问题 到现在还是不明白
 
我写关于短信发送的c++代码，我现在做了个用c++写了个dll库想让delphi调用，如果不加线程的话，调用没问题，但是一加线程，我的调用的程序就也只能在后台执行了（界面出不来，在任务管理器中可以看见运行的线程），我想问的是为什么我的程序也在后台执行呢？？
盼回复！谢谢！！
 
我的qq是342693810，欢迎加我！
 
我写关于短信发送的c++代码，我现在做了个用c++写了个dll库想让delphi调用，如果不加线程的话，调用没问题，但是一加线程，我的调用的程序就也只能在后台执行了（界面出不来，在任务管理器中可以看见运行的线程），我想问的是为什么我的程序也在后台执行呢？？
盼回复！谢谢！！
我的qq是342693810，欢迎加我！
 
UPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUPUP
 
楼主参考一下，顺便给偶提点意见，谢谢
http://www.delphibbs.com/delphibbs/dispq.asp?lid=2863644
 
没有结果,真遗憾!
 
您必须登录或注册才可回复。

Similar threads

L
谁有用delphi实现的用完成端口方式读取串口的源程序，我这调试一天不行(100)
回复
8
查看
757
lishubing_2000
L
L
关于一个多线程分割下载文件的问题,请帮我看看,谢谢! 200分(100)
回复
4
查看
842
lzp_xiaoxian
L
K
完成端口的发送问题 求救 ( 积分: 100 )
回复
3
查看
467
king1994gw
K
X
关于完成端口的内存管理，非常奇怪的现象！(100分)
回复
3
查看
556
xiaohongna
X
K
关于网上的完成端口客户端再次登陆不能发送问题 ( 积分: 100 )
回复
2
查看
516
king1994gw
K
后退
顶部