JSON 파싱 오류: [json.exception.parse_error.101] parse error at line 1, column 2264: syntax error while parsing value - unexpected '{'; expected end of input. Please help me resolve the expected end of input error.

[CheongYa]

#include <iostream>
#include <array>
#include <boost/asio.hpp>
#include <mysql/mysql.h>
#include <nlohmann/json.hpp>

using namespace boost::asio;
using json = nlohmann::json;

class AsyncTCPServer {
public:
    // 생성자
   AsyncTCPServer(io_service& io_service, short port)
       : acceptor_(io_service, ip::tcp::endpoint(ip::tcp::v4(), port)),
         socket_(io_service) {
       StartAccept();
       // MariaDB에 연결
       db_connection_ = mysql_init(nullptr);
       if (db_connection_ == nullptr) {
           std::cerr << "MariaDB 연결 초기화 실패" << std::endl;
           exit(1);
       }
       if (mysql_real_connect(db_connection_, "localhost", "root", "1234", "servertest", 3306, nullptr, 0) == nullptr) {
           std::cerr << "MariaDB 연결 실패: " << mysql_error(db_connection_) << std::endl;
           exit(1);
       }
       std::cout << "MariaDB 연결 성공" << std::endl;
   }
   // 소멸자
   ~AsyncTCPServer() {
       // MariaDB 연결 해제
       if (db_connection_ != nullptr) {
           mysql_close(db_connection_);
           std::cout << "MariaDB 연결 해제" << std::endl;
       }
   }

private:
    // 새로운 클라이언트 연결 수락 및 비동기 통신 시작
   void StartAccept() {
       acceptor_.async_accept(socket_,
           [this](boost::system::error_code ec) {
               if(ec) {
                   std::cerr << "연결 수락 중 오류 발생: " << ec.message() << std::endl;
               } else {
                   // 새로운 클라이언트를 관리하기 위해 소켓을 배열에 추가
                   AddClient(std::make_shared<ip::tcp::socket>(std::move(socket_)));
                   // 다음 클라이언트 연결 대기
                   StartAccept();
                   // 현재 클라이언트에 대한 비동기 통신 시작
                   StartRead(clients_[num_clients_ - 1]);
               }
           });
   }

    // 새로운 클라이언트를 배열에 추가하고 연결 메시지를 출력
   void AddClient(std::shared_ptr<ip::tcp::socket> client) {
       std::lock_guard<std::mutex> lock(database_mutex_);
   
       if (num_clients_ < max_clients) {
           clients_[num_clients_] = client;
           num_clients_++;
   
           // 연결 메시지 출력
           std::cout << client->remote_endpoint().address().to_string() + "와 연결되었습니다." << std::endl;
       } else {
           std::cerr << "최대 클라이언트 수를 초과하여 연결을 수락할 수 없습니다." << std::endl;
           client->close();
       }
   }

   // 클라이언트에 대한 비동기 읽기 시작
   void StartRead(std::shared_ptr<ip::tcp::socket> client) {
       async_read_until(*client, buffer_, '\n',
           [this, client](boost::system::error_code ec, std::size_t length) {
               if (ec) {
                   RemoveClient(client);
               } else {
                   std::istream is(&buffer_);
                   std::string message;
                   std::getline(is, message);
                   // DB에 저장
                   SaveToDatabase(message);
                   StartRead(client);
               }
           });
   }

   void SaveCpuToDatabase(const json& cpuData) {
       for (const auto& processor : cpuData) {
           // 각 프로세서 정보 추출
           std::string cores = processor["Cores"].get<std::string>();
           std::string model = processor["Model"].get<std::string>();
           std::string siblings = processor["Siblings"].get<std::string>();
           // MySQL에 데이터 저장
           std::string query = "INSERT INTO cpu_table (cores, model, siblings) VALUES ('" + cores + "', '" + model + "', '" + siblings + "')";
           if (mysql_query(db_connection_, query.c_str()) != 0) {
               std::cerr << "CPU 정보를 데이터베이스에 저장하는 중 오류 발생: " << mysql_error(db_connection_) << std::endl;
           }
       }
   }

