国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

  1. Toy模板網(wǎng)首頁
  2. >Toy博客

網(wǎng)絡(luò)編程 IO多路復(fù)用 [select版] (TCP網(wǎng)絡(luò)聊天室)

2年前作者：Hellomino_分類：Toy博客閱讀(24)違法舉報(bào)

這篇具有很好參考價(jià)值的文章主要介紹了網(wǎng)絡(luò)編程 IO多路復(fù)用 [select版] (TCP網(wǎng)絡(luò)聊天室)。希望對大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方，請大家不吝賜教，您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問。

//head.h? ? ? ? ? ? ? ? ?頭文件

//TcpGrpSer.c? ? ? ? 服務(wù)器端

//TcpGrpUsr.c? ? ? ? 客戶端

select函數(shù)?

功能：阻塞函數(shù)，讓內(nèi)核去監(jiān)測集合中的文件描述符是否準(zhǔn)備就緒，若準(zhǔn)備就緒則解除阻塞。

原型：


       #include <sys/select.h>

       #include <sys/time.h>
       #include <sys/types.h>
       #include <unistd.h>

       int select(int nfds, fd_set *readfds, fd_set *writefds,
                  fd_set *exceptfds, struct timeval *timeout);
參數(shù)：
        int nfds：所有集合中最大的文件描述符+1;    
        fd_set *readfds, fd_set *writefds,
        fd_set *exceptfds：讀集合，寫集合，其他集合。用不上的集合填NULL;
        struct timeval *timeout：設(shè)置超時(shí)時(shí)間; 
        1) 填NULL,不設(shè)置超時(shí)時(shí)間，會(huì)一直阻塞直到文件描述符準(zhǔn)備就緒，解除阻塞;
        2) 設(shè)置超時(shí)時(shí)間；
           struct timeval {
               long    tv_sec;         /* seconds */      秒
               long    tv_usec;        /* microseconds */
微秒
           };
返回值：
    >0, 成功，返回成功觸發(fā)事件的文件描述符個(gè)數(shù);
    =0, 超時(shí)了
    =-1，函數(shù)運(yùn)行失敗，更新errno; 
     
操作集合的函數(shù)：      
       void FD_CLR(int fd, fd_set *set);     將指定的fd從集合中刪除
       int  FD_ISSET(int fd, fd_set *set);    判斷fd是否在集合中，若存在返回真，否則返回假
       void FD_SET(int fd, fd_set *set);      將fd添加到集合中
       void FD_ZERO(fd_set *set);             清空

head.h

#ifndef __HEAD_H__
#define __HEAD_H__


#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<strings.h>
#include<unistd.h>
#include<math.h>
#include<errno.h>
#include<fcntl.h>
#include<signal.h>

#include<sys/stat.h>
#include<sys/wait.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<sys/shm.h>
#include<sys/time.h>
#include<sys/sem.h>

#include<pthread.h>
#include<semaphore.h>

#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<sys/select.h>
#include<poll.h>


#define NUM 10
#define ERR_MSG(msg) do{\
	printf("line: %d\n",__LINE__);\
	perror(msg);\
}while(0)
#define PORT 6666           //端口號(hào)的網(wǎng)絡(luò)字節(jié)序  1024～49151
#define IP "192.168.250.100"  //ifconfig查看本機(jī)IP  (ipv4)



#endif

TcpGrpSer.c

#include "head.h"


