ENDPOINT_ASYNC("GET", "ws", WS)-DPDK中文网

在 Oat++ 中，你可以使用 ENDPOINT_ASYNC 宏来定义异步的 HTTP 端点，但请注意，WebSocket 通信并不是通过普通的 HTTP GET 请求处理的。

不过，你可以用一个路由定义 WebSocket 的连接。在 Oat++ 中，当你希望通过 WebSocket 进行通信时，一般是需要设置一个特定的 WebSocket 端点。这是如何做到这一点的一个简单示例：

示例：设置 WebSocket 端点

下面是如何在 Oat++ 中实现一个简单的 WebSocket 服务器，并在控制器中使用 ENDPOINT_ASYNC 宏。

步骤1：创建 WebSocket Handler

首先，创建一个继承自 oatpp::websocket::handler::Handler 的类，用于处理连接和消息：

#include "oatpp/websocket/handler/Handler.hpp"

class MyWebSocketHandler : public oatpp::websocket::handler::Handler {
public:
    void onOpen(const std::shared_ptr<oatpp::websocket::Connection>& connection) override {
        OATPP_LOGD("WebSocket", "Connection opened");
        connection->sendText("Welcome to the WebSocket server!");
    }

    void onMessage(const std::shared_ptr<oatpp::websocket::Connection>& connection,
                   const oatpp::String& message) override {
        OATPP_LOGD("WebSocket", "Received message: %s", message->c_str());
        
        // Echo back the received message
        connection->sendText("Echo: " + message);
    }

    void onClose(const std::shared_ptr<oatpp::websocket::Connection>& connection) override {
        OATPP_LOGD("WebSocket", "Connection closed");
    }
};

步骤2：创建控制器

接下来，您可以创建一个控制器并定义一个用于升级到 WebSocket 的端点。

#include "oatpp/web/socket/Server.hpp"
#include "oatpp/web/ApiController.hpp"

class MyApiController : public oatpp::web::server::api_controller {
public:
    
    MyApiController(OATPP_COMPONENT(std::shared_ptr<MyWebSocketHandler>, myWebSocketHandler))
      : api_controller() {}

    ENDPOINT_ASYNC("GET", "/ws", ws) {

        // 设置新的 websocket handler 
        auto handler = std :: make_shared<MyWebSocketHandler>();

        // 升级 HTTP 到 websocket
        return request->getHeaders()->getHeader(oatpp::network::
            http: HttpHeaders :: CONNECTION , headerValue)
               .isEmpty()
           ? asyncResponse->sendError(Status :: BAD_REQUEST, "Invalid Connection Header")
           : asyncResponse->write(handler);
    }
};

步骤3：启动服务器

最后，在主函数中启动服务器，并注册你的 API 控制器和 WebSockets Handler。

int main() {
    
   oatppInit(); 

   /* Create a web socket handler instance */
   auto myWebSocketHandler = std :: make_shared<MyWebSocketHandler>();

   /* Create your controller instance and register it with the router */
   auto router = oatpp :: web :: server :: ApiRouter();
   router->addSharedEndpoints(MyApiController(myWebSocketHandler));

   /* Start your server */
   oatpp :: network :: Server server(oatapp : network: Address ("0.0.0.0" ,8000), router);
   
   server.run();

   return 0;
}