操作系统实验2

拼搏现实的明天。 2022-08-06 02:18 188阅读 0赞

**2、当生产者-消费者分别由位于不同计算机上的若干进程充当时，如何设计实验？给出设计方案和Linux C语言实现（重要语句加上注释）。**

\#include<stdio.h>

\#include<stdlib.h>  
\#include<string.h>  
\#include<sys/types.h>  
\#include<sys/ipc.h>  
\#include<sys/socket.h>  
\#include<netinet/in.h>  
\#include<errno.h>  
\#include<pthread.h>  
\#include<arpa/inet.h>  
\#include<unistd.h>  
\#include<sys/sem.h>  
\#include<signal.h>  
//缂撳啿鍖哄ぇ灏?  
\#define BUFFERSIZE 5  
//鑾峰彇鐨勪骇鍝佹暟  
\#define many 12  
//鍏变韩鍐呭瓨  
struct ProductBuff \{  
//in鐢熶骇鑰呮寚閽?  
int write ;  
//杈撳嚭鑰呮寚閽坰hu  
int read;  
//缂撳啿鍖?  
int buf\[BUFFERSIZE\];  
\}productBuff;  
// 涓昏姝ラ鏄痵ocket(),bind(),listen(),鍙﹀accept()鏄彇寰楃敵璇疯€呯殑鏂囦欢鎻忚堪绗︼紝濡傛灉娌℃湁鐢宠杩涚▼锛岄偅涔堣繍琛屽埌閭ｉ噷鏃朵細闃诲锛岀洿鍒版湁鐢宠杩涚▼鍙戣捣閾炬帴  
//鐢熶骇鑰呯鍙?  
int portnumber;  
//鏂囦欢鎻忚堪绗?sockfd鏄湇鍔＄殑浣跨敤鐨?newsockfd鏄拡瀵圭敵璇疯繘绋嬬殑鏂囦欢鎻忚堪绗?  
int sockfd, newsockfd;  
struct sockaddr\_in server\_addr,client\_addr;  
//姣忔璇荤殑闀垮害  
int addr\_len=sizeof(struct sockaddr\_in);  
//鍒濆鍖栫綉缁滄湇鍔?  
void serverInit()  
\{  
if((sockfd=socket(AF\_INET,SOCK\_STREAM,0))==-1)\{  
printf("Error:%s\\n",strerror(errno));  
exit(1);  
\}   
printf("寤虹珛鏈嶅姟鎴愬姛!\\nSocket id:%d\\n",sockfd);   
bzero(&server\_addr,sizeof(struct sockaddr\_in));  
server\_addr.sin\_family=AF\_INET;  
server\_addr.sin\_addr.s\_addr=htonl(INADDR\_ANY);  
server\_addr.sin\_port=htons(portnumber);  
if(bind(sockfd,(struct sockaddr\*)(&server\_addr),sizeof(struct sockaddr))==-1)\{  
printf("OH! Bind Error:%s\\n",strerror(errno));  
exit(1);  
\}  
printf("Yes! 杩炴帴鎴愬姛浜? My Port:%d\\n",portnumber);   
if(listen(sockfd,10)==-1)\{  
printf("OH! Listen Error:%s\\n",strerror(errno));  
exit(1);  
\}  
printf("Yes! Listening...\\n");  
\}  
  
  
\#define SEM\_KEY 4009  
struct sembuf semaphore;  
int semid;  
\#define mutex 0  
\#define empty 1  
\#define full 2  
//鍒濆鍖栦俊鍙烽噺  
int init()\{  
int sem=0;  
if((semid=semget(SEM\_KEY,4,IPC\_CREAT|0666))>=0)\{  
sem=1;   
semctl(semid, mutex,SETVAL,sem);  
sem=BUFFERSIZE;  
semctl(semid, empty,SETVAL,sem);  
sem=0;  
semctl(semid, full,SETVAL,sem);  
printf("init success!!\\n");  
return 1;  
\}else\{  
return 0;  
\}  
\}  
//鍒犻櫎淇″彿閲?  
void sigend(int sig)\{  
semctl(semid,IPC\_RMID,0);  
exit(0);  
\}  
//鏂板浜у搧  
void writeProductBuff(struct ProductBuff\*c,int\* value)\{  
c->buf\[c->write\]=\*value;  
c->write=(c->write+1)%BUFFERSIZE;  
\}  
//PV鎿嶄綔,鐢卞弬鏁皌纭畾鏄鍝竴涓彉閲忚繘琛孭V鎿嶄綔,t=0,1,2  
 void P(int t) \{  
    semaphore.sem\_num = t;  
    semaphore.sem\_op = -1;  
    semaphore.sem\_flg = SEM\_UNDO;  
    semop(semid, &semaphore, 1);  
\}  
void V(int t) \{  
    semaphore.sem\_num = t;  
    semaphore.sem\_op = 1;  
    semaphore.sem\_flg = SEM\_UNDO;  
    semop(semid, &semaphore, 1);  
\}  
  
  
//鍙栧嚭浜у搧  
int readProductBuff(struct ProductBuff\* c)\{  
int value;  
value=c->buf\[c->read\];  
c->buf\[c->read\]=0;  
c->read=(c->read+1)%BUFFERSIZE;  
return value;  
\}  
//閬嶅巻杈撳嚭浜у搧  
void overCirclebuf(struct ProductBuff\* c)\{  
int i;  
printf("缂撳啿鍖哄悇鍗曞厓鐨勫€?:\\t");  
for(i=0;i<BUFFERSIZE;i++)\{  
printf("%d\\t",c->buf\[i\]);  
\}  
printf("\\n");    
\}  
  
  
//鐢熶骇鑰?  
void\* produce(void \*i)\{  
int \*n=i;   
while(1)\{  
P(empty);  
P(mutex);  
writeProductBuff(&productBuff,n);  
printf("鐢熶骇鑰呰繘绋?d鍐欏叆缂撳啿鍖虹殑鍊?%d\\n",\*n,\*n);  
overCirclebuf(&productBuff);  
int j;  
for(j=0;j<50000000;j++)\{  
\}  
V(mutex);  
V(full);  
\}  
\}  
  
  
//娑堣垂鑰?  
void\* consume(void\* temp)\{  
int\* newsockfd=temp;  
int i;  
char str\[100\];  
int value=0;  
for(i=0;i<many;i++)\{  
P(full);  
P(mutex);  
value=readProductBuff(&productBuff);  
printf("娑堣垂鑰呭彇璧扮殑浜у搧鍊间负锛?d\\n",value);  
memset(str,0,sizeof(str));  
if(0!=value)\{  
sprintf(str,"%d",value);  
if(write(\*newsockfd,str,sizeof(str))==-1)\{  
printf("OH! Write Error:%s\\n",strerror(errno));  
exit(1);  
\}  
\}else\{  
puts("Oh! Get nothing!\\n");  
\}  
V(mutex);  
V(empty);  
\}   
close(\*newsockfd);  
\}  
  
  
int main(int argc,char\* argv\[\])\{  
//鍒ゆ柇鍙傛暟姝ｇ‘涓庡惁  
if(argc!=2)\{  
puts("argument error!!");  
exit(1);  
\}  
//鑾峰彇瑕佽闂殑绔彛鍙?閫氳繃灏嗚緭鍏ョ殑瀛楃涓茶浆鎹㈡垚闀挎暣褰㈡暟  
if((portnumber=atoi(argv\[1\]))<0)\{  
puts("portnumber error!");  
exit(1);  
\}  
//缃戠粶閫氫俊鍑嗗  
serverInit();  
  
  
//PV鎿嶄綔鍑嗗  
while(!init());  
signal(SIGINT,sigend);  
signal(SIGTERM,sigend);  
  
  
//pro  
int i;   
pthread\_t proid;  
printf("寮€宸ョ敓浜?\\n");  
int \*addr\_data=(int\*)malloc(22\*sizeof(int));  
//寮€鍚簡20涓敓浜ц€呯嚎绋嬶紝鍏朵腑addr\_data\[\]鏄紶閫佺粰produce()鍑芥暟鐨勫弬鏁?  
for(i=1;i<21;i++)\{  
addr\_data\[i-1\]=i;  
pthread\_create(&proid,NULL,produce,&addr\_data\[i-1\]);  
\}    
//绛夊緟杩涚▼杩炴帴,杩炴帴鍚庡悜杩炴帴鐨勮繘绋嬪彂閫佷骇鍝?  
while(1)\{  
sleep(4);     
puts("OK, I am ready! Who need product?");     
if((newsockfd=accept(sockfd,(struct sockaddr\*)(&client\_addr),&addr\_len))==-1)  
\{  
printf("eError:%s\\n",strerror(errno));  
exit(1);  
\}  
printf("Server get connection from:%s %d\\n",inet\_ntoa(client\_addr.sin\_addr),client\_addr.sin\_port);    
pthread\_t id;  
//newsockfd鏄拡瀵圭敵璇疯繘绋嬬殑鏂囦欢鎻忚堪绗?  
pthread\_create(&id,NULL,consume,&newsockfd);  
  
for(i=0;i<5000000;i++)\{  
\}  
sleep(3);  
\}  
sleep(8);  
close(sockfd);  
return 0;

\#include<stdio.h>  
\#include<stdlib.h>  
\#include<string.h>  
\#include<pthread.h>  
\#include<errno.h>  
\#include<sys/socket.h>  
\#include<sys/types.h>  
\#include<arpa/inet.h>  
\#include<netinet/in.h>  
\#include<netdb.h>  
//鑾峰彇鐨勪骇鍝佹暟  
\#define many 12  
//瀹㈡埛绔?  
int main(int argc,char\* argv\[\])  
\{  
int sockfd;  
struct hostent\* host;//瑕侀€氳鐨勬嫢鏈夌敓浜ц€呯殑涓绘満  
int port;//涓绘満绔彛鍙?  
struct sockaddr\_in server\_addr;//瀹氫箟閫歽鍦板潃缁撴瀯  
char buffer\[1024\];//缂撳啿鍖哄ぇ灏?  
if(argc!=3)//鍙傛暟涓嶄负3涓垯閿?  
\{  
puts("OH! Error and Exit!!\\n");  
exit(1);  
\}  
if((host=gethostbyname(argv\[1\]))==NULL)//鑾峰彇涓绘満,閫氳繃鍩熷悕鎴栦富鏈哄悕鑾峰彇IP鍦板潃  
\{  
printf("OH! Get Host Error and Exit!!\\n");  
exit(1);  
\}  
if((port=atoi(argv\[2\]))<0)//鑾峰彇瑕佽闂殑绔彛鍙?閫氳繃灏嗚緭鍏ョ殑瀛楃涓茶浆鎹㈡垚闀挎暣褰㈡暟  
\{  
printf("OH! Input Port Error and Exit!!\\n");  
exit(1);  
\}  
if((sockfd=socket(AF\_INET,SOCK\_STREAM,0))==-1)//濂楁帴瀛?  
\{  
printf("OH! Create Socket Error:%s\\n",strerror(errno));  
exit(1);  
\}  
printf("Yes! 鍒涘缓杩炴帴鎴愬姛! Socket Id:%d\\n",sockfd);  
        bzero(&server\_addr,sizeof(server\_addr));  
server\_addr.sin\_family=AF\_INET;  
server\_addr.sin\_port=htons(port);  
server\_addr.sin\_addr=\*((struct in\_addr\*)host->h\_addr);  
        if(connect(sockfd,(struct sockaddr\*)(&server\_addr),sizeof(struct sockaddr))==-1)//鑾峰彇鏂囦欢鎻忚堪绗?  
\{  
printf("OH! Conncet Error:%s\\n",strerror(errno));  
exit(1);  
\}  
int nbytes;  
int i=0;  
for(i=0;i<many;i++)//鑾峰彇many涓骇鍝?  
\{  
if((nbytes=read(sockfd,buffer,100))==-1)\{//鎺ュ彈鏁版嵁鐒跺悗鎵撳嵃  
printf("OH! Read Error:%s\\n",strerror(errno));  
exit(1);  
\}  
buffer\[nbytes\]='\\0';  
printf("璇诲叆鐨勪骇鍝佷负:%s\\n",buffer);  
int j;  
for(j=0;j<500000;j++)  
\{  
\}   
sleep(1);  
\}     
close(sockfd);   
return 0;  
\}

1-2.1  
  
  
gcc 1-2.1.c -o 1-2.1 -lpthread  
  
  
./1-2.1 8080  
  
  
  
  
  
  
  
  
1-2.2  
  
  
gcc 1-2.2.c -o 1-2.2 -lpthread  
  
  
./1-2.2 127.0.0.1 8080