int main(int argc, const char *argv[])
{
	//創(chuàng)建流式套接字
	int sfd = socket(AF_INET,SOCK_STREAM,0);
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}

	//填充服務(wù)器自身的地址信息結(jié)構(gòu)體
	//真實(shí)的地址信息結(jié)構(gòu)體根據(jù)地址族制定AF_INET ; man 7 ip
	struct sockaddr_in sin; 
	sin.sin_family  = AF_INET;            //必須填充AF_INET
	sin.sin_port   = htons(PORT);        //端口號(hào)的網(wǎng)絡(luò)字節(jié)序  1024～49151
	sin.sin_addr.s_addr = inet_addr(IP);  //ifconfig查看本機(jī)IP

	int reuse = 1;
	if(setsockopt(sfd, SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) < 0) //允許端口快速被重復(fù)使用
	{
		ERR_MSG("setsockopt");
		return -1;
	}
	//綁定連接
	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0)
	{
		ERR_MSG("bind");
		return -1;
	}
	printf("bind success\n");

	//設(shè)置監(jiān)聽
	if(listen(sfd,128) < 0)
	{
		ERR_MSG("listen");
		return -1;
	}

	//創(chuàng)建讀集合
	fd_set readfds,tempfds;
	//清空集合
	FD_ZERO(&readfds);
	FD_ZERO(&tempfds);

	//將集合監(jiān)測的文件描述符放入集合
	FD_SET(0,&readfds);
	FD_SET(sfd,&readfds);
	//用順序表存儲(chǔ)文件描述符的端口信息

	//監(jiān)測文件描述符是否準(zhǔn)備就緒
	int maxfd = sfd;
	int s_res = 0;
	struct sockaddr_in cin;
	socklen_t len = sizeof(cin);
	struct sockaddr_in savcin[1024];
	int newfd = -1;
	char buf[128]="";
	ssize_t res = 0;
	while(1)
	{
		tempfds = readfds;//備份readfds
		s_res = select(maxfd+1,&tempfds,NULL,NULL,NULL);
		if(s_res<0)
		{
			ERR_MSG("select");
			return -1;
		}
		else if(0 == s_res)
		{
			printf("超時(shí)...\n");
			break;
		}

		//與客戶端通信
		for(int i=0;i<=maxfd;i++)
		{
			if(!FD_ISSET(i,&tempfds))
				continue;

			if(0 == i)
			{
				printf("觸發(fā)鍵盤輸入事件\n");
				int sndfd=-1;
				res=scanf("%d %s",&sndfd,buf);
				while(getchar() !=10);
				if(res!=2)
				{
					printf("請輸入正確數(shù)據(jù)格式：[fd(4~1023)] string\n");		
					continue;
				}
				//判斷文件是否合法
				if(sndfd<sfd||sndfd>1023||!FD_ISSET(sndfd,&readfds))
				{
					printf("sndfd = %d 是非法文件描述符\n",sndfd);
					continue;
				}
				
				if(send(sndfd,buf,sizeof(buf),0)<0)
				{
					ERR_MSG("send");
				}
				bzero(buf,sizeof(buf));
			}
			else if(i == sfd)
			{
				printf("觸發(fā)客戶端連建事件\n");
				newfd = accept(sfd,(struct sockaddr *)&cin,&len);
				if(newfd < 0)
				{
					perror("accept");
					return -1;
				}
				savcin[newfd]=cin;

				printf("[%s:%d] 客戶端連接成功 newfd = %d __%d__ \n",\
						inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd,__LINE__);

				//將新生成的newfd添加到readfds
				FD_SET(newfd,&readfds);
				//更新maxfd
				maxfd = maxfd > newfd? maxfd:newfd;


			}
			else
			{
				printf("觸發(fā)客戶端連建事件__%d__\n",__LINE__);

				bzero(buf,sizeof(buf));
				//接收數(shù)據(jù)
				res = recv(i,buf,sizeof(buf),0);
				if(res < 0)
				{
					ERR_MSG("recv");
					return -1;
				}
				else if(0 == res)
				{
					printf("{%s:%d} sfd = %d,__%d__ 已下線，結(jié)束對話\n",\
							inet_ntoa(savcin[i].sin_addr),ntohs(savcin[i].sin_port),i,__LINE__);     
					close(i);//關(guān)閉文件描述符
					FD_CLR(i,&readfds);
					/*	//更新maxfd
						int j=maxfd;
						for(;j<=0;j--)
						{
						if(FD_ISSET(j,&readfds)) break;
						}
						maxfd = j;
						*/
					//更新maxfd
					while(!FD_ISSET(maxfd,&readfds)&&maxfd-->=0);
					continue;
				}

				printf("{%s:%d} sfd = %d : %s,__%d__\n",\
						inet_ntoa(savcin[i].sin_addr),ntohs(savcin[i].sin_port),i,buf,__LINE__);  
				//發(fā)送數(shù)據(jù)
				strcat(buf,"*_*");
				if(send(i,buf,sizeof(buf),0)<0)
				{
					ERR_MSG("send");
					return -1;
				}
				printf("發(fā)送成功\n");
			}
		}
	}


	if(close(sfd)<0)
	{
	ERR_MSG("close");
	return -1;
	}
	
