文章目錄

• • 1 TCP編程模型

1 TCP編程模型

先來看一下socket整體框架圖：

如下為TCP通信模型：

TCP客戶端和服務(wù)器示例代碼：
demo_tcp_server.c：

#include <stdio.h> #include <stdlib.h> #include <errno.h> #include <string.h> #include <sys/types.h>#include <netinet/in.h> //#include <Windows.h> #include <pthread.h> #include <malloc.h> #include <string.h>#include <sys/stat.h> #include <fcntl.h> #include <unistd.h>#include <netdb.h>#include <sys/time.h>#include <signal.h>#define SERVER_PORT_TCP 6666 #define TCP_BACKLOG 10/* 在sock_fd 進(jìn)行監(jiān)聽，在 new_fd 接收新的鏈接 */ int sock_fd, new_fd;void printf_hex(char *buf, int len) {int i;for(i = 0; i < len; i++){printf("0x%x ", buf[i]);}}void sig_chld(int signo) {pid_t pid;int stat;while((pid = waitpid(-1, &stat, WNOHANG)) > 0)printf("child %d terminated\r\n", pid);return; }int main(void) {char command[1024];char *str;/* 自己的地址信息 */struct sockaddr_in my_addr;/* 連接者的地址信息*/struct sockaddr_in their_addr;int sin_size;struct sockaddr_in *cli_addr;/* 1 、創(chuàng)建socket */if((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1){perror("socket is error\r\n");exit(1);}/* 主機(jī)字節(jié)順序 *//* 協(xié)議 */my_addr.sin_family = AF_INET;my_addr.sin_port = htons(6666);/* 當(dāng)前IP 地址寫入 */my_addr.sin_addr.s_addr = INADDR_ANY;/* 將結(jié)構(gòu)體其余的都清零 */bzero(&(my_addr.sin_zero), 8);/* bind 綁定*/if(bind(sock_fd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr)) == -1){perror("bind is error\r\n");exit(1);}/* 開始監(jiān)聽 */if(listen(sock_fd, TCP_BACKLOG) == -1){perror("listen is error\r\n");exit(1);}printf("start accept\n");/* 因?yàn)槲覀兒竺鏁?huì)創(chuàng)建出許多子進(jìn)程來服務(wù)新的鏈接一旦子進(jìn)程異常終止了，需要父進(jìn)程來進(jìn)行資源回收*/signal(SIGCHLD, sig_chld); //在這里處理僵死進(jìn)程/* accept() 循環(huán) */while(1){sin_size = sizeof(struct sockaddr_in);if((new_fd = accept(sock_fd, (struct sockaddr *)&their_addr, (socklen_t *)&sin_size)) == -1){perror("accept");continue;}cli_addr = malloc(sizeof(struct sockaddr));printf("accept addr\r\n");if(cli_addr != NULL){memcpy(cli_addr, &their_addr, sizeof(struct sockaddr));}//處理目標(biāo)ssize_t ret;char recvbuf[512];char *buf = "hello! I'm server!";while(1){if((ret = recv(new_fd, recvbuf, sizeof(recvbuf), 0)) == -1){printf("recv error \r\n");return -1;}printf("recv :\r\n");printf("%s", recvbuf);printf("\r\n");sleep(2);if((ret = send(new_fd, buf, strlen(buf) + 1, 0)) == -1){perror("send : ");}sleep(2);}close(new_fd);}return 0; }

demo_tcp_client.c：

#include <stdio.h> #include <stdlib.h> #include <errno.h> #include <string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> //#include <Windows.h> #include <pthread.h> #include <malloc.h> #include <string.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> #include <unistd.h>#include <netdb.h>#include <sys/time.h>#include <signal.h>int sockfd;//#define SERVER_IP "106.13.62.194" #define SERVER_IP "127.0.0.1"#define SERVER_PORT 6666void printf_hex(char *buf, int len) {int i;for(i = 0; i < len; i++){printf("0x%x ", buf[i]);}}int main(void) {char command[1024];char *str;/* 連接者的主機(jī)信息 */struct sockaddr_in their_addr; if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){/* 如果socket()調(diào)用出現(xiàn)錯(cuò)誤則顯示錯(cuò)誤信息并退出 */perror("socket"); // exit(1);}/* 主機(jī)字節(jié)順序 */their_addr.sin_family = AF_INET;/* 網(wǎng)絡(luò)字節(jié)順序，短整型 */their_addr.sin_port = htons(SERVER_PORT);their_addr.sin_addr.s_addr = inet_addr(SERVER_IP);/* 將結(jié)構(gòu)剩下的部分清零*/bzero(&(their_addr.sin_zero), 8);if(connect(sockfd, (struct sockaddr *)&their_addr, sizeof(struct sockaddr)) == -1){/* 如果connect()建立連接錯(cuò)誤，則顯示出錯(cuò)誤信息，退出 */perror("connect");exit(1);}ssize_t ret;char recvbuf[512];char *buf = "hello! I'm client!";while(1){if((ret = send(sockfd, buf, strlen(buf) + 1, 0)) == -1){perror("send : ");}sleep(2);if((ret = recv(sockfd, &recvbuf, sizeof(recvbuf), 0)) == -1){return -1;}printf("recv :\r\n");printf("%s", recvbuf);printf("\r\n");sleep(2);}close(sockfd);return 0; }

---

參考資料：

5G物聯(lián)網(wǎng)云平臺(tái)智能家居項(xiàng)目30天搞定

總結(jié)

以上是生活随笔為你收集整理的TCP编程模型的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。