Windows Socket API 使用经验

本文是我在进行MS-Windows、HP-Unix网络编程的实践过程中总结出来的一些经验，仅供大家参考。本文所谈到的Socket函数如果没有特别说明，都是指的Windows Socket API。

一、WSAStartup函数
int WSAStartup(
WORD wVersionRequested,
LPWSADATA lpWSAData
);
使用Socket的程序在使用Socket之前必须调用WSAStartup函数。该函数的第一个参数指明程序请求使用的Socket版本，其中高位字节指明副版本、低位字节指明主版本；操作系统利用第二个参数返回请求的Socket的版本信息。当一个应用程序调用WSAStartup函数时，操作系统根据请求的Socket版本来搜索相应的Socket库，然后绑定找到的Socket库到该应用程序中。以后应用程序就可以调用所请求的Socket库中的其它Socket函数了。该函数执行成功后返回0。
例：假如一个程序要使用2.1版本的Socket,那么程序代码如下
wVersionRequested = MAKEWORD( 2, 1 );
err = WSAStartup( wVersionRequested, &wsaData );

二、WSACleanup函数
int WSACleanup (void);
应用程序在完成对请求的Socket库的使用后，要调用WSACleanup函数来解除与Socket库的绑定并且释放Socket库所占用的系统资源。

三、socket函数
SOCKET socket(
int af,
int type,
int protocol
);
应用程序调用socket函数来创建一个能够进行网络通信的套接字。第一个参数指定应用程序使用的通信协议的协议族，对于TCP/IP协议族，该参数置PF_INET;第二个参数指定要创建的套接字类型，流套接字类型为SOCK_STREAM、数据报套接字类型为SOCK_DGRAM；第三个参数指定应用程序所使用的通信协议。该函数如果调用成功就返回新创建的套接字的描述符，如果失败就返回INVALID_SOCKET。套接字描述符是一个整数类型的值。每个进程的进程空间里都有一个套接字描述符表，该表中存放着套接字描述符和套接字数据结构的对应关系。该表中有一个字段存放新创建的套接字的描述符，另一个字段存放套接字数据结构的地址，因此根据套接字描述符就可以找到其对应的套接字数据结构。每个进程在自己的进程空间里都有一个套接字描述符表但是套接字数据结构都是在操作系统的内核缓冲里。下面是一个创建流套接字的例子：
struct protoent *ppe;
ppe=getprotobyname("tcp");
SOCKET ListenSocket=socket(PF_INET,SOCK_STREAM,ppe->p_proto);

四、closesocket函数
int closesocket(
SOCKET s
);
closesocket函数用来关闭一个描述符为s套接字。由于每个进程中都有一个套接字描述符表，表中的每个套接字描述符都对应了一个位于操作系统缓冲区中的套接字数据结构，因此有可能有几个套接字描述符指向同一个套接字数据结构。套接字数据结构中专门有一个字段存放该结构的被引用次数，即有多少个套接字描述符指向该结构。当调用closesocket函数时，操作系统先检查套接字数据结构中的该字段的值，如果为1，就表明只有一个套接字描述符指向它，因此操作系统就先把s在套接字描述符表中对应的那条表项清除，并且释放s对应的套接字数据结构；如果该字段大于1，那么操作系统仅仅清除s在套接字描述符表中的对应表项，并且把s对应的套接字数据结构的引用次数减1。
closesocket函数如果执行成功就返回0，否则返回SOCKET_ERROR。

