文章目录
- 前言
- 一、服务器 server
- 二、客户端 client
- 三、并发通信演示
- 四、程序源码
前言
前些日子同“ Linux应用编程 ”专栏中发布过的TCP及UDP在Linux或Windows下的通信都为单进程下的Socket编程,若还存在一些套接字相关函数模糊不清,读者可移步“Socket编程下tcp通信”和“Socket编程下udp通信”重温学习。
本篇则是对以上俩篇的一个简单提升运用,或者说是对以后多线程/进程工作的简单示例。
相关知识运用:
- PF_INET 和 AF_INET 的区别:在Windows中,AF_INET与PF_INET完全一样,而在Unix/Linux系统中,在不同的版本中这两者有微小差别。对于BSD,是AF,对于POSIX是PF。
- bzero函数与memset函数: 俩函数功能为 置字节字符串s的前n个字节为零且包括‘\0’,但bzero已被标记为遗留函数,这里推荐使用memset函数。
- fork()函数: 返回值为0时为子进程,返回值大于0时为父进程,返回值为其他数时为创建失败。
- atoi函数: 把字符串转换成整型数的一个函数,int atoi(const char *nptr)函数会扫描参数 nptr字符串,会跳过前面的空白字符(例如空格,tab缩进)等,如果 nptr不能转换成 int 或者 nptr为空字符串,那么将返回 0 。且该函数要求被转换的字符串是按十进制数理解的,atoi输入的字符串对应数字存在大小限制(与int类型大小有关),若其过大可能报错-1。
- htons: 是将整型变量从主机字节顺序转变成网络字节顺序, 就是整数在地址空间存储方式变为高位字节存放在内存的低地址处。
一、服务器 server
①创建套接字描述符
//创建一个socket文件,也就是打开一个网络通讯端口,类型是IPV4(PF_INET)+TCP(SOCK_STREAM)
int server_socket=socket(PF_INET,SOCK_STREAM,0);
②创建服务器地址结构
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(atoi(argv[1]));
server_addr.sin_addr.s_addr = INADDR_ANY;
③绑定套接字
bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr));
④监听套接字
listen(server_socket,10);
⑤多进程连接
client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_size);
int pid=fork(); //创建子进程
if(pid==0){ //子进程
struct sockaddr_in client_in_addr; // 创建临时客户端地址结构体用于存放开始accept到的客户端数据
client_in_addr.sin_addr.s_addr=client_addr.sin_addr.s_addr;
client_in_addr.sin_port=client_addr.sin_port;
recv_len = recv(client_socket, buf, sizeof(buf), 0); //接收客户端数据存入缓冲区buf中
}
else if(pid>0){ //父进程
close(client_socket);
}
else{ //创建子进程失败,直接退出
exit(-1);
}
二、客户端 client
①创建网络通信套接字描述符
int client_socket=socket(AF_INET,SOCK_STREAM,0);
②创建服务器的地址结构体
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(atoi(argv[2]));
server_addr.sin_addr.s_addr=inet_addr(argv[1]);
③连接服务器
connect(client_socket,(struct sockaddr*)&server_addr,sizeof(server_addr));
④收发数据
write(client_socket, buf, strlen(buf)); //向服务器发送缓冲区buf中的数据
read(client_socket, message, sizeof(message)); //读取服务器发过来的数据并存入缓冲区message中
三、并发通信演示
四、程序源码
若需程序源码可留言邮箱至评论区或直接私信 即可。