在工厂方法模式上的抽象工厂模式,是专门用于工厂是生产一类产品:
class Pizza
{
public:
virtual void prepare() = 0;
virtual void bake() = 0;
virtual void cut() = 0;
virtual~Pizza()
{
}
};
class Drink
{
public:
virtual void server() = 0;
virtual ~Drink()
{
}
};
class ItailanPizza : public Pizza
{
public:
void prepare()
{
std::cout << "ItailanPizza材料准备" << std::endl;
}
void bake()
{
std::cout << "ItailanPizza烘焙" << std::endl;
}
void cut()
{
std::cout << "ItailanPizza切割" << std::endl;
}
};
class AmericanPizza : public Pizza
{
public:
void prepare()
{
std::cout << "AmericanPizza材料准备" << std::endl;
}
void bake()
{
std::cout << "AmericanPizza烘焙" << std::endl;
}
void cut()
{
std::cout << "AmericanPizza切割" << std::endl;
}
};
class ItailanDrink : public Drink
{
public:
void server()
{
std::cout << "ItailanDrink饮料服务" << std::endl;
}
};
class AmericanDrink : public Drink
{
public:
void server()
{
std::cout << "AmericanDrink饮料服务" << std::endl;
}
};
class AbstractFactory
{
public:
virtual std::unique_ptr<Pizza> createPizza() = 0;
virtual std::unique_ptr<Drink> createDrink() = 0;
virtual ~AbstractFactory() = default;
};
//Itailan工厂
class ItalianFactory : public AbstractFactory
{
public:
std::unique_ptr<Pizza> createPizza()
{
return make_unique<ItailanPizza>();
}
std::unique_ptr<Drink> createDrink()
{
return make_unique<ItailanDrink>();
}
};
class AmericanFactory : public AbstractFactory
{
public:
std::unique_ptr<Pizza> createPizza()
{
return make_unique<AmericanPizza>();
}
std::unique_ptr<Drink> createDrink()
{
return make_unique<ItailanDrink>();
}
};
int main()
{
ItalianFactory italianFactory;
AmericanFactory americanFactory;
std::unique_ptr<Pizza> italianPizza = italianFactory.createPizza();
std::unique_ptr<Drink> italianDrink = italianFactory.createDrink();
std::unique_ptr<Pizza> americanPizza = americanFactory.createPizza();
std::unique_ptr<Drink> americanDrink = americanFactory.createDrink();
italianPizza->prepare();
italianDrink->server();
americanPizza->prepare();
americanDrink->server();
}
在日志系统中,如果我们有不同的落地方向,就适合运用工厂模式:
/*
日志落地模块的实现
1.抽象落地基类
2.派生子类(根据不同的落地方向进行派生)
3.使用工厂模式
*/
#ifndef __M_SINK_H__
#define __M_SINK_H__
// #include "format.hpp"
#include "message.hpp"
#include "unlit.hpp"
#include <memory>
#include <fstream>
#include <cassert>
#include <sstream>
namespace logs
{
class logSink
{
public:
using ptr = std::shared_ptr<logSink>;
logSink()
{
}
virtual ~logSink() {}
virtual void log(const char *data, size_t len) = 0;
};
// 落地方向:标注输出,指定文件,滚动文件
class StdoutSink : public logSink
{
public:
// 将日志消息写到标准输出
void log(const char *data, size_t len)
{
std::cout.write(data, len);
}
};
class FileoutSink : public logSink
{
public:
// 构造时传入人名,并打开文件,将操作句柄管理起来
FileoutSink(const std::string &pathname)
: _pathname(pathname)
{
// 1.创建日志文件所在目录
logs::util::File::createDirectory(logs::util::File::path(_pathname));
// 2.创建并打开日志文件
_ofs.open(_pathname, std::ios::binary | std::ios::app);
assert(_ofs.is_open());
}
// 将日志消息写到标准输出
void log(const char *data, size_t len)
{
_ofs.write(data, len);
assert(_ofs.good());
}
private:
std::string _pathname;
std::ofstream _ofs;
};
class RollSinkBySize : public logSink
{
public:
// 构造时传入文件名,并打开文件,将操作句柄管理起来
RollSinkBySize(const std::string &basename, size_t max_size)
: _basename(basename), _max_fsize(max_size), _cur_fsize(0),_name_count(0)
{
std::string pathname = createNewFile();
// 1.创建日志文件所在目录
logs::util::File::createDirectory(logs::util::File::path(pathname));
// 2.创建并打开日志文件
_ofs.open(pathname, std::ios::binary | std::ios::app);
assert(_ofs.is_open());
}
// 将日志消息写到标准输出
void log(const char *data, size_t len)
{
if (_cur_fsize > _max_fsize)
{
_ofs.close();
std::string pathname = createNewFile();
_ofs.open(pathname, std::ios::binary | std::ios::app);
assert(_ofs.is_open());
_cur_fsize = 0;
}
_ofs.write(data, len);
assert(_ofs.good());
_cur_fsize += len;
}
private:
std::string createNewFile() // 进行大小判断,超过指定大小则创建新文件
{
// 获取系统时间,以时间来构造文件扩展名
time_t t = logs::util::Date::get_time();
struct tm lt;
localtime_r(&t, <);
std::stringstream filename;
filename << _basename;
filename << lt.tm_year + 1900;
filename << lt.tm_mon + 1;
filename << lt.tm_mday;
filename << lt.tm_hour;
filename << lt.tm_min;
filename << lt.tm_sec;
filename << "-";
filename << _name_count++;
filename << ".log";
return filename.str();
}
private:
// 基础文件名 + 扩展文件名(以时间生成)组成一个实际的当前输出文件名
size_t _name_count;
std::string _basename; //.logs/base-
std::ofstream _ofs;
size_t _max_fsize; // 记录最大大小
size_t _cur_fsize; // 记录当前文件已经写入的大小
};
class SinkFactory
{
public:
template <typename SlinkTpe, typename... Args>
static logSink::ptr create(Args &&...args)
{
return std::make_shared<SlinkTpe>(std::forward<Args>(args)...);
}
};
}
#endif