五、send函数
int send(
SOCKET s,
const char FAR *buf,
int len,
int flags
);
不论是客户还是服务器应用程序都用send函数来向TCP连接的另一端发送数据。客户程序一般用send函数向服务器发送请求，而服务器则通常用send函数来向客户程序发送应答。该函数的第一个参数指定发送端套接字描述符；第二个参数指明一个存放应用程序要发送数据的缓冲区；第三个参数指明实际要发送的数据的字节数；第四个参数一般置0。这里只描述同步Socket的send函数的执行流程。当调用该函数时，send先比较待发送数据的长度len和套接字s的发送缓冲区的长度，如果len大于s的发送缓冲区的长度，该函数返回SOCKET_ERROR；如果len小于或者等于s的发送缓冲区的长度，那么send先检查协议是否正在发送s的发送缓冲中的数据，如果是就等待协议把数据发送完，如果协议还没有开始发送s的发送缓冲中的数据或者s的发送缓冲中没有数据，那么send就比较s的发送缓冲区的剩余空间和len，如果len大于剩余空间大小send就一直等待协议把s的发送缓冲中的数据发送完，如果len小于剩余空间大小send就仅仅把buf中的数据copy到剩余空间里（注意并不是send把s的发送缓冲中的数据传到连接的另一端的，而是协议传的，send仅仅是把buf中的数据copy到s的发送缓冲区的剩余空间里）。如果send函数copy数据成功，就返回实际copy的字节数，如果send在copy数据时出现错误，那么send就返回SOCKET_ERROR；如果send在等待协议传送数据时网络断开的话，那么send函数也返回SOCKET_ERROR。要注意send函数把buf中的数据成功copy到s的发送缓冲的剩余空间里后它就返回了，但是此时这些数据并不一定马上被传到连接的另一端。如果协议在后续的传送过程中出现网络错误的话，那么下一个Socket函数就会返回SOCKET_ERROR。（每一个除send外的Socket函数在执行的最开始总要先等待套接字的发送缓冲中的数据被协议传送完毕才能继续，如果在等待时出现网络错误，那么该Socket函数就返回SOCKET_ERROR）
注意：在Unix系统下，如果send在等待协议传送数据时网络断开的话，调用send的进程会接收到一个SIGPIPE信号，进程对该信号的默认处理是进程终止。

六、recv函数
int recv(
SOCKET s,
char FAR *buf,
int len,
int flags
);
不论是客户还是服务器应用程序都用recv函数从TCP连接的另一端接收数据。该函数的第一个参数指定接收端套接字描述符；第二个参数指明一个缓冲区，该缓冲区用来存放recv函数接收到的数据；第三个参数指明buf的长度；第四个参数一般置0。这里只描述同步Socket的recv函数的执行流程。当应用程序调用recv函数时，recv先等待s的发送缓冲中的数据被协议传送完毕，如果协议在传送s的发送缓冲中的数据时出现网络错误，那么recv函数返回SOCKET_ERROR，如果s的发送缓冲中没有数据或者数据被协议成功发送完毕后，recv先检查套接字s的接收缓冲区，如果s接收缓冲区中没有数据或者协议正在接收数据，那么recv就一直等待，只到协议把数据接收完毕。当协议把数据接收完毕，recv函数就把s的接收缓冲中的数据copy到buf中（注意协议接收到的数据可能大于buf的长度，所以在这种情况下要调用几次recv函数才能把s的接收缓冲中的数据copy完。recv函数仅仅是copy数据，真正的接收数据是协议来完成的），recv函数返回其实际copy的字节数。如果recv在copy时出错，那么它返回SOCKET_ERROR；如果recv函数在等待协议接收数据时网络中断了，那么它返回0。
注意：在Unix系统下，如果recv函数在等待协议接收数据时网络断开了，那么调用recv的进程会接收到一个SIGPIPE信号，进程对该信号的默认处理是进程终止。

七、bind函数
int bind(
SOCKET s,
const struct sockaddr FAR *name,
int namelen
);
当创建了一个Socket以后，套接字数据结构中有一个默认的IP地址和默认的端口号。一个服务程序必须调用bind函数来给其绑定一个IP地址和一个特定的端口号。客户程序一般不必调用bind函数来为其Socket绑定IP地址和断口号。该函数的第一个参数指定待绑定的Socket描述符；第二个参数指定一个sockaddr结构，该结构是这样定义的：
struct sockaddr {
u_short sa_family;
char sa_data[14];
};
sa_family指定地址族，对于TCP/IP协议族的套接字，给其置AF_INET。当对TCP/IP协议族的套接字进行绑定时，我们通常使用另一个地址结构：
struct sockaddr_in {
short sin_family;
u_short sin_port;
struct in_addr sin_addr;
char sin_zero[8];
};
其中sin_family置AF_INET；sin_port指明端口号；sin_addr结构体中只有一个唯一的字段s_addr，表示IP地址，该字段是一个整数，一般用函数inet_addr（）把字符串形式的IP地址转换成unsigned long型的整数值后再置给s_addr。有的服务器是多宿主机，至少有两个网卡，那么运行在这样的服务器上的服务程序在为其Socket绑定IP地址时可以把htonl(INADDR_ANY)置给s_addr，这样做的好处是不论哪个网段上的客户程序都能与该服务程序通信；如果只给运行在多宿主机上的服务程序的Socket绑定一个固定的IP地址，那么就只有与该IP地址处于同一个网段上的客户程序才能与该服务程序通信。我们用0来填充sin_zero数组，目的是让sockaddr_in结构的大小与sockaddr结构的大小一致。下面是一个bind函数调用的例子：
struct sockaddr_in saddr；
saddr.sin_family = AF_INET;
saddr.sin_port = htons(8888);
saddr.sin_addr.s_addr = htonl(INADDR_ANY);
bind(ListenSocket,(struct sockaddr *)&saddr,sizeof(saddr))；