   void SaveNicToDatabase(const json& nicData) {
       for (const auto& nic : nicData) {
           std::string interface = nic["Interface"].get<std::string>();
           std::string mac_address = nic["MAC Address"].get<std::string>();
           std::string operational_state = nic["Operational State"].get<std::string>();
           std::string speed = nic["Speed"].get<std::string>();
           // MySQL에 데이터 저장
           std::string query = "INSERT INTO nic_table (interface, mac_address, operational_state, speed) VALUES ('" + interface + "', '" + mac_address + "', '" + operational_state + "', '" + speed + "')";
           int queryResult = mysql_query(db_connection_, query.c_str());
           if (queryResult != 0) {
               std::cerr << "CPU 정보를 데이터베이스에 저장하는 중 오류 발생: " << mysql_error(db_connection_) << std::endl;
           }
       }
   }

   void SaveMemoryToDatabase(const json& memoryData) {
       for (const auto& memory : memoryData) {
           std::string active = memory["Active"].get<std::string>();
           std::string active_anon = memory["Active(anon)"].get<std::string>();
           std::string active_file = memory["Active(file)"].get<std::string>();
           std::string anonHugePages = memory["AnonHugePages"].get<std::string>();
           std::string anonPages = memory["AnonPages"].get<std::string>();
           std::string bounce = memory["Bounce"].get<std::string>();
           std::string buffers = memory["Buffers"].get<std::string>();
           std::string cached = memory["Cached"].get<std::string>();
           std::string cmaFree = memory["CmaFree"].get<std::string>();
           std::string cmaTotal = memory["CmaTotal"].get<std::string>();
           std::string commitLimit = memory["CommitLimit"].get<std::string>();
           std::string committed_AS = memory["Committed_AS"].get<std::string>();
           std::string directMap2M = memory["DirectMap2M"].get<std::string>();
           std::string directMap4k = memory["DirectMap4k"].get<std::string>();
           std::string dirty = memory["Dirty"].get<std::string>();
           std::string fileHugePages = memory["FileHugePages"].get<std::string>();
           std::string filePmdMapped = memory["FilePmdMapped"].get<std::string>();
           std::string hardwareCorrupted = memory["HardwareCorrupted"].get<std::string>();
           std::string hugePages_Free = memory["HugePages_Free"].get<std::string>();
           std::string hugePages_Rsvd = memory["HugePages_Rsvd"].get<std::string>();
           std::string hugePages_Surp = memory["HugePages_Surp"].get<std::string>();
           std::string hugePages_Total = memory["HugePages_Total"].get<std::string>();
           std::string hugepagesize = memory["Hugepagesize"].get<std::string>();
           std::string hugetlb = memory["Hugetlb"].get<std::string>();
           std::string inactive = memory["Inactive"].get<std::string>();
           std::string inactive_anon = memory["Inactive(anon)"].get<std::string>();
           std::string inactive_file = memory["Inactive(file)"].get<std::string>();
           std::string kreclaimable = memory["KReclaimable"].get<std::string>();
           std::string kernelStack = memory["KernelStack"].get<std::string>();
           std::string mapped = memory["Mapped"].get<std::string>();
           std::string memAvailable = memory["MemAvailable"].get<std::string>();
           std::string memFree = memory["MemFree"].get<std::string>();
           std::string memTotal = memory["MemTotal"].get<std::string>();
           std::string mlocked = memory["Mlocked"].get<std::string>();
           std::string nFS_Unstable = memory["NFS_Unstable"].get<std::string>();
           std::string pageTables = memory["PageTables"].get<std::string>();
           std::string percpu = memory["Percpu"].get<std::string>();
           std::string sReclaimable = memory["SReclaimable"].get<std::string>();
           std::string sUnreclaim = memory["SUnreclaim"].get<std::string>();
           std::string shmem = memory["Shmem"].get<std::string>();
           std::string shmemHugePages = memory["ShmemHugePages"].get<std::string>();
           std::string shmemPmdMapped = memory["ShmemPmdMapped"].get<std::string>();
           std::string slab = memory["Slab"].get<std::string>();
           std::string swapCached = memory["SwapCached"].get<std::string>();
           std::string swapFree = memory["SwapFree"].get<std::string>();
           std::string swapTotal = memory["SwapTotal"].get<std::string>();
           std::string unevictable = memory["Unevictable"].get<std::string>();
           std::string vmallocChunk = memory["VmallocChunk"].get<std::string>();
           std::string vmallocTotal = memory["VmallocTotal"].get<std::string>();
           std::string vmallocUsed = memory["VmallocUsed"].get<std::string>();
           std::string writeback = memory["Writeback"].get<std::string>();
           std::string writebackTmp = memory["WritebackTmp"].get<std::string>();
           std::string zswap = memory["Zswap"].get<std::string>();
           std::string zswapped = memory["Zswapped"].get<std::string>();
           std::string query = "INSERT INTO memory_table (active, active_anon, active_file, anonHugePages, anonPages, bounce, buffers, cached, cmaFree, cmaTotal, commitLimit, committed_AS, directMap2M, directMap4k, dirty, fileHugePages, filePmdMapped, hardwareCorrupted, hugePages_Free, hugePages_Rsvd, hugePages_Surp, hugePages_Total, hugepagesize, hugetlb, inactive, inactive_anon, inactive_file, kreclaimable, kernelStack, mapped, memAvailable, memFree, memTotal, mlocked, nFS_Unstable, pageTables, percpu, sReclaimable, sUnreclaim, shmem, shmemHugePages, shmemPmdMapped, slab, swapCached, swapFree, swapTotal, unevictable, vmallocChunk, vmallocTotal, vmallocUsed, writeback, writebackTmp, zswap, zswapped) VALUES ('" + active + "', '" + active_anon + "', '" + active_file + "', '" + anonHugePages + "', '" + anonPages + "', '" + bounce + "', '" + buffers + "', '" + cached + "', '" + cmaFree + "', '" + cmaTotal + "', '" + commitLimit + "', '" + committed_AS + "', '" + directMap2M + "', '" + directMap4k + "', '" + dirty + "', '" + fileHugePages + "', '" + filePmdMapped + "', '" + hardwareCorrupted + "', '" + hugePages_Free + "', '" + hugePages_Rsvd + "', '" + hugePages_Surp + "', '" + hugePages_Total + "', '" + hugepagesize + "', '" + hugetlb + "', '" + inactive + "', '" + inactive_anon + "', '" + inactive_file + "', '" + kreclaimable + "', '" + kernelStack + "', '" + mapped + "', '" + memAvailable + "', '" + memFree + "', '" + memTotal + "', '" + mlocked + "', '" + nFS_Unstable + "', '" + pageTables + "', '" + percpu + "', '" + sReclaimable + "', '" + sUnreclaim + "', '" + shmem + "', '" + shmemHugePages + "', '" + shmemPmdMapped + "', '" + slab + "', '" + swapCached + "', '" + swapFree + "', '" + swapTotal + "', '" + unevictable + "', '" + vmallocChunk + "', '" + vmallocTotal + "', '" + vmallocUsed + "', '" + writeback + "', '" + writebackTmp + "', '" + zswap + "', '" + zswapped + "')";
           int queryResult = mysql_query(db_connection_, query.c_str());
           if (queryResult != 0) {
               std::cerr << "Memory 정보를 데이터베이스에 저장하는 중 오류 발생: " << mysql_error(db_connection_) << std::endl;
           }
       }
   }

