同样我们要先创建一个缓冲区,然后直接循环写入消息,然后将写入的消息放到我们的缓冲区中,用一个指针接收客户输入的字符串,如果成功了这个指针保存的就是字符串的起始地址,我们在接收字符串的时候并不需要考虑\0,因为fgets这是C语言函数会自动加上\0的,断言一下空指针,然后将指针强转是为了防止出现在release版本变量被定义但是却没有使用的情况。buffer(len-1)是什么意思呢?这里其实是因为我们客户端输入字符串后会按一下回车,而回车也会被放入缓冲区中,这样的话在打印的时候服务端会多一行空白,所以我们把回车删掉就没有问题了。接下来我们让客户端输入quit的时候就退出程序,因为我们在服务端设置的是只要客户端退出服务端也就跟着退出了。然后我们向文件里写数据,把我们缓冲区的数据写到文件中,在这里同样不用考虑\0,因为只有C语言规定字符串后面必须加\0,而write是系统接口不会考虑\0的。做完这一步后我们断言一下函数返回值,不让返回值大于等于0的意思是如果是空串或者错误就不去写入了。然后同样强转一下刚刚的返回值n。最后我们将文件关闭即可,下面我们就试试可以运行吗:
运行的时候我们必须开两个窗口,当创建好两个可执行程序后,我们先运行服务端程序,这个时候程序会卡着不动,因为服务端要等待客户端打开同一个文件所以我们在运行客户端:
这样我们就完成了命名管道的通信,这里还有一个问题就是当我们运行一次程序后就有了管道文件下一次运行程序会出现文件已经存在的报错,所以我们可以直接在服务端关闭文件后取消链接这个文件:
这样的话我们每次运行程序就不用先将管道文件删除再运行了。
下面我们将这个命名管道改为用户每输入一个字符,服务端就相应的输出一个字符,大家可以理解为就像我们将手机投屏到电脑上手机上做什么操作电脑屏幕就是什么操作。
因为我们前面的实现每次需要输入回车服务端才会显示消息,现在我们需要不输入回车就写入内容的函数,这里我们用的getch函数,由于getch需要用到ncurses库,所以我们先安装这个库:
(按照ncurses库这个方法我们没有搞定,如果有搞定的小伙伴可以私信我哦~成功的方法在下面我用红字提醒出来了可直接找到后用系统方法)
如果大家是普通用户的话前面记得加上sudo提权。安装好后我们在刚刚的代码中加上这个库的头文件:
因为我们是在客户端完成这个操作所以只需要在client.cc文件中包上这个头文件即可。然后我们修改一下client.cc文件中的代码:
考虑到大家可能不熟悉getch这个函数,下面我们把这个函数的文档找出来:
修改完成后下面我们把代码运行起来:
由于编译不通过是因为我们没有引入client的库,所以我们引入一下:
引入后我们重新生成一下可执行文件:
运行后我们发现服务端不能正常打印了,其实原因在于函数的返回值问题,我们刚刚看文档人家的返回值是int类型,结果我们用char类型接收了,所以就出错了,下面我们修改一下代码:
由于我们不知道返回值是什么,所以我们先在代码中直接打印一下返回值:
通过打印我们发现返回值为-1:
然后我们将代码修改为当返回值为-1我们就继续读取字符,但是在运行的过程中由于此方法有一些错误导致还是不能成功,所以我们下面直接用系统方法不用库方法:
然后我们在服务端接收的时候不打印前面的客户端名称了,直接就是接收什么打印什么(在这里记得刷新缓冲区):
然后下面我们运行起来:
这样我们就实现了一开始的功能,通过以上管道的学习相信大家能明白如何创建命名管道以及使用,上面我们使用的系统方法也是从网络上搜的,如果有什么错误还请见谅。
匿名管道与命名管道的区别:
匿名管道由 pipe 函数创建并打开。
命名管道由 mkfififo 函数创建,打开用 open
FIFO (命名管道)与 pipe (匿名管道)之间唯一的区别在它们创建与打开的方式不同,一但这些工作完成之后,它们具有相同的语义。
命名管道的打开规则:
如果当前打开操作是为读而打开 FIFO 时
O_NONBLOCK disable :阻塞直到有相应进程为写而打开该 FIFO
O_NONBLOCK enable :立刻返回成功
如果当前打开操作是为写而打开 FIFO 时
O_NONBLOCK disable :阻塞直到有相应进程为读而打开该 FIFO
O_NONBLOCK enable :立刻返回失败,错误码为 ENXIO
总结
命名管道可用于同一主机上的任意进程间通信,并且管道通信的本质是通过内核中一块缓冲区(内存)时间数据传输,而命名管道的管道文件只是一个标识符,用于让多个进程能够访问同一块缓冲区,并且管道是半双工通信,是可以选择方向的单向通信。命名管道和匿名有一个相同点,就是他们的本质都是内核中的一块缓冲区。同时补充一点,管道的生命周期是随进程的,本质是内核中的缓冲区,命名管道文件只是标识,用于让多个进程找到同一块缓冲区,删除后,之前已经打开管道的进程依然可以通信。