1. POCO 라이브러리를 설치합니다.
https://pocoproject.org/download.html
POCO C++ Libraries - Simplify C++ Development
The POCO C++ Libraries are powerful cross-platform and open source C++ class libraries for building network- and internet-based applications that run on desktop, server, mobile, IoT and embedded systems.
pocoproject.org
2. vcpkg를 이용하여 쉽게 설치할 수 있습니다.
- vcpkg를 설치합니다.
- vcpkg search poco를 실행한다.
- vcpkg install poco[core,json,net]:x64-windows으로 필요한 라이브러리를 설치한다.
- vcpkg install mariadb-connector-cpp:x64-windows로 mariaDB C++ Connector를
설치한다.(SQL Server로 mariaDB Server를 사용합니다)
3. Database.h 파일을 추가합니다.
#pragma once
#include <mariadb/conncpp.hpp>
#include <memory>
class Database
{
public:
static std::unique_ptr<sql::Connection> GetConnection();
private:
static constexpr const char* URL = "jdbc:mariadb://127.0.0.1:3306/database1";
static constexpr const char* USER = "user1";
static constexpr const char* PASSWORD = "password1";
};
4. Database.cpp 파일을 추가합니다.
#include "Database.h"
#include <iostream>
#include <cstdlib>
std::unique_ptr<sql::Connection>
Database::GetConnection()
{
sql::SQLString url(URL);
sql::Properties properties(
{
{"user", USER},
{"password", PASSWORD},
});
_putenv_s("MARIADB_TLS_DISABLE_PEER_VERIFICATION", "1");
sql::Driver* driver = sql::mariadb::get_driver_instance();
std::unique_ptr<sql::Connection> conn;
try {
conn.reset(driver->connect(url, properties));
}
catch (sql::SQLException& e)
{
std::cerr << "Connection error: " << e.what() << std::endl;
return nullptr;
}
return conn;
}
6. BaseHandler.h 파일을 추가합니다.
#pragma once
#include <Poco/Net/HTTPRequestHandler.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
#include <Poco/JSON/Object.h>
#include <Poco/JSON/Parser.h>
#include <Poco/Dynamic/Var.h>
#include <vector>
#include <string>
class BaseHandler : public Poco::Net::HTTPRequestHandler
{
protected:
void SendJson(Poco::Net::HTTPServerResponse& response, Poco::JSON::Object& obj, Poco::Net::HTTPResponse::HTTPStatus status = Poco::Net::HTTPResponse::HTTP_OK);
void SendJson(Poco::Net::HTTPServerResponse& response, Poco::JSON::Array& arr, Poco::Net::HTTPResponse::HTTPStatus status = Poco::Net::HTTPResponse::HTTP_OK);
void SendError(Poco::Net::HTTPServerResponse& response, const std::string& message, Poco::Net::HTTPResponse::HTTPStatus status = Poco::Net::HTTPResponse::HTTP_BAD_REQUEST);
void SendFile(Poco::Net::HTTPServerResponse& response, const std::string& filename, const std::string& contentType);
Poco::JSON::Object::Ptr ParseJson(Poco::Net::HTTPServerRequest& request);
std::vector<std::string> SplitUri(const std::string& uri);
};
7. BaseHandler.cpp 파일을 추가합니다.
#include "BaseHandler.h"
#include "Poco/FileStream.h"
#include <Poco/JSON/Object.h>
#include <Poco/JSON/Array.h>
#include <Poco/JSON/Stringifier.h>
#include <Poco/Dynamic/Var.h>
#include <Poco/JSON/Parser.h>
#include <sstream>
using namespace Poco::JSON;
using namespace Poco::Net;
void BaseHandler::SendJson(HTTPServerResponse& response, Object& obj, HTTPResponse::HTTPStatus status)
{
response.setStatus(status);
response.setContentType("application/json");
std::stringstream ss;
obj.stringify(ss);
response.send() << ss.str();
}
void BaseHandler::SendJson(HTTPServerResponse& response, Array& arr, HTTPResponse::HTTPStatus status)
{
response.setStatus(status);
response.setContentType("application/json");
std::stringstream ss;
arr.stringify(ss);
response.send() << ss.str();
}
void BaseHandler::SendError(HTTPServerResponse& response, const std::string& message, HTTPResponse::HTTPStatus status)
{
Object obj;
obj.set("success", false);
obj.set("message", message);
SendJson(response, obj, status);
}
void BaseHandler::SendFile(Poco::Net::HTTPServerResponse& response, const std::string& filename, const std::string& contentType)
{
response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
response.setContentType(contentType);
Poco::FileInputStream fis(
filename,
std::ios::binary);
std::ostream& out = response.send();
char buffer[4096];
while (fis.good())
{
fis.read(buffer, sizeof(buffer));
std::streamsize n = fis.gcount();
if (n > 0)
{
out.write(buffer, n);
}
}
}
Object::Ptr BaseHandler::ParseJson(HTTPServerRequest& request)
{
std::istream& in = request.stream();
std::string body(std::istreambuf_iterator<char>(in), {});
Parser parser;
Poco::Dynamic::Var result = parser.parse(body);
return result.extract<Object::Ptr>();
}
std::vector<std::string> BaseHandler::SplitUri(const std::string& uri)
{
std::vector<std::string> parts;
std::stringstream ss(uri);
std::string part;
while (std::getline(ss, part, '/'))
{
if (!part.empty())
{
parts.push_back(part);
}
}
return parts;
}
8. MemberHandler.h 파일을 추가합니다.
#pragma once
#include "BaseHandler.h"
#include <Poco/Net/HTTPRequestHandler.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
class MemberHandler : public BaseHandler
{
public:
void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response) override;
};
9. MemberHandler.cpp 파일을 추가합니다.
#include "MemberHandler.h"
#include "Database.h"
#include <Poco/JSON/Object.h>
#include <Poco/JSON/Array.h>
#include <Poco/JSON/Stringifier.h>
#include <Poco/Dynamic/Var.h>
#include <Poco/JSON/Parser.h>
//#include <mysql/jdbc.h>
#include <mariadb/conncpp.hpp>
#include <sstream>
using namespace Poco::JSON;
using namespace Poco::Net;
void MemberHandler::handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
{
response.setContentType("application/json");
auto conn = Database::GetConnection();
if (request.getMethod() == "GET")
{
std::cout << "GET request received" << std::endl;
std::string uri = request.getURI();
if (uri == "/")
{
SendError(response, "POCO REST Server Running");
}
else if (uri == "/members")
{
std::unique_ptr<sql::PreparedStatement> pstmt{ conn->prepareStatement("SELECT id, name, image_id FROM member") };
std::unique_ptr<sql::ResultSet> rs{ pstmt->executeQuery() };
Array arr;
while (rs->next())
{
Object::Ptr obj = new Object;
auto setStringOrNull = [&](const std::string& key)
{
auto value = rs->getString(key);
if (rs->wasNull())
obj->set(key, Poco::Dynamic::Var());
else
obj->set(key, std::string(value.c_str()));
};
obj->set("id", rs->getInt("id"));
setStringOrNull("name");
obj->set("image_id", rs->getInt("image_id"));
arr.add(obj);
}
SendJson(response, arr);
}
}
if (request.getMethod() == "POST")
{
std::cout << "POST request received" << std::endl;
std::string uri = request.getURI();
if (uri == "/members")
{
auto j = ParseJson(request);
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("INSERT INTO member (name, image_id) VALUES (?, ?)");
pstmt->setString(1, j->getValue<std::string>("name"));
pstmt->setInt(2, j->getValue<int>("image_id"));
pstmt->executeUpdate();
Object obj;
obj.set("success", true);
obj.set("message", "member created");
SendJson(response, obj, HTTPResponse::HTTP_CREATED);
}
else
{
SendError(response, "Invalid uri", Poco::Net::HTTPResponse::HTTP_BAD_REQUEST);
}
}
if (request.getMethod() == "PUT")
{
std::cout << "PUT request received" << std::endl;
std::string uri = request.getURI();
auto parts = SplitUri(uri);
if (parts.size() == 2 && parts[0] == "members")
{
int id = std::stoi(parts[1]);
auto obj = ParseJson(request);
std::string name = obj->getValue<std::string>("name");
int image_id = obj->getValue<int>("image_id");
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("UPDATE member SET name=?, image_id=? WHERE id=?");
pstmt->setString(1, name);
pstmt->setInt(2, image_id);
pstmt->setInt(3, id);
pstmt->executeUpdate();
Poco::JSON::Object result;
result.set("success", true);
result.set("message", "member updated");
result.set("id", id);
SendJson(response, result, Poco::Net::HTTPResponse::HTTP_OK);
}
else
{
SendError(response, "invalid uri", Poco::Net::HTTPResponse::HTTP_BAD_REQUEST);
}
}
if (request.getMethod() == "DELETE")
{
std::cout << "DELETE request received" << std::endl;
std::string uri = request.getURI();
auto parts = SplitUri(uri);
if (parts.size() == 2 && parts[0] == "members")
{
int id = std::stoi(parts[1]);
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("DELETE FROM member WHERE id=?");
pstmt->setInt(1, id);
pstmt->executeUpdate();
Poco::JSON::Object result;
result.set("success", true);
result.set("message", "member deleted");
SendJson(response, result, Poco::Net::HTTPResponse::HTTP_OK);
}
else
{
SendError(response, "invalid uri", Poco::Net::HTTPResponse::HTTP_BAD_REQUEST);
}
}
}
10. ImageHandler.h 파일을 추가합니다.
#pragma once
#include "BaseHandler.h"
#include <Poco/Net/HTTPRequestHandler.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
class ImageHandler : public BaseHandler
public:
void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response) override;
};
11. ImageHandler.cpp 파일을 추가합니다.
#include "ImageHandler.h"
#include "Database.h"
#include "Poco/FileStream.h"
#include <Poco/JSON/Object.h>
#include <Poco/JSON/Array.h>
#include <Poco/JSON/Stringifier.h>
#include <Poco/Dynamic/Var.h>
#include <Poco/JSON/Parser.h>
using namespace Poco::JSON;
using namespace Poco::Net;
void ImageHandler::handleRequest(HTTPServerRequest& request, HTTPServerResponse& response)
{
if (request.getMethod() == "GET")
{
std::cout << "GET request received" << std::endl;
std::string uri = request.getURI();
auto parts = SplitUri(uri);
if (parts.size() == 0)
{
SendError(response, "POCO REST Server Running");
}
else if (parts.size() == 1 && parts[0] == "images")
{
auto conn = Database::GetConnection();
std::unique_ptr<sql::PreparedStatement> pstmt{ conn->prepareStatement("SELECT id, file FROM image") };
std::unique_ptr<sql::ResultSet> rs{ pstmt->executeQuery() };
Array arr;
while (rs->next())
{
Object::Ptr obj = new Object;
auto setStringOrNull = [&](const std::string& key)
{
auto value = rs->getString(key);
if (rs->wasNull())
obj->set(key, Poco::Dynamic::Var());
else
obj->set(key, std::string(value.c_str()));
};
obj->set("id", rs->getInt("id"));
setStringOrNull("file");
arr.add(obj);
}
SendJson(response, arr);
}
else if (parts.size() == 2 && parts[0] == "images")
{
int id = std::stoi(parts[1]);
std::string filename;
auto conn = Database::GetConnection();
auto pstmt = std::unique_ptr<sql::PreparedStatement>{ conn->prepareStatement("SELECT file FROM image WHERE id=?") };
pstmt->setInt(1, id);
auto res = std::unique_ptr<sql::ResultSet>{ pstmt->executeQuery() };
if (res->next())
{
filename = res->getString("file");
}
SendFile(response, filename, "image/jpg");
}
}
if (request.getMethod() == "POST")
{
std::cout << "POST request received" << std::endl;
std::string uri = request.getURI();
if (uri == "/images")
{
auto j = ParseJson(request);
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("INSERT INTO image (file) VALUES (?)");
pstmt->setString(1, j->getValue<std::string>("file"));
pstmt->executeUpdate();
Object obj;
obj.set("success", true);
obj.set("message", "image created");
SendJson(response, obj, Poco::Net::HTTPResponse::HTTP_CREATED);
}
else
{
SendError(response, "invalid uri");
}
}
if (request.getMethod() == "PUT")
{
std::cout << "PUT request received" << std::endl;
std::string uri = request.getURI();
auto parts = SplitUri(uri);
if (parts.size() == 2 && parts[0] == "images")
{
int id = std::stoi(parts[1]);
auto obj = ParseJson(request);
std::string file = obj->getValue<std::string>("file");
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("UPDATE image SET file=? WHERE id=?");
pstmt->setString(1, file);
pstmt->setInt(2, id);
pstmt->executeUpdate();
Poco::JSON::Object result;
result.set("success", true);
result.set("message", "image updated");
result.set("id", id);
SendJson(response, result);
}
else
{
SendError(response, "invalid uri");
}
}
if (request.getMethod() == "DELETE")
{
std::cout << "DELETE request received" << std::endl;
std::string uri = request.getURI();
auto parts = SplitUri(uri);
if (parts.size() == 2 && parts[0] == "images")
{
int id = std::stoi(parts[1]);
auto conn = Database::GetConnection();
auto pstmt = conn->prepareStatement("DELETE FROM image WHERE id=?");
pstmt->setInt(1, id);
pstmt->executeUpdate();
Poco::JSON::Object result;
result.set("success", true);
result.set("message", "image deleted");
SendJson(response, result);
}
else
{
SendError(response, "invalid uri");
}
}
}
12. NullHandler.h 파일을 추가합니다.
#pragma once
#include "BaseHandler.h"
#include <Poco/Net/HTTPRequestHandler.h>
#include <Poco/Net/HTTPServerRequest.h>
#include <Poco/Net/HTTPServerResponse.h>
class NullHandler : public BaseHandler
{
public:
void handleRequest(Poco::Net::HTTPServerRequest& request, Poco::Net::HTTPServerResponse& response) override;
};
13. NullHandler.cpp 파일을 추가합니다.
#include "NullHandler.h"
#include <Poco/JSON/Object.h>
#include <Poco/JSON/Stringifier.h>
void NullHandler::handleRequest(
Poco::Net::HTTPServerRequest& request,
Poco::Net::HTTPServerResponse& response
)
{
SendError(response, "Invalid API endpoint", Poco::Net::HTTPResponse::HTTP_NOT_FOUND);
}
14. Factory.h 파일을 추가합니다.
#pragma once
#include <memory>
#include "MemberHandler.h"
#include "ImageHandler.h"
#include "NullHandler.h"
#include <Poco/Net/HTTPRequestHandlerFactory.h>
class Factory : public Poco::Net::HTTPRequestHandlerFactory
{
public:
Poco::Net::HTTPRequestHandler* createRequestHandler(const Poco::Net::HTTPServerRequest& request) override
{
constexpr auto MEMBERS = "/members/";
constexpr auto IMAGES = "/images/";
std::string uri = request.getURI();
if (uri == "/members" || uri.starts_with(MEMBERS))
return new MemberHandler();
if (uri == "/images" || uri.starts_with(IMAGES))
return new ImageHandler();
return new NullHandler();
}
};
15. main.cpp 파일을 추가합니다.
#include "MemberHandler.h"
#include "ImageHandler.h"
#include "Factory.h"
#include <Poco/Net/HTTPServer.h>
#include <Poco/Net/ServerSocket.h>
#include <iostream>
using namespace Poco::Net;
int main()
{
ServerSocket socket(8080);
HTTPServer server(new Factory(), socket, new HTTPServerParams);
server.start();
std::cout << "REST Server Start : 8080\n";
getchar();
server.stop();
return 0;
}
16. 프로잭트를 실행합니다.
* 참고
- C++ : Poco라이브러리로 REST API 서버 만들기(1)
C++ : Poco라이브러리로 REST API 서버 만들기(1)
1. POCO 라이브러리를 설치합니다.https://pocoproject.org/download.html POCO C++ Libraries - Simplify C++ DevelopmentThe POCO C++ Libraries are powerful cross-platform and open source C++ class libraries for building network- and internet-based ap
taekho.tistory.com
- C++ : Poco라이브러리로 REST API 서버 만들기(2)
C++ : Poco라이브러리로 REST API 서버 만들기(2)
1. POCO 라이브러리를 설치합니다.https://pocoproject.org/download.html POCO C++ Libraries - Simplify C++ DevelopmentThe POCO C++ Libraries are powerful cross-platform and open source C++ class libraries for building network- and internet-based ap
taekho.tistory.com
* 참고
- REST API Client는 다음을 참고하세요
- C++ GUI : wxWidgets & POCO 라이브러리를 REST API Client 만들기
C++ GUI : wxWidgets & POCO 라이브러리를 REST API Client 만들기
1. wxWidgets를 설치합니다.https://taekho.tistory.com/5 C++ GUI : wxWidgets 설치Visual Studio 2022( Community 판) 기준으로 설치를 진행함.참고 : Visual Studio Community 다운로드 - https://visualstudio.microsoft.com/ko/vs/community/ V
taekho.tistory.com
'C_C++' 카테고리의 다른 글
| C++ : Poco라이브러리로 REST API 서버 만들기(2) (0) | 2026.06.01 |
|---|---|
| C++ : Poco라이브러리로 REST API 서버 만들기(1) (0) | 2026.06.01 |
| C++ : 배열eotls modern C++ std::vector 사용하기 (0) | 2026.05.23 |
| C++ : matiaDB ODBC 설치하기 (0) | 2026.05.08 |
| C++ : Visual Studio에서 Static Library 제작 및 사용하기 (0) | 2026.05.02 |
