2017-2018-1 20155209 實(shí)驗(yàn)三 實(shí)時(shí)系統(tǒng)

學(xué)習(xí)使用Linux命令wc(1)

基于Linux Socket程序設(shè)計(jì)實(shí)現(xiàn)wc（1）服務(wù)器(端口號(hào)是你學(xué)號(hào)的后6位)和客戶端
客戶端傳一個(gè)文本文件給服務(wù)器
服務(wù)器返加文本文件中的單詞數(shù)

• 使用man 1 wc查看wc
• 代碼實(shí)現(xiàn)如下：
• 客戶端

#include <stdio.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <string.h>#define RIO_BUFSIZE 8192typedef struct{int rio_fd;int rio_cnt;char *rio_bufptr;char rio_buf[RIO_BUFSIZE];}rio_t;#define MAXLINE 200int main(int argc,char **argv){int clientfd,port;char *host,buf[MAXLINE];char sbuf[MAXLINE];char rbuf[MAXLINE];rio_t rio;char str1[MAXLINE]="客戶端IP:";char str2[MAXLINE]="服務(wù)器實(shí)現(xiàn)者學(xué)號(hào):20155209”;char str3[MAXLINE]="當(dāng)?shù)貢r(shí)間:";FILE *fp;char filename[MAXLINE];if(argc!=3){fprintf(stderr,"usage:%s <host> <port>\n",argv[0]);exit(0);}host = argv[1];port = atoi(argv[2]);clientfd = open_clientfd(host,port);while(1){printf("輸入文件名(.txt):\n");gets(filename);fp = fopen(filename,"rb");while(!feof(fp)){fgets(sbuf,MAXLINE,fp);send(clientfd,sbuf,MAXLINE,0);bzero(sbuf,sizeof(sbuf)); }printf("%s",str1);puts(host);printf("%s",str2);putchar('\n');//printf("%s",str3);//puts(rbuf);fclose(fp);//sleep(1000);//recv(clientfd,rbuf,MAXLINE,0);//printf("傳輸完成，該文件單詞數(shù)為%s\n!",rbuf);//puts(rbuf);close(clientfd);exit(0);}}

• 服務(wù)器

#include <stdio.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <sys/wait.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <time.h> #include <string.h>#define MAXLINE 200 #define RIO_BUFSIZE 8192typedef struct{int rio_fd;int rio_cnt;char *rio_bufptr;char rio_buf[RIO_BUFSIZE];}rio_t;typedef struct sockaddr SA;typedef struct{ int tm_sec; int tm_min; int tm_hour; int tm_mday; int tm_mon; int tm_year; int tm_wday; int tm_yday; int tm_isdst; }tm;void sigchld_handler(int sig){pid_t pid;int stat;while((pid = waitpid(-1,&stat,WNOHANG))>0){printf("child %d terminated\n",pid);}return; }void itoa (int n,char s[]) {int i,j,sign;char temp[MAXLINE];if((sign=n)<0)//記錄符號(hào)n=-n;//使n成為正數(shù)i=0;do{temp[i++]=n%10+'0';//取下一個(gè)數(shù)字}while ((n/=10)>0);//刪除該數(shù)字if(sign<0)temp[i++]='-';for(j=0;j<i;j++){//生成的數(shù)字是逆序的，所以要逆序輸出s[j] = temp[i-j-1];}s[i] = '\0'; } int main(int argc,char **argv){int count=0,cnt=0,listenfd,connfd,port,clientlen;struct sockaddr_in clientaddr;struct hostent *hp;char *haddrp;char sbuf[MAXLINE];// char *bufp = sbuf;char rbuf[MAXLINE];rio_t rio;time_t lt;tm *local;char str1[MAXLINE]="客戶端IP:";char str2[MAXLINE]="服務(wù)器實(shí)現(xiàn)者學(xué)號(hào):";char str3[MAXLINE]="當(dāng)?shù)貢r(shí)間:";FILE *fp = fopen("test.txt","wb");if(argc != 2){fprintf(stderr,"usage:%s <port>\n",argv[0]);exit(0);}port = atoi(argv[1]);signal(SIGCHLD,sigchld_handler);listenfd = open_listenfd(port);while(1){clientlen = sizeof(clientaddr);connfd = accept(listenfd,(SA *)&clientaddr,&clientlen);hp = gethostbyaddr((const char*)&clientaddr.sin_addr.s_addr,sizeof(clientaddr.sin_addr.s_addr),AF_INET);haddrp = inet_ntoa(clientaddr.sin_addr);printf("server connected to %s (%s)\n",hp->h_name,haddrp);if(fork() == 0){close(listenfd);/*lt = time(NULL); local = localtime(&lt);strftime(sbuf,64,"%Y-%m-%d %H:%M:%S",local);*/while(cnt = recv(connfd,rbuf,MAXLINE,0)){//printf("%d\n",recv(connfd,rbuf,MAXLINE,0)); fputs(rbuf,fp);bzero(rbuf,sizeof(rbuf));count += cnt;}//printf("傳輸成功!,該文件單詞數(shù)共%d\n!",count);fclose(fp);itoa(count,sbuf);//send(connfd,sbuf,MAXLINE,0);printf("該文件單詞數(shù)為%s!\n",sbuf);close(connfd);exit(0);}close(connfd);} }

• 實(shí)現(xiàn)截圖：

使用多線程實(shí)現(xiàn)wc服務(wù)器并使用同步互斥機(jī)制保證計(jì)數(shù)正確