return 0;
}

TcpGrpUsr.c

#include "head.h"


int main(int argc, const char *argv[])
{
	//創(chuàng)建流式套接字
	int sfd = socket(AF_INET,SOCK_STREAM,0);
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}

	int reuse = 1;
	if(setsockopt(sfd, SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) < 0) //允許端口快速被重復(fù)使用
	{
		ERR_MSG("setsockopt");
		return -1;
	}
	//填充服務(wù)器自身的地址信息結(jié)構(gòu)體
	//真實(shí)的地址信息結(jié)構(gòu)體根據(jù)地址族制定AF_INET ;
	struct sockaddr_in sin; 
	sin.sin_family      = AF_INET;            //必須填充AF_INET
	sin.sin_port        = htons(PORT);        //端口號(hào)的網(wǎng)絡(luò)字節(jié)序  1024～49151
	sin.sin_addr.s_addr = inet_addr(IP);      //ifconfig查看本機(jī)IP

	if(connect(sfd,(struct sockaddr *)&sin,sizeof(sin))<0)
	{
		perror("connect");
		return -1;
	}
	printf("連接成功\n");

	//創(chuàng)建集合
	struct pollfd fds[2];

	fds[0].fd = 0;
	fds[0].events = POLLIN;
	fds[1].fd = sfd;
	fds[1].events = POLLIN;

	char buf[128]="";
	int res=0;

	while(1)
	{
		//阻塞方式監(jiān)測集合
		res = poll(fds,2,-1);
		if(res < 0)
		{
			ERR_MSG("poll");
			return -1;
		}
		else if(0 == res)
		{
			printf("time out...\n");      //超時(shí)
			break;
		}

		//判斷0文件描述符是否有POLLIN事件
		if((fds[0].revents & POLLIN))
		{
			fgets(buf,sizeof(buf),stdin);
			buf[strlen(buf)-1] = 0;
			if(send(sfd,buf,sizeof(buf),0) < 0)
			{
				ERR_MSG("send");
				return -1;
			}
			printf("發(fā)送成功\n");
		}
		//判斷sfd文件描述符是否有POLLIN事件
		if(fds[1].revents & POLLIN)
		{
			//接收數(shù)據(jù)
			bzero(buf,sizeof(buf));
			res = recv(sfd,buf,sizeof(buf),0);
			if(res<0)
			{
				ERR_MSG("recv");
				return -1;
			}
			else if(res == 0)
			{
				printf("[%s:%d] 服務(wù)器下線__%d__ \n",\
					inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),__LINE__);
				break;
			}
			printf("[%s:%d] cfd = %d : %s__%d__ \n",\
					inet_ntoa(sin.sin_addr),ntohs(sin.sin_port),sfd,buf,__LINE__);
		}	
	}

	if(close(sfd)<0)
	{
		ERR_MSG("close");
		return -1;
	}

	return 0;
}

網(wǎng)絡(luò)編程 IO多路復(fù)用 [select版] (TCP網(wǎng)絡(luò)聊天室),網(wǎng)絡(luò)編程,網(wǎng)絡(luò),tcp/ip,php?

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

到了這里，關(guān)于網(wǎng)絡(luò)編程 IO多路復(fù)用 [select版] (TCP網(wǎng)絡(luò)聊天室)的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！

本文來自互聯(lián)網(wǎng)用戶投稿，該文觀點(diǎn)僅代表作者本人，不代表本站立場。本站僅提供信息存儲(chǔ)空間服務(wù)，不擁有所有權(quán)，不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載，請注明出處： 如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實(shí)不符，請點(diǎn)擊違法舉報(bào)進(jìn)行投訴反饋，一經(jīng)查實(shí)，立即刪除！

領(lǐng)支付寶紅包贊助服務(wù)器費(fèi)用

相關(guān)文章

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請作者喝杯咖啡吧~博客贊助

支付寶掃一掃領(lǐng)取紅包，優(yōu)惠每天領(lǐng)

二維碼1

領(lǐng)取紅包

二維碼2

領(lǐng)紅包