📄 3-3.htm
字号:
<html>
<head>
<title>3-3</title>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312">
</head>
<body bgcolor="#FFFFFF">
<table width="100%" border="0">
<tr>
<td height="31">
<div align="center"><b><font color="#000099">3.3 Windows Sockets与UNIX套接口编程实例</font></b></div>
</td>
</tr>
<tr>
<td height="46">下面是一个简单的基于连接的点对点实时通信程序.它由两部分组成,服务器在主机UNIX下直接运行, 客户机在Windows下运行.</td>
</tr>
<tr>
<td height="36">3.3.1 SERVER介绍</td>
</tr>
<tr>
<td height="55">由于SERVER是在UNIX下运行的,它对套接口的使用都是BSD的标准函数,程序也比较简单, 只有一段程序,下面简要解释一下</td>
</tr>
<tr>
<td height="64">首先,建立自己的套接口.在互连网的进程通信中,全局标识一个进程需要一个被称为"半相关"的三元组(协议,本地主机地址,本地端口号)来描述,而一个完整的进程通信实例则需要一个被称为"相关"的五元组(协议,
本地主机地址,本地端口号,远端主机地址,远端端口号)来描述</td>
</tr>
<tr>
<td height="34">s=socket(AF_INET, SOCK_STREAM, 0)</td>
</tr>
<tr>
<td height="49">该函数建立指定地址格式,数据类型和协议下的套接口,地址格式为AF_INET(唯一支持的格式),数据类型SOCK_STREAM表示建立流式套接口,参数三为0,即协议缺省</td>
</tr>
<tr>
<td height="32">bind(s, (struct sockaddr *)&server, sizeof(server))</td>
</tr>
<tr>
<td height="42">该函数将建立服务器本地的半相关,其中,server是sockaddr_in结构,其成员描述了本地端口号和本地主机地址,经过bind()将服务器进程在网上标识出来.</td>
</tr>
<tr>
<td height="30">然后,建立连接.先是调用listen()函数表示开始侦听.再通过accept()调用等待接收连接.</td>
</tr>
<tr>
<td height="52">listen(s,1)表示连接请求队列长度为1,即只允许有一个请求,若有多个请求,则出现错误,给出错误代码WSAECONNREFUSED.</td>
</tr>
<tr>
<td>ns = accept(s, (struct sockaddr *)&client, &namelen)) </td>
</tr>
<tr>
<td height="49">accept()阻塞(缺省)等待请求队列中的请求,一旦有连接请求来,该函数就建立一个和s有相同属性的新的套接口.client也是一个sockaddr_in结构,连接建立时填入请求连接的套接口的半相关信息.</td>
</tr>
<tr>
<td height="25">接下来,就可以接收和发送数据了</td>
</tr>
<tr>
<td height="74">
<p>recv(ns,buf,1024,0) </p>
<p>send(ns,buf,pktlen,0) </p>
</td>
</tr>
<tr>
<td height="44">上面两个函数分别负责接收和发送数据,recv从ns(建立连接的套接口)接收数据放入buf中,send则将buf中数据发送给ns.至于第四个参数,表示该函数调用方式,可选择MSG_DONTROUTE和MSG_OOB,
0表示缺省</td>
</tr>
<tr>
<td height="31">最后,关闭套接口.</td>
</tr>
<tr>
<td height="53">
<p>close(ns); </p>
<p>close(s); </p>
</td>
</tr>
<tr>
<td height="28">3.3.2 CLIENT介绍</td>
</tr>
<tr>
<td height="53">客户端是在Windows上运行的,使用了一些Windows Sockets的扩展函数,稍微复杂一些.包括了.RC和.C两个文件,其中的主窗口函数ClientProc()是程序的主要部分,下面简单解释一下.</td>
</tr>
<tr>
<td height="53">首先,是在WinMain()中建立好窗口后,即向主窗口函数发一条自定义的WM_USER消息, 做相关的准备工作.在主窗口函数中,一接收到WM_USER消息,首先调用WSAStartup()函数初始化Windows
Sockets DLL,并检查版本号.如下:</td>
</tr>
<tr>
<td height="36">Status = WSAStartup(VersionReqd, lpmyWSAData);</td>
</tr>
<tr>
<td height="53">其中,VersionReqd描述了WINSOCK的版本(这里为1.1版),lpmyWSAData指向一个WSADATA结构,该结构描述了Windows
Sockets的实现细节.</td>
</tr>
<tr>
<td height="53">WSAStartup()之后,进程通过主机名(运行时命令行参数传入)获取主机地址,如下:</td>
</tr>
<tr>
<td height="53">hostaddr = gethostbyname(server_address);</td>
</tr>
<tr>
<td height="53">hostaddr指向hostent结构,内容参见5.2.1.</td>
</tr>
<tr>
<td height="53">然后,进程就不断地消息循环,等待用户通过菜单选择"启动".这时,通过调用Client()来启动套接口.在Client()中,首先也是调用socket()来建立套接口.如下:</td>
</tr>
<tr>
<td height="53">
<p>if ((s = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) </p>
<p>{ AlertUser(hWnd, "Socket Failed"); </p>
<p>return (FALSE); } </p>
</td>
</tr>
<tr>
<td height="53">紧接着,调用WSAAsyncSelect()函数提名FD_CONNECT网络事件,如下: </td>
</tr>
<tr>
<td height="34">if (!SetSelect(hWnd, FD_CONNECT)) return (FALSE); </td>
</tr>
<tr>
<td height="53">SetSelect()主要就是调用WSAASyncSelect(),让Windows Sockets DLL在侦测到连接建立时,就发送一条UM_SOCK的自定义消息,使消息循环继续下去.如下:</td>
</tr>
<tr>
<td height="47">BOOL SetSelect(HWND hWnd, long lEvent) { if (WSAAsyncSelect(s,
hWnd, UM_SOCK, lEvent) == SOCKET_ERROR) { AlertUser(hWnd, "WSAAsyncSelect
Failure."); return (FALSE); } return (TRUE); } </td>
</tr>
<tr>
<td height="41">为建立连接,必须马上调用connect()如下,由于先调用了WSAASyncSelect(),connect()便是非阻塞调用.进程发出连接请求后就不管了,当连接建立好后,WINSOCK
DLL自动发一条消息给主窗口函数,以使程序运行下去.</td>
</tr>
<tr>
<td height="32">connect(s, (struct sockaddr FAR *)&dst_addr, sizeof(dst_addr));</td>
</tr>
<tr>
<td height="53">窗口函数在收到UM_SOCK消息后,判断是由哪个网络事件引起的,第一次,必然是由连接事件引起的,这样,就会执行相应的程序段,同样调用SetSelect()来提名FD_WRITE事件.希望在套接口可发送数据时接到消息.在收到FD_WRITE消息时,先调用send()发送数据,再调用SetSelect()来提名FD_READ事件,
希望在套接口可接收数据是接到消息.在收到FD_READ消息时,先调用recv()来接收数据再提名FD_WRITE事件,如此循环下去.直到发生连接关闭的事件FD_CLOSE,这时就调用WSAAsyncSelect(s,hWnd,0,0)来停止异步选择.在窗口函数接到WM_DESTROY消息时(即关闭窗口之前),先调用closesocket()(作用同UNIX
中的close())来关闭套接口,再调用WSACleanup()终止Windows Sockets DLL,并释放资源.</td>
</tr>
<tr>
<td height="28">3.3.3 源程序清单</td>
</tr>
<tr>
<td height="53">
<p>程序1:</p>
<p>CLIENT.RC </p>
<p>ClientMenu </p>
<p>MENU </p>
<p>BEGIN </p>
<p>POPUP "&Server" </p>
<p>BEGIN </p>
<p>MENUITEM "&Start...", 101 </p>
<p>MENUITEM "&Exit", 102 </p>
<p>END END </p>
</td>
</tr>
<tr>
<td height="10034">
<p><font face="宋体" lang="ZH-CN" size=3>程序</font><font size=3>2:CLIENT.C</font></p>
<font size=3>
<p>#define USERPORT 10001</p>
<p>#define IDM_START 101</p>
<p>#define IDM_EXIT 102</p>
<p>#define UM_SOCK WM_USER + 0X100</p>
<p>#include <alloc.h></p>
<p>#include <mem.h></p>
<p>#include <windows.h></p>
<p>#include <winsock.h></p>
<p>#define MAJOR_VERSION 1</p>
<p>#define MINOR_VERSION 2</p>
<p>#define WSA_MAKEWORD(x,y) ((y)*256+(x))</p>
<p>HANDLE hInst;</p>
<p>char server_address[256] = {0};</p>
<p>char buffer[1024];</p>
<p>char FAR * lpBuffer = &buffer[0];</p>
<p>SOCKET s = 0;</p>
<p>struct sockaddr_in dst_addr;</p>
<p>struct hostent far *hostaddr;</p>
<p>struct hostent hostnm;</p>
<p>struct servent far *sp;</p>
<p>int count = 0;</p>
<p>BOOL InitApplication(HINSTANCE hInstance);</p>
<p>long FAR PASCAL ClientProc(HWND hWnd, unsigned message, UINT wParam,
LONG lParam);</p>
<p>void AlertUser(HWND hWnd, char *message);</p>
<p>BOOL Client(HWND hWnd);</p>
<p>BOOL ReceivePacket(HWND hWnd);</p>
<p>BOOL SetSelect(HWND hWnd, long lEvent);</p>
<p>BOOL SendPacket(HWND hWnd, int len);</p>
<p>int PASCAL WinMain(HANDLE hInstance, HANDLE hPrevInstance, LPSTR lpCmdLine,
int nCmdShow)</p>
<p>{</p>
<p>	HWND hWnd;</p>
<p>	MSG msg;</p>
<p>	lstrcpy((LPSTR)server_address, lpCmdLine);</p>
<p>	if (!hPrevInstance)</p>
<p>		if (!InitApplication(hInstance))</p>
<p>			return (FALSE);</p>
<p>	hInst = hInstance;</p>
<p>	hWnd = CreateWindow("ClientClass", "Windows ECHO Client", WS_OVERLAPPEDWINDOW,\</p>
<p>		CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, NULL,
NULL,\</p>
<p>		hInstance, NULL);</p>
<p>	if (!hWnd)</p>
<p>		return (FALSE);</p>
<p>	ShowWindow(hWnd, nCmdShow);</p>
<p>	UpdateWindow(hWnd);</p>
<p>	PostMessage(hWnd, WM_USER, (WPARAM)0, (LPARAM)0);</p>
<p>	while (GetMessage(&msg, NULL, NULL, NULL))</p>
<p>	{</p>
<p>		TranslateMessage(&msg);</p>
<p>		DispatchMessage(&msg);</p>
<p>	}</p>
<p>	return (msg.wParam);</p>
<p>}</p>
<p>BOOL InitApplication(HINSTANCE hInstance)</p>
<p>{</p>
<p> WNDCLASS WndClass;</p>
</font>
<p> <font face="宋体" lang="ZH-CN" size=3>	</font><font size=3>char *szAppName
= "ClientClass";</font></p>
<font size=3>
<p> // fill in window class information</p>
<p>	WndClass.lpszClassName = (LPSTR)szAppName;</p>
<p>	WndClass.hInstance = hInstance;</p>
</font>
<p><font face="宋体" lang="ZH-CN" size=3>	</font><font size=3>WndClass.lpfnWndProc
= ClientProc;</font></p>
<p><font face="宋体" lang="ZH-CN" size=3>	</font><font size=3>WndClass.hCursor
= LoadCursor(NULL, IDC_ARROW);</font></p>
<font size=3>
<p>	WndClass.hIcon = LoadIcon(hInstance, NULL);</p>
<p>	WndClass.lpszMenuName = "ClientMenu";</p>
<p>	WndClass.hbrBackground = GetStockObject(WHITE_BRUSH);</p>
<p>	WndClass.style = CS_HREDRAW | CS_VREDRAW;</p>
<p>	WndClass.cbClsExtra = 0;</p>
<p>	WndClass.cbWndExtra = 0;</p>
<p> // register the class</p>
<p> if (!RegisterClass(&WndClass))</p>
<p>		return(FALSE);</p>
<p> return(TRUE);</p>
<p>}</p>
<p>long FAR PASCAL ClientProc(HWND hWnd, unsigned message, UINT wParam,
LONG lParam)</p>
<p>{</p>
<p>	int length, i;</p>
<p>	WSADATA wsaData;</p>
<p>	int Status;</p>
<p>	switch (message)</p>
<p>	{</p>
<p>		case WM_USER:</p>
<p>		{</p>
<p>			WORD	wMajorVersion, wMinorVersion;</p>
<p>			LPWSADATA	lpmyWSAData;</p>
<p>			WORD 		VersionReqd;</p>
<p>			int			ret;</p>
<p>			wMajorVersion = MAJOR_VERSION;</p>
<p>			wMinorVersion = MINOR_VERSION;</p>
<p>			VersionReqd = WSA_MAKEWORD(wMajorVersion,wMinorVersion);</p>
<p>		</p>
<p>			lpmyWSAData = (LPWSADATA)malloc(sizeof(WSADATA));</p>
<p>			Status = WSAStartup(VersionReqd, lpmyWSAData);</p>
<p>			if (Status != 0)</p>
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -