引言: 大家好！又來叨擾大家了！ 上次問大家的ServerSocket還有一點問題，就是每次若Client端中斷或者在連線之後，好像都無法把ServerSocket關閉（按視窗右角的X），每次都只能按Ctrl Alt Del好多次才能關閉，能否再請各位幫幫忙看到底為何會這樣子呢？是不是Timer寫得不好的關係？ 再次感謝大家！ //以下是小弟完整的Server程式 //--------------------------------------------------------------------------- #define MAX_STRLEN 16 #define MAX_FILENAME_LEN 255 #define MAX_DATASIZE 1024 typedef struct _MyPack { char szHeader[MAX_STRLEN]; char szFileName[MAX_FILENAME_LEN]; DWORD dwPackTotal; DWORD dwPackCount; DWORD dwTotalDataSize; DWORD dwThisDataSize; BYTE pbThisData[MAX_DATASIZE]; } MYPACK; #include #pragma hdrstop #include "Unit1.h" #include //--------------------------------------------------------------------------- #pragma package(smart_init) #pragma resource "*.dfm" FILE *fp; TForm1 *Form1; //--------------------------------------------------------------------------- __fastcall TForm1::TForm1(TComponent* Owner) : TForm(Owner) { } //--------------------------------------------------------------------------- void __fastcall TForm1::FormCreate(TObject *Sender) { Button1->Enabled = false ; JPEG_PATH = "c:\\My Documents\\My Pictures\\"; SLEEP_TIME = 50 ; Timer1->Enabled = false ; Timer1->Interval = 30000 ; Timer2->Enabled = false ; Timer2->Interval = 1000 ; fp=fopen("c:\\server.msg","w"); } //--------------------------------------------------------------------------- void __fastcall TForm1::FormDestroy(TObject *Sender) { ServerSocket1->Active = false ; ServerSocket1->Close(); Timer1->Enabled = false ; Timer2->Enabled = false ; fclose(fp); } //--------------------------------------------------------------------------- void __fastcall TForm1::Button1Click(TObject *Sender) { TMemoryStream *msFile=new TMemoryStream; OpenDialog1->Filter = "*.jpg"; if (OpenDialog1->Execute()) msFile->LoadFromFile(OpenDialog1->FileName); MYPACK mp; int i=0; int block=(msFile->Size%MAX_DATASIZE==0)? msFile->Size/MAX_DATASIZE: msFile->Size/MAX_DATASIZE 1; for(i=0; iFileName.c_str()); mp.dwPackTotal=block; mp.dwPackCount=i; mp.dwTotalDataSize=msFile->Size; mp.dwThisDataSize=((i 1)*MAX_DATASIZE>msFile->Size)? msFile->Size-i*MAX_DATASIZE: MAX_DATASIZE; msFile->Position=i*MAX_DATASIZE; msFile->Read(mp.pbThisData, mp.dwThisDataSize); ServerSocket1->Socket->Connections[0]->SendBuf(&mp, sizeof(MYPACK)); Sleep(SLEEP_TIME); } StatusBar1->SimpleText = OpenDialog1->FileName "(" mp.dwTotalDataSize "Byte)傳送完成" ; delete msFile; } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1Accept(TObject *Sender, TCustomWinSocket *Socket) { StatusBar1->SimpleText = "接受" Socket->RemoteHost "之連線" ; Button1->Enabled = true ; Button1->Caption = "傳送圖片給" Socket->RemoteHost ; } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1ClientConnect(TObject *Sender, TCustomWinSocket *Socket) { StatusBar1->SimpleText = "與" Socket->RemoteHost "連線中" ; } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1ClientDisconnect(TObject *Sender, TCustomWinSocket *Socket) { StatusBar1->SimpleText = "與" Socket->RemoteHost "連線中斷" ; } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1ClientError(TObject *Sender, TCustomWinSocket *Socket, TErrorEvent ErrorEvent, int &ErrorCode) { ErrorCode = 0 ; StatusBar1->SimpleText = "Error from Client socket" ; StatusBar1->SimpleText = "Client 端發生錯誤！已中斷與" Socket->RemoteHost "之連線，請重新開啟伺服器" ; for(int i=0; iSocket->ActiveConnections; i ) { if(Socket->RemoteAddress==ServerSocket1->Socket->Connections[i]->RemoteAddress) { ServerSocket1->Socket->Disconnect(i); } } } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1Listen(TObject *Sender, TCustomWinSocket *Socket) { StatusBar1->SimpleText = Socket->LocalHost " Port" Socket->LocalPort "等待用戶連線…" ; } //--------------------------------------------------------------------------- void __fastcall TForm1::mnuListenClick(TObject *Sender) { ServerSocket1->Port=StrToInt(InputBox("伺服器設定","傳輸埠","4000")); ServerSocket1->Open(); } //--------------------------------------------------------------------------- void __fastcall TForm1::ServerSocket1ClientRead(TObject *Sender, TCustomWinSocket *Socket) { ClientMessage = Socket->ReceiveText(); AnsiString filename; if (ClientMessage==exp_ClientMessage) { ClientReceived = true ; } else if ((ClientMessage.Length()>=9)) { if (ClientMessage=="Command_1") { for (int i=0;i<1000;i ) { filename.printf("d",i&); filename=JPEG_PATH filename ".jpg"; SendImage0(filename); } } } } //--------------------------------------------------------------------------- void TForm1::SendImage0(AnsiString image_name) { TMemoryStream *msFile=new TMemoryStream; msFile->LoadFromFile(image_name); MYPACK mp; int i=0; int block=(msFile->Size%MAX_DATASIZE==0)? msFile->Size/MAX_DATASIZE: msFile->Size/MAX_DATASIZE 1; for(i=0; iSize; mp.dwThisDataSize=((i 1)*MAX_DATASIZE>msFile->Size)? msFile->Size-i*MAX_DATASIZE: MAX_DATASIZE; msFile->Position=i*MAX_DATASIZE; msFile->Read(mp.pbThisData, mp.dwThisDataSize); exp_ClientMessage = mp.szFileName ; exp_ClientMessage = exp_ClientMessage IntToStr(mp.dwPackCount) IntToStr(mp.dwThisDataSize) ; ServerSocket1->Socket->Connections[0]->SendBuf(&mp, sizeof(MYPACK)); ClientReceived = false ; LastPacketSize = mp.dwThisDataSize ; Timer1->Enabled = true ; //在Server端未接獲Client端傳來訊息前暫時停止傳送封包 StatusBar1->SimpleText = "等待Client端回報訊息..." ; Timer2->Enabled = true ; elaps_time = 0; while (!ClientReceived) { Application->ProcessMessages(); StatusBar1->SimpleText = "等待Client回應 :" IntToStr(elaps_time) "/" IntToStr(Timer1->Interval/1000) ; } Timer1->Enabled = false ; Timer2->Enabled = false ; } StatusBar1->SimpleText = image_name "(" mp.dwTotalDataSize "Byte)傳送完成" ; delete msFile; } //--------------------------------------------------------------------------- //void TForm1::SendImage(TObject *Sender,AnsiString image_name) void TForm1::SendImage(TServerSocket *Sender,AnsiString image_name) { TMemoryStream *msFile=new TMemoryStream; msFile->LoadFromFile(image_name); MYPACK mp; int i=0; int block=(msFile->Size%MAX_DATASIZE==0)? msFile->Size/MAX_DATASIZE: msFile->Size/MAX_DATASIZE 1; for(i=0; iSize; mp.dwThisDataSize=((i 1)*MAX_DATASIZE>msFile->Size)? msFile->Size-i*MAX_DATASIZE: MAX_DATASIZE; msFile->Position=i*MAX_DATASIZE; msFile->Read(mp.pbThisData, mp.dwThisDataSize); Sender->Socket->Connections[0]->SendBuf(&mp, sizeof(MYPACK)); } StatusBar1->SimpleText = image_name "(" mp.dwTotalDataSize "Byte)傳送完成" ; delete msFile; } //--------------------------------------------------------------------------- void __fastcall TForm1::SleepTime1Click(TObject *Sender) { SLEEP_TIME = StrToInt(InputBox("Sleep Time Setting","Sleep Time (ns) = ","100")); } //--------------------------------------------------------------------------- void __fastcall TForm1::jpegpath1Click(TObject *Sender) { JPEG_PATH = InputBox("JPEG Path Setting","The Path including JPEGs : ","c:\\My Documents\\My Pictures\\"); } //--------------------------------------------------------------------------- void __fastcall TForm1::Timer1Timer(TObject *Sender) { Timer1->Enabled = false ; Timer2->Enabled = false ; // ServerSocket1->Socket->Disconnect(0); ServerSocket1->Active = false ; // StatusBar1->SimpleText = ServerSocket1->Socket->Connections[0]->RemoteHost "沒有回應，連線中斷" ; } //--------------------------------------------------------------------------- void __fastcall TForm1::WaitTime1Click(TObject *Sender) { Wait_Time = StrToInt(InputBox("Wait Time Setting : ","Wait Client for (ms) : ","")); Timer1->Interval = Wait_Time ; ServerSocket1->Socket->SendText("Clinet Response Timeout"); } //--------------------------------------------------------------------------- void __fastcall TForm1::Timer2Timer(TObject *Sender) { elaps_time ; } //---------------------------------------------------------------------------

danielj 你好:
(1)小弟我並沒有實際執行過你的程式碼 (因為沒有 client 端的程式)
(>    -- 
        

 
void TForm1::SendImage0(AnsiString image_name)
{    // 我想這裡可能會個死結,當client端斷線, 你永遠再也收不到任何訊息時???
while (!ClientReceived)
{
Application->ProcessMessages();
StatusBar1->SimpleText = "等待Client回應 :"   IntToStr(elaps_time)   "/"   IntToStr(Timer1->Interval/1000) ;
}    }