命名管道Linux

 管道是

毫不相关的进程进程间通信::命名管道

管道

首先自己要用用户层缓冲区，还得把用户层缓冲区拷贝到管道里，（从键盘里输入数据到用户层缓冲区里面），然后用户层缓冲区通过系统调用（write）写到管道里，然后再通过read系统调用，被对方（读端）读取，就要从管道拷贝到读端，然后再显示到显示器上。

mkfifo命名管道

1号手册是指令，。2号系统调用接口

创建一个管道，p开头就是命名管道，并不会直接刷新到磁盘中，实际是个符号

这样会阻塞

这样会显示出来（先输入左边的，再输入右边的就会显示），左右两边是两个进程

>>追加写入的方式，但空间一直是0

所以这就是文件里大小一直是0的原因         

你怎么知道打开的是同一个文件

正好符合前提

所以要创建两个可执行程序，各自跑各自的，创建一个common是为了方便使用头文件        

client是客户   server是服务者

makefile中一下运行两个程序

mkfifo，用程序的方式创建管道，第一个参数是要创建的这个管道在那个路径下叫什么名字，也就是要保持唯一性的那些点，第二个是创建一个管道

这里是3号手册是函数。

返回 -1创建失败 

创建一个共享文件

./myfifo

server.cc和client.cc想看到同一个文件，包含上头文件就可以了

这里先用server控制管道文件

创建管道失败了设置为1 ,如果失败了就exit(1)

谁控制的先运行运行谁就好了

make一下生成两个可执行程序,因为是server控制的，所以要先运行server

运行后就会多一个myfifo命名管道

命名管道的删除

想删除这个myfifo用unlink(成功返回0 ，失败返回-1） 

命令行删除

代码也可以删(成功返回0 ，失败返回-1)，头文件是unistd.h

创建完文件，5秒后就删除了

思路

用到了open

打开管道文件，第二个参数是只进行读取

enum中

fd<0打开失败了

服务端读取数据

客户端，只要用就行

 第二个参数就是打开文件为了写入的

用户输入完成以后，就要发送输入的消息到另一端

打开顺序一定

然后打开的顺序就一定了，先打开server，然后再打开另一个cc

先打开服务端，会阻塞在这里，然后再打开客户端，进行输入

右边输入啥，左边就会有啥

无法输入空格问题（getline）

但有一个问题就是cin没法输入空格，，要用到getline

会发现一个问题，客户端退出了，服务端还没退出

客户端退出，会read到0，所以服务端（读端）也要退出

 改正

sever端

等待写入方式打开后，自己才会打开文件，向后执行，open阻塞了！

优化一下

写成进程池的样子

日志

创建一个新文件

用到了可变参数(形参实例化是从右到左)

可变参数必须右至少一个具体的参数

举个例子：步骤：s指向可变部分

这里的sum第一个参数是几个数求和的意思，传不同的类型不可以的，因为上面va_arg里已经写死了

开始写日志，level日志等级

先定义时间，time，时间戳

ctime

头文件

打印具体年月日 

年是从1900年开始的

 年月日时分秒

vsnprint

vsnprint，跟不带v的区别就是，去除了...换成了可变参数部分

把日记等级转换成字符串风格,所有有可能的地方都需要返回

改进

va_start(s,format)，用format修饰s的指向，上面的sum是（s,n),类似

这里要用c_str，因为返回的是string

用完以后再用end

这里是往显示器打印的,这里要*3，以为%s和%s中间有几个空格，空间不够

把这里修改一下,打开失败的话

这样就形成日志了

打印最后一行就是正常打开

这里也改一下

测试，先./server，然后会阻塞，然后./client，就会打印出,logmessage里的信息

为啥./client之前不打印

因为等待写入方式打开后，自己才会打开文件，向后执行，open阻塞了！

往文件里打印（上面是往屏幕打印）

先把这些内容全放在Log,日志类

分类

1：向屏幕打印

2：向一个文件打印

3：分类打印

打印格式printMethod

这里构造默认往屏幕去印

析构

打印方式也改一下

打印单个

以0666的权限打开这个文件

打印多个文件（添加一下level）

实现一下

优化一下

以后再打印日志就不用这样打了

这样就可以了，要记住先创建一个Log对象

这样以后就写入一个文件了，写入log.txt

这样就把日志分类了

结果

但是日志文件这么多太混乱了

这样操作后就统一进入一个文件了

makefile也修改一下，先把path定义的log目录创建一下

日志放入一个文件测试结果：

日志分类测试结果：

log.hpp里头文件

优化一下调用

然后修改一下server.cc

 

client.cc

