嵌入式學(xué)習(xí)-網(wǎng)絡(luò)編程-Day5

一、思維導(dǎo)圖

文章來源地址http://www.zghlxwxcb.cn/news/detail-806985.html

二、作業(yè)

1.使用poll實(shí)現(xiàn)TCP服務(wù)器的并發(fā)

include <myhead.h>
//tcp服務(wù)器端
int main(int argc, const char *argv[])
{
	//1 創(chuàng)建通信套接字
	int sfd=-1;
	if((sfd=socket(AF_INET,SOCK_STREAM,0))==-1)
	{
		perror("socket error");
		return -1;
	}
	//快速重用端口號(hào)
	int reuse = 1;
	if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1)
	{
		perror("setsockopt error");
		return -1;
	}

	//2 綁定IP地址和端口號(hào)
	struct sockaddr_in sin;  //地址信息結(jié)構(gòu)體  man 7 ip
	sin.sin_family = AF_INET;//通信域 ipv4
	sin.sin_port = htons(8888);//端口號(hào) 轉(zhuǎn)為網(wǎng)絡(luò)字節(jié)序 2字節(jié)
	sin.sin_addr.s_addr = inet_addr("192.168.122.39");//ip地址
	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)//綁定
	{
		perror("bind error");
		return -1;
	}

	//3 監(jiān)聽
	if(listen(sfd,128)==-1)
	{
		perror("listen error");
		return -1;
	}

	//4 接受客戶端鏈接請(qǐng)求
	struct sockaddr_in cin;          //用于接收地址信息
	socklen_t socklen = sizeof(cin); //用于接收地址信息的大小
	
	//定義地址信息結(jié)構(gòu)體數(shù)組,存儲(chǔ)鏈接的客戶端信息
	struct sockaddr_in cin_arr[1024];

	//定義一個(gè)等待文件描述符結(jié)構(gòu)體數(shù)組
	int count_fd=4;  //文件描述符的個(gè)數(shù)
	struct pollfd pfd[count_fd];
	pfd[0].fd=0;
	pfd[3].fd=sfd;

	pfd[0].events=POLLIN;
	pfd[3].events=POLLIN;
	
	int maxfd=sfd;  //存儲(chǔ)最大的文件描述符
	int newfd=-1;
	
	char rbuf[128]="";
	char wbuf[128]="";
	while(1)
	{
		int flag=poll(pfd,count_fd,-1);
		
		if(flag<0)
		{
			perror("poll error");
			return -1;
		}
		
		//1 新客戶端鏈接 
		if(pfd[sfd].revents=POLLIN)
		{
			newfd=accept(sfd,(struct sockaddr*)&cin,&socklen);
			if(newfd==-1)
			{
				perror("accept error");
				return -1;
			}
			cin_arr[newfd]=cin;
			printf("[%s:%d]發(fā)來連接請(qǐng)求，newfd=%d\n",inet_ntoa(cin_arr[newfd].sin_addr),ntohs(cin_arr[newfd].sin_port),newfd);
			pfd[newfd].events=POLLIN;
			pfd[newfd].fd=newfd;
			//更新描述符的長度
			if(newfd>maxfd)
			{
				maxfd=newfd;
				count_fd++;
			}
		}

		//向客戶端發(fā)送消息
		if(pfd[0].revents==POLLIN)
		{
			memset(wbuf,0,sizeof(wbuf));
			//scanf(" %s",wbuf);
			fgets(wbuf,sizeof(wbuf),stdin);
			wbuf[strlen(wbuf)-1]=0;
			
			for(int i=4;((i<=count_fd)&&(pfd[i].fd!=-1));i++)
			{
				//sendto(i,wbuf,sizeof(wbuf),0,(struct sockaddr*)&cin_arr[i],sizeof(cin_arr[i]));
				send(i,wbuf,sizeof(wbuf),0);
			}
			printf("發(fā)送成功\n");
		}

		//接收客戶端的消息
		for(int i=4;i<=maxfd&&pfd[i].fd!=-1;i++)
		{
			if(pfd[i].revents==POLLIN)
			{
				//接收客戶端消息
				memset(rbuf,0,sizeof(rbuf));
				//int res=read(i,rbuf,sizeof(rbuf));
				int res=recv(i,rbuf,sizeof(rbuf),0);
				if(res==0)
				{
					printf("客戶端已經(jīng)下線\n");
					close(i);
					//更新pfd 從集合中刪除
					pfd[i].fd=-1;
				}
				printf("[%s:%d]:%s\n",inet_ntoa(cin_arr[i].sin_addr),\
						ntohs(cin_arr[i].sin_port),rbuf);
				//給客戶端發(fā)消息
				strcat(rbuf,"^_^");
				send(i,rbuf,sizeof(rbuf),0);
				printf("發(fā)送成功\n");
			}
		}
	}
	return 0;
}

使用select實(shí)現(xiàn)TCP客戶端的并發(fā)

#include <myhead.h>
//TCP 客戶端
#define SER_IP "192.168.122.39"  //服務(wù)器ip地址
#define SER_PORT 8888          //服務(wù)器端口號(hào)

int main(int argc, const char *argv[])
{
	//1 創(chuàng)建套接字
	int cfd=-1;
	if((cfd=socket(AF_INET,SOCK_STREAM,0))==-1)
	{
		perror("socket error\n");
		return -1;
	}
	//2 可以不綁定
	//2.1填寫地址信息結(jié)構(gòu)體
	struct sockaddr_in cin;
	cin.sin_family=AF_INET;
	cin.sin_port=htons(6666);
	cin.sin_addr.s_addr=inet_addr("192.168.122.39");
	//2.2綁定
	if(bind(cfd,(struct sockaddr*)&cin,sizeof(cin))==-1)
	{
		perror("bind error");
		return -1;
	}
	//3 連接服務(wù)器
	struct sockaddr_in sin;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(8888);
	sin.sin_addr.s_addr=inet_addr("192.168.122.39");

	if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("connect error");
		return -1;
	}
	printf("connect success\n");
	
	//準(zhǔn)備文件描述符容器
	fd_set readfds,tempfds;
	FD_ZERO(&readfds);
	FD_SET(0,&readfds);
	FD_SET(cfd,&readfds);
	int maxfd=cfd;
	
	//4 收發(fā)數(shù)據(jù)
	char buf[128]="";
	while(1)
	{
		tempfds=readfds;
		int res=select(maxfd+1,&tempfds,NULL,NULL,NULL);
		if(res==-1)
		{
			perror("select error");
			return -1;
		}else if(res==0)
		{
			printf("timeout\n");
			return -1;
		}
		if(FD_ISSET(0,&tempfds))
		{
			//發(fā)送數(shù)據(jù)
			memset(buf,0,sizeof(buf));
			read(0,buf,sizeof(buf));
			buf[strlen(buf)-1]=0;
			if(strcmp(buf,"quit")==0)
			{
				printf("已退出\n");
				close(cfd);
				break;
			}
			write(cfd,buf,sizeof(buf));
			printf("發(fā)送成功\n");
		}
		if(FD_ISSET(cfd,&tempfds))
		{
			//接收數(shù)據(jù)
			recv(cfd,buf,sizeof(buf),0);
			printf("[%s:%d]:%s\n",SER_IP,SER_PORT,buf);
		}
	}
	return 0;
}

到了這里，關(guān)于嵌入式學(xué)習(xí)-網(wǎng)絡(luò)編程-Day5的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！