服務端與客戶端單連接
服務端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void * thread_write(void *argv)
{unsigned char * buf_sock_write;buf_sock_write = (unsigned char *)malloc(30);int client_fd = *((int *)argv);//以ctrl+D為結束信號,結束本端的寫線程while (read(STDIN_FILENO,buf_sock_write,30)){send(client_fd,buf_sock_write,30,0);memset(buf_sock_write,0,30);}printf("服務端收到關閉信號\n");//關閉WR時,對端的recv會收到一個0字節的數據包,從而結束對端讀線程,不同時關閉讀端是為了接收對端的關閉信號//本端關閉寫端,但是仍然可以接收數據包shutdown(client_fd,SHUT_WR);free(buf_sock_write);
}void * thread_read(void *argv)
{unsigned char * buf_sock_read;buf_sock_read = (unsigned char *)malloc(30);int client_fd = *((int *)argv);//對端關閉WR之后,本端的recv會接收到一個0字節的數據包,從而結束本端的讀線程while (recv(client_fd,buf_sock_read,30,0)){printf("%s",buf_sock_read);memset(buf_sock_read,0,30);}printf("客戶端斷開連接\n");free(buf_sock_read);
}int main(int argc, char const *argv[])
{int server_fd,tmp,client_fd;//創建服務端,客戶端ip地址結構體struct sockaddr_in server,client;memset(&server,0,sizeof(server));memset(&client,0,sizeof(client));//1,創建服務端套接字并返回文件描述符,家族選擇AF_INET(IPV4),使用TCP就選擇SOCK_STREAM,UDP就選擇SOCK_DGRAMserver_fd = socket(AF_INET,SOCK_STREAM,0);//2,設置服務端的ip和端口號server.sin_family = AF_INET;inet_pton(AF_INET,"0.0.0.0",&server.sin_addr);server.sin_port = htons(8888);//3,將套接字綁定地址,我們使用的是IPV4專屬的struct sockaddr_in結構體,需要強轉為專用的struct sockaddr *tmp = bind(server_fd,(struct sockaddr *)&server,sizeof(server));handle_error("bind",tmp);//4,服務端進入監聽模式,隨時準備接受連接tmp = listen(server_fd,128);handle_error("listen",tmp);//5,服務端接受客戶端的連接,同時會獲取到客戶端套接字的文件描述符和ip地址等信息,通過文件描述符和客戶端進行通信socklen_t client_addr_len;client_fd = accept(server_fd,(struct sockaddr *)&client,&client_addr_len);printf("客戶端連接成功\n");pthread_t thread_id_write;pthread_t thread_id_read;pthread_create(&thread_id_write,NULL,thread_write,(void *)&client_fd);pthread_create(&thread_id_read,NULL,thread_read,(void *)&client_fd);pthread_join(thread_id_write,NULL);pthread_join(thread_id_read,NULL);close(server_fd);close(client_fd);return 0;
}
客戶端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void * thread_write(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_write = (unsigned char *)malloc(30);//客戶端同樣以ctrl+D為關閉信號,關閉寫端while (read(STDIN_FILENO,buf_sock_write,30)){send(client_fd,buf_sock_write,30,0);memset(buf_sock_write,0,30);}printf("客戶端收到關閉信號\n");//關閉寫功能會向對端發送一個0字節的數據包,不同時關閉讀端是為了接收對端的關閉信號//本端關閉寫端,但是仍然可以接收數據包shutdown(client_fd,SHUT_WR);free(buf_sock_write);
}void * thread_read(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_read = (unsigned char *)malloc(30);//對端關閉WR之后,本端的recv會接收到一個0字節的數據包,從而結束本端的讀線程while (recv(client_fd,buf_sock_read,30,0)){printf("%s",buf_sock_read);memset(buf_sock_read,0,30);}printf("服務端關閉連接\n");free(buf_sock_read);
}int main(int argc, char const *argv[])
{int client_fd,tmp;struct sockaddr_in server_addr,client_addr;memset(&server_addr,0,sizeof(server_addr));memset(&client_addr,0,sizeof(client_addr));//1,創建套接字client_fd = socket(AF_INET,SOCK_STREAM,0);handle_error("socket",client_fd);//2,設置服務端的ip地址和端口號inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);server_addr.sin_family = AF_INET;server_addr.sin_port = htons(8888);//端口號要和服務端設置的相匹配//3,綁定套接字,客戶端可以跳過本步驟,會自動分配ip地址和端口號inet_pton(AF_INET,"0.0.0.0",&client_addr.sin_addr);client_addr.sin_family = AF_INET;client_addr.sin_port = htons(6666);//要避免使用和客戶端相同的端口,因為是本機通信,端口不能被多個進程同時使用tmp = bind(client_fd,(struct sockaddr *)&client_addr,sizeof(client_addr));handle_error("bind",tmp);//4,連接服務端tmp = connect(client_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("connect",tmp);printf("成功連接到服務端\n");pthread_t thread_id_write;pthread_t thread_id_read;pthread_create(&thread_id_write,NULL,thread_write,(void *)&client_fd);pthread_create(&thread_id_read,NULL,thread_read,(void *)&client_fd);pthread_join(thread_id_write,NULL);pthread_join(thread_id_read,NULL);close(client_fd);return 0;
}
過程及結果解釋
? ? ? ? 客戶端和服務端代碼均使用多線程,分別為讀寫線程,均通過終端接收數據并向對端發送數據,接收到對端的數據之后就會打印在終端上。在服務端/客戶端關閉本端的寫功能之后,都可以繼續接收對端的數據,但是無法發送數據。
????????在兩個終端中分別運行服務端和客戶端代碼,要先運行服務端代碼,不然客戶端會連接不到。
? ? ? ? ?服務端發送一次hello csdn,客戶端發送一次hello wrold
? ? ? ? ?關閉服務端,客戶端繼續發送數據
? ? ? ? 關閉客戶端?
?服務端基于多線程的支持多個客戶端連接
服務端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void *thread_recv_send(void *argv)
{int client_fd; ssize_t cnt;client_fd = *((int *)argv);char *buf = (char *)malloc(100);while (cnt = recv(client_fd,buf,100,0)){handle_error("recv",cnt);cnt = send(client_fd,buf,cnt,0);handle_error("send",cnt);printf("客戶端%d發來消息,內容為%s",client_fd,buf);memset(buf,0,100);}shutdown(client_fd,SHUT_WR);printf("有客戶端斷開連接,文件描述符為%d\n",client_fd);free(buf);close(client_fd);
}int main(int argc, char const *argv[])
{int server_fd,client_fd,tmp;struct sockaddr_in server_addr,client_addr;//創建服務端套接字server_fd = socket(AF_INET,SOCK_STREAM,0);handle_error("socket",server_fd);//設置服務端ip地址和端口號server_addr.sin_family = AF_INET;inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);server_addr.sin_port = htons(8888);//綁定服務端套接字tmp = bind(server_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("bind",tmp);tmp = listen(server_fd,128);handle_error("listen",tmp);while (1){socklen_t sock_len;client_fd = accept(server_fd,(struct sockaddr *)&client_addr,&sock_len);handle_error("accept",client_fd);printf("有客戶端連接,ip地址為%s,端口號為%d,文件描述符為%d\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port),client_fd);pthread_t thread_id_sock;pthread_create(&thread_id_sock,NULL,thread_recv_send,(void *)&client_fd);pthread_detach(thread_id_sock);}close(server_fd);return 0;
}
客戶端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void * thread_write(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_write = (unsigned char *)malloc(30);//客戶端同樣以ctrl+D為關閉信號,關閉寫端while (read(STDIN_FILENO,buf_sock_write,30)){send(client_fd,buf_sock_write,30,0);memset(buf_sock_write,0,30);}printf("客戶端收到關閉信號\n");//關閉寫功能會向對端發送一個0字節的數據包,不同時關閉讀端是為了接收對端的關閉信號//本端關閉寫端,但是仍然可以接收數據包shutdown(client_fd,SHUT_WR);free(buf_sock_write);
}void * thread_read(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_read = (unsigned char *)malloc(30);//對端關閉WR之后,本端的recv會接收到一個0字節的數據包,從而結束本端的讀線程while (recv(client_fd,buf_sock_read,30,0)){printf("%s",buf_sock_read);memset(buf_sock_read,0,30);}printf("服務端關閉連接\n");free(buf_sock_read);
}int main(int argc, char const *argv[])
{int client_fd,tmp;struct sockaddr_in server_addr,client_addr;memset(&server_addr,0,sizeof(server_addr));memset(&client_addr,0,sizeof(client_addr));//1,創建套接字client_fd = socket(AF_INET,SOCK_STREAM,0);handle_error("socket",client_fd);//2,設置服務端的ip地址和端口號inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);server_addr.sin_family = AF_INET;server_addr.sin_port = htons(8888);//端口號要和服務端設置的相匹配//3,綁定套接字,客戶端可以跳過本步驟,會自動分配ip地址和端口號,如果固定端口號的話//多個線程無法共用一個端口,導致無法創建多連接/*inet_pton(AF_INET,"0.0.0.0",&client_addr.sin_addr);client_addr.sin_family = AF_INET;client_addr.sin_port = htons(6666);//要避免使用和客戶端相同的端口,因為是本機通信,端口不能被多個進程同時使用tmp = bind(client_fd,(struct sockaddr *)&client_addr,sizeof(client_addr));handle_error("bind",tmp);*///4,連接服務端tmp = connect(client_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("connect",tmp);printf("成功連接到服務端\n");pthread_t thread_id_write;pthread_t thread_id_read;pthread_create(&thread_id_write,NULL,thread_write,(void *)&client_fd);pthread_create(&thread_id_read,NULL,thread_read,(void *)&client_fd);pthread_join(thread_id_write,NULL);pthread_join(thread_id_read,NULL);close(client_fd);return 0;
}
過程及結果解釋
? ? ? ? 客戶端的代碼幾乎沒有變化,只是取消了ip地址、端口號與套接字的綁定,因為客戶端會默認設置本機的ip地址,并選擇一個空閑端口使用,所以無需進行綁定。相反如果固定了端口號,因為端口號不能被多個進程共用,反而會導致無法創建多連接。
? ? ? ? 服務端的接受連接的邏輯與之前相同,在每次接受連接之后都會創建一個新線程并傳入服務端的套接字,并將線程設置為detach狀態,使其在結束之后自動回收資源,不使用join,從而不會阻擋創立新連接。在新線程中維護與客戶端的連接并進行數據傳輸,將服務端接收到的消息發送回客戶端并打印到終端上。當客戶端從終端中接收了ctrl+D之后,客戶端退出,調用shutdown會向服務端發送揮手信號,此時recv接收到的數據長度為0,服務端也隨之退出。
? ? ? ? 打開三個終端,在終端1中運行服務端,終端2,3運行客戶端
? ? ? ? ?終端2,3分別發送消息
? ? ? ? ?終端2,3退出
? ? ? ? 可以看到此時客戶端已經全部退出,服務端仍然在接收連接
? ? ? ? 終端2,3繼續運行客戶端,與服務端建立連接?
?服務端基于多進程的支持客戶端多連接
服務端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>
#include <signal.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void singal_handle(int sig)
{while (waitpid(-1,NULL,WNOHANG)){}}void recv_send(int client_fd,struct sockaddr_in * client_addr)
{ssize_t cnt;char *buf = malloc(30);while (cnt = recv(client_fd,buf,30,0)){send(client_fd,buf,cnt,0);printf("客戶端%d發來消息,內容為%s",ntohs(client_addr->sin_port),buf);memset(buf,0,30);}printf("客戶端%d斷開連接\n",client_fd);shutdown(client_fd,SHUT_WR);free(buf);
}int main(int argc, char const *argv[])
{int server_fd,client_fd,tmp;struct sockaddr_in server_addr,client_addr;server_fd = socket(AF_INET,SOCK_STREAM,0);handle_error("socket",server_fd);server_addr.sin_family = AF_INET;inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);server_addr.sin_port = htons(8888);tmp = bind(server_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("bind",tmp);tmp = listen(server_fd,128);handle_error("listen",tmp);//注冊信號處理函數,調用waitpid回收子進程防止成為僵尸進程signal(SIGCHLD,singal_handle);while (1){socklen_t client_len;client_fd = accept(server_fd,(struct sockaddr*)&client_addr,&client_len);handle_error("accept",client_fd);printf("有客戶端建立連接,ip地址為%s,端口號為%d,文件描述符為%d\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port),client_fd);pid_t pid = fork();if(pid == 0)//子進程{//子進程不需要使用服務端描述符close(server_fd);recv_send(client_fd,&client_addr);close(client_fd);exit(EXIT_SUCCESS);}else if(pid > 0){//父進程不需要使用客戶端描述符close(client_fd);}}return 0;
}
客戶端代碼
? ? ? ? 客戶端代碼和多線程的相同。
運行結果及過程解釋
? ? ? ? 服務端通過fork創建多個進程來維護與客戶端的連接,在子進程中執行數據傳輸,父進程阻塞等待客戶端的連接。子進程在客戶端斷開之后調用exit退出進程,向父進程發送SIGCHLD信號,父進程通過注冊信號處理函數調用waitpid來回收每一個子進程,防止出現僵尸進程。
? ? ? ? 程序的運行結果和多線程的基本相同。開啟三個終端,終端1執行服務端,2,3執行客戶端并發送消息,之后關閉客戶端
? ? ? ? ?和多線程不同的是,我們發現兩個客戶端的文件描述符是相同的,這是因為accept在父進程進行,數據傳輸的任務在子進程執行,父進程不需要使用客戶端的文件描述符,所以已經將其關閉了,進而導致下一次返回的文件描述符相同。
UDP的數據傳輸
????????UDP通訊也使用socket,但是接收和發送的函數與TCP不一樣。由于UDP不存在握手這一步驟,所以在綁定地址之后,服務端不需要listen,客戶端也不需要connect,服務端同樣不需要accept。只要服務端綁定以后,就可以相互發消息了,由于沒有握手過程,兩端都不能確定對方是否收到消息,這也是UDP協議不如TCP協議可靠的地方。
? ? ? ? UDP的通訊流程相比之下就簡單了很多,TCP是通過accept和connect綁定文件描述符進行通信,UDP則是通過目標地址的ip和端口號來通信,使用的是struct sockaddr結構體的信息。在接收對方的數據之后,就可以獲得對方的ip地址和端口號等信息,進而向對方回傳數據。
服務端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \int main(int argc, char const *argv[])
{//UDP通訊過程中只涉及一個套接字就是本端套接字int sock_fd,tmp;char buf[30];struct sockaddr_in server_addr,client_addr;socklen_t client_len = sizeof(client_addr);sock_fd = socket(AF_INET,SOCK_DGRAM,0);handle_error("sock",sock_fd);server_addr.sin_family = AF_INET;inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);server_addr.sin_port = htons(8888);tmp = bind(sock_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("bind",tmp);ssize_t cnt = 0;while (cnt = recvfrom(sock_fd,buf,30,0,(struct sockaddr *)&client_addr,&client_len)){printf("%s",buf);sendto(sock_fd,buf,30,0,(struct sockaddr *)&client_addr,client_len);memset(buf,0,30);}printf("客戶端退出\n");return 0;
}
客戶端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \int main(int argc, char const *argv[])
{int sock_fd,tmp;sock_fd = socket(AF_INET,SOCK_DGRAM,0);handle_error("socket",sock_fd);struct sockaddr_in server_addr;socklen_t server_len;server_addr.sin_family = AF_INET;server_addr.sin_port = htons(8888);inet_pton(AF_INET,"0.0.0.0",&server_addr.sin_addr);char buf[30];while (read(STDIN_FILENO,buf,30)){sendto(sock_fd,buf,30,0,(struct sockaddr *)&server_addr,sizeof(server_addr));memset(buf,0,30);recvfrom(sock_fd,buf,30,0,(struct sockaddr *)&server_addr,&server_len);printf("%s",buf);memset(buf,0,30);}sendto(sock_fd,"",0,0,(struct sockaddr *)&server_addr,sizeof(server_addr));return 0;
}
? ? ? ? 客戶端必須先向服務端發送消息,之后服務端才可以獲取到客戶端的ip地址和端口號。運行結果如下
套接字用于進程間通信
????????Socket編程原本是為了網絡服務的,后來逐漸發展成一種進程間通信的方式:Unix Domain Socket IPC。它允許在同一臺主機上運行的進程之間進行高效的數據傳輸,無需經過網絡協議棧,因此具有低延遲和高性能的特點。通過文件系統中的特殊文件(通常是一個套接字文件),進程可以通過套接字(socket)來進行通信,實現雙向的數據傳輸。
? ? ? ? 和網絡通信不同的是,UNIX通信域使用的結構體是struct sockaddr_un,結構體的sun_family固定使用AF_UNIX,第二個成員變為了套接字的地址,也就是聲明一個使用本地文件的socket,其他進程可以綁定該文件完成進程間通信。在使用完成之后,服務端需要調用unlink清除該套接字文件,否則下次進行綁定時會提示該地址已經被使用。除此之外,服務端和客戶端的程序編寫流程和TCP并無區別。
? ? ? ? 服務端代碼
#include <stdlib.h>
#include <stdio.h>
#include <stddef.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <sys/stat.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void *thread_recv_send(void *argv)
{int client_fd; ssize_t cnt;client_fd = *((int *)argv);char *buf = (char *)malloc(100);while (cnt = recv(client_fd,buf,100,0)){handle_error("recv",cnt);cnt = send(client_fd,buf,cnt,0);handle_error("send",cnt);printf("客戶端%d發來消息,內容為%s",client_fd,buf);memset(buf,0,100);}shutdown(client_fd,SHUT_WR);printf("有客戶端斷開連接,文件描述符為%d\n",client_fd);free(buf);close(client_fd);
}int main(int argc, char const *argv[])
{int server_fd,client_fd,tmp;struct sockaddr_un server_addr,client_addr;//創建套接字server_fd = socket(AF_UNIX,SOCK_STREAM,0);handle_error("socket",server_fd);//設置地址server_addr.sun_family = AF_UNIX;strcpy(server_addr.sun_path,"test.socket");//綁定套接字tmp = bind(server_fd,(struct sockaddr*)&server_addr,sizeof(server_addr));handle_error("bind",tmp);tmp = listen(server_fd,128);handle_error("listen",tmp);while (1){socklen_t client_len = sizeof(client_addr);client_fd = accept(server_fd,(struct sockaddr*)&client_addr,&client_len);handle_error("accept",client_fd);printf("有客戶端連接,文件描述符為%d\n",client_fd);pthread_t thread_id_sock;pthread_create(&thread_id_sock,NULL,thread_recv_send,(void *)&client_fd);pthread_detach(thread_id_sock);}unlink("test.socket");return 0;
}
客戶端代碼
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>
#include <sys/un.h>
#include <sys/stat.h>
#include <errno.h>
#include <string.h>#define handle_error(cmd,result) \if(result < 0) \{ \perror(cmd); \exit(EXIT_FAILURE); \} \void * thread_write(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_write = (unsigned char *)malloc(30);//客戶端同樣以ctrl+D為關閉信號,關閉寫端while (read(STDIN_FILENO,buf_sock_write,30)){send(client_fd,buf_sock_write,30,0);memset(buf_sock_write,0,30);}printf("客戶端收到關閉信號\n");//關閉寫功能會向對端發送一個0字節的數據包,不同時關閉讀端是為了接收對端的關閉信號//本端關閉寫端,但是仍然可以接收數據包shutdown(client_fd,SHUT_WR);free(buf_sock_write);
}void * thread_read(void *argv)
{int client_fd = *((int *)argv);unsigned char * buf_sock_read = (unsigned char *)malloc(30);//對端關閉WR之后,本端的recv會接收到一個0字節的數據包,從而結束本端的讀線程while (recv(client_fd,buf_sock_read,30,0)){printf("%s",buf_sock_read);memset(buf_sock_read,0,30);}printf("服務端關閉連接\n");free(buf_sock_read);
}int main(int argc, char const *argv[])
{int client_fd,tmp;struct sockaddr_un server_addr,client_addr;memset(&server_addr,0,sizeof(server_addr));memset(&client_addr,0,sizeof(client_addr));//創建套接字client_fd = socket(AF_UNIX,SOCK_STREAM,0);handle_error("socket",client_fd);//設置服務端的地址server_addr.sun_family = AF_UNIX;strcpy(server_addr.sun_path,"test.socket");//連接服務端tmp = connect(client_fd,(struct sockaddr *)&server_addr,sizeof(server_addr));handle_error("connect",tmp);printf("成功連接到服務端\n");pthread_t thread_id_write;pthread_t thread_id_read;pthread_create(&thread_id_write,NULL,thread_write,(void *)&client_fd);pthread_create(&thread_id_read,NULL,thread_read,(void *)&client_fd);pthread_join(thread_id_write,NULL);pthread_join(thread_id_read,NULL);close(client_fd);return 0;
}
過程解釋及運行結果
? ? ? ? 服務端仍然采用多線程方式支持多個連接,接收客戶端數據之后打印在終端并傳回客戶端。
?????????總結一下,套接字用于進程間通信時,類似于TCP協議下的編程順序,但是套接字地址結構體變為了struct sockaddr_un 其中的family寫為AF_UNIX,第二個成員改為了路徑,客戶端服務端的路徑要一致。創建套接字的第二個參數還是sock_stream和TCP一樣。服務端的編程順序是初始化地址,給地址賦值,創建套接字,綁定套接字,進入監聽模式,接受連接(會返回客戶端的套接字和地址),發送/接收數據,unlink釋放套接字。客戶端的編程順序是初始化地址,給地址賦值,創建套接字,連接客戶端,發送/接收數據。