程式為DELPHI7寫的，用了TTHREAD類，但是執行緒到了10就不再增加，請問各位是什么問題呢？
uj5u.com熱心網友回復：
問題比較模糊不清，先說清楚啊uj5u.com熱心網友回復：
不好意思，重新描述一遍：
uj5u.com熱心網友回復：
不好意思，重新描述下：
DELPHI7的一個程式，用了TTHREAD+原生的TCPSERVER的，當執行緒數量達到10就不再連接，等待之前的某一個銷毀后才連接
uj5u.com熱心網友回復：
windows非server版本的話，系統并發連接數是有限制的，默認是10，你可以搜索下工具，關鍵詞“windows TCP/IP 并發連接數修改”
uj5u.com熱心網友回復：
我的測驗系統是WIN2003 SERVER
uj5u.com熱心網友回復：
那這種情況，檢查代碼里有無限制吧。
uj5u.com熱心網友回復：
最好還是貼點代碼看看，光這么說也不好判斷是哪里的問題uj5u.com熱心網友回復：
1、ONCREATEprocedure TForm1.FormCreate(Sender: TObject);
var
File_Path: array [0..MAX_PATH] of Char;
Cfg_String: array [0..MAX_PATH] of Char;
Cfg_FileName: string;
ComputerName: array[0..MAX_COMPUTERNAME_LENGTH+1] of char;
Size:Cardinal;
begin
ci:=0;
LB_MaxWidth:=0;
bLockUpdateTree:=FALSE;
//當前路徑
GetCurrentDirectory(MAX_PATH,File_Path);
Cur_Directory :=File_Path;
Cfg_FileName := File_Path + '\\config.ini';
MyLogFile := File_Path + '\\DServer.log';
// DeleteFile(MyLogFile);
//讀取資料庫連接配置
//1. 資料庫地址
GetPrivateProfileString('DelphiDBServer','Database_Server','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := '127.0.0.1';
WritePrivateProfileString('DelphiDBServer','Database_Server',Cfg_String,PCHAR(Cfg_FileName));
end;
DB_Server := Cfg_string;
GetPrivateProfileString('DelphiDBServer','Database_Server_Port','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := '1433';
WritePrivateProfileString('DelphiDBServer','Database_Server_Port',Cfg_String,PCHAR(Cfg_FileName));
end;
DB_Server_Port := Cfg_string;
//2. 用戶名
GetPrivateProfileString('DelphiDBServer','Database_Username','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := 'username';
WritePrivateProfileString('DelphiDBServer','Database_Username',Cfg_String,PCHAR(Cfg_FileName));
end;
DB_Username := Cfg_string;
//3. 密碼
GetPrivateProfileString('DelphiDBServer','Database_Password','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := 'password';
WritePrivateProfileString('DelphiDBServer','Database_Password',Cfg_String,PCHAR(Cfg_FileName));
end;
DB_Password := Cfg_string;
//4. 資料庫名稱
GetPrivateProfileString('DelphiDBServer','Database_Name','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := 'dbname';
WritePrivateProfileString('DelphiDBServer','Database_Name',Cfg_String,PCHAR(Cfg_FileName));
end;
DB_Name := Cfg_string;
//5. 服務器程式 監聽埠
GetPrivateProfileString('DelphiServer','Listening_Port','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := '80';
WritePrivateProfileString('DelphiServer','Listening_Port',Cfg_String,PCHAR(Cfg_FileName));
end;
TCP_Listenning_Port := Cfg_string;
TcpServer1.LocalPort:= TCP_Listenning_Port;
GetPrivateProfileString('DelphiServer','TimeOut','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String='' then
begin
Cfg_String := '0';
WritePrivateProfileString('DelphiServer','TimeOut',Cfg_String,PCHAR(Cfg_FileName));
end;
Beats_TimeOut := StrtoInt(Cfg_string);
GetPrivateProfileString('DelphiServer','ReTime','',Cfg_String,MAX_PATH,PCHAR(Cfg_FileName));
if Cfg_String = '' then
begin
Cfg_String := '06:20:01';
WritePrivateProfileString('DelphiServer','ReTime',Cfg_String,PCHAR(Cfg_FileName));
end;
Fwzqdsj:=strtodatetime(Cfg_String);
//連接資料庫
ADOConnection1.connectionstring:='Provider=SQLOLEDB.1;Data Source='+DB_Server+','+DB_Server_Port+';Persist Security Info=True;User ID='+DB_Username+';password='+DB_Password+';Initial Catalog='+DB_Name+';';
Size := MAX_COMPUTERNAME_LENGTH+1;
GetComputerName(ComputerName,Size);
MyComputerName:=StrPas(ComputerName);
Timer1.Enabled:=True;
end;
2、有連接接入
procedure MyClientHandleThreadFunc(ClientSocket: TCustomIpClient);
var
myThread:TMyClientHandleThread;
begin
myThread:=TMyClientHandleThread.Create(TRUE);
myThread.myClientSocket :=ClientSocket;
myThread.FreeOnTerminate :=TRUE;
myThread.Execute;
end;
3、處理
procedure TMyClientHandleThread.Execute;
var
RecvBUF:array[0..4096] OF Char ;
AdoQuery_1:TADOQuery;
AdoQuery_2:TADOQuery;
idStr:string;
sbipStr:string;
jhStr:string;
str_YQ:string;
retstr1,retstr2,retstr3:string;
cxsj :Tdatetime;
LastTickCount:real; //系統tick
Timeout_time:Integer; //超時 ms
CurTime:TDATETIME;
iKYE:currency;
iPrice:currency;
iXFnum:Integer;
xScreen,yScreen:integer;
begin
if not Assigned(myClientSocket) then
Exit;
if not myClientSocket.Active then
Exit;
iOnline:=0; //初始不在線
AdoQuery_1:=TADOQuery.Create(Form1);
AdoQuery_1.Connection:=Form1.ADOConnection1;
AdoQuery_2:=TADOQuery.Create(Form1);
AdoQuery_2.Connection:=Form1.ADOConnection1;
{ AdoQuery_3:=TADOQuery.Create(Form1);
AdoQuery_3.Connection:=Form1.ADOConnection1;
AdoQuery_4:=TADOQuery.Create(Form1);
AdoQuery_4.Connection:=Form1.ADOConnection1;
AdoQuery_5:=TADOQuery.Create(Form1);
AdoQuery_5.Connection:=Form1.ADOConnection1; }
//判斷address是否存在sbcx
if Form1.MyQueryOpen(AdoQuery_1,'select * from "sbcs" where sbip='''+myClientSocket.RemoteHost+''' and JSJM='''+Form1.MyComputerName+'''',true)=0 then
begin //不存在
strLog := '資料庫中找不到'+myClientSocket.RemoteHost+'對應的設備記錄，連接被拒絕。';
synchronize(AddLog);
AdoQuery_1.Close;
AdoQuery_2.Close;
myClientSocket.Close;
ci:=ci-1;
exit;
end
else
begin
strLog := '設備'+myClientSocket.RemoteHost+'已連接到服務器。['+myClientSocket.RemotePort+']'+inttostr(ci);
synchronize(AddLog);
//判斷設備是否已在串列中
with AdoQuery_1 do
begin
First;
sbipStr:=FieldByName('sbip').AsString;
jhStr:=FieldByName('jh').AsString;
idStr:=FieldByName('id').AsString;
iOnline:=2;
Form1.UpdateDevInListView(idStr,IntToStr(iOnline),sbipStr,jhStr);
end;
end;
LastTickCount :=GetTickCount;
Timeout_time := Form1.Beats_TimeOut*1000;
ZeroMemory(@RecvBUF[0],SizeOf(RecvBUF));
if (Assigned(myClientSocket) and not (myClientSocket.Active) and not (myClientSocket.Connected)) then
begin
myClientSocket.Free;
exit;
end;
while (Assigned(myClientSocket) and (myClientSocket.active) and (myClientSocket.Connected)) do
begin
if Timeout_time>0 then
begin
if GetTickCount-LastTickCount>Timeout_time then
begin
if(iOnline<>1) then
begin
if (iOnline>2) then
Form1.UpdateDevInListView(idStr,'1',sbipStr,jhStr);
iOnline:=1;
end;
break;
end;
if myClientSocket.WaitForData(Timeout_time)=False then
begin
if(iOnline<>1) then
begin
if (iOnline>2) then
Form1.UpdateDevInListView(idStr,'1',sbipStr,jhStr);
iOnline:=1;
end;
break;
end;
end;
ZeroMemory(@RecvBUF[0],SizeOf(RecvBUF));
//接收資料
if(myClientSocket.ReceiveBuf(RecvBUF,SizeOf(RecvBUF))<=0) then
continue;
if RecvBUF[0]=#0 then
continue;
//bufstr:=RecvBuF;
xScreen:=0;
yScreen:=0;
//決議報文
retstr1:=GetValueFromPacket(RecvBUF,'CID');
if Assigned(myClientSocket) then
myClientSocket.Close;
end;
end;
//添加到日志視窗
procedure TMyClientHandleThread.AddLog;
begin
Form1.AddLogInfo(strLog);
end;
//接受新的client連接時
procedure TForm1.TcpServer1Accept(Sender: TObject;
ClientSocket: TCustomIpClient);
begin
MyClientHandleThreadFunc(ClientSocket);
end;
uj5u.com熱心網友回復：
myThread.Execute;看到這句就知道你代碼有問題了，TThread不是這么用的。
uj5u.com熱心網友回復：
額。。。。那應該怎么處理這個位置？
uj5u.com熱心網友回復：
先理解TThread類，Execute不是由使用者呼叫的，你這么錯誤使用根本就不是多執行緒。
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/88777.html
標籤：VCL組件開發及應用