上方提交代碼
下方提交測(cè)試
對(duì)比單線程版本的性能，并分析原因

• 代碼實(shí)現(xiàn)如下：
• 客戶端

#include <stdio.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <string.h>#define RIO_BUFSIZE 8192typedef struct{int rio_fd;int rio_cnt;char *rio_bufptr;char rio_buf[RIO_BUFSIZE];}rio_t;#define MAXLINE 200int main(int argc,char **argv){int clientfd,port;char *host,buf[MAXLINE];char sbuf[MAXLINE];char rbuf[MAXLINE];rio_t rio;char str1[MAXLINE]="客戶端IP:";char str2[MAXLINE]="服務(wù)器實(shí)現(xiàn)者學(xué)號(hào):20155209”;char str3[MAXLINE]="當(dāng)?shù)貢r(shí)間:";FILE *fp;char filename[MAXLINE];if(argc!=3){fprintf(stderr,"usage:%s <host> <port>\n",argv[0]);exit(0);}host = argv[1];port = atoi(argv[2]);clientfd = open_clientfd(host,port);while(1){printf("輸入文件名(.txt):\n");gets(filename);fp = fopen(filename,"rb");while(!feof(fp)){fgets(sbuf,MAXLINE,fp);send(clientfd,sbuf,MAXLINE,0);bzero(sbuf,sizeof(sbuf)); }printf("%s",str1);puts(host);printf("%s",str2);putchar('\n');//printf("%s",str3);//puts(rbuf);fclose(fp);//sleep(1000);//recv(clientfd,rbuf,MAXLINE,0);//printf("傳輸完成，該文件單詞數(shù)為%s\n!",rbuf);//puts(rbuf);close(clientfd);exit(0);}}

• 服務(wù)器

#include <stdio.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <sys/wait.h> #include <sys/types.h> #include <sys/socket.h> #include <stdlib.h> #include <time.h> #include <string.h> #include <pthread.h>#define MAXLINE 200 #define RIO_BUFSIZE 8192typedef struct{int rio_fd;int rio_cnt;char *rio_bufptr;char rio_buf[RIO_BUFSIZE];}rio_t;typedef struct sockaddr SA;typedef struct{ int tm_sec; int tm_min; int tm_hour; int tm_mday; int tm_mon; int tm_year; int tm_wday; int tm_yday; int tm_isdst; }tm;void itoa (int n,char s[]);void *thread(void *vargp);int main(int argc,char **argv){int listenfd,*connfdp,port;int clientlen;struct sockaddr_in clientaddr;struct hostent *hp;char *haddrp;pthread_t tid;if(argc != 2){fprintf(stderr,"usage:%s <port>\n",argv[0]);exit(0);}port = atoi(argv[1]);listenfd = open_listenfd(port);while(1){clientlen = sizeof(clientaddr);connfdp =malloc(sizeof(int));*connfdp = accept(listenfd,(SA *)&clientaddr,&clientlen);hp = gethostbyaddr((const char*)&clientaddr.sin_addr.s_addr,sizeof(clientaddr.sin_addr.s_addr),AF_INET);haddrp = inet_ntoa(clientaddr.sin_addr);printf("server connected to %s (%s)\n",hp->h_name,haddrp);pthread_create(&tid,NULL,thread,connfdp);pthread_join(tid,NULL);} }void *thread(void *vargp){time_t lt;tm *local;char sbuf[MAXLINE];int cnt = 0,count = 0;char *fp = fopen("test.txt","wb");char rbuf[MAXLINE];int connfd = *((int*)vargp);free(vargp);pthread_detach(pthread_self());/*lt = time(NULL); local = localtime(&lt);strftime(sbuf,64,"%Y-%m-%d %H:%M:%S",local);send(connfd,sbuf,MAXLINE,0);*/ while(cnt = recv(connfd,rbuf,MAXLINE,0)){//printf("%d\n",recv(connfd,rbuf,MAXLINE,0)); fputs(rbuf,fp);bzero(rbuf,sizeof(rbuf));count += cnt;}//printf("傳輸成功!,該文件單詞數(shù)共%d\n!",count);fclose(fp);itoa(count,sbuf);//send(connfd,sbuf,MAXLINE,0);printf("該文件單詞數(shù)為%s!\n",sbuf);close(connfd);return NULL; }void itoa (int n,char s[]) {int i,j,sign;char temp[MAXLINE];if((sign=n)<0)//記錄符號(hào)n=-n;//使n成為正數(shù)i=0;do{temp[i++]=n%10+'0';//取下一個(gè)數(shù)字}while ((n/=10)>0);//刪除該數(shù)字if(sign<0)temp[i++]='-';for(j=0;j<i;j++){//生成的數(shù)字是逆序的，所以要逆序輸出s[j] = temp[i-j-1];}s[i] = '\0'; }

• 程序運(yùn)行結(jié)果截圖：
• 實(shí)驗(yàn)中遇到的問(wèn)題：在自己電腦（Mac）運(yùn)行代碼出現(xiàn)如下問(wèn)題：Static library link issue with Mac OS X: symbol(s) not found for architecture x86_64。

• 解決方法：在網(wǎng)上尋找了許多方法都不能編譯成功。最后在Mac里安裝了Linux虛擬機(jī)，在虛擬機(jī)里做這個(gè)實(shí)驗(yàn)了。

轉(zhuǎn)載于:https://www.cnblogs.com/lhyhahaha/p/7862818.html

總結(jié)

以上是生活随笔為你收集整理的2017-2018-1 20155209 实验三 实时系统的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。