网络编程（TCP循环服务）

/*

 * 数据流套接字实现 客户——服务器之间数据的传输

 * 服务器程序

 * Lzy 2011-6-21

 */

 

#include

#include

#include

#include

#include

#include

#include

 

#define SERVPORT  5555   //服务器监听端口

#define BACKLOG       10      //请求队列的长度数

 

int main(void)

{

    int ret;

    time_t tt;

    struct tm *ttm;

   

    int socketfd;         //定义监听Socket描述符

    int clientfd;         //定义数据传输Socket描述符

    struct sockaddr_in host_addr;   //本机IP地址和端口信息

    struct sockaddr_in client_addr; //客户端IP地址和端口信息

    int addrlen = sizeof(client_addr);

    char buf[256];            //发送数据缓冲区

 

    /*创建套接字*/

    socketfd = socket(AF_INET, SOCK_STREAM, 0);   //使用TCP/IP协议族 数据流

    if(socketfd == -1)

    {

        perror("socketfd");

        exit(0);

    }

   

    /*绑定套接字*/

    memset(&host_addr, 0, sizeof(host_addr));

    host_addr.sin_family = AF_INET;         //TCP/IP协议

    host_addr.sin_port = htons(SERVPORT);  //把主机字节顺序转换为网络字节顺序

    host_addr.sin_addr.s_addr = INADDR_ANY;   //填入本机IP地址

    ret = bind(socketfd, (struct sockaddr *)&host_addr, sizeof(host_addr));   /*绑定套接字*/

    if(ret == -1)

    {

        perror("blind");

        exit(0);

    }

 

    /**监听网络端口**/

    ret = listen(socketfd, BACKLOG);  

    if(ret == -1)

    {

        perror("listen");

        exit(0);

    }

   

    while(1)  

    {      

        clientfd = accept(socketfd, (struct sockaddr *)&client_addr, &addrlen);   /**接收链接请求**/

        if(clientfd == -1)

        {

            perror("connect");

            exit(0);

        }

       

        printf("Client IP:%s\n", inet_ntoa(client_addr.sin_addr.s_addr));  //打印连接上客服IP地址

        tt = time(NULL);

        ttm = localtime(&tt);

        strcpy(buf, asctime(ttm));

       

        send(clientfd, buf, strlen(buf), 0);               //发送数据

        close(clientfd);

    }

 

    return 0;

}

 

 

 

/*

 * 数据流套接字实现 客户——服务器之间数据的传输

 * 客户端程序

 * Lzy 2011-6-21

 */

 

#include

#include

#include

#include

#include

#include

 

#define SERVPORT  5555   //服务器监听端口

#define BACKLOG       10      //请求队列的长度数

 

int main(int argc, char *argv[])

{

    int ret;

    int socketfd;         //定义Socket描述符    

    struct sockaddr_in serv_addr;   //客户端IP地址和端口信息

    int addrlen = sizeof(serv_addr);

    char buf[256];            //发送数据缓冲区

 

    if(argc != 2)

    {

        printf("命令行参数太少\n");

        exit(0);

    }

   

    /*创建套接字*/

    socketfd = socket(AF_INET, SOCK_STREAM, 0);   //使用TCP/IP协议族 数据流

    if(socketfd == -1)

    {

        perror("socketfd");

        exit(0);

    }

   

    /*建立连接*/

    memset(&serv_addr, 0, sizeof(serv_addr));

    serv_addr.sin_family = AF_INET;                 //TCP/IP协议

    serv_addr.sin_port = htons(SERVPORT);          //把主机字节顺序转换为网络字节顺序

    inet_aton(argv[1], (struct sockaddr *)&serv_addr.sin_addr.s_addr); //填入本机IP地址

    ret = connect(socketfd, (struct sockaddr *)&serv_addr, addrlen);   /*建立连接*/

    if(ret == -1)

    {

        perror("connect");

        exit(0);

    }

   

    while(1)  

    {              

        recv(socketfd, buf, sizeof(buf), 0);               //接收数据

        printf("接收：%s", buf);

        sleep(3);

    }

 

    return 0;

}

 

 

/*
 * 网络字节顺序转换
 * 主机和网络字节序值转换
 * 对数据字节顺序进行转换
 * Lzy 2011-6-21
 */

#include <stdio.h>
#include <stdlib.h>
#include <netinet/in.h>

int main(void)
{
    int x = 0x12345678;

    printf("x = %x\n",x);
    printf("转换之后：%x\n", htonl(x));

    return 0;
}


/*
 * 建立全双工“管道”
 * Lzy 2011-6-21
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>

int main(void)
{
    int fd[2];
    pid_t pid;
    int ret;
    char buf[30];

    ret = socketpair(PF_LOCAL, SOCK_STREAM, 0, fd);
    if(ret == -1)
    {
        perror("socketpair");
        exit(0);
    }

    pid = fork();
    if(pid == 0)
    {
        close(fd[0]);
        while(1)
        {
            printf("<子进程>发送：");
            scanf("%s",buf);
            write(fd[1], buf, strlen(buf));

            bzero(buf, sizeof(buf));
            read(fd[1], buf, sizeof(buf));
            printf("<子进程>接收：%s\n",buf);
        }
    }
    else if(pid > 0)
    {
        close(fd[1]);
        while(1)
        {
            bzero(buf, sizeof(buf));
            read(fd[0], buf, sizeof(buf));
            printf("<父进程>接收：%s\n",buf);

            printf("<父进程>发送：");
            scanf("%s",buf);
            write(fd[0], buf, strlen(buf));
        }
    }
    return 0;
}