[feat]project create

.vscode/c_cpp_properties.json

@@ -0,0 +1,19 @@
+{
+    "configurations": [
+        {
+            "name": "Mac",
+            "includePath": [
+                "${workspaceFolder}/**"
+            ],
+            "defines": [],
+            "macFrameworkPath": [
+                "/Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX.sdk/System/Library/Frameworks"
+            ],
+            "compilerPath": "/usr/bin/clang",
+            "cStandard": "c17",
+            "cppStandard": "c++17",
+            "intelliSenseMode": "macos-clang-arm64"
+        }
+    ],
+    "version": 4
+}

.vscode/launch.json

@@ -0,0 +1,25 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Debug",
+            "type": "cppdbg",
+            "request": "launch",
+            "program": "${workspaceFolder}/signalServer",
+            "args": ["8888"],
+            "stopAtEntry": false,
+            "cwd": "${workspaceFolder}",
+            "environment": [],
+            "externalConsole": false,
+            "MIMode": "lldb",
+            "preLaunchTask": "build",
+            "setupCommands": [
+                {
+                    "description": "Enable pretty-printing for lldb",
+                    "text": "enable",
+                    "ignoreFailures": true
+                }
+            ]
+        }
+    ]
+}

.vscode/settings.json

@@ -0,0 +1,84 @@
+{
+    "files.associations": {
+        "*.cc": "cpp",
+        "__bit_reference": "cpp",
+        "__bits": "cpp",
+        "__config": "cpp",
+        "__debug": "cpp",
+        "__errc": "cpp",
+        "__hash_table": "cpp",
+        "__locale": "cpp",
+        "__mutex_base": "cpp",
+        "__node_handle": "cpp",
+        "__nullptr": "cpp",
+        "__split_buffer": "cpp",
+        "__string": "cpp",
+        "__threading_support": "cpp",
+        "__tree": "cpp",
+        "__tuple": "cpp",
+        "array": "cpp",
+        "atomic": "cpp",
+        "bitset": "cpp",
+        "cctype": "cpp",
+        "chrono": "cpp",
+        "clocale": "cpp",
+        "cmath": "cpp",
+        "compare": "cpp",
+        "complex": "cpp",
+        "concepts": "cpp",
+        "cstdarg": "cpp",
+        "cstddef": "cpp",
+        "cstdint": "cpp",
+        "cstdio": "cpp",
+        "cstdlib": "cpp",
+        "cstring": "cpp",
+        "ctime": "cpp",
+        "cwchar": "cpp",
+        "cwctype": "cpp",
+        "deque": "cpp",
+        "exception": "cpp",
+        "forward_list": "cpp",
+        "initializer_list": "cpp",
+        "ios": "cpp",
+        "iosfwd": "cpp",
+        "iostream": "cpp",
+        "istream": "cpp",
+        "limits": "cpp",
+        "list": "cpp",
+        "locale": "cpp",
+        "map": "cpp",
+        "memory": "cpp",
+        "mutex": "cpp",
+        "new": "cpp",
+        "numeric": "cpp",
+        "optional": "cpp",
+        "ostream": "cpp",
+        "queue": "cpp",
+        "ratio": "cpp",
+        "sstream": "cpp",
+        "stdexcept": "cpp",
+        "streambuf": "cpp",
+        "string": "cpp",
+        "string_view": "cpp",
+        "system_error": "cpp",
+        "tuple": "cpp",
+        "type_traits": "cpp",
+        "typeinfo": "cpp",
+        "unordered_map": "cpp",
+        "valarray": "cpp",
+        "variant": "cpp",
+        "vector": "cpp",
+        "algorithm": "cpp",
+        "shared_mutex": "cpp",
+        "__memory": "cpp",
+        "thread": "cpp",
+        "bit": "cpp",
+        "charconv": "cpp",
+        "condition_variable": "cpp",
+        "format": "cpp",
+        "future": "cpp",
+        "functional": "cpp",
+        "memory_resource": "cpp",
+        "utility": "cpp"
+    }
+}

.vscode/tasks.json

@@ -0,0 +1,26 @@
+{
+    "version": "2.0.0",
+    "tasks": [
+        {
+            "label": "build",
+            "type": "shell",
+            "command": "g++",
+            "args": [
+                "-std=c++14",
+                "-g",
+                "-o",
+                "signalServer",
+                "-I",
+                "include",
+                "src/*.cpp",
+                "-lhv",
+                "-lspdlog"
+                
+            ],
+            "group": {
+                "kind": "build",
+                "isDefault": true
+            }
+        }
+    ]
+}

