Linux Linux程序练习九

题目：利用多线程与有名管道技术，实现两个进程之间发送即时消息，实现聊天功能

思路：关键在于建立两个有名管道，利用多线程技术，进程A中线程1向管道A写数据，进程B中线程2从管道A读数据，进程A线程2从管道B中读数据，进程B中线程1往管道B中写数据。

//利用多线程与有名管道技术，实现两个进程之间发送即时消息，实现聊天功能
//进程A
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

//从管道1中读数据
void * Threadread(void * arg)
{
//open the fifo
int fd = 0;
//open the fifo in read and write mode--以读写方式打开管道
fd = open("/home/test/1/fifo1", O_RDONLY);
if (fd == -1)
{
printf("open the fifo failed ! error message :%s\n", strerror(errno));
return NULL;
}
char buf[100] = { 0 };
//从管道中读数据
while (read(fd, buf, sizeof(buf)) > 0)
{
printf("%s", buf);
memset(buf, 0, sizeof(buf));
}
close(fd);
return NULL;
}

//往管道2中写数据
void * ThreadWrite(void * arg)
{
//open the fifo
int fd = 0;
//open the fifo in read and write mode--以读写方式打开管道
fd = open("/home/test/1/fifo2", O_WRONLY);
if (fd == -1)
{
printf("open the fifo failed ! error message :%s\n", strerror(errno));
return NULL;
}
char buf[100] = { 0 };
while (1)
{
//往标准输入上读数据
read(STDIN_FILENO, buf, sizeof(buf));
//在管道中写数据
write(fd, buf, strlen(buf));
memset(buf, 0, sizeof(buf));
}
close(fd);
return NULL;
}

int main(int arg, char * args[])
{
//两线程共用一个文件描述符
pthread_t thr1, thr2;
//创建读数据线程
if (pthread_create(&thr1, NULL, Threadread, NULL) != 0)
{
printf("create thread is failed ! error mesage :%s\n", strerror(errno));
return -1;
}
//创建写数据线程
if (pthread_create(&thr2, NULL, ThreadWrite, NULL) != 0)
{
printf("create thread is failed ! error mesage :%s\n", strerror(errno));
return -1;
}
//等待两线程都返回 关闭文件描述符
pthread_join(thr1, NULL);
pthread_join(thr2, NULL);
return 0;
}

.SUFFIXES:.c .o
CC=gcc
SRCS1=tec01.c
SRCS2=tec02.c
OBJS1=$(SRCS1:.c=.o)
OBJS2=$(SRCS2:.c=.o)
EXEC1=a
EXEC2=b

start:$(OBJS1) $(OBJS2)
$(CC) -lpthread -o $(EXEC1) $(OBJS1)
$(CC) -lpthread -o $(EXEC2) $(OBJS2)
@echo "^_^-----OK------^_^"
.c.o:
$(CC) -Wall -g -o $@ -c $<
clean:
rm -f $(OBJS1)
rm -f $(OBJS2)
rm -f $(EXEC1)
rm -f $(EXEC2)