基于TCP的服务器端/客户端(2) 三次握手/四次挥手-蒲公英云

回声客户端的完美实现

回声客户端问题解决办法

为了确保read函数能读取完所有write函数发送的数据，可以通过在接受时用一个变量记录接受的数据量是否和发送的数据相同（或者大于发送量）

改进后的客户端代码：

/* 回声客户端2 */
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
#define BUF_SIZE 1024
void error_handling(char *message)
{
    fputs(message,stderr);
    fputc('\n',stderr);
    exit(1);
}
int main(int argc,char *argv[])
{
    int sock;
    char message[BUF_SIZE];
    int str_len,recv_len,recv_cnt;
    struct sockaddr_in serv_adr;
    if(argc != 3) {
        printf("Usage : %s <IP> <port>\n",argv[0]);
        exit(1);
    }
    sock = socket(PF_INET,SOCK_STREAM,0);
    if (sock == -1)
        error_handling("socket() error!");
    memset(&serv_adr,0,sizeof(serv_adr));
    serv_adr.sin_family = AF_INET;
    serv_adr.sin_addr.s_addr = inet_addr(argv[1]);
    serv_adr.sin_port = htons(atoi(argv[2]));
    if (connect(sock,(struct sockaddr*) &serv_adr,sizeof(serv_adr)) == -1)
        error_handling("connect() error!");
    else 
        puts("Connected.........");
    while (1) {
        fputs("Input message(Q to quit): ",stdout);
        fgets(message,BUF_SIZE,stdin);
        if (!strcmp(message,"q\n") || !strcmp(message,"Q\n"))        // 输入q/Q退出
            break;
        str_len = write(sock,message,strlen(message));
        recv_len = 0;
        while (recv_len < str_len) {                //确保读取的数据大于等于发送的数据。
            recv_cnt = read(sock,&message[recv_len],BUF_SIZE-1);
            if (recv_cnt == -1)
                error_handling("read() error!");
            recv_len += recv_cnt;
        }
        message[str_len] = 0;
        printf("Message from server: %s",message);
    }
    close(sock);
    return 0;
}

54-59行利用循环条件石读取的数据大于等于发送的数据。

如果问题不在于回声客户端：定义应用层协议

应用层协议不是高深莫测的存在，只不过是为特定程序的实现而制定的规则。

例如程序中：收到Q就立即终止连接

服务端/客户端实现过程中逐步定义的这些规则集合就是应用层协议。

计算器服务器端/客户端示例

编写程序前设计了如下应用层协议：

这种程度的协议相当于实现了一半程序，说明了应用层协议设计在网络编程中的重要性。

客户端：

/* 计算器客户端 */
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
#define BUF_SIZE 1024
void error_handling(char *message)
{
    fputs(message,stderr);
    fputc('\n',stderr);
    exit(1);
}
int main(int argc,char *argv[])
{
    int sock;
    char message[BUF_SIZE];
    int len,str_len;
    struct sockaddr_in serv_adr;
    if(argc != 3) {
        printf("Usage : %s <IP> <port>\n",argv[0]);
        exit(1);
    }
    sock = socket(PF_INET,SOCK_STREAM,0);
    if (sock == -1)
        error_handling("socket() error!");
    memset(&serv_adr,0,sizeof(serv_adr));
    serv_adr.sin_family = AF_INET;
    serv_adr.sin_addr.s_addr = inet_addr(argv[1]);
    serv_adr.sin_port = htons(atoi(argv[2]));
    if (connect(sock,(struct sockaddr*) &serv_adr,sizeof(serv_adr)) == -1)
        error_handling("connect() error!");
    else 
        puts("Connected.........");
    scanf("%d",&len);
    for (int i=0; i < len; i++ ) {
        printf("读入第%d个数据:",i+1);
        scanf("%d",(int*)&message[i];
    }
    fgetc(stdin);                //读取运算符之前先用fgetc函数删除缓冲区中的字符\n
    printf("读取operator:");
    scanf("%c",&message[len]);
    write(sock,message,strlen(message));
    int result = 0;
    read(sock,&result,len);
    printf("The result is %d",result);
    close(sock);
    return 0;
}

服务器端：

/* 计算服务器端 */
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
#define BUF_SIZE 1024
void error_handling(char *message)
{
    fputs(message,stderr);
    fputc('\n',stderr);
    exit(1);
}
int main(int argc,char *argv[])
{
    int serv_sock, clnt_sock;
    char message[BUF_SIZE];
    int str_len, i;
    struct sockaddr_in serv_adr, clnt_adr;
    socklen_t clnt_adr_sz;
    if (argc != 2) {
        printf("Usage : %s <port> \n",argv[0]);
        exit(1);
    }
    serv_sock = socket(PF_INET,SOCK_STREAM,0);
    if (serv_sock == -1)
        error_handling("socket() error!");
    memset(&serv_adr,0,sizeof(serv_adr));
    serv_adr.sin_family = AF_INET;
    serv_adr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_adr.sin_port = htons(atoi(argv[1]));
    if (bind(serv_sock,(struct sockaddr*) &serv_adr,sizeof(serv_adr)) == -1)
        error_handling("bind() error!");
    if (listen(serv_sock,5) == -1)
        error_handling("listen() error!");
    clnt_adr_sz = sizeof(clnt_adr);
    for (i = 0; i < 5; i++)                //迭代5次
    {
        clnt_sock = accept(serv_sock,(struct sockaddr*)&clnt_adr,&clnt_adr_sz);
        if (clnt_sock == -1)
            error_handling("accept() error!");
        else 
            printf("Connected client %d\n",i+1);
        str_len = read(clnt_sock,message,BUF_SIZE);
        int result = 0;
        char op = message[str_len - 1]; 
        for (int a = 0; a < str_len-1 ; ++a)
        {
            switch(op) {
                case '+':    result += message[a];    break;
                case '-':    result -= message[a];    break;
                case '*':    result *= message[a];    break;
                case '/':    result /= message[a];    break;
                default :    printf("operator is wrong!\n");
            }
        }
        printf("计算结果是:%d\n",result);
        write(clnt_sock,(char*)&result,1);
        close(clnt_sock);
    }
    close(serv_sock);
    return 0;
}