ddx_cbstring_ddr和ddx_东方财富ddx抓涨停(54)

下面的代码演示了如何建立连接和发送/接收数据：

/*

服务器方在端口6802上等待连接，当连接建立后关闭套接口

客户方向服务器端口6802发起连接请求

*/

BOOL CMy63_s1_serverDlg::OnInitDialog()

{

CDialog::OnInitDialog();

CSocket sockListen;

//创建本地套接口

sockListen.Create(6802,SOCK_STREAM,"127.0.0.1");

//绑定参数

sockListen.Bind(6802,"127.0.0.1");

sockListen.Listen(5);

//等待连接请求，m_sockSend为成员变量，用于通信

sockListen.Accept(m_sockSend);

//关闭套接口

sockListen.Close();

//启动定时器，定时发送数据

SetTimer(1,3000,NULL);

...

}

void CMy63_s1_serverDlg::OnTimer(UINT nIDEvent)

{

static iIndex=0;

char szSend[20];

sprintf(szSend,"%010d",iIndex++);

//发送TCP数据

int iSend= m_sockSend.Send(szSend,10,0);

...

}

BOOL CMy63_s1_clientDlg::OnInitDialog()

{

CDialog::OnInitDialog();

//创建本地套接口

m_sockRecv.Create();

//发起连接请求

BOOL fC=m_sockRecv.Connect("127.0.0.1",6802); TRACE("connect is %s\n",(fC)?"OK":"Error"); //启动定时器，定时接收数据

SetTimer(1,3000,NULL);

...

}

void CMy63_s1_clientDlg::OnTimer(UINT nIDEvent)

{

char szRecv[20];

//接收TCP数据

int iRecv =m_sockRecv.Receive(szRecv,10,0); TRACE("received %d byte\n",iRecv);

if(iRecv>=0)

{

szRecv[iRecv]='\0';

m_szRecv=szRecv;

UpdateData(FALSE);

}

...

}

下载例子代码，63_s1_client工程为客户，63_s1_server工程为服务器方。

本文来自电脑杂谈，转载请注明本文网址：
https://www.pc-fly.com/a/ruanjian/article-35251-54.html