Linux-C-day-3-进程间通信--FIFO/套接字

FIFIO管道

通过命名管道通信，命名管道之间的通信读和写必须同时执行，否则就会阻塞，但是命名管道可以用于非亲缘进程间通信；
创建命名管道：int mkfifo(pathname,mode)，pathname表示文件路径，该文件必须不存在；mode表示文件模式；返回值0表示成功，否则表示失败；
打开FIFO文件：int open(const char *path,int mode)，pathname：文件路径，也就是已经创建的文件的路径；O_RDONLY：表示阻塞只读模式；O_RDONLY| O_NONBLOCK：表示非阻塞只读模式；O_WRONLY：表示阻塞只写模式；O_WRONLY | O_NONBLOCK：表示的是非阻塞只写模式；函数的返回值是-1时表示失败，否则返回正常的文件描述符；和文件的操作是相同的；

FIFO管道的创建

fifocreate.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

int main(){
    if(-1 == mkfifo("/tmp/test",0644)){
        perror("mkfifo error");
        return 1;
    }
}

FIFO管道的读操作

fiforead.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>

int main(){
    int fd = open("/tmp/test",O_RDONLY);
    if(-1 == fd){
        perror("open error");
        return 1;
    }
    char buf[BUFSIZ];
    bzero(buf,BUFSIZ);
    read(fd,buf,BUFSIZ);
    printf("read:%s\n",buf);
}

FIFO管道的写操作

fifowrite.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>

int main(){
    int fd = open("/tmp/test",O_WRONLY|O_NONBLOCK);
    if(-1 == fd){
        perror("open error");
        return 1;
    }
    char str[] = "Hello fifo";
    write(fd,str,sizeof(str));
    printf("write:%s\n",str);
}

FIFO管道的删除操作

fiform.c:

#include <unistd.h>

int main(){
    unlink("/tmp/test");
}

使用管道实现CS模型

C-S服务模型的实现

使用单个管道实现C-S模型的程序，getoptin.c缺点是server没有启动时，client自己写，自己读取；
client.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    mkfifo("/tmp/cs",0644);
    int fifofd = open("/tmp/cs",O_RDWR);
    char buf[BUFSIZ];
    write(fifofd,argv[1],strlen(argv[1])+1);    
    printf("%d write file:%s",getpid(),argv[1]);
    //sleep(1);
    read(fifofd,buf,BUFSIZ);
    printf("%d client read:\n%s",getpid(),buf);
}

server.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    mkfifo("/tmp/cs",0644);
    int fifofd = open("/tmp/cs",O_RDWR);
    char buf[BUFSIZ];
    read(fifofd,buf,BUFSIZ);
    printf("%d file path:%s\n",getpid(),buf);
    int fd = open(buf,O_RDONLY);
    bzero(buf,BUFSIZ);
    read(fd,buf,BUFSIZ);
    write(fifofd,buf,BUFSIZ);
    close(fifofd);
}

使用两个管道实现CS模型
client02.c：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    mkfifo("/tmp/cs",0644);
    mkfifo("/tmp/cs1",0644);
    int fifofd = open("/tmp/cs",O_WRONLY);
    char buf[BUFSIZ];
    write(fifofd,argv[1],strlen(argv[1])+1);    
    printf("%d write file:%s",getpid(),argv[1]);
    //sleep(1);
    int fifofd1 = open("/tmp/cs1",O_RDONLY);
    read(fifofd1,buf,BUFSIZ);
    printf("%d client read:\n%s",getpid(),buf);
}

server02.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    mkfifo("/tmp/cs",0644);
    int fifofd = open("/tmp/cs",O_RDONLY);
    char buf[BUFSIZ];
    read(fifofd,buf,BUFSIZ);
    printf("%d file path:%s\n",getpid(),buf);
    int fd = open(buf,O_RDONLY);
    bzero(buf,BUFSIZ);
    read(fd,buf,BUFSIZ);

    mkfifo("/tmp/cs1",0644);
    int fifofd1= open("/tmp/cs1",O_WRONLY);
    write(fifofd1,buf,BUFSIZ);
    close(fifofd);
    close(fifofd1);
}

使用双匿名管道实现CS模型
client-server01.c

