2018-2019-1 20165219 实验三 实时系统

2018-2019-1 20165219 实验三 实时系统

任务一

实验要求

学习使用Linux命令wc(1)

基于Linux Socket程序设计实现wc（1）服务器(端口号是你学号的后6位)和客户端

客户端传一个文本文件给服务器

服务器返加文本文件中的单词数

客户端

#include<netinet/in.h>  // sockaddr_in 
#include<sys/types.h>  // socket 
#include<sys/socket.h>  // socket 
#include<stdio.h>    // printf 
#include<stdlib.h>    // exit 
#include<string.h>    // bzero #define SERVER_PORT 165219 
#define BUFFER_SIZE 1024 
#define FILE_NAME_MAX_SIZE 512 int main() 
{ struct sockaddr_in client_addr; bzero(&client_addr, sizeof(client_addr)); client_addr.sin_family = AF_INET; client_addr.sin_addr.s_addr = htons(INADDR_ANY); client_addr.sin_port = htons(0); int client_socket_fd = socket(AF_INET, SOCK_STREAM, 0); if(client_socket_fd < 0) { perror("Create Socket Failed:"); exit(1); } if(-1 == (bind(client_socket_fd, (struct sockaddr*)&client_addr, sizeof(client_addr)))) { perror("Client Bind Failed:"); exit(1); } struct sockaddr_in server_addr; bzero(&server_addr, sizeof(server_addr)); server_addr.sin_family = AF_INET; if(inet_pton(AF_INET, "127.0.0.1", &server_addr.sin_addr) == 0) { perror("Server IP Address Error:"); exit(1); } server_addr.sin_port = htons(SERVER_PORT); socklen_t server_addr_length = sizeof(server_addr); if(connect(client_socket_fd, (struct sockaddr*)&server_addr, server_addr_length) < 0) { perror("Can Not Connect To Server IP:"); exit(0); } char file_name[FILE_NAME_MAX_SIZE+1]; bzero(file_name, FILE_NAME_MAX_SIZE+1); printf("Please Input File Name On Server:\t"); scanf("%s", file_name); char buffer[BUFFER_SIZE]; bzero(buffer, BUFFER_SIZE); strncpy(buffer, file_name, strlen(file_name)>BUFFER_SIZE?BUFFER_SIZE:strlen(file_name)); if(send(client_socket_fd, buffer, BUFFER_SIZE, 0) < 0) { perror("Send File Name Failed:"); exit(1); } FILE *fp = fopen(file_name, "w"); if(NULL == fp) { printf("File:\t%s Can Not Open To Write\n", file_name); exit(1); } bzero(buffer, BUFFER_SIZE); int length = 0; while((length = recv(client_socket_fd, buffer, BUFFER_SIZE, 0)) > 0) { if(fwrite(buffer, sizeof(char), length, fp) < length) { printf("File:\t%s Write Failed\n", file_name); break; } bzero(buffer, BUFFER_SIZE); } printf("Send File:\t%s  Successful!\n", file_name); close(fp); close(client_socket_fd);char *argv[]={"wc","-w",file_name,0};execvp("wc",argv);return 0; 
}

服务器

#include<netinet/in.h> // sockaddr_in
#include<sys/types.h>  // socket
#include<sys/socket.h> // socket
#include<stdio.h>    // printf
#include<stdlib.h>   // exit
#include<string.h>   // bzero#define SERVER_PORT 8000
#define LENGTH_OF_LISTEN_QUEUE 20
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512int main(void)
{struct sockaddr_in server_addr;bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htons(INADDR_ANY);server_addr.sin_port = htons(SERVER_PORT);int server_socket_fd = socket(PF_INET, SOCK_STREAM, 0);if(server_socket_fd < 0){perror("Create Socket Failed:");exit(1);}int opt = 1;setsockopt(server_socket_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));if(-1 == (bind(server_socket_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)))){perror("Server Bind Failed:");exit(1);}if(-1 == (listen(server_socket_fd, LENGTH_OF_LISTEN_QUEUE))){perror("Server Listen Failed:");exit(1);}while(1){struct sockaddr_in client_addr;socklen_t client_addr_length = sizeof(client_addr);int new_server_socket_fd = accept(server_socket_fd, (struct sockaddr*)&client_addr, &client_addr_length);if(new_server_socket_fd < 0){perror("Server Accept Failed:");break;}char buffer[BUFFER_SIZE];bzero(buffer, BUFFER_SIZE);if(recv(new_server_socket_fd, buffer, BUFFER_SIZE, 0) < 0){perror("Server Recieve Data Failed:");break;}char file_name[FILE_NAME_MAX_SIZE+1];bzero(file_name, FILE_NAME_MAX_SIZE+1);strncpy(file_name, buffer, strlen(buffer)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer));printf("%s\n", file_name);FILE *fp = fopen(file_name, "r");if(NULL == fp){printf("File:%s Not Found\n", file_name);}else{bzero(buffer, BUFFER_SIZE);int length = 0;while((length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0){if(send(new_server_socket_fd, buffer, length, 0) < 0){printf("Send File:%s Failed./n", file_name);break;}bzero(buffer, BUFFER_SIZE);}fclose(fp);printf("File:%s Transfer Successful!\n", file_name);}close(new_server_socket_fd);}close(server_socket_fd);return 0;
}