   void SaveDiskToDatabase(const json& diskData) {
       for (const auto& disk : diskData) {
           std::string device = disk["Device"].get<std::string>();
           int completed_io_operations = disk["Completed I/O operations"].get<int>();
           int merged_io_operations = disk["Merged I/O operations"].get<int>();
           int time_spent_reading = disk["Time spent reading (ms)"].get<int>();
           int time_spent_writing = disk["Time spent writing (ms)"].get<int>();
           int total_sectors = disk["Total sectors"].get<int>();
           // MySQL에 데이터 저장을 위한 쿼리 생성
           std::stringstream query;
           query << "INSERT INTO disk_table (device, completed_io_operations, merged_io_operations, time_spent_reading, time_spent_writing, total_sectors) VALUES ('"
                 << device << "', " << completed_io_operations << ", " << merged_io_operations << ", " << time_spent_reading << ", " << time_spent_writing << ", " << total_sectors << ")";
           // MySQL에 데이터 저장
           int queryResult = mysql_query(db_connection_, query.str().c_str());
           if (queryResult != 0) {
               std::cerr << "Disk 정보를 데이터베이스에 저장하는 중 오류 발생: " << mysql_error(db_connection_) << std::endl;
           }
       }
   }

   // 데이터베이스에 메시지 저장
   void SaveToDatabase(const std::string& message) {
      // 예시: JSON으로 가정하고 데이터베이스에 저장하는 코드
      try {
         auto j = json::parse(message);
         std::lock_guard<std::mutex> lock(database_mutex_);
           
         if (j.find("CPU") != j.end()) {
            SaveCpuToDatabase(j["CPU"]);
         }
         if (j.find("NIC") != j.end()) {
            SaveNicToDatabase(j["NIC"]);
         }
         if (j.find("Memory") != j.end()) {
            SaveMemoryToDatabase(j["Memory"]);
         }
         if (j.find("Disk") != j.end()) {
            SaveDiskToDatabase(j["Disk"]);
         }
         std::cout << "데이터베이스에 저장 완료" << std::endl;
      } catch (const nlohmann::detail::parse_error& e) { // JSON 파싱 오류 캐치
         std::cerr << "JSON 파싱 오류: " << e.what() << std::endl;
         std::cerr << "오류가 발생한 메시지: " << message << std::endl;
      } catch (const std::exception& e) {
         std::cerr << "데이터베이스 저장 실패: " << e.what() << std::endl;
         std::cerr << "오류가 발생한 메시지: " << message << std::endl;
      }
   }
   
