void Data_Processing(std::string msg) { json msg_data = json::parse(msg); // 访问JSON对象中的属性 std::string yb_data = msg_data["data"]; std::cout << "函数调用" << "data: " << yb_data << std::endl; //获取当前时间 auto now = std::chrono::system_clock::now(); std::time_t now_c = std::chrono::system_clock::to_time_t(now); // 将时间转换为本地时间 std::tm* local_now = std::localtime(&now_c); if(atoi(yb_data.c_str()) > 20) { std::ofstream out("data.txt", std::ios::app); // 将数据写入文件,每次写默认不会清空 out << std::put_time(local_now, "%Y-%m-%d %H:%M:%S") << " " << atoi(yb_data.c_str()) << std::endl; out.close(); } }一秒内只能写一个数据吗
时间: 2024-01-20 15:04:43 浏览: 57
不是的,可以将满足条件的数据存储到一个容器中,比如说vector,在一秒钟结束时将所有满足条件的数据一次性写入文件。可以使用定时器或者线程等方式来实现。以下是一种可能的实现方式:
1. 定义一个vector来存储满足条件的数据:
```
std::vector<std::pair<std::time_t, int>> data_buffer;
```
2. 在函数中判断当前时间是否与上一次写入文件的时间相同,如果相同则将数据存入vector,否则将vector中的数据一次性写入文件并清空vector:
```
void Data_Processing(std::string msg) {
json msg_data = json::parse(msg);
std::string yb_data = msg_data["data"];
std::cout << "函数调用" << "data: " << yb_data << std::endl;
auto now = std::chrono::system_clock::now();
std::time_t now_c = std::chrono::system_clock::to_time_t(now);
std::tm* local_now = std::localtime(&now_c);
static std::time_t last_time = 0;
if (std::strftime("%S", local_now) == std::strftime("%S", std::localtime(&last_time))) {
if (atoi(yb_data.c_str()) > 20) {
data_buffer.push_back(std::make_pair(now_c, atoi(yb_data.c_str())));
}
} else {
if (!data_buffer.empty()) {
std::ofstream out("data.txt", std::ios::app);
for (const auto& data : data_buffer) {
out << std::put_time(std::localtime(&data.first), "%Y-%m-%d %H:%M:%S") << " " << data.second << std::endl;
}
out.close();
data_buffer.clear();
}
last_time = now_c;
if (atoi(yb_data.c_str()) > 20) {
std::ofstream out("data.txt", std::ios::app);
out << std::put_time(local_now, "%Y-%m-%d %H:%M:%S") << " " << atoi(yb_data.c_str()) << std::endl;
out.close();
}
}
}
```
3. 在程序中调用该函数,并传入相应的参数即可。
阅读全文