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
", 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
", 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
", strerror(errno));
        return -1;
    }
    //创建写数据线程
    if (pthread_create(&thr2, NULL, ThreadWrite, NULL) != 0)
    {
        printf("create thread is failed ! error mesage :%s
", 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)