   // 클라이언트를 배열에서 제거하고 연결 종료 메시지를 출력
   void RemoveClient(std::shared_ptr<ip::tcp::socket> client) {
       for (int i = 0; i < max_clients; ++i) {
           if (clients_[i] == client) {
               clients_[i] = nullptr;
               num_clients_--;
               // 연결 종료 메시지 출력
               std::cout << client->remote_endpoint().address().to_string() + "와 연결이 종료되었습니다." << std::endl;
               break;
           }
       }
   }

   ip::tcp::acceptor acceptor_; // TCP 연결 수용기
   ip::tcp::socket socket_; // TCP 소켓
   streambuf buffer_; // 버퍼
   static const int max_clients = 100000;  // 최대 클라이언트 수
   std::array<std::shared_ptr<ip::tcp::socket>, max_clients> clients_; // 최대 클라이언트 수에 따른 TCP 소켓
   int num_clients_ = 0; // 현재 연결된 클라이언트 수
   std::mutex database_mutex_;
   // MariaDB 연결 핸들러
   MYSQL* db_connection_;
};

int main() {
    try {
        boost::asio::io_service io_service; // io_service 객체 생성
        AsyncTCPServer server(io_service, 12345); // AsyncTCPServer 클래스의 객체 생성(객체, 포트번호)
        io_service.run(); // 이벤트 루프 시작
    } catch (std::exception& e) {
        std::cerr << "예외 발생: " << e.what() << std::endl;
    }

    return 0;
}

The above code throws an error.

Here's what happens:
Information sent from one client is entered correctly. However, if there are more than 2 units, an error occurs.

Compilation is done as follows.
g++ -o test test.cpp -lboost_system -I/usr/include/ -L/usr/lib64 -lmysqlclient -ljsoncpp

[nlohmann]

Can you print the string you pass to the library? Please make sure it is valid JSON.

[CheongYa]

