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;对外的产品主要是腾讯会议。然后他我一个朋友就截图了他的腾讯会议的软件截图过来。音视频是一个很好玩…
阅读更多...
详解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;每个事件都…
阅读更多...
项目专访|在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是…
阅读更多...
国内MCU厂商也开始卷了

国内MCU厂商也开始卷了

最近我大学老师准备做一个项目&#xff0c;需要用到STM32的芯片&#xff0c;然后我就帮忙着一起找&#xff0c;不找不知道&#xff0c;找了才知道这个东西真的是贵。然后我就看了GD32&#xff0c;不了解不知道&#xff0c;这个东西也是真的贵。然后我又去看的MM32&#xff0c;结…
阅读更多...
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…
阅读更多...
什么是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;并将它对…
阅读更多...
单件模式(Singleton Pattern)

单件模式(Singleton Pattern)

1、单件模式试用与窗口管理器或者是打印假脱机、数据库连接池&#xff1b;2、目的&#xff1a;在单独得对象实例中&#xff0c;集中了这个对象所属类得所有权利&#xff1b;3、DoNet解决方案 public class DotNetSigleton { private static readonly DotNetSiglet…
阅读更多...
LeetCode：二进制手表【401】

LeetCode：二进制手表【401】

LeetCode&#xff1a;二进制手表【401】 题目描述 二进制手表顶部有 4 个 LED 代表小时&#xff08;0-11&#xff09;&#xff0c;底部的 6 个 LED 代表分钟&#xff08;0-59&#xff09;。 每个 LED 代表一个 0 或 1&#xff0c;最低位在右侧。 例如&#xff0c;上面的二进制手…
阅读更多...
反馈电路中相位补偿，到底是什么鬼？

反馈电路中相位补偿，到底是什么鬼？

帮朋友做镍氢充电器&#xff0c;利用镍氢电池充满电时电压有一个微小的下降这个特点来识别是否已经充满&#xff0c;比如1.2V的镍氢电池&#xff0c;快充满的时候&#xff0c;电压在1.35V&#xff0c;之后逐步下降&#xff0c;电压可以低于1.30V。所以需要单片机间歇检测电池两…
阅读更多...
RoseHA集群：RHEL+RoseMirror+Oracle【2】

RoseHA集群：RHEL+RoseMirror+Oracle【2】

博主正在参加“2011年度IT博客大赛”&#xff0c;欢迎帮顶&#xff01; 投票地址 --------------------------------------------- 三&#xff0e;安装Rose Mirror HA&#xff1a;准备工作&#xff1a;在安装 Rose Mirror HA 前检查相应的软件包是否安装&#xff0c;如果没有安…
阅读更多...
c语言笔试面试面试题,最新华为c语言笔试面试题

c语言笔试面试面试题,最新华为c语言笔试面试题

最新华为c语言笔试面试题本文是百分网小编搜索整理的一份最新华为c语言笔试面试题&#xff0c;有需要的朋友们一起看看吧!想了解更多相关信息请持续关注我们应届毕业生考试网!1、局部变量能否和全局变量重名答&#xff1a;能&#xff0c;局部会屏蔽全局。要用全局变量&#xff…
阅读更多...
【项目管理】CMMI-需求跟踪矩阵模版

【项目管理】CMMI-需求跟踪矩阵模版

需求菜单/功能模块需求名称需求变更类型&#xff08;新增、修改&#xff09;需求状态&#xff08;已建议、已批准、已设计、已实现、已验证、已删除&#xff09;优先级&#xff08;高、中、低&#xff09;软件需求&#xff08;工作产品、章节号&#xff09;概要设计&#xff08…
阅读更多...
嵌入式工程师薪资调查

嵌入式工程师薪资调查

大家好&#xff0c;嵌入式行业薪资一直是大家关心的问题&#xff0c;刚好我的好朋友发起了一个调查&#xff0c;大家可以匿名写下自己的薪资&#xff0c;也可以看看其他的薪资水平。3月4月份确实是找工作的好机会&#xff0c;求职和跳槽最好的月份要来了吗 &#xff0c;最近看到…
阅读更多...
在STM32单片机上跑神经网络算法

在STM32单片机上跑神经网络算法

摘要&#xff1a;为什么可以在STM32上面跑神经网络&#xff1f;简而言之就是使用STM32CubeMX中的X-Cube-AI扩展包将当前比较热门的AI框架进行C代码的转化&#xff0c;以支持在嵌入式设备上使用&#xff0c;目前使用X-Cube-AI需要在STM32CubeMX版本5.0以上&#xff0c;支持转化的…
阅读更多...
CF Edu54 E. Vasya and a Tree DFS+树状数组

CF Edu54 E. Vasya and a Tree DFS+树状数组

Vasya and a Tree 题意&#xff1a; 给定一棵树&#xff0c;对树有3e5的操作&#xff0c;每次操作为&#xff0c;把树上某个节点的不超过d的子节点都加上值x; 思路&#xff1a; 多开一个vector记录每个点上的操作。dfs这颗树&#xff0c;同时以深度开一个树状数组&#xff0c;踩…
阅读更多...
通信教程 | 串口丢数据常见的原因

通信教程 | 串口丢数据常见的原因

UART&#xff1a;Universal Asynchronous Receiver / Transmitter&#xff0c;通用异步收发传输器&#xff0c;即我们通常说的串口。串口是工程师最常用的串行外设之一&#xff0c;但在实际应用中还是会经常遇到各种问题。比如&#xff1a;丢失一字节数据。今天我们就结合STM32…
阅读更多...
三次握手 四次握手 与socket函数的关系

三次握手 四次握手 与socket函数的关系

我们深谙信息交流的价值&#xff0c;那网络中进程之间如何通信&#xff0c;如我们每天打开浏览器浏览网页时&#xff0c;浏览器的进程怎么与web服务器通信的&#xff1f;当你用QQ聊天时&#xff0c;QQ进程怎么与服务器或你好友所在的QQ进程通信&#xff1f;这些都得靠socket&am…
阅读更多...
110-简单类型之整数类型和小数类型

110-简单类型之整数类型和小数类型

简单类型-整数 简单类型-小数 float myFloat12.5f;转载于:https://www.cnblogs.com/wuxiaohui1983/p/9965493.html
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023