简单的数据缓存程序C++_c++数据存入缓存

基本问题

对于接触过数据采集存储的同学应该遇见过这种情况，向数据库中频繁写入数据，往往最后很大一部分数据最后丢失了。不是说数据库写入数据的速度跟不上，而是因为操作文件的速度跟不上。可以这么理解，数据库写入数据分为3步，打开数据库的表、向表中写入数据、关闭数据库的表。写入数据所需要的时间是与数据量多少相关的，这个一般数据库能达到1秒十几兆的，但每次打开和关闭数据库的表的时间确实固定的，打开关闭的次数越多占用的时间越多。一秒中写入20次数据，进打开和关闭表的时间就会超过1秒了，跟本就没有给写入数据留足够的时间，所以数据必然就会出现严重的丢失的情况。采集数据的正确做法是采集数据后将采集的数据采用对列暂存一下，存储的时间满1s后，从队列中读取一段数据，一次性写入到数据库中即可，只要保证队列中不堆积过多数据即可。此时最重要的就是需要设计一个对列可以暂存数据，最好这个对列能够兼容非常多的数据类型。

基本需求

构建一个简单的对列的类，用于存储数据实现数据的先进先出的功能，另外该类还需要能够实现多种数据类型的兼容的功能。

设计思路

考虑到该类应该尽可能地兼容更多类型地数据类型，所以应当设计成模板类地形式。这里需要使用到对列的功能，最容易想到的是STL里面的那个对列，但是那是双端对列，所以还需要进行一定的修改。另外根据我的个人习惯，凡是涉及到数据的输入和输出方面一致设计成输入输出符号进行的。

类相关程序

#include <queue>
using namespace std;
template <class T>
class CBuffer{
public:CBuffer();
	   ~CBuffer();
	   queue<T> getQueue();
	   CBuffer<T>& operator=(const CBuffer<T> data);
	   CBuffer<T>& operator=(const queue<T> data);
	   CBuffer<T>& operator>>(T& data);
	   CBuffer<T>& operator>>(vector<T>& data);
	   CBuffer<T>& operator <<(const T& data);
	   CBuffer<T>& operator <<(const vector<T>& data);
	   void setCount(int count);        
private:queue<T> que;
		int count;
		bool input(vector<T> src);
		bool input(T src);
		vector<T> output(unsigned int count);
};

template<class T>
CBuffer<T>::CBuffer()
{
	count = 1;  //默认一次读取一个数据
}

template<class T>
CBuffer<T>::~CBuffer()
{
}

template<class T>
queue<T> CBuffer<T>::getQueue()
{
	return que;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator=(const CBuffer<T> data)
{
	// TODO: 在此处插入 return 语句
	if (data.getQueue().empty())
	{
		return {};
	}
	que = data.getQueue();
	return *this;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator=(const queue<T> data)
{
	// TODO: 在此处插入 return 语句
	if (data.empty())
	{
		return {};
	}
	que = data;
	return *this;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator>>(T & data)
{
	// TODO: 在此处插入 return 语句
	data = output(1)[0];
	return *this;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator>>(vector<T>& data)
{
	// TODO: 在此处插入 return 语句
	data = output(count);
	return * this;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator<<(const T & data)
{
	// TODO: 在此处插入 return 语句
	input(data);
	return *this;
}

template<class T>
CBuffer<T>& CBuffer<T>::operator<<(const vector<T>& data)
{
	// TODO: 在此处插入 return 语句
	input(data);
	return *this;
}

template<class T>
void CBuffer<T>::setCount(int count)
{
	this->count = count;
}

template<class T>
bool CBuffer<T>::input(vector<T> src)
{
	if (src.empty())
		return false;
	unsigned int srcsize = src.size();
	for (unsigned int i = 0; i < srcsize; i++)
	{
		que.push(src[i]);
	}
	return true;
}

template<class T>
bool CBuffer<T>::input(T src)
{
	que.push(src);
	return true;
}

template<class T>
vector<T> CBuffer<T>::output(unsigned int count)
{
	vector<T> vec;
	unsigned count1;
	if (que.size() > count)
		count1 = count;
	else
		count1 = que.size();
	for (unsigned int i = 0; i < count1; i++)
	{
		vec.push_back(que.front());
		que.pop();
	}
	return vec;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

简单测试

使用vs建一个控制台项目，测试一下数据的输入和输出

int main()
{
    std::cout << "Hello World!\n";
	CBuffer<string> q;
	for (int i = 0; i < 10; i++)
	{
		q<<to_string(i);
	}
	q.setCount(2);
	vector<string> vec; q >> vec;
	cout << "共有元素:" << q.getQueue().size()<<"个" << endl;
	cout << "队头元素为" << q.getQueue().front() << endl;
	system("pause");
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

调试输出的结果如下图