1.Client端
阻塞模式常用在单通道Server自动响应收发数据里面，比如ClientA向ServerB发送报文，并且ClientA只需要它发送的这条数据ServerB对它有一个响应。其实c++ builder 里面阻塞模式的收发数据主要理解TWinSocketStream这个流。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
void
__fastcall TForm1::btn_1Click(TObject *Sender)
{
//1.初始化一些socket参数
ClientSocket1->Address=
"127.0.0.1"
;
ClientSocket1->Port=10101;
ClientSocket1->ClientType=ctBlocking;
//此处表示socket是阻塞模式
int
TIMEOUT=300000,MAXLENGTH=1024;
TWinSocketStream *pClientStream;
//TWinSocketStream to read or write information over a blocking socket connection
pClientStream=
new
TWinSocketStream(ClientSocket1->Socket,TIMEOUT);
//2.连接Server端
ClientSocket1->Open();
//3.发送数据
char
sendBuf[1024];
int
sendCount=0;
strcpy(sendBuf,E_send->Text.c_str()) ;
sendCount=pClientStream->Write(sendBuf,strlen(sendBuf)+1);
if
(sendCount==0) ShowMessage(
"发送失败!"
);
//4.接收数据
char
receiveBuf[1024];
int
Len=0;
if
(pClientStream->WaitForData(TIMEOUT))
//在TIMEOUT时间内如果没有接收到数据程序是直会在此挂起,因此如果阻塞模式接收数据的话一般放在线程里面
Len=pClientStream->Read(receiveBuf,MAXLENGTH);
receiveBuf[Len]=0;
Memo1->Lines->Add(receiveBuf);
}
|
2.Server端(TServerSocket 多线程阻塞模式收发数据)
使用多线程的阻塞模式要从一个TServerClientThread对象中派生一个类，在类的execute()方法中写收发数据的代码。收数据一般通过TWinSocketStream流实现。
这是派生的类的代码头
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
//---------------------------------------------------------------------------
#ifndef UnitServerThreadH
#define UnitServerThreadH
//---------------------------------------------------------------------------
#include <ScktComp.hpp>
#include <StdCtrls.hpp>
#include "UnitMain.h"
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
class
TServerThread :
public
TServerClientThread
{
protected
:
void
__fastcall ClientExecute(
void
);
int
__fastcall ReadStr(
char
* buf);
public
:
__fastcall TServerThread(
bool
CreateSuspended, TServerClientWinSocket* ASocket,HWND hWnd);
__fastcall ~TServerThread();
private
:
TWinSocketStream *pStream;
HWND m_hwnd;
};
#endif
|
//cpp文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
#include <vcl.h>
#pragma hdrstop
#include "UnitServerThread.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
//---------------------------------------------------------------------------
__fastcall TServerThread::TServerThread(
bool
CreateSuspended, TServerClientWinSocket* ASocket,
HWND
hWnd) : TServerClientThread(CreateSuspended,ASocket)
{
m_hwnd=hWnd;
FreeOnTerminate=
false
;
}
//---------------------------------------------------------------------------
void
__fastcall TServerThread::ClientExecute(
void
)
{
//当一个客户连接的时候进入ClientExecute
//1.接收数据
try
{
pStream=
new
TWinSocketStream(ClientSocket,60000);
char
buf[1024];
memset
(buf,0,
sizeof
(buf));
try
{
int
len=0;
if
(pStream->WaitForData(60000))
{
len=pStream->Read(buf,1024);
buf[len]=0;
}
}
catch
(Exception &E)
{
}
//2.发送数据
ClientSocket->SendText(
"已经收到消息!消息为"
+AnsiString(buf));
}
__finally
{
ClientSocket->Close();
delete
pStream;
}
}
|
下面是主窗口代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
//---------------------------------------------------------------------------
#include <vcl.h>
#pragma hdrstop
#include "UnitMain.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TForm1 *Form1;
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
: TForm(Owner)
{
ServerSocket1->Port=10101;
ServerSocket1->ServerType=stThreadBlocking;
//设置为阻塞模式
//指定缓存使用的线程的个数:如果第一个Client连接Server会自动生成一个TServerThread类对象
//当这个客户端断开时，这个对象不会释放，当第二个Cliet连接时，会重用这个TServerThread而不是
//重新创建此对象。ThreadCacheSize实际上指线程类不被释放的个数。
ServerSocket1->ThreadCacheSize=10;
//
ServerSocket1->Open() ;
}
//---------------------------------------------------------------------------
void
__fastcall TForm1::ServerSocket1GetThread(TObject *Sender,
TServerClientWinSocket *ClientSocket,
TServerClientThread *&SocketThread)
{
SocketThread=
new
TServerThread(
false
,ClientSocket,Form1->Handle);
}
//-----------------
|
