Posted on 2007-12-01 00:22
张旭 阅读(624)
评论(0) 编辑 收藏 引用
今天重新把socket编程中的每一个函数的功能和说明都仔细的看了一遍,也有了更深一层的理解。在经历一次面试的失利之后,我觉得最大的问题就出在没有对学过的知识力求甚解,导致对概念不清楚。所以在看这部分知识的时候,倍加用心的研究。
socket编程中主要用到一个结构 sockaddr和以下几个函数,socket(),bind(),connect(),listen(),accept(),send(),recv()。
bind函数是使用listen函数的必要条件,如果只需要connect的话,bind是不需要的。bind的作用是将套接字和机器的端口联系起来。
connect()是建立两台电脑连接的必要函数,首先要有一个已经建立好的socket套接字,还有你要连接的目标主机的ip地址以及端口号等信息。
accept(),当connect的时候,主机需要通过accept来接受本次连接,accept需要对套接字进行bind()。当accept成功之后,函数会返回一个新的套接字描述符,通过新的描述符可以真对新的套接字进行send和recv操作。
listen()是对端口的监听,你可以设定一个列队的数量上线,这样,在多个访问请求到达的时候,可以排成队伍,超过列队上限的访问将被拒绝。
简单的服务器
这个服务器所做的全部工作是在流式连接上发送字符串 "Hello, World!\n"。你要测试这个程序的话,可以在一台机器上运行该程序,然后 在另外一机器上登陆:
$ telnet remotehostname 3490
remotehostname 是该程序运行的机器的名字。
服务器代码:
1
#include <stdio.h>
2
#include <stdlib.h>
3
#include <errno.h>
4
#include <string.h>
5
#include <sys/types.h>
6
#include <netinet/in.h>
7
#include <sys/socket.h>
8
#include <sys/wait.h>
9
#define MYPORT 3490 /*定义用户连接端口*/
10
#define BACKLOG 10 /*多少等待连接控制*/
11
main()
12![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedBlockStart.gif)
{
13![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
int sockfd, new_fd; /**//* listen on sock_fd, new connection on new_fd
14
*/
15![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
struct sockaddr_in my_addr; /**//* my address information */
16![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
struct sockaddr_in their_addr; /**//* connector's address information */
17
int sin_size;
18![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
19
perror("socket");
20
exit(1);
21
}
22![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
23![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
my_addr.sin_family = AF_INET; /**//* host byte order */
24![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
my_addr.sin_port = htons(MYPORT); /**//* short, network byte order */
25![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
my_addr.sin_addr.s_addr = INADDR_ANY; /**//* auto-fill with my IP */
26![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
bzero(&(my_addr.sin_zero),; /**//* zero the rest of the struct */
27![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
28
if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct
29![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
sockaddr))== -1)
{
30
perror("bind");
31
exit(1);
32
}
33![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if (listen(sockfd, BACKLOG) == -1)
{
34
perror("listen");
35
exit(1);
36
}
37![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
38![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
while(1)
{ /**//* main accept() loop */
39
sin_size = sizeof(struct sockaddr_in);
40
if ((new_fd = accept(sockfd, (struct sockaddr *)&their_addr, \
41![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
&sin_size)) == -1)
{
42
perror("accept");
43
continue;
44
}
45
printf("server: got connection from %s\n", \
46
inet_ntoa(their_addr.sin_addr));
47![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if (!fork())
{ /**//* this is the child process */
48
if (send(new_fd, "Hello, world!\n", 14, 0) == -1)
49
perror("send");
50
close(new_fd);
51
exit(0);
52
}
53![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
close(new_fd); /**//* parent doesn't need this */
54![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
while(waitpid(-1,NULL,WNOHANG) > 0); /**//* clean up child processes */
55
}
56
}
57![](http://www.cppblog.com/Images/OutliningIndicators/None.gif)
58![](http://www.cppblog.com/Images/OutliningIndicators/None.gif)
简单的客户程序
这个程序比服务器还简单。这个程序的所有工作是通过 3490 端口连接到命令行中指定的主机,然后得到服务器发送的字符串。
客户代码:
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#define PORT 3490 /* 客户机连接远程主机的端口 */
#define MAXDATASIZE 100 /* 每次可以接收的最大字节 */
int main(int argc, char *argv[])
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedBlockStart.gif)
{
int sockfd, numbytes;
char buf[MAXDATASIZE];
struct hostent *he;
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
struct sockaddr_in their_addr; /**//* connector's address information */
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if (argc != 2)
{
fprintf(stderr,"usage: client hostname\n");
exit(1);
}
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if ((he=gethostbyname(argv[1])) == NULL)
{ /**//* get the host info */
herror("gethostbyname");
exit(1);
}
![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
perror("socket");
exit(1);
}
![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
their_addr.sin_family = AF_INET; /**//* host byte order */
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
their_addr.sin_port = htons(PORT); /**//* short, network byte order */
their_addr.sin_addr = *((struct in_addr *)he->h_addr);
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
bzero(&(their_addr.sin_zero),; /**//* zero the rest of the struct */
if (connect(sockfd, (struct sockaddr *)&their_addr,sizeof(struct
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
sockaddr)) == -1)
{
perror("connect");
exit(1);
}
![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
if ((numbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1)
{
perror("recv");
exit(1);
}
buf[numbytes] = '\0';
printf("Received: %s",buf);
close(sockfd);
return 0;
}
![](http://www.cppblog.com/Images/OutliningIndicators/None.gif)
![](http://www.cppblog.com/Images/OutliningIndicators/None.gif)