In the SaveToDatabase function std::cout << message << std::endl; I'll add it and print it out.

    void SaveToDatabase(const std::string& message) {
        std::cout << message << std::endl;
        try {
            auto j = json::parse(message);
            std::lock_guard<std::mutex> lock(database_mutex_);

            if (j.find("CPU") != j.end()) {
                SaveCpuToDatabase(j["CPU"]);
            }

This is the result of cout.

{"CPU":{"0":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"},"1":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"}},"Disk":{"11":{"Completed I/O operations":0,"Device":"11","Merged I/O operations":0,"Time spent reading (ms)":140732119179856,"Time spent writing (ms)":140732119180552,"Total sectors":4327081},"253":{"Completed I/O operations":1,"Device":"253","Merged I/O operations":0,"Time spent reading (ms)":140732119179856,"Time spent writing (ms)":140732119180552,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140732119179856,"Time spent writing (ms)":140732119180552,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"336736kB","Active(anon)":"1984kB","Active(file)":"334752kB","AnonHugePages":"868352kB","AnonPages":"1174040kB","Bounce":"0kB","Buffers":"2860kB","Cached":"974700kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3962728kB","DirectMap2M":"4069376kB","DirectMap4k":"124864kB","Dirty":"8kB","FileHugePages":"0kB","FilePmdMapped":"0kB","HardwareCorrupted":"0kB","HugePages_Free":"0","HugePages_Rsvd":"0","HugePages_Surp":"0","HugePages_Total":"0","Hugepagesize":"2048kB","Hugetlb":"0kB","Inactive":"1843560kB","Inactive(anon)":"1230184kB","Inactive(file)":"613376kB","KReclaimable":"65968kB","KernelStack":"7728kB","Mapped":"255736kB","MemAvailable":"1982332kB","MemFree":"1203104kB","MemTotal":"3737844kB","Mlocked":"96kB","NFS_Unstable":"0kB","PageTables":"16316kB","Percpu":"1216kB","SReclaimable":"65968kB","SUnreclaim":"60692kB","Shmem":"29432kB","ShmemHugePages":"0kB","ShmemPmdMapped":"0kB","Slab":"126660kB","SwapCached":"0kB","SwapFree":"4145148kB","SwapTotal":"4145148kB","Unevictable":"96kB","VmallocChunk":"0kB","VmallocTotal":"34359738367kB","VmallocUsed":"38696kB","Writeback":"0kB","WritebackTmp":"0kB","Zswap":"0kB","Zswapped":"0kB"}},"NIC":{"enp0s3":{"Interface":"enp0s3","MAC Address":"08:00:27:0b:b8:b7","Operational State":"up","Speed":"1000"},"enp0s8":{"Interface":"enp0s8","MAC Address":"08:00:27:23:4d:a2","Operational State":"up","Speed":"1000"},"lo":{"Interface":"lo","MAC Address":"00:00:00:00:00:00","Operational State":"unknown","Speed":""}}}

Do you also need client code?

[nlohmann]

That looks OK. And the parser threw an error?

[CheongYa]

no. In that case, no error occurred because only one client sent.

[gregmarr]

[json.exception.parse_error.101] parse error at line 1, column 2264: syntax error while parsing value - unexpected '{'; expected end of input.

Your provided input is 2263 characters, that tells me that when there are two clients, the two strings get combined into one. You need to make sure that you are only parsing one string at a time.

                   std::istream is(&buffer_);
                   std::string message;
                   std::getline(is, message);
                   // DB에 저장
                   SaveToDatabase(message);

I suspect that your client messages don't end with a newline, and thus std::getline pulls them both at once.

[CheongYa]

If more than one client is sending, does that mean the messages are mixed?

So how to solve it?

[CheongYa]

Thanks to you, I solved it. But another problem arose.

While communicating with multiple clients, I am getting the following error:

Exception thrown: remote_endpoint: Transport endpoint is not connected.

Can I get help with this problem?

[CheongYa]

The current code is:

#include <iostream>
#include <array>
#include <map>
#include <boost/asio.hpp>
#include <mysql/mysql.h>
#include <nlohmann/json.hpp>

using namespace boost::asio;
using json = nlohmann::json;

class AsyncTCPServer {
public:
    // 생성자
    AsyncTCPServer(io_service& io_service, short port)
        : acceptor_(io_service, ip::tcp::endpoint(ip::tcp::v4(), port)),
        socket_(io_service) {
            StartAccept();
            ConnectToMariaDB();
    }
    // 소멸자
    ~AsyncTCPServer() {
        // MariaDB 연결 해제
        if (db_connection_ != nullptr) {
            mysql_close(db_connection_);
            std::cout << "MariaDB 연결 해제" << std::endl;
        }
    }

private:
    // 새로운 클라이언트 연결 수락 및 비동기 통신 시작
    void StartAccept() {
        acceptor_.async_accept(socket_,
            [this](boost::system::error_code ec) {
                if(ec) {
                    std::cerr << "연결 수락 중 오류 발생: " << ec.message() << std::endl;
                } else {
                    // 새로운 클라이언트를 관리하기 위해 소켓을 배열에 추가
                    AddClient(std::make_shared<ip::tcp::socket>(std::move(socket_)));
                    // 다음 클라이언트 연결 대기
                    StartAccept();
                    // 현재 클라이언트에 대한 비동기 통신 시작
                    StartRead(clients_[num_clients_ - 1]);
                }
            });
    }
 
    // 새로운 클라이언트를 배열에 추가하고 연결 메시지를 출력
    void AddClient(std::shared_ptr<ip::tcp::socket> client) {
        std::lock_guard<std::mutex> lock(mutex_);
    
        if (num_clients_ < max_clients) {
            clients_[num_clients_] = client;
            num_clients_++;
    
            // 연결 메시지 출력
            std::cout << client->remote_endpoint().address().to_string() + "와 연결되었습니다." << std::endl;
        } else {
            std::cerr << "최대 클라이언트 수를 초과하여 연결을 수락할 수 없습니다." << std::endl;
            client->close();
        }
    }
 
    // 클라이언트에 대한 비동기 읽기 시작
    void StartRead(std::shared_ptr<ip::tcp::socket> client) {
        auto& buffer = buffers_[client];  // 클라이언트에 연관된 버퍼를 가져옴
        async_read_until(*client, buffer, '\n',
            [this, client, &buffer](boost::system::error_code ec, std::size_t length) {
                if (ec) {
                    RemoveClient(client);
                } else {
                    std::istream is(&buffer);
                    std::string message;
                    std::getline(is, message);
                    // DB에 저장
                    SaveToDatabase(message);
                    StartRead(client);
                }
            });
    }
 
    void SaveCpuToDatabase(const json& cpuData) {
        // skip..
    }
 
    void SaveNicToDatabase(const json& nicData) {
        // skip..
    }
 
    void SaveMemoryToDatabase(const json& memoryData) {
        // skip..
    }
 
    void SaveDiskToDatabase(const json& diskData) {
        // skip..
    }

    // 데이터베이스에 메시지 저장
    void SaveToDatabase(const std::string& message) {
       // 예시: JSON으로 가정하고 데이터베이스에 저장하는 코드
       try {
          auto j = json::parse(message);
          std::lock_guard<std::mutex> lock(mutex_);
            
          if (j.find("CPU") != j.end()) {
             SaveCpuToDatabase(j["CPU"]);
          }
          if (j.find("NIC") != j.end()) {
             SaveNicToDatabase(j["NIC"]);
          }
          if (j.find("Memory") != j.end()) {
             SaveMemoryToDatabase(j["Memory"]);
          }
          if (j.find("Disk") != j.end()) {
             SaveDiskToDatabase(j["Disk"]);
          }
          std::cout << "데이터베이스에 저장 완료" << std::endl;
       } catch (const nlohmann::detail::parse_error& e) { // JSON 파싱 오류 캐치
          std::cerr << "JSON 파싱 오류: " << e.what() << std::endl;
          std::cerr << "오류가 발생한 메시지: " << message << std::endl;
       } catch (const std::exception& e) {
          std::cerr << "데이터베이스 저장 실패: " << e.what() << std::endl;
          std::cerr << "오류가 발생한 메시지: " << message << std::endl;
       }
    }
   
    // 클라이언트를 배열에서 제거하고 연결 종료 메시지를 출력
    void RemoveClient(std::shared_ptr<ip::tcp::socket> client) {
        for (int i = 0; i < max_clients; ++i) {
            if (clients_[i] == client) {
                clients_[i] = nullptr;
                num_clients_--;
                // 연결 종료 메시지 출력
                std::cout << client->remote_endpoint().address().to_string() + "와 연결이 종료되었습니다." << std::endl;

                boost::system::error_code ec;
                client->shutdown(ip::tcp::socket::shutdown_both, ec);
                client->close(ec);

                break;
            }
        }
    }

    void ConnectToMariaDB() {
        // MariaDB 연결
        db_connection_ = mysql_init(nullptr);
        if (db_connection_ == nullptr) {
            std::cerr << "MariaDB 연결 초기화 실패" << std::endl;
            exit(1);
        }

        const char* host = "localhost";
        const char* user = "root";
        const char* password = "1234";
        const char* database = "servertest";
        unsigned int port = 3306;

        if (mysql_real_connect(db_connection_, host, user, password, database, port, nullptr, 0) == nullptr) {
            std::cerr << "MariaDB 연결 실패: " << mysql_error(db_connection_) << std::endl;
            exit(1);
        }

        std::cout << "MariaDB 연결 성공" << std::endl;
    }

    ip::tcp::acceptor acceptor_; // TCP 연결 수용기
    ip::tcp::socket socket_; // TCP 소켓
    static const int max_clients = 100000;  // 최대 클라이언트 수
    std::array<std::shared_ptr<ip::tcp::socket>, max_clients> clients_; // 최대 클라이언트 수에 따른 TCP 소켓
    int num_clients_ = 0; // 현재 연결된 클라이언트 수
    std::mutex mutex_;
    // MariaDB 연결 핸들러
    MYSQL* db_connection_;
    std::map<std::shared_ptr<ip::tcp::socket>, streambuf> buffers_;  // 클라이언트별로 버퍼를 관리하는 맵
};

int main() {
    try {
        boost::asio::io_service io_service; // io_service 객체 생성
        AsyncTCPServer server(io_service, 12345); // AsyncTCPServer 클래스의 객체 생성(객체, 포트번호)
        io_service.run(); // 이벤트 루프 시작
    } catch (std::exception& e) {
        std::cerr << "예외 발생: " << e.what() << std::endl;
    }

    return 0;
}

[gregmarr]

That's not related to this library. Sorry that I don't have any experience with your communications system.

[CheongYa]

In the above case, only one client's transmission was received. Next, transmissions from multiple clients were sent simultaneously (case in which an error occurs). The server is receiving information from 30 clients.

JSON 파싱 오류: [json.exception.parse_error.101] parse error at line 1, column 1027: syntax error while parsing object separator - invalid literal; last read: '"Direc{"C'; expected ':'

오류가 발생한 메시지: {"CPU":{"0":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"},"1":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"}},"Disk":{"11":{"Completed I/O operations":0,"Device":"11","Merged I/O operations":0,"Time spent reading (ms)":140727977909952,"Time spent writing (ms)":140727977910648,"Total sectors":4327081},"253":{"Completed I/O operations":1,"Device":"253","Merged I/O operations":0,"Time spent reading (ms)":140727977909952,"Time spent writing (ms)":140730181844872,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140730181844176,"Time spent writing (ms)":140730181844872,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"846100kB","Bounce":"0kB","Buffers":"2860kB","Cached":"683552kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3440608kB","Direc{"CPU":{"0":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"},"1":{"Cores":"2","Model":"Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz","Siblings":"2"}},"Disk":{"11":{"Completed I/O operations":0,"Device":"11","Merged I/O operations":0,"Time spent reading (ms)":140729720050944,"Time spent writing (ms)":140729720051640,"Total sectors":4327081},"253":{"Completed I/O operations":1,"Device":"253","Merged I/O operations":0,"Time spent reading (ms)":140729720050944,"Time spent writing (ms)":140733805849656,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140733805848960,"Time spent writing (ms)":140733805849656,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"846300kB","Bounce":"0kB","Buffers":"2860kB","Cached":"683852kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3440740kB","DirectMap2M":"4098048kB","DirectMap4k":"96192kB","Dirty":"56kB","FileHugePages":"0kB","FilePmdMapped":"0kB","HardwareCorrupted":"0kB","HugePages_Free":"0","HugePages_Rsvd":"0","HugePages_Surp":"0","HugePages_Total":"0","Hugepagesize":"2048kB","Hugetlb":"0kB","Inactive":"1384428kB","Inactive(anon)":"901952kB","Inactive(file)":"482476kB","KReclaimable":"62584kB","KernelStack":"7744kB","Mapped":"243928kB","MemAvailable":"2380636kB","MemFree":"1886508kB","MemTotal":"3737844kB","Mlocked":"0kB","NFS_Unstable":"0kB","PtMap2M":"4098048kB","DirectMap4k":"96192kB","Dirty":"56kB","FileHugePages":"0kB","FilePmdMapped":"0kB","HardwareCorrupted":"0kB","HugePages_Free":"0","HugePages_Rsvd":"0","HugePages_Surp":"0","HugePages_Total":"0","Hugepagesize":"2048kB","Hugetlb":"0kB","Inactive":"1384728kB","Inactive(anon)":"902052kB","Inactive(file)":"482676kB","KReclaimable":"62584kB","KernelStack":"7744kB","Mapped":"244528kB","MemAvailable":"2380360kB","MemFree":"1886032kB","MemTotal":"3737844kB","Mlocked":"0kB","NFS_Unstable":"0kB","P":140723900340168,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140723900339472,"Time spent writing (ms)":140723900340168,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"846700kB","Bounce":"0kB","Buffers":"2860kB","Cached":"684352kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3441448kB","Direc":140732365628248,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140732365627552,"Time spent writing (ms)":140732365628248,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"846300kB","Bounce":"0kB","Buffers":"2860kB","Cached":"683852kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3440740kB","Direc":140724326735240,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140724326734544,"Time spent writing (ms)":140724326735240,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"847700kB","Bounce":"0kB","Buffers":"2860kB","Cached":"685852kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3442696kB","Direc":140724186805624,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140724186804928,"Time spent writing (ms)":140724186805624,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"845800kB","Bounce":"0kB","Buffers":"2860kB","Cached":"683052kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3440080kB","Direc":140726872345736,"Total sectors":4327081},"8":{"Completed I/O operations":2,"Device":"8","Merged I/O operations":0,"Time spent reading (ms)":140726872345040,"Time spent writing (ms)":140726872345736,"Total sectors":4327081}},"Memory":{"Memory":{"Active":"184264kB","Active(anon)":"2020kB","Active(file)":"182244kB","AnonHugePages":"299008kB","AnonPages":"847800kB","Bounce":"0kB","Buffers":"2860kB","Cached":"685952kB","CmaFree":"0kB","CmaTotal":"0kB","CommitLimit":"6014068kB","Committed_AS":"3442876kB","DirectMap2M":"4098048kB","DirectMap4k":"96192kB","Dirty":"56kB","FileHugePages":"0kB","FilePmdMapped":"0kB","HardwareCorrupted":"0kB","HugePages_Free":"0","HugePages_Rsvd":"0","HugePages_Surp":"0","HugePages_Total":"0","Hugepagesize":"2048kB","Hugetlb":"0kB","Inactive":"1387928kB","Inactive(anon)":"903352kB","Inactive(file)":"484576kB","KReclaimable":"62584kB","KernelStack":"7772kB","Mapped":"246328kB","MemAvailable":"2378760kB","MemFree":"1882532kB","MemTotal":"3737844kB","Mlocked":"0kB","NFS_Unstable":"0kB","PageTables":"15648kB","Percpu":"1160kB","SReclaimable":"62584kB","SUnreclaim":"57972kB","Shmem":"21992kB","ShmemHugePages":"0kB","ShmemPmdMapped":"0kB","Slab":"120556kB","SwapCached":"0kB","SwapFree":"4145148kB","SwapTotal":"4145148kB","Unevictable":"0kB","VmallocChunk":"0kB","VmallocTotal":"34359738367kB","VmallocUsed":"38772kB","Writeback":"0kB","WritebackTmp":"0kB","Zswap":"0kB","Zswapped":"0kB"}},"NIC":{"enp0s3":{"Interface":"enp0s3","MAC Address":"08:00:27:0b:b8:b7","Operational State":"up","Speed":"1000"},"enp0s8":{"Interface":"enp0s8","MAC Address":"08:00:27:23:4d:a2","Operational State":"up","Speed":"1000"},"lo":{"Interface":"lo","MAC Address":"00:00:00:00:00:00","Operational State":"unknown","Speed":""}}}