八、listen函数
int listen( SOCKET s, int backlog );
服务程序可以调用listen函数使其流套接字s处于监听状态。处于监听状态的流套接字s将维护一个客户连接请求队列，该队列最多容纳backlog个客户连接请求。假如该函数执行成功，则返回0；如果执行失败，则返回SOCKET_ERROR。

九、accept函数
SOCKET accept(
SOCKET s,
struct sockaddr FAR *addr,
int FAR *addrlen
);
服务程序调用accept函数从处于监听状态的流套接字s的客户连接请求队列中取出排在最前的一个客户请求，并且创建一个新的套接字来与客户套接字创建连接通道，如果连接成功，就返回新创建的套接字的描述符，以后与客户套接字交换数据的是新创建的套接字；如果失败就返回INVALID_SOCKET。该函数的第一个参数指定处于监听状态的流套接字；操作系统利用第二个参数来返回新创建的套接字的地址结构；操作系统利用第三个参数来返回新创建的套接字的地址结构的长度。下面是一个调用accept的例子：
struct sockaddr_in ServerSocketAddr;
int addrlen;
addrlen=sizeof(ServerSocketAddr);
ServerSocket=accept(ListenSocket,(struct sockaddr *)&ServerSocketAddr,&addrlen);

十、connect函数
int connect(
SOCKET s,
const struct sockaddr FAR *name,
int namelen
);
客户程序调用connect函数来使客户Socket s与监听于name所指定的计算机的特定端口上的服务Socket进行连接。如果连接成功，connect返回0；如果失败则返回SOCKET_ERROR。下面是一个例子：
struct sockaddr_in daddr;
memset((void *)&daddr,0,sizeof(daddr));
daddr.sin_family=AF_INET;
daddr.sin_port=htons(8888);
daddr.sin_addr.s_addr=inet_addr("133.197.22.4");
connect(ClientSocket,(struct sockaddr *)&daddr,sizeof(daddr));

网友对该文章的评论 Windows

网友: 毛志君(ts398@sohu.com) 发表于: 2004-5-26 15:02:10

我在VC中编一个服务器和一个客户端
服务器是::
// ssDlg.cpp : implementation file
//

#include "stdafx.h"
#include "ss.h"
#include "ssDlg.h"
#include "afxsock.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

#define SD_RECEIVE 0x00
#define SD_SEND 0x01
#define SD_BOTH 0x02

#define DEFAULT_PORT 11000
#define DEFAULT_BUFFER 4096

int iPort = 11000;
BOOL bInterface = FALSE,
bRecvOnly = FALSE;
char chrTemp[DEFAULT_BUFFER];

/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App About

class CAboutDlg : public CDialog
{
public:
CAboutDlg();

// Dialog Data
//{{AFX_DATA(CAboutDlg)
enum { IDD = IDD_ABOUTBOX };
//}}AFX_DATA

// ClassWizard generated virtual function overrides
//{{AFX_VIRTUAL(CAboutDlg)
protected:
virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support
//}}AFX_VIRTUAL

// Implementation
protected:
//{{AFX_MSG(CAboutDlg)
//}}AFX_MSG
DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
//{{AFX_DATA_INIT(CAboutDlg)
//}}AFX_DATA_INIT
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CAboutDlg)
//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
//{{AFX_MSG_MAP(CAboutDlg)
// No message handlers
//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CSsDlg dialog

