socket網(wǎng)絡(luò)編程linux下實現(xiàn)聊天室費下載

1、 SOCKET網(wǎng)絡(luò)編程：Linux下實現(xiàn)聊天室程序介紹：本聊天室程序在Ubuntu下，采用C語言實現(xiàn)，結(jié)構(gòu)為Client/Server結(jié)構(gòu);服務(wù)端程序通過共享存儲區(qū)存儲聊天數(shù)據(jù)，并發(fā)送給每個連接的客戶端；服務(wù)端程序和客戶端程序都是通過父子進程分別負責(zé)發(fā)送和接收數(shù)據(jù)的，以避免數(shù)據(jù)沖撞；需按以下格式調(diào)用客戶端程序：client.exe 服務(wù)端主機IP 端口號(本程序設(shè)定為：3490) 用戶名(在聊天室中顯示的用戶名)。 程序截圖:/-服務(wù)端-/-客戶端1：真水無香-/-客戶端2：蠟筆小新-程序代碼如下：/-/包含工程所需的頭文件#include<stdio.h> #include<

2、;stdlib.h>#include<sys/types.h> /數(shù)據(jù)類型定義#include<sys/stat.h>#include<netinet/in.h> /定義數(shù)據(jù)結(jié)構(gòu)sockaddr_in#include<sys/socket.h> /提供socket函數(shù)及數(shù)據(jù)結(jié)構(gòu)#include<string.h>#include<unistd.h>#include<signal.h>#include<sys/ipc.h>#include<errno.h>#include<sy

3、s/shm.h>#include<time.h>#define PERM S_IRUSR|S_IWUSR #define MYPORT 3490 /宏定義定義通信端口#define BACKLOG 10 /宏定義，定義服務(wù)程序可以連接的最大客戶數(shù)量#define WELCOME "|-Welcome to the chat room! -|" /宏定義，當(dāng)客戶端連接服務(wù)端時，想客戶發(fā)送此歡迎字符串/轉(zhuǎn)換函數(shù)，將int類型轉(zhuǎn)換成char *類型void itoa(int i,char*string) int power,j; j=i; for(power=1

4、;j>=10;j/=10) power*=10; for(;power>0;power/=10) *string+='0'+i/power; i%=power; *string='0'/得到當(dāng)前系統(tǒng)時間void get_cur_time(char * time_str) time_t timep; struct tm *p_curtime; char *time_tmp; time_tmp=(char *)malloc(2); memset(time_tmp,0,2); memset(time_str,0,20); time(&timep);

5、 p_curtime = localtime(&timep); strcat(time_str," ("); itoa(p_curtime->tm_hour,time_tmp); strcat(time_str,time_tmp); strcat(time_str,":"); itoa(p_curtime->tm_min,time_tmp); strcat(time_str,time_tmp); strcat(time_str,":"); itoa(p_curtime->tm_sec,time_tmp); s