#include "common.hpp"
#include "log.hpp"int main()
{int fd = open(FIFO_FILE,O_WRONLY);if(fd < 0){perror("open");exit(FIFO_OPEN_ERR);}string line;while(true){cout<< "Please Enter@ ";// cin>> line;getline(cin, line);write(fd, line.c_str(),line.size());}close(fd);return 0;
}

common.hpp

#pragma noce
#include<iostream>
#include<vector>
#include<string>
#include<unistd.h>
#include <sys/types.h>
#include <sys/wait.h> 
#include <sys/stat.h>
#include<fcntl.h>
#include<stdio.h>
using namespace std;#define FIFO_FILE "./myfifo"
#define MODE 0664 //用于设置文件的权限，0664代表着8进制写法，4是其他用户可读不可写enum
{FIFO_CREATE_ERR = 1,FIFO_DELETE_ERR,FIFO_OPEN_ERR
};class Init
{
public:Init(){//创建管道int n = mkfifo(FIFO_FILE,MODE);if(n == -1){perror("mkfofi");exit(FIFO_CREATE_ERR);}}~Init(){//删除命名管道int m = unlink(FIFO_FILE);if(m == -1){perror("unlink");exit(FIFO_DELETE_ERR);}      }
};

log.hpp

#pragma noce
#include <stdarg.h>
// #include "common.hpp"
#include <iostream>
#include <stdio.h>
#include<string.h>//strerror(errno)头文件
#include<stdlib.h>
using namespace std;#define Info        0
#define Debug       1
#define Warning     2
#define Error       3
#define Fatal       4 // 致命的//打印方式
#define Screen      1 //屏幕
#define Onefile     2 //一个文件
#define Classfile   3 //多个文件#define LogFile    "log.txt" class Log
{
public:Log(){printMehod = Screen;path = "./log/";}void Enable(int method){printMehod = method;}string levelToString(int level){switch (level){case Info:return "Info";case Debug:return "Debug";case Warning:return "Warning";case Error:return "Error";case Fatal:return "Fatal";default:return "";}return "";}// void logmessage(int level, const char *format, ...)// {//     time_t t = time(nullptr);//     struct tm *ctime = localtime(&t);//     char leftbuffer[1024];//     snprintf(leftbuffer, sizeof(leftbuffer), "[%s][%d-%d-%d  %d:%d:%d]", levelToString(level).c_str(),//             ctime->tm_year + 1900, ctime->tm_mon + 1, ctime->tm_mday, ctime->tm_hour, ctime->tm_min, ctime->tm_sec);//     va_list s;//     va_start(s, format);//     char rightbuffer[1024];//     vsnprintf(rightbuffer, sizeof(rightbuffer), format, s);//     va_end(s);//     // 格式：默认部分+自定义部分//     char logtxt[1024 * 3];//     snprintf(logtxt, sizeof(logtxt), "%s  %s\n", leftbuffer, rightbuffer);//     //cout << logtxt << endl; // 暂时打印//     printLog(level, logtxt);// }void operator()(int level, const char* format, ...){time_t t = time(nullptr);struct tm *ctime = localtime(&t);char leftbuffer[1024];snprintf(leftbuffer, sizeof(leftbuffer), "[%s][%d-%d-%d  %d:%d:%d]", levelToString(level).c_str(),ctime->tm_year + 1900, ctime->tm_mon + 1, ctime->tm_mday, ctime->tm_hour, ctime->tm_min, ctime->tm_sec);va_list s;va_start(s, format);char rightbuffer[1024];vsnprintf(rightbuffer, sizeof(rightbuffer), format, s);va_end(s);// 格式：默认部分+自定义部分char logtxt[1024 * 3];snprintf(logtxt, sizeof(logtxt), "%s  %s\n", leftbuffer, rightbuffer);//cout << logtxt << endl; // 暂时打印printLog(level, logtxt);}void printLog(int level, const string &logtxt){switch(printMehod){case Screen:cout<< logtxt <<endl;break;case Onefile:printOneFile(LogFile, logtxt);//"log.txt" break;case Classfile:printClassFile(level, logtxt);break;default:break;}}void printOneFile(const string &logname, const string &logtxt){//          "./log/" "log.txt"string _logname =path + logname;int fd = open(_logname.c_str(), O_WRONLY|O_CREAT|O_APPEND, 0666);if(fd < 0) return;write(fd, logtxt.c_str(), logtxt.size());close(fd);}void printClassFile(int level, const string &logtxt){string filename = LogFile;//"log.txt" filename += ".";//"log.txt." filename += levelToString(level); //log.txt.Debug/Waring/FatalprintOneFile(filename, logtxt);}~Log(){}
private:int printMehod;string path;
};

makefile

.PHONY:all
all:client server
server:server.ccg++ -o $@ $^ -g -std=c++11mkdir log
client:client.ccg++ -o $@ $^ -g -std=c++11
.PHONY:clean
clean:rm -f server client

server.cc

#include "common.hpp"
#include "log.hpp"int main()
{//logmessage(Info, "hello");//创建管道Init init;Log log;//log.Enable(Onefile);log.Enable(Classfile);// //创建管道// int n = mkfifo(FIFO_FILE,MODE);// if(n == -1)// {//     perror("mkfofi");//     exit(FIFO_CREATE_ERR);// }// sleep(5);//打开管道int fd = open(FIFO_FILE,O_RDONLY);if(fd < 0){//log.logmessage(Fatal, "error string:%s,error code:%d",strerror(errno), errno);//优化后log(Fatal, "error string:%s,error code:%d",strerror(errno), errno);exit(FIFO_OPEN_ERR);}// log.logmessage(Info, "server open file done,error string:%s,error code:%d",strerror(errno), errno);// log.logmessage(Warning, "server open file done,error string:%s,error code:%d",strerror(errno), errno);//优化后log(Info, "server open file done,error string:%s,error code:%d",strerror(errno), errno);log(Warning, "server open file done,error string:%s,error code:%d",strerror(errno), errno);//......//开始通信while(true){char buffer[1024] = {0};int x = read(fd, buffer, sizeof(buffer));if(x > 0){buffer[x] = 0;cout<< "client say# " << buffer <<endl;}else if(x == 0){//log.logmessage(Debug, "sclient quit too!,error string:%s,error code:%d",strerror(errno), errno);//优化后log(Debug, "sclient quit too!,error string:%s,error code:%d",strerror(errno), errno);//cout<< "client quit too!\n" <<endl;break;}else break;}close(fd);// //删除命名管道// int m = unlink(FIFO_FILE);// if(n == -1)// {//     perror("unlink");//     exit(FIFO_DELETE_ERR);// }return 0;
}