3、等待接收数据(recvfrom)。 4、关闭套接字。 客户端(发送端)程序: 1、创建套接字(socket)。 2、向服务器发送数据(sendto)。 3、关闭套接字。 服务器端代码:
#i nclude
WORD wVersionRequested; WSADATA wsaData; int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData ); if ( err != 0 ) { return; }
if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1 ) { WSACleanup( ); return; }
SOCKET sockSrv=socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY); addrSrv.sin_family=AF_INET; addrSrv.sin_port=htons(6000);
bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR)); SOCKADDR_IN addrClient; int len=sizeof(SOCKADDR); char recvBuf[100];
recvfrom(sockSrv,recvBuf,100,0,(SOCKADDR*)&addrClient,&len); printf(\closesocket(sockSrv); WSACleanup();
}
客户端代码:
#i nclude
WORD wVersionRequested; WSADATA wsaData; int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData ); if ( err != 0 ) { return; }
if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1 ) { WSACleanup( ); return; }
SOCKET sockClient=socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=inet_addr(\addrSrv.sin_family=AF_INET; addrSrv.sin_port=htons(6000);
sendto(sockClient,\(SOCKADDR*)&addrSrv,sizeof(SOCKADDR)); closesocket(sockClient); WSACleanup(); }
UDP的不再加注释了。因为它比TCP的简单多了。
3.基于字符界面的聊天程序,用的是UDP式套接字。代码略。 4.如何添加新的工程?
首先选择中Build工具栏,然后在工程管理器上点击右键,选择增加新的工程即可。
第15课多线程与网络编程 1.多线程介绍,略
2.一个简单的多线程程序
MSND中参数[in]和[out]的含义要注意 #i nclude
DWORD WINAPI Fun2Proc( LPVOID lpParameter // thread data );
int index=0; int tickets=100;
HANDLE hMutex;互斥对象的句柄 void main() {
HANDLE hThread1; HANDLE hThread2;
hThread1=CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);创建线程1 hThread2=CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);创建线程2
CloseHandle(hThread1);关闭线程的句柄,为什么要关闭?它将线程的使用计数减1
CloseHandle(hThread2);这样当线程结束时,线程内核对象被释放,否则只有当进程结束,才释放线程的内核对象 /*while(index++<1000)
cout<<\thread is running\
//hMutex=CreateMutex(NULL,TRUE,NULL);将第二个参数设为true后,互斥对象的计数加1 hMutex=CreateMutex(NULL,TRUE,\此段代码可以让系统只一份实例在运行! if(hMutex) {
if(ERROR_ALREADY_EXISTS==GetLastError()) {
cout<<\instance can run!\return; } }
WaitForSingleObject(hMutex,INFINITE);此代码也将互斥对象的计数加1 ReleaseMutex(hMutex);所以要释放两次互斥对象 ReleaseMutex(hMutex); Sleep(4000);睡眠4000毫秒
// Sleep(10); }
DWORD WINAPI Fun1Proc( LPVOID lpParameter // thread data ) {
/*while(index++<1000)
cout<<\is running\/*while(TRUE) {
//ReleaseMutex(hMutex);
WaitForSingleObject(hMutex,INFINITE);等待互斥对象的到来,到来后将互斥对象的计数加1 if(tickets>0) { Sleep(1);
cout<<\sell ticket : \} else break;
ReleaseMutex(hMutex);释放互斥对象,将其计数减1,这样可以保证,这两句话之间的代码!的执行连续性! }*/
WaitForSingleObject(hMutex,INFINITE); cout<<\is running\return 0; }
DWORD WINAPI Fun2Proc( LPVOID lpParameter // thread data ) {
/*while(TRUE) {
//ReleaseMutex(hMutex);
WaitForSingleObject(hMutex,INFINITE); if(tickets>0) { Sleep(1);
cout<<\sell ticket : \
} else break;
ReleaseMutex(hMutex); }*/
WaitForSingleObject(hMutex,INFINITE); cout<<\is running\return 0; }
3.多线程聊天程序
1.加载套接字库在InitInstance()中,调用AfxSocketInit(),此时可以不加载库文件,但要加入Afxsock.h\头文件
2.在CChatDlg中创建成员变量m_socket,然后增加一个成员函数,IniSocket(),在其中完成m_socket的初始化和绑定。在OnInitDialog中调用InitSocket完成初始化工作。
3.定义一个结构体,包含两个参数,sock和hwnd,在OnInitDialog()中初始化这个结构体的对象。
4.创建一个线程,CreateThread(),须将线程函数RecvProc定义为静态的或者全局函数。 ::PostMessage()完成将收到的数据发送给对话框。用自定义的消息,自定义的消息如何写?以前说过,参考下面的代码。注意要将EDitBox的MultiLine属性选上。 在ChatDlg.h中#define WM_RECVDATA WM_USER+1
afx_msg void OnRecvData(WPARAM wParam,LPARAM lParam); 在ChatDlg.cpp中
ON_MESSAGE(WM_RECVDATA,OnRecvData) 然后实现这个函数
void CChatDlg::OnRecvData(WPARAM wParam,LPARAM lParam) {
CString str=(char*)lParam; CString strTemp;
GetDlgItemText(IDC_EDIT_RECV,strTemp); str+=\str+=strTemp;
SetDlgItemText(IDC_EDIT_RECV,str); }
最后在DWORD WINAPI CChatDlg::RecvProc(LPVOID lpParameter) 中调用 ::PostMessage(hwnd,WM_RECVDATA,0,(LPARAM)tempBuf); //不能用SendMessage() 4.对发送按纽的响应代码: void CChatDlg::OnBtnSend()