1296533-20181118155339557-1381356004.png

任务二

实验要求

使用多线程实现wc服务器并使用同步互斥机制保证计数正确

上方提交代码

下方提交测试

对比单线程版本的性能，并分析原因

服务器

#include "csapp.h"
#include<stdio.h>
#include<stdlib.h>
static int byte_cnt;  /* byte counter */
static sem_t mutex;
#define NTHREADS  4
#define SBUFSIZE  16
typedef struct {int *buf;          /* Buffer array */        int n;             /* Maximum number of slots */int front;         /* buf[(front+1)%n] is first item */int rear;          /* buf[rear%n] is last item */sem_t mutex;       /* Protects accesses to buf */sem_t slots;       /* Counts available slots */sem_t items;       /* Counts available items */
} sbuf_t;
void echo_cnt(int connfd);
void *thread(void *vargp);
int wc(char *name)
{char ch;FILE *fp;long count=0;char s[21];if ((fp=fopen(name,"r+"))==NULL){fprintf(stderr,"不能打开文件\n");exit(EXIT_FAILURE);}
while(fscanf(fp,"%s",s)!=EOF)count++;fclose(fp);printf("File %s has %ld characters\n",name,count);return 0;
}sbuf_t sbuf; /* shared buffer of connected descriptors */int main(int argc, char **argv)
{int i, listenfd, connfd, port, clientlen=sizeof(struct sockaddr_in);struct sockaddr_in clientaddr;pthread_t tid;if (argc != 2) {fprintf(stderr, "usage: %s <port>\n", argv[0]);exit(0);}port = atoi(argv[1]);sbuf_init(&sbuf, SBUFSIZE);listenfd = Open_listenfd(port);for (i = 0; i < NTHREADS; i++)  /* Create worker threads */Pthread_create(&tid, NULL, thread, NULL);while (1) {connfd = Accept(listenfd, (SA *) &clientaddr, &clientlen);sbuf_insert(&sbuf, connfd); /* Insert connfd in buffer */}
}static void init_echo_cnt(void)
{Sem_init(&mutex, 0, 1);byte_cnt = 0;
}void echo_cnt(int connfd)
{int n,x;long int count;char buf[MAXLINE];char name[MAXLINE]rio_t rio;static pthread_once_t once = PTHREAD_ONCE_INIT;Pthread_once(&once, init_echo_cnt);Rio_readinitb(&rio, connfd);while((n = Rio_readlineb(&rio, buf, MAXLINE)) != 0) {P(&mutex);byte_cnt += n;/*x = sizeof(buf);buf[x] = 0;count = wc(buf);*/printf("thread %d received %d (%d total) bytes on fd %d\n",(int) pthread_self(), n, byte_cnt, connfd);//name = buf;V(&mutex);//sprint(buf,"%s:%ld characters".count);Rio_writen(connfd, buf, n);}
}void sbuf_init(sbuf_t *sp, int n)
{sp->buf = Calloc(n, sizeof(int));sp->n = n;                       /* Buffer holds max of n items */sp->front = sp->rear = 0;        /* Empty buffer iff front == rear */Sem_init(&sp->mutex, 0, 1);      /* Binary semaphore for locking */Sem_init(&sp->slots, 0, n);      /* Initially, buf has n empty slots */Sem_init(&sp->items, 0, 0);      /* Initially, buf has zero data items */
}
/* $end sbuf_init *//* Clean up buffer sp */
/* $begin sbuf_deinit */
void sbuf_deinit(sbuf_t *sp)
{Free(sp->buf);
}
/* $end sbuf_deinit *//* Insert item onto the rear of shared buffer sp */
/* $begin sbuf_insert */
void sbuf_insert(sbuf_t *sp, int item)
{P(&sp->slots);                          /* Wait for available slot */P(&sp->mutex);                          /* Lock the buffer */sp->buf[(++sp->rear)%(sp->n)] = item;   /* Insert the item */V(&sp->mutex);                          /* Unlock the buffer */V(&sp->items);                          /* Announce available item */
}
/* $end sbuf_insert *//* Remove and return the first item from buffer sp */
/* $begin sbuf_remove */
int sbuf_remove(sbuf_t *sp)
{int item;P(&sp->items);                          /* Wait for available item */P(&sp->mutex);                          /* Lock the buffer */item = sp->buf[(++sp->front)%(sp->n)];  /* Remove the item */V(&sp->mutex);                          /* Unlock the buffer */V(&sp->slots);                          /* Announce available slot */return item;
}void *thread(void *vargp)
{ Pthread_detach(pthread_self());while (1) {int connfd = sbuf_remove(&sbuf); /* Remove connfd from buffer */echo_cnt(connfd);                /* Service client */Close(connfd);}
}

客户端

#include "csapp.h"
#include<stdio.h>
#include<stdlib.h>
int wc(char *name)
{char ch;FILE *fp;long count=0;char s[21];if ((fp=fopen("test1.txt","r+"))==NULL){fprintf(stderr,"不能打开文件%s\n",name);exit(EXIT_FAILURE);}
while(fscanf(fp,"%s",s)!=EOF)count++;fclose(fp);printf("File %s has %ld characters\n",name,count);return 0;
}
int main(int argc, char **argv)
{int clientfd, port,n,count;char *host, buf[MAXLINE];rio_t rio;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);Rio_readinitb(&rio, clientfd);while (Fgets(buf, MAXLINE, stdin) != NULL) {if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1){printf("recv() error\n");exit(1);}buf[num-1]='\0';Rio_writen(clientfd, buf, strlen(buf));Rio_readlineb(&rio, buf, MAXLINE);Fputs(buf, stdout);}Close(clientfd);exit(0);
}
/* $end echoclientmain */
/* $begin echoclientmain */
//#include "csapp.h"
/*int main(int argc, char **argv)
{int clientfd, port;char *host, buf[MAXLINE];char *name;rio_t rio;FILE *fp;if (argc != 4) {fprintf(stderr, "usage: %s <host> <port> <filename>\n", argv[0]);exit(0);}host = argv[1];port = atoi(argv[2]);name = argv[3];clientfd = Open_clientfd(host, port);Rio_readinitb(&rio, clientfd);fp=fopen(name,"r+");while (Fgets(buf, MAXLINE,fp) != NULL) {Rio_writen(clientfd, buf, strlen(buf));Rio_readlineb(&rio, buf, MAXLINE);Fputs(buf, stdout);}Close(clientfd);exit(0);
}

1296533-20181118154632673-1654630807.jpg

新学到的知识点

更深入的理解了客户端和服务端

学习了man查询命令

转载于:https://www.cnblogs.com/wyb-1998/p/9959040.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/464368.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

音视频基础知识大全

音视频基础知识大全

今天跟几个朋友聊天&#xff0c;他们问我是不是在腾讯&#xff0c;在腾讯做什么&#xff1f;然后我就说了我做的事情&#xff0c;我说我在腾讯做音频方面的开发&#xff0c;对外的产品主要是腾讯会议。然后他我一个朋友就截图了他的腾讯会议的软件截图过来。音视频是一个很好玩…
阅读更多...
读取config文件中的键值

读取config文件中的键值

新建个config文件 <?xml version"1.0" encoding"utf-8"?><!-- 注意: 除了手动编辑此文件以外&#xff0c;您还可以使用 Web 管理工具来 配置应用程序的设置。 可以使用 Visual Studio 中的“网站”->“Asp.Net 配置”选项。 设置…
阅读更多...
单片机c语言pwm整流的程序,基于 单片机控制PWM整流电源的设计.doc

单片机c语言pwm整流的程序,基于 单片机控制PWM整流电源的设计.doc

PAGE \* MERGEFORMAT II摘??? 要本文介绍了用PWM实现直流电机调整的基本方法。本文在给出直流电机调整和PWM实现方法的基础上,提供一种用单片机软件实现PWM调速的方法,以及直流电机调速的相关知识和PWM调整的基本原理和实现方法.介绍了基于MCS-51单片机用软件产生PWM信号的途…
阅读更多...
详解Android Touch事件的传递机制

详解Android Touch事件的传递机制

1、基础知识 (1) 所有Touch事件都被封装成了MotionEvent对象&#xff0c;包括Touch的位置、时间、历史记录以及第几个手指(多指触摸)等。 (2) 事件类型分为ACTION_DOWN, ACTION_UP, ACTION_MOVE, ACTION_POINTER_DOWN, ACTION_POINTER_UP, ACTION_CANCEL&#xff0c;每个事件都…
阅读更多...
asp.net登录状态验证

asp.net登录状态验证

文章&#xff1a;ASP.NET 登录验证 文章&#xff1a;ASP.NET MVC下判断用户登录和授权状态方法 文章&#xff1a;.net学习笔记---HttpHandle与HttpModule 第一篇文章&#xff0c;介绍了 1&#xff09;早期的BasePage类&#xff0c;每个页面继承自BasePage类&#xff0c;取sessi…
阅读更多...
Wiki的介绍

Wiki的介绍

何为Wiki&#xff08;维客&#xff09;&#xff1f; 首先&#xff0c;我们要搞清楚&#xff1a;wiki概念的发明人是Ward Cunningham。wiki这个字到底是什幺意思呢&#xff1f;根据FAQ的说法&#xff0c;WikiWiki 一词来源于夏威夷语的“wee kee wee kee”&#xff0c;原本是“快…
阅读更多...
项目专访|在ESP32上移植Linux

项目专访|在ESP32上移植Linux

大家好&#xff0c;我是写代码的篮球球痴&#xff0c;最近在网上看到一个非常有意思的项目&#xff0c;有大神把Linux内核移植到ESP32上&#xff0c;并成功运行。在国外网站上&#xff0c;有很多人在议论这件事情https://hackaday.com/2021/07/21/its-linux-but-on-an-esp32/ES…
阅读更多...
4.3英寸屏双核 LG Prada K2通过FCC认证

4.3英寸屏双核 LG Prada K2通过FCC认证

我们此前曝光过一款型号为LG Prada K2的智能手机&#xff0c;这款手机不仅配置出色而且外观极为时尚。如今&#xff0c;来自国外媒体的最新消息显示&#xff0c;LG Prada K2已经通过FCC认证&#xff0c;这意味着它距离上市已经为期不远。 LG Prada K2通过FCC认证 LG Prada K2是…
阅读更多...
c语言第4份实验报告,C语言实验报告04.doc

c语言第4份实验报告,C语言实验报告04.doc

实验报告人&#xff1a;张静成 数学3班 10080338一、实验目的1、掌握选择结构的程序书写&#xff01;2、了解条件与程序流程的关系3、了解用不同的数据使程序的流程覆盖不同的语句、分支和路径。二、实验内容(一)、题目 11、题目内容描述&#xff1a;改写第三章小写字母转换为大…
阅读更多...
VC中Error spawning cl.exe错误的解决方法.

VC中Error spawning cl.exe错误的解决方法.

VC中Error spawning cl.exe错误的解决方法. 转载地址&#xff1a;http://blog.csdn.net/badboyfind/article/details/1816189 可能很多人在安装VC 6.0后有过点击“Compile”或者“Build”后被出现的 “Compiling... ,Error spawning cl.exe”错误提示给郁闷过。很多人的 选择是…
阅读更多...
Swift中空合运算符、闭区间运算符、单侧区间、半开区间

Swift中空合运算符、闭区间运算符、单侧区间、半开区间

空合运算符&#xff08;Nil Coalescing Operator&#xff09; 用于取代3目判空运算&#xff0c;提供超短的写法比如常规判空写法如下&#xff0c;反正我写java就是这么干的 var anOptionalInt: Int? 10var anInt: Int 0if anOptionalInt ! nil { anInt anOptionalInt! } 空…
阅读更多...
关于禁止svn客户端长驻内存的方法

关于禁止svn客户端长驻内存的方法

公司到目前为止版本控制多用svn&#xff0c;安装后会自动加载tsvncache.exe主程序&#xff0c;尝试手动关闭该进程&#xff0c;过几分钟又会再出现。 使用svn一段时间以来&#xff0c;发现该程序除了会自动加载&#xff0c;偶尔还会自动扫描磁盘空间&#xff0c;并且对于未标记…
阅读更多...
国内MCU厂商也开始卷了

国内MCU厂商也开始卷了

最近我大学老师准备做一个项目&#xff0c;需要用到STM32的芯片&#xff0c;然后我就帮忙着一起找&#xff0c;不找不知道&#xff0c;找了才知道这个东西真的是贵。然后我就看了GD32&#xff0c;不了解不知道&#xff0c;这个东西也是真的贵。然后我又去看的MM32&#xff0c;结…
阅读更多...
c语言朋友,[原创]写给初学 c语言的朋友

c语言朋友,[原创]写给初学 c语言的朋友

C语言的教材有很多&#xff0c;但基本都没有本质上的区别。随便拿两本里面的内容都差不多。对于第一次学习编程的人来说&#xff0c;看教材会产生很多疑问&#xff0c;比如为什么a a 1;是正确的、什么时候用变量、在什么地方定义变量等等。继续深入学习后又会产生许多疑问&am…
阅读更多...
Google Flash转换HTML5工具Swiffy测试版发布

Google Flash转换HTML5工具Swiffy测试版发布

Google今年六月推出的Flash转换HTML5工具已经从实验室转为测试版&#xff0c;并新增一个Flash Professional扩充模组&#xff0c;可以直接将档案储存为HTML5格式。一开始Swiffy仅以网站方式&#xff0c;让使用者上传Flash的.swf档案&#xff0c;支持Flash所使用的swf 8格式与Ac…
阅读更多...
求字符串全排列的递归算法

求字符串全排列的递归算法

求字符串全排列的递归算法 void permutation(char * p_str, char * p_begin) { if(!p_str || !p_begin) { return; } if(\0 *p_begin) { printf("%s\n", p_str); }else { char * p_ch; for(p_ch p_begin; *p_ch ! \0; p_ch) { char temp; /* Swap …
阅读更多...
ssis 排程更新

ssis 排程更新

昨天&#xff0c;在as裡面再次看看以前作的一個cube發現&#xff0c;數據竟然一點都沒變&#xff0c;不大對勁&#xff0c;因為這些數據我都已經刪掉了。同事說是我沒選雪花&#xff0c;星型。我想都不想就說&#xff0c;肯定不是哪個樣子&#xff0c;因為sql 2005根本就沒讓你…
阅读更多...
Clipboard.js复制粘贴到剪贴板

Clipboard.js复制粘贴到剪贴板

来自他人参考链接&#xff1a;https://www.cnblogs.com/kevinCoder/p/6144376.html转载于:https://www.cnblogs.com/jiaqi1719/p/9962342.html
阅读更多...
什么是MCU里应尽量遵循的寄存器谨慎赋值法？

什么是MCU里应尽量遵循的寄存器谨慎赋值法？

有人觉得搞MCU是一件简单的事情&#xff0c;往往觉得简单的事反而出错更多&#xff0c;今天转发一篇我朋友痞子衡的文章&#xff0c;说说MCU里面的寄存器的事。大家好&#xff0c;我是痞子衡&#xff0c;是正经搞技术的痞子。今天痞子衡给大家介绍的是改动i.MXRT1xxx里IOMUXC_G…
阅读更多...
惠普电脑如何下载c语言软件,惠普笔记本电脑上的语言栏怎么弄

惠普电脑如何下载c语言软件,惠普笔记本电脑上的语言栏怎么弄

满意答案mygood12f32013.01.23采纳率&#xff1a;53% 等级&#xff1a;11已帮助&#xff1a;6723人首先运行“regedit”&#xff0c;展开“HKEY_CURRENT_USER/keyboard layout/preload”分支&#xff0c;在其下新建一个字符串值&#xff0c;命名为“1”&#xff0c;并将它对…
阅读更多...
最新文章

Copyright @ 2022~2023