c语言 线程phread 结合domain socket，c/s代码

服务端：

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <sys/unistd.h>
#include <sys/select.h>
#include <pthread.h>


#define MAXSIZE (4096)

static void pthread_proc(int *peer_ptr)
{
    char recvmsg[MAXSIZE], sendmsg[MAXSIZE];
    int peer = *peer_ptr;
    static int ii;

    printf("phread %d\n", ii++);
    while (1) {
        memset(recvmsg, 0, MAXSIZE);
        memset(sendmsg, 0, MAXSIZE);

        if (read(peer, recvmsg, sizeof(recvmsg)) < 0) {
            perror("recv err");
            break;
        }

        printf("client: %s\n", recvmsg);
        if (!strcmp(recvmsg, "quit")) {
            break;
        }

        strcpy(sendmsg, recvmsg);
        strcat(sendmsg, " send back");
        write(peer, sendmsg, strlen(sendmsg));
    }
    close(peer);

    return;
}

int main(int argc, char *argv[])
{
    int sockfd, peer, len, ready;
    fd_set fds;
    struct sockaddr_un serv_addr;
    pthread_t phd;

    sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("socket error");
        return -1;
    }

    serv_addr.sun_family = AF_UNIX;
    strcpy((char *)serv_addr.sun_path, "e:\\sockfile");
    unlink("e:\\sockfile");

    if (bind(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
        perror("bind err");
        return -1;
    }

    if (listen(sockfd, 1) < 0) {
        perror("listen error");
        close(sockfd);
        return -1;
    }

    len = sizeof(serv_addr);
    while (1) {
        printf("begin to accept\n");
        FD_ZERO(&fds);
        FD_SET(sockfd, &fds);

        ready = select(sockfd + 1, &fds, 0, 0, NULL);
        if (ready > 0 && FD_ISSET(sockfd, &fds)) {
            peer = accept(sockfd, (struct sockaddr *)&serv_addr, &len);
     if (peer < 0) {
     perror("Server: accept failed.\n");
     close(sockfd);
                return -1;
            }
            if (pthread_create(&phd, NULL, (void *)pthread_proc, (void *)&peer) != 0) {
                close(peer);
            }
        }
    }

    return 0;
}

客户端：

 

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <sys/un.h>
#include <sys/socket.h>
#include <sys/unistd.h>
#include <sys/select.h>

#define MAXSIZE (4096)

int main(int argc, char *argv[])
{
    int sockfd, ret;
    unsigned long opt;
    struct sockaddr_un serv_addr;
    char recvmsg[MAXSIZE], sendmsg[MAXSIZE];

    sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("socket error");
        return -1;
    }

    memset(&serv_addr, 0, sizeof(serv_addr));
    serv_addr.sun_family = AF_UNIX;
    strcpy((char *)serv_addr.sun_path, "e:\\sockfile");

    ret = 0;
    if ((ret = connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr))) < 0) {
        perror("connect err");
        return -1;
    }
    printf("connect to server success!\n");

    while (1) {
        memset(sendmsg, 0, sizeof(sendmsg));
        memset(recvmsg, 0, sizeof(recvmsg));

        printf("client:\n");
        gets(sendmsg);

        if (write(sockfd, sendmsg, strlen(sendmsg)) < 0) {
            printf("send msg failed!\n");
            break;
        }

        if (!strcmp(sendmsg, "quit")) {
            break;
        }
        if (!strcmp(sendmsg, "quit server")) {
            break;
        }

        if (read(sockfd, recvmsg, MAXSIZE) < 0) {
            printf("recv msg failed!\n");
            break;
        }

        printf("server:\n%s\n", recvmsg);
    }

    printf("\nclose connection!\n\n");
    close(sockfd);

    return 0;
}