当前位置:早雪网网络学院编程文档其他语言 → 网络socket编程指南

网络socket编程指南

减小字体 增大字体 作者:未知  来源:supcode.com收集整理  发布时间:2005-7-1 14:57:35
address information */
if (argc != 2) {
   fprintf(stderr,"usage: client hostname\n");
   exit(1);
   }
if ((he=gethostbyname(argv[1])) == NULL) { /* get the host info */
   herror("gethostbyname");
   exit(1);
   }

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
   perror("socket");
   exit(1);
   }

their_addr.sin_family = AF_INET; /* host byte order */
  their_addr.sin_port = htons(PORT); /* short, network byte order */
  their_addr.sin_addr = *((struct in_addr *)he->h_addr);
  bzero(&(their_addr.sin_zero),; /* zero the rest of the struct */
if (connect(sockfd, (struct sockaddr *)&their_addr,sizeof(struct
sockaddr)) == -1) {
   perror("connect");
   exit(1);
   }
if ((numbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1) {
   perror("recv");
   exit(1);
   }
buf[numbytes] = '\0';
printf("Received: %s",buf);
close(sockfd);
return 0;
   }
注意,如果你在运行服务器之前运行客户程序,connect() 将返回 "Connection refused" 信息,这非常有用。


数据包 Sockets

我不想讲更多了,所以我给出代码 talker.c 和 listener.c。
listener 在机器上等待在端口 4590 来的数据包。talker 发送数据包到 一定的机器,它包含用户在命令行输入的内容。
这里就是 listener.c:
#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 MYPORT 4950 /* the port users will be sending to */
#define MAXBUFLEN 100
main()
   {
   int sockfd;
   struct sockaddr_in my_addr; /* my address information */
   struct sockaddr_in their_addr; /* connector's address information */
   int addr_len, numbytes;
   char buf[MAXBUFLEN];
if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
   perror("socket");
   exit(1);
   }
my_addr.sin_family = AF_INET; /* host byte order */
   my_addr.sin_port = htons(MYPORT); /* short, network byte order */
   my_addr.sin_addr.s_addr = INADDR_ANY; /* auto-fill with my IP */
   bzero(&(my_addr.sin_zero),; /* zero the rest of the struct */
if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr))
\
   == -1) {
   perror("bind");
   exit(1);
   }
addr_len = sizeof(struct sockaddr);
   if ((numbytes=recvfrom(sockfd, buf, MAXBUFLEN, 0, \
   (struct sockaddr *)&their_addr, &addr_len)) == -1) {
   perror("recvfrom");
   exit(1);
   }
printf("got packet from %s\n",inet_ntoa(their_addr.sin_addr));
   printf("packet is %d bytes long\n",numbytes);
   buf[numbytes] = '\0';
   printf("packet contains \"%s\"\n",buf);
close(sockfd);
   }

注意在我们的调用 socket(),我们最后使用了 SOCK_DGRAM。同时, 没有必要去使用 listen() 或者 accept()。我们在使用无连接的数据报套接字!

下面是 talker.c:
#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 MYPORT 4950 /* the port users will be sending to */
int main(int argc, char *argv[])
   {
   int sockfd;
   struct sockaddr_in their_addr; /* connector's address information */
   struct hostent *he;
   int numbytes;

if (argc != 3) {
   fprintf(stderr,"usage: talker hostname message\n");
   exit(1);
   }

if ((he=gethostbyname(argv[1])) == NULL) { /* get the host info */
   herror("gethostbyname");
   exit(1);
   }

if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
   perror("socket");
   exit(1);
   }

their_addr.sin_family = AF_INET; /* host byte order */
   their_addr.sin_port = htons(MYPORT); /* short, network byte order
*/
   their_addr.sin_addr = *((struct in_addr *)he->h_addr);
   bzero(&(their_addr.sin_zero),; /* zero the rest of the struct */
if ((numbytes=sendto(sockfd, argv[2], strlen(argv[2]), 0, \
   (struct sockaddr *)&their_addr, sizeof(struct sockaddr))) == -1) {
   perror("sendto");
   exit(1);
   }
printf("sent %d bytes to
%s\n",numbytes,inet_ntoa(their_addr.sin_addr));
close(sockfd);
return 0;
   }

这就是所有的了。在一台机器上运行 listener,然后在另外一台机器上 运行 talker。观察它们的通讯!
除了一些我在上面提到的数据套接字连接的小细节外,对于数据套接 字,我还得说一些,当一个讲话者呼叫connect()函数时并指定接受者的地 址时,从这点可以看出,讲话者只能向connect()函数指定的地址发送和接 受信息。因此,你不需要使用sendto()和recvfrom(),你完全可以用send() 和recv()代替。


阻塞

  阻塞,你也许早就听说了。"阻塞"是 "sleep" 的科技行话。你可能注意 到前面运行的 listener 程序,它在那里不停地运行,等待数据包的到来。 实际在运行的是它调用 recvfrom(),然后没有数据,因此 recvfrom() 说" 阻塞 (block)",直到数据的到来。

很多函数都利用阻塞。accept() 阻塞,所有的 recv*() 函数阻塞。它 们之所以能这样做是因为它们被允许这样做。当你第一次调用 socket() 建 立套接字描述符的时候,内核就将它设置为阻塞。如果你不想套接字阻塞, 你就要调用函数 fcntl():
#include "unistd.h"
  #include "fontl.h"
   .
   .
   sockfd = socket(AF_INET, SOCK_STREAM, 0);
   fcntl(sockfd, F_SETFL, O_NONBLOCK);
   .
   .
  通过设置套接字为非阻塞,你能够有效地"询问"套接字以获得信息。如 果你尝试着从一个非阻塞

上一页  [1] [2] [3] [4] [5] [6] [7] [8] [9]  下一页

[数据载入中...] [返回上一页] [打 印]