6、trcat(time_str,time_tmp); strcat(time_str,")"); free(time_tmp);/創(chuàng)建共享存儲區(qū)key_t shm_create() key_t shmid; /shmid = shmget(IPC_PRIVATE,1024,PERM); if(shmid = shmget(IPC_PRIVATE,1024,PERM) = -1) fprintf(stderr,"Create Share Memory Error:%sna",strerror(errno); exit(1); return shmid;/端口

7、綁定函數(shù),創(chuàng)建套接字，并綁定到指定端口int bindPort(unsigned short int port) int sockfd; struct sockaddr_in my_addr; sockfd = socket(AF_INET,SOCK_STREAM,0);/創(chuàng)建基于流套接字 my_addr.sin_family = AF_INET;/IPv4協(xié)議族 my_addr.sin_port = htons(port);/端口轉(zhuǎn)換 my_addr.sin_addr.s_addr = INADDR_ANY; bzero(&(my_addr.sin_zero),0); if(bind

8、(sockfd,(struct sockaddr*)&my_addr,sizeof(struct sockaddr) = -1) perror("bind"); exit(1); printf("bing success!n"); return sockfd;int main(int argc, char *argv) int sockfd,clientfd,sin_size,recvbytes; /定義監(jiān)聽套接字、客戶套接字 pid_t pid,ppid; /定義父子線程標(biāo)記變量 char *buf, *r_addr, *w_addr, *te

9、mp, *time_str;/="0" /定義臨時存儲區(qū) struct sockaddr_in their_addr; /定義地址結(jié)構(gòu) key_t shmid; shmid = shm_create(); /創(chuàng)建共享存儲區(qū) temp = (char *)malloc(255); time_str=(char *)malloc(20); sockfd = bindPort(MYPORT);/綁定端口 while(1) if(listen(sockfd,BACKLOG) = -1)/在指定端口上監(jiān)聽 perror("listen"); exit(1); pr

10、intf("listening.n"); if(clientfd = accept(sockfd,(struct sockaddr*)&their_addr,&sin_size) = -1)/接收客戶端連接 perror("accept"); exit(1); printf("accept from:%dn",inet_ntoa(their_addr.sin_addr); send(clientfd,WELCOME,strlen(WELCOME),0);/發(fā)送問候信息 buf = (char *)malloc(255)

11、; ppid = fork();/創(chuàng)建子進程 if(ppid = 0) /printf("ppid=0n"); pid = fork(); /創(chuàng)建子進程 while(1) if(pid > 0) /父進程用于接收信息 memset(buf,0,255); /printf("recvn"); /sleep(1); if(recvbytes = recv(clientfd,buf,255,0) <= 0) perror("recv1"); close(clientfd); raise(SIGKILL); exit(1); /w

12、rite buf's data to share memory w_addr = shmat(shmid, 0, 0); memset(w_addr, '0', 1024); strncpy(w_addr, buf, 1024); get_cur_time(time_str); strcat(buf,time_str); printf(" %sn",buf); else if(pid = 0) /子進程用于發(fā)送信息 /scanf("%s",buf); sleep(1); r_addr = shmat(shmid, 0, 0); /

13、printf("-%sn",r_addr); /printf("cmp:%dn",strcmp(temp,r_addr); if(strcmp(temp,r_addr) != 0) strcpy(temp,r_addr); get_cur_time(time_str); strcat(r_addr,time_str); /printf("discriptor:%dn",clientfd); /if(send(clientfd,buf,strlen(buf),0) = -1) if(send(clientfd,r_addr,strlen

14、(r_addr),0) = -1) perror("send"); memset(r_addr, '0', 1024); strcpy(r_addr,temp); else perror("fork"); printf("-n"); free(buf); close(sockfd); close(clientfd); return 0;/-/包含工程所需的頭文件#include<stdio.h>#include<netinet/in.h> /定義數(shù)據(jù)結(jié)構(gòu)sockaddr_in#include&l

15、t;sys/socket.h> /提供socket函數(shù)及數(shù)據(jù)結(jié)構(gòu)#include<sys/types.h> /數(shù)據(jù)類型定義#include<string.h>#include<stdlib.h>#include<netdb.h>#include<unistd.h>#include<signal.h>#include<time.h>int main(int argc, char *argv) struct sockaddr_in clientaddr;/定義地址結(jié)構(gòu) pid_t pid; int clien

16、tfd,sendbytes,recvbytes;/定義客戶端套接字 struct hostent *host; char *buf,*buf_r; if(argc < 4) printf("usage:n"); printf("%s host port namen",argv0); exit(1); host = gethostbyname(argv1); if(clientfd = socket(AF_INET,SOCK_STREAM,0) = -1) /創(chuàng)建客戶端套接字 perror("socketn"); exit(1);

17、 /綁定客戶端套接字 clientaddr.sin_family = AF_INET; clientaddr.sin_port = htons(uint16_t)atoi(argv2); clientaddr.sin_addr = *(struct in_addr *)host->h_addr); bzero(&(clientaddr.sin_zero),0); if(connect(clientfd,(struct sockaddr *)&clientaddr,sizeof(struct sockaddr) = -1) /連接服務(wù)端 perror("conne

18、ctn"); exit(1); buf=(char *)malloc(120); memset(buf,0,120); buf_r=(char *)malloc(100); if( recv(clientfd,buf,100,0) = -1) perror("recv:"); exit(1); printf("n%sn",buf); pid = fork();/創(chuàng)建子進程 while(1) if(pid > 0) /父進程用于發(fā)送信息 /get_cur_time(time_str); strcpy(buf,argv3); strcat(buf,":"); memset(buf_r,0,100); /gets(buf_r); fgets(buf_r,100,stdin); strncat(buf,buf_r,strlen(buf_r)-1); /strcat(buf,time_str); /printf("-%sn",buf); if(sendbytes = send(clientfd,buf,str