文件I/O编程之： 实验内容

6.6 实验内容

6.6.1 文件读写及上锁

1．实验目的

通过编写文件读写及上锁的程序，进一步熟悉Linux中文件I/O相关的应用开发，并且熟练掌握open()、read()、write()、fcntl()等函数的使用。

2．实验内容

在Linux中FIFO是一种进程之间的管道通信机制。Linux支持完整的FIFO通信机制。

本实验内容比较有趣，通过使用文件操作，仿真FIFO（先进先出）结构以及生产者-消费者运行模型。

本实验中需要打开两个虚拟终端，分别运行生产者程序（producer）和消费者程序（customer）。此时两个进程同时对同一个文件进行读写操作。因为这个文件是临界资源，所以可以使用文件锁机制来保证两个进程对文件的访问都是原子操作。

先启动生产者进程，它负责创建仿真FIFO结构的文件（其实是一个普通文件）并投入生产，就是按照给定的时间间隔，向FIFO文件写入自动生成的字符（在程序中用宏定义选择使用数字还是使用英文字符），生产周期以及要生产的资源数通过参数传递给进程（默认生产周期为1s，要生产的资源数为10个字符）。

后启动的消费者进程按照给定的数目进行消费，首先从文件中读取相应数目的字符并在屏幕上显示，然后从文件中删除刚才消费过的数据。为了仿真FIFO结构，此时需要使用两次复制来实现文件内容的偏移。每次消费的资源数通过参数传递给进程，默认值为10个字符。

3．实验步骤

（1）画出实验流程图。

本实验的两个程序的流程图如图6.4所示。

图6.4 节流程图

（2）编写代码。

本实验中的生产者程序的源代码如下所示，其中用到的lock_set()函数可参见第6.3.2节。

/* producer.c */

#include <stdio.h>

#include <unistd.h>

#include <stdlib.h>

#include <string.h>

#include <fcntl.h>

#include "mylock.h"

#define MAXLEN 10 /* 缓冲区大小最大值*/

#define ALPHABET 1 /* 表示使用英文字符 */

#define ALPHABET_START 'a' /* 头一个字符，可以用 'A'*/

#define COUNT_OF_ALPHABET 26 /* 字母字符的个数 */

#define DIGIT 2 /* 表示使用数字字符 */

#define DIGIT_START '0' /* 头一个字符 */

#define COUNT_OF_DIGIT 10 /* 数字字符的个数 */

#define SIGN_TYPE ALPHABET /* 本实例选用英文字符 */

const char *fifo_file = "./myfifo"; /* 仿真FIFO文件名 */

char buff[MAXLEN]; /* 缓冲区 */

/* 功能：生产一个字符并写入仿真FIFO文件中 */

int product(void)

{

int fd;

unsigned int sign_type, sign_start, sign_count, size;

static unsigned int counter = 0;

/* 打开仿真FIFO文件 */

if ((fd = open(fifo_file, O_CREAT|O_RDWR|O_APPEND, 0644)) < 0)

{

printf("Open fifo file error\n");

exit(1);

}

sign_type = SIGN_TYPE;

switch(sign_type)

{

case ALPHABET:/* 英文字符 */

{

sign_start = ALPHABET_START;

sign_count = COUNT_OF_ALPHABET;

}

break;

case DIGIT:/* 数字字符 */

{

sign_start = DIGIT_START;

sign_count = COUNT_OF_DIGIT;

}

break;

default:

{

return -1;

}

}/*end of switch*/

sprintf(buff, "%c", (sign_start + counter));

counter = (counter + 1) % sign_count;

lock_set(fd, F_WRLCK); /* 上写锁*/

if ((size = write(fd, buff, strlen(buff))) < 0)

{

printf("Producer: write error\n");

return -1;

}

lock_set(fd, F_UNLCK); /* 解锁 */

close(fd);

return 0;

}

int main(int argc ,char *argv[])

{

int time_step = 1; /* 生产周期 */

int time_life = 10; /* 需要生产的资源数 */

if (argc > 1)

{/* 第一个参数表示生产周期 */

sscanf(argv[1], "%d", &time_step);

}

if (argc > 2)

{/* 第二个参数表示需要生产的资源数 */

sscanf(argv[2], "%d", &time_life);

}

while (time_life--)

{

if (product() < 0)

{

break;

}

s