Linux系統編程作業(mutex互斥鎖)

作業內容:

1:使用多執行緒編程實作以下功能
(1)創建兩個執行緒,一個用來存入資料,一個用來當作網路通訊(TCP)的服務器給客戶端發送請求資料
(2)使用mutex互斥鎖來確保多執行緒訪問公共變數時的安全問題
注意事項
(1)由于硬體問題,溫濕度的資料暫時使用scanf函式由用戶手動輸入

服務器代碼

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;//靜態初始化互斥鎖

float data[20][3];
void *rcv_data();
void *get_data();

int main(int argc,char **argv)
{
        int rtn1,rtn2;
        pthread_t thread_id1;
        pthread_t thread_id2;
        rtn1=pthread_create(&thread_id1,NULL,&rcv_data,NULL);
        rtn2=pthread_create(&thread_id2,NULL,&get_data,NULL);
        pthread_join(thread_id1,NULL);
        pthread_join(thread_id2,NULL);
        pthread_exit(0);
}
void *rcv_data()
{
	int home_id=0;
	while(1)
	{
		
		printf("請輸入房間號(1-20)\n");
		scanf("%d",&home_id);
		pthread_mutex_lock(&mutex);
		printf("請輸入溫度和濕度用逗號隔開\n");
		scanf("%f,%f",&data[home_id-1][1],&data[home_id-1][2]);
		pthread_mutex_unlock(&mutex);	
	}
}
void *get_data()
{
	int ret = -1;
	int sockfd;
	int confd;
	struct sockaddr_in serveraddr, listenaddr;
	char ipstr[1024];
	int listenaddrlen;
	int len = 0;
 	char recbuf[1024],sendbuf[1024];

	sockfd = socket(AF_INET,SOCK_STREAM,0);
	if(sockfd == -1){
		perror("socked");
		exit(1);
	}

	bzero(&serveraddr,sizeof(serveraddr));
	serveraddr.sin_family = AF_INET;
	serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);
	serveraddr.sin_port = htons(5678);

	ret = bind(sockfd,(struct sockaddr *)&serveraddr,sizeof(serveraddr));
	if(ret == -1){
		perror("bind");
		exit(1);
	}

	ret = listen(sockfd,128);
	if(ret == -1){
		perror("listen");
		exit(0);		
	}

	listenaddrlen = sizeof(listenaddr);
	confd = accept(sockfd,(struct sockaddr *)&listenaddr,&listenaddrlen); 
	if(confd == -1){
		perror("confd");
		exit(1);
	}
	while(1)
	{	
		int roomid;
		memset(recbuf,0,sizeof(recbuf));
		memset(sendbuf,0,sizeof(sendbuf));		
		int len = recv(confd,recbuf,sizeof(recbuf),0);
		roomid=atoi(recbuf);
		sprintf(sendbuf,"%d號房間的溫度為:%.2f,濕度為:%.2f",roomid,data[roomid-1][1],data[roomid-1][2]);
        send(confd,sendbuf,strlen(sendbuf),0);		
	}
	close(confd);
	close(sockfd);	
}

客戶端代碼:

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>

int main()
{
	int sockfd;
	char ipstr[] = "127.0.0.1";
	char recbuf[1024],sendbuf[1024];
	struct sockaddr_in sfdaddr;	

	sockfd  = socket(AF_INET,SOCK_STREAM,0);
	if(sockfd == -1){
		perror("sockfd");
		exit(1);
	}
	bzero(&sfdaddr,sizeof(sfdaddr));
	sfdaddr.sin_family = AF_INET;
	sfdaddr.sin_port = htons(5678);
	inet_pton(AF_INET,ipstr,&sfdaddr.sin_addr.s_addr );
	connect(sockfd,(struct sockaddr *)&sfdaddr,sizeof(sfdaddr));
	while(1){
                memset(sendbuf,0,sizeof(sendbuf));
                memset(recbuf,0,sizeof(recbuf));
                
                printf("\n請輸入要查詢的房間號(1-20)\n");
                fgets(sendbuf,sizeof(sendbuf),stdin);
                send(sockfd,sendbuf,strlen(sendbuf),0);
                
                printf("查詢結果(0.00為未采集):");
                recv(sockfd,recbuf,sizeof(recbuf),0);
		
                fputs(recbuf,stdout);

        }

	close(sockfd);
	return 0;
}

運行效果