socket服务端与客户端进行通信

使用socket编程实现双端的收发功能
6步:
socket() 创建套接字
bind() 为套接字添加信息(IP地址和端口)
listen() 监听网络连接
accept() 监听到有客户端接入,接受一个连接
read() 数据交互
write()
read()
clsoe() 关闭断开连接
突破口1:
因为使用while不断检测
检测客户端,read,write要使用三个进程fork两次
read,write要使用两个进程fork一次
突破口2:
要使用memset(msg,0,sizeof(msg));进行数据的清空
突破口3:
服务器端
server.c

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<stdlib.h>
#include<string.h>
int main(int argc,char **argv){
	int s_fd;
	int c_fd;
	int n_read;
	char readBuf[128];	
	char msg[128]= {0};
	//char *msg = "i get you connet";
	struct sockaddr_in s_addr;
	struct sockaddr_in c_addr;
	memset(&s_addr,0,sizeof(struct sockaddr_in));
	memset(&c_addr,0,sizeof(struct sockaddr_in));

//1.socket int socket(int domain, int type, int protocol);
	s_fd = socket(AF_INET,SOCK_STREAM,0);
	if(s_fd == -1){
		perror("socket");
		exit(-1);
	}
	s_addr.sin_family = AF_INET;
	s_addr.sin_port = htons(atoi(argv[2]));
	inet_aton(argv[1],&s_addr.sin_addr);
//2.bind
	bind(s_fd,(struct sockaddr *)&s_addr,sizeof(struct sockaddr_in));
//3.listen
	listen(s_fd,10);
//4.accept
	int clen = sizeof(struct sockaddr_in);
	while(1){
		c_fd = accept(s_fd,(struct sockaddr *)&c_addr,&clen);
		if(c_fd == -1){
			perror("accept");
		}
		printf("connet%s\n",inet_ntoa(c_addr.sin_addr));
//5.write
		if(fork()==0){
			if(fork()==0){
				while(1){
				memset(msg,0,sizeof(msg));
				printf("input: ");
				gets(msg);
				write(c_fd,msg,strlen(msg));
				}
		}
//6.read
			while(1){	
				memset(readBuf,0,sizeof(readBuf));
				n_read = read(c_fd,readBuf,128);
				printf("get msg%d,%s\n",n_read,readBuf);
			}
		}
	}
	return 0;
}

客户端
client.c

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<stdlib.h>
#include<string.h>
int main(int argc,char **argv){
        int c_fd;
        int n_read;
        char readBuf[128];
        //char *msg = "msg from client";
        char msg[128]={0};
        struct sockaddr_in c_addr;
        memset(&c_addr,0,sizeof(struct sockaddr_in));

//1.socket int socket(int domain, int type, int protocol);
        c_fd = socket(AF_INET,SOCK_STREAM,0);
        if(c_fd == -1){
                perror("socket");
                exit(-1);
        }
        c_addr.sin_family = AF_INET;
        c_addr.sin_port = htons(atoi(argv[2]));
        inet_aton(argv[1],&c_addr.sin_addr);
//2.connect
        if(connect(c_fd,(struct sockaddr *)&c_addr,sizeof(struct sockaddr))==-1){
        perror("connet");
        exit(-1);
        }
	while(1){
//3.send
	        if(fork()==0){
		        while(1){
		                memset(msg,0,sizeof(msg));
		                printf("input: ");
		                gets(msg);
		                write(c_fd,msg,strlen(msg));
		         }
	        }
//4.read
	        while(1){
	        memset(msg,0,sizeof(msg));
	        n_read = read(c_fd,readBuf,128);
	        printf("get msg%d,%s\n",n_read,readBuf);
	        }
	}     
    return 0;
}

相关文章

学习编程是顺着互联网的发展潮流,是一件好事。新手如何学习...
IT行业是什么工作做什么?IT行业的工作有:产品策划类、页面...
女生学Java好就业吗?女生适合学Java编程吗?目前有不少女生...
Can’t connect to local MySQL server through socket \'/v...
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 ...
一、背景 因为项目中需要通北京网络,所以需要连vpn,但是服...