Dockerfile

@@ -0,0 +1,64 @@
+# Use an official Ubuntu runtime as a parent image
+FROM ubuntu:latest
+
+# 设置非交互式环境变量，以避免 tzdata 安装时的交互
+ENV DEBIAN_FRONTEND=noninteractive
+
+# Use Aliyun mirrors for apt-get
+RUN sed -i 's/http:\/\/archive.ubuntu.com\/ubuntu\//http:\/\/mirrors.aliyun.com\/ubuntu\//g' /etc/apt/sources.list
+
+# Update the package lists
+RUN apt-get update
+
+# Install build tools
+RUN apt-get install -y g++ make cmake autoconf automake libtool
+
+# 安装 spdlog 依赖
+RUN apt-get install -y \
+    libfmt-dev
+
+# Download and build libhv from source
+RUN apt-get install -y git
+RUN git clone https://github.com/ithewei/libhv.git /usr/src/libhv
+WORKDIR /usr/src/libhv
+RUN make
+RUN make install
+
+# Add the libhv library path
+RUN ldconfig
+
+# 克隆 spdlog 仓库
+RUN git clone https://github.com/gabime/spdlog.git /usr/src/spdlog
+
+WORKDIR /usr/src/spdlog
+
+# 运行 CMake 配置
+RUN cmake .
+
+# 运行构建
+RUN make
+
+# 运行安装
+RUN make install
+
+RUN ldconfig
+
+# Set the working directory to /app
+WORKDIR /app
+
+# Copy the source code into the container
+COPY . .
+
+RUN apt-get install -y tzdata
+
+# 设置时区为 Asia/Shanghai
+ENV TZ=Asia/Shanghai
+
+RUN dpkg-reconfigure --frontend noninteractive tzdata
+
+# Compile the C++ program
+RUN g++ -std=c++14 -g -o signalServer src/*.cpp -I include -lhv -lspdlog
+
+EXPOSE 8888
+# Run my_program when the container launches
+CMD ["./signalServer"]

src/main_signal.cpp

@@ -0,0 +1,202 @@
+#include "hv/HttpServer.h"
+#include <iostream>
+#include <cstdlib>
+#include <ctime>
+
+#include "spdlog/spdlog.h"
+#include "spdlog/async.h"
+#include "spdlog/sinks/stdout_color_sinks.h"
+
+using namespace hv;
+
+// 生成一个指定长度的随机字符串
+std::string generateRandomString(int length) {
+    const std::string characters = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
+    const int charactersLength = characters.length();
+    std::string randomString;
+
+    for (int i = 0; i < length; ++i) {
+        randomString += characters[rand() % charactersLength];
+    }
+
+    return randomString;
+}
+int generateRandomNumber() {
+    return rand() % 100000; // 生成 0 到 999 之间的随机数
+}
+
+std::string generateChannelToken(int csid) {
+    // 使用当前时间戳作为一部分
+    auto timestamp = std::to_string(std::chrono::system_clock::now().time_since_epoch().count());
+    
+
+    // 拼接成最终的通道令牌
+    return "datachannel_" + std::to_string(csid) + "_" + timestamp + "_" + std::to_string(rand() % 256);
+}
+
+static int port = 8888;
+int main(int argc, char** argv) {
+    if (argc == 2) {
+        port = atoi(argv[1]);
+    }
+    
+    auto console_sink = std::make_shared<spdlog::sinks::stdout_color_sink_mt>();
+    auto logger = std::make_shared<spdlog::logger>("my_logger", console_sink);
+
+    // 设置异步模式，设置线程数（0 表示使用 CPU 核心数）
+    spdlog::init_thread_pool(8192, 2);
+
+    // 设置异步日志器
+    spdlog::set_default_logger(std::make_shared<spdlog::async_logger>(
+        "ProxyServer", console_sink, spdlog::thread_pool(), spdlog::async_overflow_policy::block));
+
+
+    std::srand(std::time(0));
+    HttpService router;
+    router.POST("/api/open.login.loginV2", [](const HttpContextPtr& ctx) {
+        auto tcp_chan_sid = generateRandomNumber();
+        auto udp_chan_sid = generateRandomNumber();
+        nlohmann::json data = {
+            {"signalSessionId", generateRandomString(32)},
+            {"channelAuthList", {
+                {
+                    {"dataChannelSessionId", tcp_chan_sid},
+                    {"channelIp", "192.168.0.1"},
+                    {"port", 8080},
+                    {"proType", "TCP"},
+                    {"channelSt", generateChannelToken(tcp_chan_sid)},
+                    {"secretType", "ST"}
+                },
+                {
+                    {"dataChannelSessionId", udp_chan_sid},
+                    {"channelIp", "192.168.0.2"},
+                    {"port", 8081},
+                    {"proType", "UDP"},
+                    {"channelSt", generateChannelToken(udp_chan_sid)},
+                    {"secretType", "ST"}
+                }
+            }}
+        };
+
+        // 创建 State 对象
+        nlohmann::json state = {
+            {"code", 2000000},
+            {"msg", "OK"}
+        };
+
+        // 创建 Result 对象
+        nlohmann::json result = {
+            {"data", data},
+            {"state", state}
+        };
+
+        // 创建 LoginBean 对象
+        nlohmann::json loginBean = {
+            {"result", result}
+        };
+    
+        return ctx->send(loginBean.dump());
+    });
+
+    router.POST("/api/open.login.logoutV2", [](const HttpContextPtr& ctx) {
+        nlohmann::json result;
+
+        // 设置 data 部分
+        result["data"]["isSuccess"] = 1;
+        result["data"]["msg"] = "成功";
+
+        // 设置 state 部分
+        result["state"]["code"] = 2000000;
+        result["state"]["msg"] = "ok";
+
+        nlohmann::json logoutBean = {
+            {"result", result}
+        };
+        return ctx->send(logoutBean.dump());
+    });
+
+    router.POST("/api/open.heartbeat.heartbeatV2", [](const HttpContextPtr& ctx) {
+        nlohmann::json result;
+
+        // 设置 data 部分
+        result["data"]["isSuccess"] = 1;
+        result["data"]["msg"] = "成功";
+
+        // 设置 state 部分
+        result["state"]["code"] = 2000000;
+        result["state"]["msg"] = "ok";
+
+        nlohmann::json heartbeatBean = {
+            {"result", result}
+        };
+        return ctx->send(heartbeatBean.dump());
+    });
+
+    router.POST("/api/open.auth.getChannelStV2", [](const HttpContextPtr& ctx) {
+        std::string body = ctx->request->body;
+            
+        nlohmann::json result;
+        // 解析 JSON
+        try {
+            nlohmann::json requestBody = nlohmann::json::parse(body);
+            nlohmann::json data;
+            data["dataChannelList"] = requestBody["result"]["data"]["channelAuthList"];
+            auto now = std::chrono::system_clock::now();
+            auto tomorrow = now + std::chrono::hours(24);
+            auto tomorrow_timestamp = std::chrono::duration_cast<std::chrono::seconds>(tomorrow.time_since_epoch()).count();
+            for (auto& item : data["dataChannelList"]) {
+                item["expireTime"] = tomorrow_timestamp;
+            }
+
+            // 创建 State 对象
+            nlohmann::json state = {
+                {"code", 2000000},
+                {"msg", "OK"}
+            };
+
+            // 创建 Result 对象
+            result = {
+                {"data", data},
+                {"state", state}
+            };
+        } catch (const nlohmann::json::parse_error& e) {
+
+            // 设置 data 部分
+            result["data"]["isSuccess"] = 1;
+            result["data"]["msg"] = "成功";
+
+            // 设置 state 部分
+            result["state"]["code"] = 4000000;
+            result["state"]["msg"] = "error";
+        }
+
+        nlohmann::json getChannelStV2 = {
+            {"result", result}
+        };
+        return ctx->send(getChannelStV2.dump());
+    });
+
+    router.GET("/test", [](HttpRequest* req, HttpResponse* resp) {
+        print("/test");
+        resp->json["origin"] = req->client_addr.ip;
+        resp->json["url"] = req->url;
+        resp->json["args"] = req->query_params;
+        resp->json["headers"] = req->headers;
+        hv::Json myArray = hv::Json::array();
+        myArray.push_back("apple");
+        myArray.push_back("banana");
+        myArray.push_back("orange");
+        resp->json["fruits"] = myArray;
+        resp->json["test"]["a"] = "json_serializer";
+        return 200;
+    });
+
+    HttpServer server(&router);
+    server.setPort(port);
+    server.setThreadNum(2);
+
+    spdlog::info("SignalServer start :{}", port);
+
+    server.run();
+    return 0;
+}