利用套接字实现进程通信一例

下面程序实现的功能是：客户端将从键盘输入的内容发送给服务器，然后服务器在将受到的数据原封不动的发给客户端。

先看看服务器端的程序：

/*
 * =====================================================================================
 *
 *       Filename:  server.c
 *
 *    Description:  tcp
 *
 *        Version:  1.0
 *        Created:  03/11/2013 02:34:43 PM
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  YOUR NAME (),
 *        Company:
 *
 * =====================================================================================
 */

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>

typedef struct sockaddr SA;  //
#define N 128

int main(int argc, char *argv[])
{
    int listenfd, confd;  //定义listend用于存放监听套接字的描述符，confd用于存放accept返回的已建立连接套接字的描述符。
    struct sockaddr_in my_addr, peer_addr;//my_addr用于存放监听套接字要绑定的信息，peer_addr存放客户端套接字的信息
    socklen_t peer_len = sizeof(my_addr);  //peer_len最好定义时初始化，且必须初始化！
    char buffer[N]; //
    int n;

    if(argc < 3)  //参数检查
    {
        printf("input error! %s <ip> <port>\n",argv[0]);
        exit(-1);
    }

    if((listenfd = socket(PF_INET, SOCK_STREAM, 0)) < 0)  //创建套接字，用于TCP连接
    {
        perror("socket error!");
        exit(-1);
    }

   bzero(&my_addr, sizeof(my_addr));  //先将my_addr清空

   //初始化监听套接字的绑定信息
   my_addr.sin_family = PF_INET;     //网络协议

   /*
      ./client 192.168.1.173 8888
      argv[2]中是字符串“8888”的首地址，atoi将字符串“8888”，转化成数字8888，
      因为端口号是需要发送的，所以需要转换成网络字节序，通过htons实现
   */
   my_addr.sin_port = htons(atoi(argv[2]));

   my_addr.sin_addr.s_addr = inet_addr(argv[1]);//将字符串"192.168.1.173"转成32位的无符号整型

   if(bind(listenfd, (SA *)&my_addr, sizeof(my_addr)) < 0)  //将监听套接字进行绑定
   {
       perror("error bind");
       exit(-1);
   }

   if(listen(listenfd, 5) < 0)  //将监听套接字设置为监听模式，等待请求队列长度为5
   {

       perror("listen error!");
       exit(-1);
   }

   while(1)
   {
   /*
         当没有客户端请求时，服务器在此阻塞。直到有客户端请求，然后返回一个新的套接字描述符confd，与
         listenfd是相同类型的，但是confd可以用于与客户端收发数据，而listenfd不行，它只能监听。
         注意：accept返回的是一个新的已经与客户端建立连接的套接字confd，他有两个缓冲区，输入和输出，
         只有他才可以与客户端进行通信。他的类型与监听套接字一样。
   */
       if((confd = accept(listenfd, (SA *)&peer_addr, &peer_len)) < 0)
       {
           perror("accpt error!");
           exit(-1);
       }

       printf("client : [%s:%d]\n",inet_ntoa(peer_addr.sin_addr), ntohs(peer_addr.sin_port));

       while(recv(confd, buffer, N,0) > 0)  //将套接字confd的接收缓冲区的数据拷贝到buffer，当客户端关闭连接时，返回0。
       {
           printf("I have get > %s",buffer);
           if(send(confd, buffer, N, 0) == -1)   //将buffer中的数据拷贝到confd的发送缓冲区
           {
               perror("fail to send");
               exit(-1);
           }
       }

       printf("client : [%s:%d] have closed!\n",inet_ntoa(peer_addr.sin_addr), ntohs(peer_addr.sin_port));
       close(confd);
   }

    return 0;
}

 

客户端：

/*
 * =====================================================================================
 *
 *       Filename:  server.c
 *
 *    Description:  tcp
 *
 *        Version:  1.0
 *        Created:  03/11/2013 02:34:43 PM
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  YOUR NAME (),
 *        Company:
 *
 * =====================================================================================
 */

#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>


#define N 128

typedef struct sockaddr SA;

int main(int argc, char *argv[])
{
    int sockfd;  //客户端套接字，客户端只需一个，且不需要绑定
    struct sockaddr_in server_addr;  //服务器的ip端口信息
    char buffer[N];

    if(argc < 3)
    {
        printf("usage! %s <ip> <port>\n",argv[0]);
        exit(-1);
    }

    if((sockfd = socket(PF_INET, SOCK_STREAM, 0)) < 0)   //创建客户端套接字
    {
        perror("socket error!");
        exit(-1);
    }

   bzero(&server_addr, sizeof(server_addr));

   /*
   初始化要连接的服务器信息
   */
   server_addr.sin_family = PF_INET;
   server_addr.sin_port = htons(atoi(argv[2]));
   server_addr.sin_addr.s_addr = inet_addr(argv[1]);

   if(connect(sockfd, (SA *)&server_addr, sizeof(server_addr)) < 0)  //连接服务器
   {
       perror("fail to connect");
       exit(-1);
   }

   printf("> ");
   while(fgets(buffer, N, stdin) != 0)
   {
       if(send(sockfd, buffer, N, 0) == -1)
       {
           perror("fail to send");
           exit(-1);
       }
        if(strncmp(buffer, "quit", 4) == 0)
        {
            break;
        }
       bzero(buffer, N);

       if(recv(sockfd, buffer, N, 0) == -1)
       {
           perror("fail to recv");
           exit(-1);
       }
       printf("-------->%s\n> ",buffer);
   }
   close(sockfd);

    return 0;
}