feat: integrate Aeron native bindings

Author: cuihairu

.github/workflows/build-cpp.yml

@@ -9,6 +9,8 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
+        with:
+          submodules: recursive
       - name: Detect C++ project
         id: detect
         run: |

.github/workflows/build-go.yml

@@ -9,6 +9,8 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
+        with:
+          submodules: recursive
       - name: Detect Go project
         id: detect
         run: |
@@ -24,7 +26,12 @@ jobs:
           go-version: "1.24.x"
       - name: Build
         if: steps.detect.outputs.present == 'true'
+        env:
+          CGO_ENABLED: "1"
+          LD_LIBRARY_PATH: ${{ github.workspace }}/native/build
         run: |
+          chmod +x native/build.sh
+          ./native/build.sh
           cd go
           go test ./... -coverprofile=coverage.out
       - name: Upload coverage

.gitignore

@@ -70,6 +70,7 @@ node/dist/
 
 # Build outputs
 cppbuild/
+native/build/
 java/target/
 java/.cache/
 dotnet/bin/

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "third_party/aeron"]
+	path = third_party/aeron
+	url = https://github.com/aeron-io/aeron.git

README.md

@@ -43,3 +43,9 @@ corepack enable
 pnpm install
 pnpm run docs:dev
 ```
+
+## Aeron 原生库
+```bash
+./native/build.sh
+```
+非 Java 语言默认从 `native/build` 加载 `epoch_aeron`，或通过 `EPOCH_AERON_LIBRARY` 指定路径。

cpp/CMakeLists.txt

@@ -1,12 +1,42 @@
 cmake_minimum_required(VERSION 3.20)
-project(epoch_cpp VERSION 0.1.0 LANGUAGES CXX)
+project(epoch_cpp VERSION 0.1.0 LANGUAGES C CXX)
 
 add_library(epoch_cpp src/epoch.cpp src/engine.cpp src/actor_id.cpp src/aeron_transport.cpp)
 
 target_include_directories(epoch_cpp PUBLIC ${CMAKE_CURRENT_SOURCE_DIR}/include)
 
 target_compile_features(epoch_cpp PUBLIC cxx_std_17)
 
+find_package(Threads REQUIRED)
+set(AERON_ROOT ${CMAKE_CURRENT_SOURCE_DIR}/../third_party/aeron)
+set(AERON_CLIENT_DIR ${AERON_ROOT}/aeron-client/src/main/c)
+if (EXISTS ${AERON_CLIENT_DIR}/CMakeLists.txt)
+    include(CheckIncludeFile)
+    file(STRINGS ${AERON_ROOT}/version.txt AERON_VERSION_TXT LIMIT_COUNT 1)
+    string(REGEX MATCH "^([0-9]+)\\.([0-9]+)\\.([0-9]+)" _ ${AERON_VERSION_TXT})
+    set(AERON_VERSION_MAJOR ${CMAKE_MATCH_1})
+    set(AERON_VERSION_MINOR ${CMAKE_MATCH_2})
+    set(AERON_VERSION_PATCH ${CMAKE_MATCH_3})
+    execute_process(
+        COMMAND git -C ${AERON_ROOT} rev-parse --short HEAD
+        OUTPUT_VARIABLE AERON_VERSION_GITSHA
+        OUTPUT_STRIP_TRAILING_WHITESPACE
+        ERROR_QUIET)
+    if (AERON_VERSION_GITSHA STREQUAL "")
+        set(AERON_VERSION_GITSHA "unknown")
+    endif()
+    add_definitions(-DAERON_VERSION_TXT="${AERON_VERSION_TXT}")
+    add_definitions(-DAERON_VERSION_MAJOR=${AERON_VERSION_MAJOR})
+    add_definitions(-DAERON_VERSION_MINOR=${AERON_VERSION_MINOR})
+    add_definitions(-DAERON_VERSION_PATCH=${AERON_VERSION_PATCH})
+    add_definitions(-DAERON_VERSION_GITSHA="${AERON_VERSION_GITSHA}")
+    set(AERON_INSTALL_TARGETS OFF CACHE BOOL "" FORCE)
+    add_subdirectory(${AERON_CLIENT_DIR} ${CMAKE_CURRENT_BINARY_DIR}/aeron-client)
+    target_link_libraries(epoch_cpp PUBLIC aeron::aeron_static)
+else()
+    message(FATAL_ERROR "Aeron submodule not found. Run: git submodule update --init --recursive")
+endif()
+
 enable_testing()
 add_executable(epoch_cpp_test tests/epoch_vector_test.cpp)
 target_link_libraries(epoch_cpp_test PRIVATE epoch_cpp)

cpp/include/epoch/aeron_transport.h

@@ -2,6 +2,9 @@
 
 #include "epoch/transport.h"
 
+#include <aeronc.h>
+
+#include <cstdint>
 #include <string>
 
 namespace epoch {
@@ -10,19 +13,46 @@ struct AeronConfig {
     std::string channel;
     std::int32_t stream_id;
     std::string aeron_directory;
+    std::int32_t fragment_limit = 64;
+    std::int32_t offer_max_attempts = 10;
+};
+
+struct AeronStats {
+    std::int64_t sent_count = 0;
+    std::int64_t received_count = 0;
+    std::int64_t offer_back_pressure = 0;
+    std::int64_t offer_not_connected = 0;
+    std::int64_t offer_admin_action = 0;
+    std::int64_t offer_closed = 0;
+    std::int64_t offer_max_position = 0;
+    std::int64_t offer_failed = 0;
 };
 
 class AeronTransport final : public Transport {
 public:
     explicit AeronTransport(AeronConfig config);
+    ~AeronTransport() override;
+
+    AeronTransport(const AeronTransport &) = delete;
+    AeronTransport &operator=(const AeronTransport &) = delete;
+    AeronTransport(AeronTransport &&) = delete;
+    AeronTransport &operator=(AeronTransport &&) = delete;
 
     void send(const Message &message) override;
     std::vector<Message> poll(std::size_t max) override;
     void close() override;
 
+    const AeronConfig &config() const;
+    const AeronStats &stats() const;
+
 private:
     AeronConfig config_;
+    AeronStats stats_;
     bool closed_ = false;
+    aeron_context_t *context_ = nullptr;
+    aeron_t *client_ = nullptr;
+    aeron_publication_t *publication_ = nullptr;
+    aeron_subscription_t *subscription_ = nullptr;
 };
 
 } // namespace epoch