CSsDlg::CSsDlg(CWnd* pParent /*=NULL*/)
: CDialog(CSsDlg::IDD, pParent)
{ //{{AFX_DATA_INIT(CSsDlg)
m_get = _T("");
m_put = _T("");
m_lcl_IP = _T("");
m_far_IP = _T("");
m_far_Port = _T("");
m_lcl_Port = _T("");
//}}AFX_DATA_INIT
// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}

void CSsDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CSsDlg)
DDX_Control(pDX, IDC_BUTTON1, m_ServBGN);
DDX_Text(pDX, IDC_EDIT1, m_get);
DDX_Text(pDX, IDC_EDIT2, m_put);
DDX_Text(pDX, IDC_EDIT3, m_lcl_IP);
DDX_Text(pDX, IDC_EDIT4, m_far_IP);
DDX_Text(pDX, IDC_EDIT6, m_far_Port);
DDX_Text(pDX, IDC_EDIT5, m_lcl_Port);
// NOTE: the ClassWizard will add DDX and DDV calls here
//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CSsDlg, CDialog)
//{{AFX_MSG_MAP(CSsDlg)
ON_WM_SYSCOMMAND()
ON_WM_PAINT()
ON_WM_QUERYDRAGICON()
ON_BN_CLICKED(IDC_BUTTON1, OnButton1)
ON_BN_CLICKED(IDC_BUTTON2, OnButton2)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CSsDlg message handlers

BOOL CSsDlg::OnInitDialog()
{
CDialog::OnInitDialog();

// Add "About..." menu item to system menu.

// IDM_ABOUTBOX must be in the system command range.
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000);

CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
CString strAboutMenu;
strAboutMenu.LoadString(IDS_ABOUTBOX);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
}

// Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon

// TODO: Add extra initialization here
UpdateData(TRUE);
m_get = "127.0.0.1";
UpdateData(FALSE);
WORD wVersionRequested = MAKEWORD(1, 1);
WSADATA wsaData;
if (WSAStartup(wVersionRequested, &wsaData)) {
sprintf(chrTemp, "WSAStartup() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return -1;
}
char chrHstname[256];
int res = gethostname(chrHstname, sizeof(chrHstname));
if (res != 0) {
sprintf(chrTemp, "gethostname() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return -1;
}
hostent* pHostent = gethostbyname(chrHstname);
if (pHostent==NULL) {
sprintf(chrTemp, "gethostbyname() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return -1;
}
hostent& he = *pHostent;
printf("name=%snaliases=%snaddrtype=%dnlength=%dn",
he.h_name, he.h_aliases, he.h_addrtype, he.h_length);

sockaddr_in sa;
for (int nAdapter=0; he.h_addr_list[nAdapter]; nAdapter++) {
memcpy ( &sa.sin_addr.s_addr,
he.h_addr_list[nAdapter],
he.h_length );
}
WSACleanup();
UpdateData(TRUE);
m_lcl_IP = inet_ntoa(sa.sin_addr); // 显示IP地址串
// m_far_IP = inet_ntoa(sa.sin_addr);
m_lcl_Port = "11000";
m_get = "127.0.0.1 " + m_lcl_IP;
UpdateData(FALSE);

return TRUE; // return TRUE unless you set the focus to a control
}

void CSsDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
if ((nID & 0xFFF0) == IDM_ABOUTBOX)
{
CAboutDlg dlgAbout;
dlgAbout.DoModal();
}
else
{
CDialog::OnSysCommand(nID, lParam);
}
}

// If you add a minimize button to your dialog, you will need the code below
// to draw the icon. For MFC applications using the document/view model,
// this is automatically done for you by the framework.

void CSsDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // device context for painting

SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);

// Center icon in client rectangle
int cxIcon = GetSystemMetrics(SM_CXICON);
int cyIcon = GetSystemMetrics(SM_CYICON);
CRect rect;
GetClientRect(&rect);
int x = (rect.Width() - cxIcon + 1) / 2;
int y = (rect.Height() - cyIcon + 1) / 2;

// Draw the icon
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialog::OnPaint();
}
}

