Linux系统创建TCP连接流程介绍

目录Linux创建TCP的步骤服务端客户端TCP建立流程示例代码

Linux创建TCP的步骤

TCP编程需要客户端和服务器两套编码，其创建TCP的流程也是不完全一致的

服务端

使用socket函数创建一个套接字

使用setsockopt函数设置套接字的属性

使用bind函数绑定IP地址、端口信息到套接字上使用listen函数监听指定端口

使用accept函数接收客户端的连接请求

使用send/recv和read/write函数进行数据的收发

使用close函数关闭网络连接和监听

客户端

使用socket函数创建套接字使用setsockopt函数设置套接字属性

使用bind函数绑定IP地址和端口信息

设置需要连接的IP地址和端口使用connect函数请求建立连接

使用send/recv和read/write函数进行数据的收发

使用close函数关闭网路连接

TCP建立流程

示例代码

服务器

#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #include <fcntl.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <pthread.h> #include <time.h> #define MAXSIZE 128 char news[MAXSIZE]; int res; //用以接收函数返回值 void* pthread_chat(void * arg) //创建线程用以接收数据 { int confd = *(int *)arg; while(1) { res = recv(confd, news, sizeof(news), 0); if(res <= 0) { perror(“recv”); break; } printf(“The news is: %sn”,news); memset(news,0,MAXSIZE); send(confd,”OK”,2,0); } printf(“One client overn”); close(confd); } char *Time() //获取当前时间 { time_t timer; struct tm *tblock; timer = time(NULL); tblock = localtime(&timer); return asctime(tblock); } void save(char *s) //储存日志文件 { int fd; fd = open(“journal”,O_RDWR|O_APPEND|O_CREAT); if(fd < 0) perror(“open”); else { char *buf = Time(); strcat(buf,s); write(fd,buf,MAXSIZE); lseek(fd,0,SEEK_END); if(res < 0) perror(“write”); } } int main() { int sockfd = socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in saddr, caddr; saddr.sin_family = AF_INET; saddr.sin_port = htons(6666); saddr.sin_addr.s_addr = inet_addr(“127.0.0.1”); res = bind(sockfd,(struct sockaddr*)&saddr, sizeof(saddr)); if(res < 0) perror(“bind”); listen(sockfd, 5); //监听端口 while(1) { int len = sizeof(caddr); int confd = accept(sockfd,(struct sockaddr*)&caddr, &len); if(confd < 0) { perror(“accept”); continue; }else { save(inet_ntoa(caddr.sin_addr)); } printf(“Accept confdis:%d, ip=%sn”,confd,inet_ntoa(caddr.sin_addr)); pthread_t tid; pthread_create(&tid, NULL, pthread_chat, &confd); } }

客户端

#include <string.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #define MAXSIZE 128 char news[MAXSIZE]; int res; //用来接收函数返回值 int main() { printf(“——Welcome join the chat room—–n”); printf(“If you want to quit,please input –bye–n”); int sockfd = socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in saddr; saddr.sin_family = AF_INET; saddr.sin_port = htons(6666); saddr.sin_addr.s_addr = inet_addr(“127.0.0.1”); int confd = connect(sockfd,(struct sockaddr*)&saddr,sizeof(saddr)); if(confd < 0) perror(“connect”); while(1) { printf(“Please input the newsn”); fgets(news,MAXSIZE,stdin); if(strncmp(news,”bye”,3) == 0) { break; } send(sockfd, news, strlen(news), 0); memset(news,0,MAXSIZE); recv(sockfd, news, sizeof(news), 0); printf(“The serves news is: %sn”,news); } close(sockfd); exit(0); }

请注意，服务端由于使用了多线程开发，需要在编译时添加-lpthread选项

程序运行效果如下：