使用单个管道实现CS模型
client-server03.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    mkfifo("/tmp/cs",0644);
    int fifofd = open("/tmp/cs",O_RDWR);
    char buf[BUFSIZ];
    if(fork()){// parent
        write(fifofd,argv[1],strlen(argv[1])+1);    
        printf("write file:%s",argv[1]);
        //sleep(1);
        read(fifofd,buf,BUFSIZ);
        printf("client read:\n%s",buf);
    }else{// child
        read(fifofd,buf,BUFSIZ);
        printf("file path:%s\n",buf);
        int fd = open(buf,O_RDONLY);
        bzero(buf,BUFSIZ);
        read(fd,buf,BUFSIZ);
        write(fifofd,buf,BUFSIZ);
    //  read(pfd[1],buf,BUFSIZ);
    }
    close(fifofd);
    unlink("/tmp/cs");
}

进程间通信--套接字

套接字是一种进程间全双工通信模型，套接字的创建使用int socketpair(int domain，int type，int protocol，int sv[2])；domain：表示的是套接口的域，AF_LOCAL表示本地域；AF_UNIX 表示的是跨网络域；type：表示的是套接口的乐行，SOCK_STREAM，SOCK_DGRAM；protocol：表示的是协议，必须是0；sv：表示的是文件描述符的指针，s[0]，s[1]，都可以用来读写；返回值0表示成功，-1表示出错；如果需要进行关闭则两个都需要进行关闭：close(sv[0]);close(sv[1])；
创建套接字的一个实例：
socketpair.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(){
    int sv[2];
    if(-1 == socketpair(AF_LOCAL,SOCK_STREAM,0,sv)){
        perror("socketpair error");
        return 1;
    }
    printf("%d %d",sv[0],sv[1]);

    char str[]="Hello sockerpair\n";
    write(sv[0],str,sizeof(str));
    char buf[BUFSIZ];
    
    //fcntl(sv[0],F_SETFL,O_NONBLOCK);
    read(sv[0],buf,BUFSIZ);
    printf("read %s\n",buf);
    
    bzero(buf,BUFSIZ);
    read(sv[0],buf,BUFSIZ);
    printf("read %s\n",buf);
}

无数据写入时，读取阻塞的一个程序
socketpair02.c:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(){
    int sv[2];
    if(-1 == socketpair(AF_LOCAL,SOCK_STREAM,0,sv)){
        perror("socketpair error");
        return 1;
    }
    printf("%d %d\n",sv[0],sv[1]);
    if(fork()){
            char str[]="Hello sockerpair\n";
            write(sv[0],str,sizeof(str));
    }else{  
            char buf[BUFSIZ];
            read(sv[1],buf,BUFSIZ);
            printf("read %s\n",buf);

            bzero(buf,BUFSIZ);
            read(sv[1],buf,BUFSIZ);
            printf("read %s\n",buf);
    }   
}

无数据写入时，阻塞取消的一种写法
socketpair03.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(){
    int sv[2];
    if(-1 == socketpair(AF_LOCAL,SOCK_STREAM,0,sv)){
        perror("socketpair error");
        return 1;
    }
    printf("%d %d\n",sv[0],sv[1]);
    if(fork()){
            char str[]="Hello sockerpair\n";
            write(sv[0],str,sizeof(str));
    }else{  
            char buf[BUFSIZ];
            read(sv[1],buf,BUFSIZ);
            printf("read %s\n",buf);

            fcntl(sv[1],F_SETFL,O_NONBLOCK);
            bzero(buf,BUFSIZ);
            read(sv[1],buf,BUFSIZ);
            printf("read %s\n",buf);
    }   
}

使用套接字实现CS模型

client-server01.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <fcntl.h>

int main(int argc,char* argv[]){
    int sv[2];
    char buf[BUFSIZ];
    socketpair(AF_LOCAL,SOCK_STREAM,0,sv);
    if(fork()){// parent
        close(sv[0]);
        write(sv[1],argv[1],strlen(argv[1])+1); 
        read(sv[1],buf,BUFSIZ);
        printf("client read:\n%s",buf);
    }else{// child
        close(sv[1]);
        read(sv[0],buf,BUFSIZ);
        printf("file path:%s\n",buf);
        int fd = open(buf,O_RDONLY);
        bzero(buf,BUFSIZ);
        read(fd,buf,BUFSIZ);
        write(sv[0],buf,BUFSIZ);
    //  read(sv[1],buf,BUFSIZ);
    }
}

最后编辑于：2017.12.08 01:29:00

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 212,686评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,668评论 3赞 385
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 158,160评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,736评论 1赞 284
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,847评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,043评论 1赞 291
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,129评论 3赞 410
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,872评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,318评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,645评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,777评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,470评论 4赞 333
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,126评论 3赞 317
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,861评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,095评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,589评论 2赞 362
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,687评论 2赞 351