// The system calls this to obtain the cursor to display while the user drags
// the minimized window.
HCURSOR CSsDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}

void CSsDlg::OnButton1()
{
WSADATA wsaData;
SOCKET sckListen, sckClient;
int iAddrSize, ret;
struct sockaddr_in local, client;
char chrTemp[DEFAULT_BUFFER];
char chrRecv[DEFAULT_BUFFER];
char chrSend[DEFAULT_BUFFER];

if (WSAStartup(MAKEWORD(2,2),&wsaData) != 0){ //------------------------01
AfxMessageBox("Failed to load Winsock!");
return ;
}

sckListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); //---------------02
if (sckListen == SOCKET_ERROR){
sprintf(chrTemp, "socket() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return ;
}

UpdateData(TRUE);
iPort = atoi(m_lcl_Port);
UpdateData(FALSE);
local.sin_addr.s_addr = inet_addr(m_lcl_IP);
local.sin_family = AF_INET;
local.sin_port = htons(iPort);
if (bind(sckListen, (struct sockaddr *)&local, sizeof(local)) //--------03
== SOCKET_ERROR){
sprintf(chrTemp, "bind() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return ;
}

listen(sckListen, 5); //------------------------------------------------04

iAddrSize = sizeof(client);
m_ServBGN.EnableWindow(FALSE);
sckClient = accept(sckListen, (struct sockaddr *)&client, &iAddrSize); //05
//AfxMessageBox("accept End!");
m_ServBGN.EnableWindow(TRUE); //ServBGN按钮有效
if (sckClient == INVALID_SOCKET){
sprintf(chrTemp, "accept() failed:%d", WSAGetLastError());
AfxMessageBox(chrTemp);
return;
}

//hThread = CreateThread(NULL, 0, ClientThread, (LPVOID)sckClient, 0, &dwThreadID);
//AfxMessageBox("recv Begin!--4--");
ret = recv(sckClient, chrRecv, DEFAULT_BUFFER, 0); //-------------------06
if (ret == SOCKET_ERROR){
sprintf(chrTemp, "recv() failed : %d", WSAGetLastError());
AfxMessageBox(chrTemp);
return;
}

chrRecv[ret] = '\0';
UpdateData(TRUE);
m_get = chrRecv;
UpdateData(FALSE);

char backStr[] = " EchoByServ";
sprintf(chrSend, "%s%s", chrRecv, backStr);

int nLen = ret + sizeof(backStr);
ret = send(sckClient, chrSend, nLen, 0); //-----------------------------07
if (ret == SOCKET_ERROR){
sprintf(chrTemp, "send() failed : %d", WSAGetLastError());
AfxMessageBox(chrTemp);
return;
}//1054 WSAECONNRESET 1057 WSAENOTCONN

sprintf(chrTemp, "IP=%s|port=%d|size=%d|%s",
inet_ntoa(client.sin_addr),
ntohs(client.sin_port),
iAddrSize,
chrRecv);

UpdateData(TRUE);
//m_put = chrSend;
m_put = chrTemp;
m_far_IP = inet_ntoa(client.sin_addr);
m_far_Port.Format("%d", m_far_Port, ntohs(client.sin_port));
UpdateData(FALSE);

CTime cTime1=CTime::GetCurrentTime();
CTime cTime2=CTime::GetCurrentTime();
int miao1 = cTime1.GetSecond();
int miao2 = cTime2.GetSecond();
for ( ; ; ){
if ( (miao1 -miao2 ) >= 1 || (miao2 -miao1 ) >= 1 ){
break;
}
cTime2=CTime::GetCurrentTime();
miao2 = cTime2.GetSecond();
}

//shutdown(sckListen, SD_RECEIVE); //从容中断
closesocket(sckListen); //----------------------------------------------08
WSACleanup(); //--------------------------------------------------------09

}

void CSsDlg::OnButton2()
{
UpdateData(TRUE);
m_get = "";
m_put = "";
m_far_Port = "";
UpdateData(FALSE);
}
这么改成连续获取客户端发过来的数据包,一个数据包为48字节.

我好急呀,
我是在做毕业设计,6月1号就要教了.谢谢了

位置：中国教育学习网 > 电脑教育 > 程序设计 > VC语言 > 正文